add FCE examples

ipfs-node/effector/Cargo.toml

@@ -0,0 +1,14 @@
+[package]
+name = "ipfs-effector"
+version = "0.1.0"
+authors = ["Fluence Labs"]
+edition = "2018"
+publish = false
+
+[[bin]]
+name = "ipfs_effector"
+path = "src/main.rs"
+
+[dependencies]
+fluence = { version = "=0.3.2", features = ["logger"] }
+log = "0.4.11"

ipfs-node/effector/src/main.rs

@@ -0,0 +1,98 @@
+/*
+ * Copyright 2020 Fluence Labs Limited
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#![allow(improper_ctypes)]
+
+mod path;
+
+use crate::path::to_full_path;
+
+use fluence::fce;
+use fluence::WasmLoggerBuilder;
+use fluence::MountedBinaryResult;
+
+const RESULT_FILE_PATH: &str = "/tmp/ipfs_rpc_file";
+const IPFS_ADDR_ENV_NAME: &str = "IPFS_ADDR";
+const TIMEOUT_ENV_NAME: &str = "timeout";
+
+pub fn main() {
+    WasmLoggerBuilder::new()
+        .with_log_level(log::Level::Info)
+        .build()
+        .unwrap();
+}
+
+/// Put file from specified path to IPFS and return its hash.
+#[fce]
+pub fn put(file_path: String) -> String {
+    log::info!("put called with file path {}", file_path);
+
+    let file_path = to_full_path(file_path);
+
+    let timeout = std::env::var(TIMEOUT_ENV_NAME).unwrap_or_else(|_| "1s".to_string());
+    let cmd = vec![
+        String::from("add"),
+        String::from("--timeout"),
+        timeout,
+        String::from("-Q"),
+        file_path,
+    ];
+
+    let ipfs_result = unsafe { ipfs(cmd) };
+    ipfs_result
+        .into_std()
+        .unwrap()
+        .unwrap_or_else(std::convert::identity)
+}
+
+/// Get file by provided hash from IPFS, saves it to a temporary file and returns a path to it.
+#[fce]
+pub fn get(hash: String) -> String {
+    log::info!("get called with hash {}", hash);
+
+    let result_file_path = to_full_path(RESULT_FILE_PATH);
+
+    let timeout = std::env::var(TIMEOUT_ENV_NAME).unwrap_or_else(|_| "1s".to_string());
+    let cmd = vec![
+        String::from("get"),
+        String::from("--timeout"),
+        timeout,
+        String::from("-o"),
+        result_file_path,
+        hash,
+    ];
+
+    unsafe { ipfs(cmd) };
+    RESULT_FILE_PATH.to_string()
+}
+
+#[fce]
+pub fn get_address() -> String {
+    match std::env::var(IPFS_ADDR_ENV_NAME) {
+        Ok(addr) => addr,
+        Err(e) => format!(
+            "getting {} env variable failed with error {:?}",
+            IPFS_ADDR_ENV_NAME, e
+        ),
+    }
+}
+
+#[fce]
+#[link(wasm_import_module = "host")]
+extern "C" {
+    /// Execute provided cmd as a parameters of ipfs cli, return result.
+    pub fn ipfs(cmd: Vec<String>) -> MountedBinaryResult;
+}

ipfs-node/effector/src/path.rs

@@ -0,0 +1,52 @@
+/*
+ * Copyright 2020 Fluence Labs Limited
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+pub(super) fn to_full_path<S>(cmd: S) -> String
+where
+    S: Into<String>,
+{
+    use std::path::Path;
+    use std::path::Component;
+
+    let cmd = cmd.into();
+    let path = Path::new(&cmd);
+
+    let mut components = path.components();
+    let is_absolute = components.next() == Some(Component::RootDir);
+
+    if !is_absolute {
+        return cmd;
+    }
+
+    let parent = match components.next() {
+        Some(Component::Normal(path)) => path.to_str().unwrap(),
+        _ => return cmd,
+    };
+
+    match std::env::var(parent) {
+        Ok(to_dir) => {
+            let mut full_path = std::path::PathBuf::from(to_dir);
+
+            // TODO: optimize this
+            #[allow(clippy::while_let_on_iterator)]
+            while let Some(component) = components.next() {
+                full_path.push(component);
+            }
+            full_path.to_string_lossy().into_owned()
+        }
+        Err(_) => cmd,
+    }
+}