rename repo

aqua-examples/aqua-ceramic-integration/.aqua/call0.aqua

@@ -0,0 +1,4 @@
+import "/Users/bebo/localdev/examples/aqua-examples/ceramic-demo/aqua/ceramic_demo.aqua"
+
+func callerUniqueFunction():
+  roundtrip("one", "two", "12D3KooWJ4bTHirdTFNZpCS72TAzwtdmavTBkkEXtzo6wHL25CtE", "cac2af1e-16fe-4f44-8b92-4c0b34877971")

aqua-examples/aqua-ceramic-integration/compiled-aqua/ceramic_demo.create.air

@@ -0,0 +1,37 @@
+(xor
+ (seq
+  (seq
+   (seq
+    (seq
+     (seq
+      (seq
+       (seq
+        (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
+        (call %init_peer_id% ("getDataSrv" "payload") [] payload)
+       )
+       (call %init_peer_id% ("getDataSrv" "node") [] node)
+      )
+      (call %init_peer_id% ("getDataSrv" "service_id") [] service_id)
+     )
+     (call -relay- ("op" "noop") [])
+    )
+    (xor
+     (seq
+      (call -relay- ("op" "noop") [])
+      (call node (service_id "create_stream") [payload] create_res)
+     )
+     (seq
+      (call -relay- ("op" "noop") [])
+      (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
+     )
+    )
+   )
+   (call -relay- ("op" "noop") [])
+  )
+  (xor
+   (call %init_peer_id% ("callbackSrv" "response") [create_res.$.stdout!])
+   (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
+  )
+ )
+ (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
+)

aqua-examples/aqua-ceramic-integration/compiled-aqua/ceramic_demo.create_obj.air

@@ -0,0 +1,37 @@
+(xor
+ (seq
+  (seq
+   (seq
+    (seq
+     (seq
+      (seq
+       (seq
+        (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
+        (call %init_peer_id% ("getDataSrv" "payload") [] payload)
+       )
+       (call %init_peer_id% ("getDataSrv" "node") [] node)
+      )
+      (call %init_peer_id% ("getDataSrv" "service_id") [] service_id)
+     )
+     (call -relay- ("op" "noop") [])
+    )
+    (xor
+     (seq
+      (call -relay- ("op" "noop") [])
+      (call node (service_id "create_stream") [payload] create_res)
+     )
+     (seq
+      (call -relay- ("op" "noop") [])
+      (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
+     )
+    )
+   )
+   (call -relay- ("op" "noop") [])
+  )
+  (xor
+   (call %init_peer_id% ("callbackSrv" "response") [create_res])
+   (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
+  )
+ )
+ (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
+)

aqua-examples/aqua-ceramic-integration/compiled-aqua/ceramic_demo.roundtrip.air

@@ -0,0 +1,46 @@
+(xor
+ (seq
+  (seq
+   (seq
+    (seq
+     (seq
+      (seq
+       (seq
+        (seq
+         (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
+         (call %init_peer_id% ("getDataSrv" "payload") [] payload)
+        )
+        (call %init_peer_id% ("getDataSrv" "payload_two") [] payload_two)
+       )
+       (call %init_peer_id% ("getDataSrv" "node") [] node)
+      )
+      (call %init_peer_id% ("getDataSrv" "service_id") [] service_id)
+     )
+     (call -relay- ("op" "noop") [])
+    )
+    (xor
+     (seq
+      (seq
+       (seq
+        (call -relay- ("op" "noop") [])
+        (call node (service_id "create_stream") [payload] create_res)
+       )
+       (call node (service_id "show") [create_res.$.stdout!] show_res)
+      )
+      (call node (service_id "update") [create_res.$.stdout! payload_two] update_res)
+     )
+     (seq
+      (call -relay- ("op" "noop") [])
+      (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
+     )
+    )
+   )
+   (call -relay- ("op" "noop") [])
+  )
+  (xor
+   (call %init_peer_id% ("callbackSrv" "response") [create_res.$.stdout! show_res.$.stdout! update_res.$.stdout!])
+   (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
+  )
+ )
+ (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
+)

aqua-examples/aqua-ceramic-integration/services/stage_deployment.txt

@@ -0,0 +1,11 @@
+fldist --verbose new_service --ms artifacts/curl_adapter.wasm:configs/curl_adapter_cfg.json artifacts/ceramic_adapter.wasm:configs/ceramic_adapter_cfg.json --name ceramic-adapter --env stage
+client seed: 7APvd44uLAiKya9MUoPqu6wtrRnLgUbG814pfMbS3yXH
+client peerId: 12D3KooWS5rn3Vz9t5Swfdj7Y8sM4j8ApLpYUMfp2rxHEhyU9uZe
+relay peerId: 12D3KooWJ4bTHirdTFNZpCS72TAzwtdmavTBkkEXtzo6wHL25CtE
+service id: 58c05beb-4979-482b-bb48-3b4475d2ba08
+service created successfully
+
+
+
+
+fldist --env stage --node 12D3KooWJ4bTHirdTFNZpCS72TAzwtdmavTBkkEXtzo6wHL25CtE run_air --generated --wait -p air/ceramic_demo.roundtrip.air -d '{"payload": "one", "payload_two": "two", "node": "12D3KooWJ4bTHirdTFNZpCS72TAzwtdmavTBkkEXtzo6wHL25CtE", "service_id": "2a36d436-83b8-42e4-a541-1ddf867e4714"}'