summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--.gitignore1
-rw-r--r--Cargo.lock7
-rw-r--r--Cargo.toml8
-rw-r--r--src/main.rs262
4 files changed, 278 insertions, 0 deletions
diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..ea8c4bf
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1 @@
+/target
diff --git a/Cargo.lock b/Cargo.lock
new file mode 100644
index 0000000..5fc74b0
--- /dev/null
+++ b/Cargo.lock
@@ -0,0 +1,7 @@
+# This file is automatically @generated by Cargo.
+# It is not intended for manual editing.
+version = 3
+
+[[package]]
+name = "git-annex-remote-remarkable2"
+version = "0.1.0"
diff --git a/Cargo.toml b/Cargo.toml
new file mode 100644
index 0000000..4fb32cf
--- /dev/null
+++ b/Cargo.toml
@@ -0,0 +1,8 @@
+[package]
+name = "git-annex-remote-remarkable2"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
diff --git a/src/main.rs b/src/main.rs
new file mode 100644
index 0000000..b500951
--- /dev/null
+++ b/src/main.rs
@@ -0,0 +1,262 @@
+use std::{io::{Stdin, IsTerminal}, process::{exit, Command, Stdio}};
+
+
+struct Config {
+ ssh_destination: String,
+ xochitl_path: String,
+ ssh_key_path: Option<String>,
+ extensions: Extensions
+}
+
+#[derive(Default, Clone)]
+struct Extensions {
+ unavailable_response: bool,
+ info: bool
+}
+
+fn get_line(stdin: &mut Stdin) -> Option<String> {
+ let mut buf = String::new();
+ match stdin.read_line(&mut buf) {
+ Ok(0) => None,
+ Err(err) => {
+ eprintln!("read encountered error: {}", err);
+ None
+ }
+ _ => Some(buf)
+ }
+}
+
+fn get_value(stdin: &mut Stdin) -> Option<String> {
+ if let Some(line) = get_line(stdin) {
+ if let Some(value) = line.strip_prefix("VALUE ") {
+ if value.split_ascii_whitespace().count() == 0 {
+ return None
+ } else {
+ return Some(value.to_owned());
+ }
+ }
+ if line == "VALUE" {
+ return None;
+ }
+ }
+ eprintln!("did not receive value when expected");
+ exit(1);
+}
+
+fn get_config_value(stdin: &mut Stdin, key: &str) -> Option<String> {
+ println!("GETCONFIG {}", key);
+ get_value(stdin)
+}
+
+fn get_config(stdin: &mut Stdin, extensions: &Extensions) -> Config {
+ Config {
+ ssh_destination: get_config_value(stdin, "ssh_destination").unwrap()
+ .strip_suffix("\n").unwrap().to_string(),
+ xochitl_path: get_config_value(stdin, "xochitl_directory")
+ .map(|s| s.strip_suffix("\n").unwrap().to_string())
+ .unwrap_or_else(|| ".local/share/remarkable/xochitl".to_owned()),
+ ssh_key_path: get_config_value(stdin, "ssh_key"),
+ extensions: extensions.to_owned()
+ }
+}
+
+fn startup(stdin: &mut Stdin) -> Config {
+ let mut extensions = Extensions::default();
+ while let Some(line) = get_line(stdin) {
+ let mut words = line.split_ascii_whitespace();
+ let verb = words.next().expect("missing command verb");
+ match verb {
+ "EXTENSIONS" => {
+ let supported: Vec<_> = words.collect();
+ extensions.unavailable_response = supported.contains(&"UNAVAILABLERESPONSE");
+ extensions.info = supported.contains(&"INFO");
+ println!(
+ "EXTENSIONS {} {}",
+ if extensions.unavailable_response { "UNAVAILABLERESPONSE" } else { "" },
+ if extensions.info { "INFO" } else { "" }
+ )
+ }
+ "PREPARE" => {
+ let config = get_config(stdin, &extensions);
+ println!("PREPARE-SUCCESS");
+ return config;
+ },
+ "LISTCONFIGS" => {
+ println!("CONFIG ssh_destination ssh destination under which the reMarkable tablet can be reached.");
+ println!("CONFIG ssh_key the path to an ssh key to use (optional).");
+ println!("CONFIG xochitl_directory the directory on the remarkable device in which data is stored (default .local/share/remarkable/xochitl).");
+ println!("CONFIGEND")
+ },
+ "INITREMOTE" => {
+ let config = get_config(stdin, &extensions);
+ let check = Command::new("ssh")
+ .arg(config.ssh_destination)
+ .arg("ls")
+ .arg(config.xochitl_path)
+ .stdout(Stdio::null())
+ .status();
+ if let Ok(status) = check {
+ if status.success() {
+ println!("INITREMOTE-SUCCESS");
+ } else {
+ println!("INITREMOTE-FAILURE ssh check returned {}", status);
+ }
+ } else {
+ println!("INITREMOTE-FAILURE failed to spawn ssh check command");
+ }
+ }
+ _ => {
+ println!("UNSUPPORTED-REQUEST");
+ eprintln!("got unsupported verb while getting config: {}", line);
+ }
+ }
+ }
+ println!("DEBUG done early?");
+ exit(0);
+}
+
+
+fn key_to_uuid(key: &str) -> String {
+ let maybe = Command::new("uuidgen")
+ .arg("-s")
+ .arg("-n")
+ .arg("435bb27b-6704-416f-bc5b-3e2d02d0cf8f")
+ .arg("-N")
+ .arg(key)
+ .output();
+ match maybe {
+ Ok(uuid) => String::from_utf8_lossy(&uuid.stdout)
+ .split_ascii_whitespace().next().unwrap().to_owned(),
+ Err(e) => {
+ println!("DEBUG conversion to uuid failed: {}", e);
+ exit(1)
+ }
+ }
+}
+
+fn check_key_present<'a>(config: &Config, mut words: impl Iterator<Item=&'a str>) {
+ let key = words.next().unwrap();
+ assert_no_args_left(words);
+ let uuid = key_to_uuid(key);
+ let check = Command::new("ssh")
+ .arg(&config.ssh_destination)
+ .arg(format!("test -f {dir}/{uuid}.pdf && test ! -f {dir}/{uuid}.tombstone", dir=config.xochitl_path, uuid=uuid))
+ .status();
+ if let Ok(code) = check {
+ if code.success() {
+ println!("CHECKPRESENT-SUCCESS {}", key);
+ } else {
+ println!("CHECKPRESENT-FAILURE {}", key); // TODO: check if remote present or not
+ }
+ } else {
+ println!("CHECKPRESENT-UNKNOWN {} ssh failed", key);
+ }
+}
+
+fn store_key<'a>(config: &Config, mut words: impl Iterator<Item=&'a str>) {
+ let key = words.next().unwrap();
+ let file = words.next().unwrap();
+ assert_no_args_left(words);
+ let uuid = key_to_uuid(key);
+ let check = Command::new("scp")
+ .arg(file)
+ .arg(format!("{}:{}/{}.pdf", config.ssh_destination, config.xochitl_path, uuid))
+ .status();
+ if let Ok(code) = check {
+ if code.success() {
+ println!("TRANSFER-SUCCESS STORE {}", key);
+ } else {
+ println!("TRANSFER-FAILURE STORE {}", key); // TODO: check if remote present or not
+ }
+ } else {
+ println!("TRANSFER-FAILURE STORE {} ssh failed", key);
+ }
+}
+
+fn retrieve_key<'a>(config: &Config, mut words: impl Iterator<Item=&'a str>) {
+ let key = words.next().unwrap();
+ let file = words.next().unwrap();
+ assert_no_args_left(words);
+ let uuid = key_to_uuid(key);
+ let check = Command::new("scp")
+ .arg(format!("{}:{}/{}.pdf", config.ssh_destination, config.xochitl_path, uuid))
+ .arg(file)
+ .status();
+ if let Ok(code) = check {
+ if code.success() {
+ println!("TRANSFER-SUCCESS RETRIEVE {}", key);
+ } else {
+ println!("TRANSFER-FAILURE RETRIEVE {}", key); // TODO: check if remote present or not
+ }
+ } else {
+ println!("TRANSFER-FAILURE RETRIEVE {} ssh failed", key);
+ }
+}
+
+fn remove_key<'a>(config: &Config, mut words: impl Iterator<Item=&'a str>) {
+ let key = words.next().unwrap();
+ assert_no_args_left(words);
+ let uuid = key_to_uuid(key);
+
+ let cmd = Command::new("ssh")
+ .arg(&config.ssh_destination)
+ .arg(format!("rm -r {dir}/{uuid}*", dir=config.xochitl_path, uuid=uuid))
+ .status();
+ if let Ok(code) = cmd {
+ if code.success() {
+ println!("REMOVE-SUCCESS {}", key);
+ } else {
+ println!("REMOVE-FAILURE {} command failed", key); // TODO: check if remote present or not
+ }
+ } else {
+ println!("REMOVE-FAILURE {} ssh failed", key);
+ }
+}
+
+fn whereis<'a>(config: &Config, mut words: impl Iterator<Item=&'a str>) {
+ let key = words.next().unwrap();
+ assert_no_args_left(words);
+ let uuid = key_to_uuid(key);
+ println!("WHEREIS-SUCCESS {ssh}:{dir}/{uuid}.pdf", ssh=config.ssh_destination, dir=config.xochitl_path, uuid=uuid);
+}
+
+fn assert_no_args_left<'a>(mut words: impl Iterator<Item=&'a str>) {
+ if words.next().is_some() {
+ println!("UNSUPPORTED-REQUEST");
+ println!("ERROR");
+ exit(1);
+ }
+}
+
+fn main() {
+ let mut stdin = std::io::stdin();
+ if stdin.is_terminal() {
+ eprintln!("warning: this program is not meant to be invoked by hand.");
+ }
+
+ println!("VERSION 2");
+
+ let config = startup(&mut stdin);
+
+ while let Some(line) = get_line(&mut stdin) {
+ let mut words = line.split_ascii_whitespace();
+ let verb = words.next().expect("missing command verb");
+ match verb {
+ "CHECKPRESENT" => check_key_present(&config, words),
+ "TRANSFER" => match words.next().expect("missing STORE/RETRIEVE") {
+ "STORE" => store_key(&config, words),
+ "RETRIEVE" => retrieve_key(&config, words),
+ _ => println!("UNSUPPORTED-REQUEST")
+ }
+ "REMOVE" => remove_key(&config, words),
+ "WHEREIS" => whereis(&config, words),
+ "GETAVAILABILITY" => {
+ println!("ERROR");
+ unimplemented!()
+ // check routing table if usb network device is present?
+ }
+ _ => println!("UNSUPPORTED-REQUEST")
+ }
+ }
+
+}
generated by cgit v1.2.3 (git 2.25.1) at 2024-12-22 04:59:29 +0000