feat(hermes): add ipfs connection opening to doc_sync (#685)

* feat(hermes): add ipfs connection opening to doc_sync

* chore(hermes): rafactoring

* feat(hermes): add doc-sync opening test

* fix(CI): fix spelling

* fix(hermes): fix test

* fix(CI): ignore some lints

* chore(hermes): update lock file

* fix(hermes): change document id to cbor encoded CID

* chore(hermes): remove unused imports

* fix(hermes): forbid usage of sync channel resource after close

* chore(hermes): fix lints

* chore(hermes): update code so that it uses 4 byte hash

* chore(hermes): add comment

Author: aido-mth

.config/dictionaries/project.dic

@@ -155,6 +155,7 @@ reentrancy
 removedir
 renameat
 reqwest
+reusage
 rfind
 Rmax
 Rmin

hermes/Cargo.lock

@@ -6,7 +6,8 @@ members = [
     "bin/tests/integration/components/failed_init",
     "bin/tests/integration/components/sleep_component",
     "bin/tests/integration/components/cron_callback",
-    "bin/tests/integration/components/staked_ada_indexer_mock"
+    "bin/tests/integration/components/staked_ada_indexer_mock",
+    "bin/tests/integration/components/ipfs_subscribe",
 ]
 default-members = [
     "bin",

hermes/Cargo.toml

@@ -102,6 +102,7 @@ orx-concurrent-vec = "3.10.0"
 keyed-lock = "0.2.3"
 wasmprinter = "0.240.0"
 wat = "1.239.0"
+multihash = { version = "0.19.3", features = ["serde-codec"] }
 
 [build-dependencies]
 build-info-build = "0.0.42"

hermes/bin/Cargo.toml

@@ -118,7 +118,7 @@ pub(crate) fn hermes_ipfs_subscribe(
     } else {
         let handle = ipfs.pubsub_subscribe(&topic)?;
         ipfs.apps.added_topic_stream(topic.clone(), handle);
-        tracing::debug!(app_name = %app_name, pubsub_topic = %topic, "added subscription topic stream");
+        tracing::info!(app_name = %app_name, pubsub_topic = %topic, "added subscription topic stream");
     }
     ipfs.apps
         .added_app_topic_subscription(app_name.clone(), topic);