feat: Added notify

orchestrator/src/indexer/rooch.ts

@@ -22,6 +22,10 @@ function isValidJson(jsonString: string): boolean {
   }
 }
 
+function decodeNotifyValue(hex: string): string {
+  return `${hex.slice(0, 66)}${Buffer.from(hex.slice(66), "hex").toString()}`;
+}
+
 export default class RoochIndexer {
   private keyPair: Secp256k1Keypair;
   private orchestrator: string;
@@ -82,6 +86,8 @@ export default class RoochIndexer {
     const client = new RoochClient({
       url: getRoochNodeUrl(this.chainId),
     });
+    log.debug(JSON.stringify({ notify: data.notify }));
+
     const tx = new Transaction();
     tx.callFunction({
       target: `${this.oracleAddress}::oracles::fulfil_request`,
@@ -93,7 +99,21 @@ export default class RoochIndexer {
       signer: this.keyPair,
     });
 
-    log.debug(receipt.execution_info);
+    log.debug(JSON.stringify({ execution_info: receipt.execution_info }));
+
+    if ((data.notify?.value?.vec?.at(0)?.length ?? 0) > 66) {
+      const tx = new Transaction();
+      tx.callFunction({
+        target: decodeNotifyValue(data.notify?.value?.vec?.at(0) ?? ""),
+      });
+
+      const receipt = await client.signAndExecuteTransaction({
+        transaction: tx,
+        signer: this.keyPair,
+      });
+
+      // log.debug(receipt.execution_info);
+    }
     return receipt;
   }
 

orchestrator/src/types.ts

@@ -43,7 +43,7 @@ interface VecValue {
 }
 
 export interface IRequestAdded {
-  notify: NotifyValue;
+  notify?: NotifyValue;
   oracle: string;
   params: ParamsValue;
   pick: string;

rooch/Move.toml

@@ -8,8 +8,8 @@ MoveosStdlib = { git = "https://github.com/rooch-network/rooch.git", subdir = "f
 # RoochFramework = { git = "https://github.com/rooch-network/rooch.git", subdir = "frameworks/rooch-framework", rev = "main" }
 
 [addresses]
-verity = "_"
-verity_test_foreign_module = "_"
+verity = "0x9a759932a6640790b3e2a5fefdf23917c8830dcd8998fe8af3f3b49b0ab5ca35"
+verity_test_foreign_module = "0x9a759932a6640790b3e2a5fefdf23917c8830dcd8998fe8af3f3b49b0ab5ca35"
 std = "0x1"
 moveos_std = "0x2"
 # rooch_framework = "0x3"

rooch/sources/example_caller.move

@@ -44,9 +44,9 @@ module verity_test_foreign_module::example_caller {
     ) {
         let http_request = Oracles::build_request(url, method, headers, body);
 
-        // We're passing the address and function name of the module as the recipient.
+        // We're passing the address and function identifier of the recipient address. in this from <module_name>::<function_name>
         // If you do not want to pay for the Oracle to notify your contract, you can pass in option::none() as the argument.
-        let request_id = Oracles::new_request(http_request, pick, oracle, Oracles::with_notify(@verity_test_foreign_module, b"receive_data"));
+        let request_id = Oracles::new_request(http_request, pick, oracle, Oracles::with_notify(@verity_test_foreign_module, b"example_caller::receive_data"));
         // let no_notify_request_id = Oracles::new_request(http_request, pick, oracle, Oracles::without_notify());
         let params = account::borrow_mut_resource<GlobalParams>(@verity_test_foreign_module);
         vector::push_back(&mut params.pending_requests, request_id);

rooch/sources/oracles.move

@@ -35,7 +35,7 @@ module verity::oracles {
         params: HTTPRequest,
         pick: String, // An optional JQ string to pick the value from the response JSON data structure.
         oracle: address,
-        response_status: u8,
+        response_status: u16,
         response: Option<String>
     }
 
@@ -153,7 +153,7 @@ module verity::oracles {
     public entry fun fulfil_request(
         sender: &signer,
         id: ObjectID,
-        response_status: u8,
+        response_status: u16,
         result: String
         // proof: String
     ) {
@@ -184,7 +184,7 @@ module verity::oracles {
     public entry fun test_fulfil_request(
         sender: &signer,
         id: ObjectID,
-        response_status: u8,
+        response_status: u16,
         result: String
         // proof: String
     ) {
@@ -265,7 +265,7 @@ module verity::oracles {
     }
 
     #[view]
-    public fun get_response_status(id: &ObjectID): u8 {
+    public fun get_response_status(id: &ObjectID): u16 {
         let request = borrow_request(id);
         request.response_status
     }
@@ -324,7 +324,7 @@ module verity::test_oracles {
         assert!(oracles::get_request_params_url(&id) == string::utf8(b"https://api.example.com/data"), 99952);
         assert!(oracles::get_request_params_method(&id) == string::utf8(b"GET"), 99953);
         assert!(oracles::get_request_params_body(&id) == string::utf8(b""), 99954);
-        assert!(oracles::get_response_status(&id) ==(0 as u8), 99955);
+        assert!(oracles::get_response_status(&id) ==(0 as u16), 99955);
     }
 
     #[test]