multi callbacks working

Author: joaquim-verges

Assets/ButtonBehavior.cs.meta

@@ -1,12 +1,19 @@
 mergeInto(LibraryManager.library, {
-  ThirdwebInvoke: function (route, payload, cb) {
+  ThirdwebInvoke: function (taskId, route, payload, cb) {
+    // convert taskId from pointer to str and allocate it to keep in memory
+    var id = UTF8ToString(taskId);
+    var idSize = lengthBytesUTF8(id) + 1;
+    var idPtr = _malloc(idSize);
+    stringToUTF8(id, idPtr, idSize);
+    // execute bridge call
     window.bridge
       .invoke(UTF8ToString(route), UTF8ToString(payload))
       .then((returnStr) => {
         var bufferSize = lengthBytesUTF8(returnStr) + 1;
         var buffer = _malloc(bufferSize);
         stringToUTF8(returnStr, buffer, bufferSize);
-        dynCall_vi(cb, buffer);
+        // callback into unity
+        dynCall_vii(cb, idPtr, buffer);
       });
   },
 });

Assets/Plugin/thirdweb.jslib

@@ -18,10 +18,14 @@ void Update()
 
     }
 
+    int count;
+
     public async void OnLoginClick()
     {
         Debug.Log("Button clicked ");
-        string result = await SDK.Initialize();
-        Debug.Log("result" + result);
+        count++;
+        NFT result = await SDK.GetNFT(count.ToString());
+        Debug.Log("name: " + result.metadata.name);
+        Debug.Log("owner: " + result.owner);
     }
 }

Assets/SDKTest.cs

@@ -12,7 +12,6 @@ public class Bridge
         [System.Serializable]
         private struct Result<T>
         {
-            public string ack_id;
             public T result;
         }
 
@@ -26,36 +25,43 @@ public RequestMessageBody(string[] arguments)
             public string[] arguments;
         }
 
-        private static TaskCompletionSource<string> utcs;
+        private static Dictionary<string, TaskCompletionSource<string>> taskMap = new Dictionary<string, TaskCompletionSource<string>>();
 
-        [AOT.MonoPInvokeCallback(typeof(Action<string>))]
-        private static void testFuncCB(string result)
+        [AOT.MonoPInvokeCallback(typeof(Action<string, string>))]
+        private static void jsCallback(string taskId, string result)
         {
-            utcs.TrySetResult(result);  
+            if (taskMap.ContainsKey(taskId))
+            {
+                taskMap[taskId].TrySetResult(result);  
+                taskMap.Remove(taskId);
+            }
         }
 
         public static async Task<T> InvokeRoute<T>(string route, string[] body)
         {
             var msg = JsonUtility.ToJson(new RequestMessageBody(body));
-            var ack_id = ThirdwebInvoke(route, msg, testFuncCB);
-            var tr = new TaskCompletionSource<string>();
-            string result = await tr.Task;
+            string taskId = System.Guid.NewGuid().ToString();
+            var task = new TaskCompletionSource<string>();
+            taskMap[taskId] = task;
+            ThirdwebInvoke(taskId, route, msg, jsCallback);
+            string result = await task.Task;
             // Debug.LogFormat("Result from {0}: {1}", route, result);
             return JsonUtility.FromJson<Result<T>>(result).result;
         }
 
         public static async Task<string> InvokeRouteRaw(string route, string[] body)
         {
             var msg = JsonUtility.ToJson(new RequestMessageBody(body));
-            Debug.LogFormat("Calling JS");
-            utcs = new TaskCompletionSource<string>();
-            ThirdwebInvoke(route, msg, testFuncCB);
-            var result = await utcs.Task;
+            string taskId = System.Guid.NewGuid().ToString();
+            var task = new TaskCompletionSource<string>();
+            taskMap[taskId] = task;
+            ThirdwebInvoke(taskId, route, msg, jsCallback);
+            string result = await task.Task;
             // Debug.LogFormat("Result from {0}: {1}", route, result);
             return result;
         }
 
         [DllImport("__Internal")]
-        private static extern string ThirdwebInvoke(string route, string payload, Action<string> cb);
+        private static extern string ThirdwebInvoke(string taskId, string route, string payload, Action<string, string> cb);
     }
 }

Assets/Thirdweb/Scripts/Bridge.cs

@@ -4,11 +4,30 @@
 
 namespace Thirdweb
 {
+
+    [System.Serializable]
+    public struct NFTMetadata
+    {
+        public string id;
+        public string uri;
+        public string description;
+        public string image;
+        public string name;
+        // TODO: support properties;
+    }
+
+    [System.Serializable]
+    public struct NFT
+    {
+        public NFTMetadata metadata;
+        public string owner;
+    }
+
     public class SDK
     {
-        public static async Task<string> Initialize()
+        public static async Task<NFT> GetNFT(string id)
         {
-            var result = await Bridge.InvokeRouteRaw("initialize", new string[] { });
+            var result = await Bridge.InvokeRoute<NFT>("erc721.get", new string[] { id });
             return result;
         }
 

Assets/Thirdweb/Scripts/SDK.cs

@@ -78,15 +78,17 @@
             loadingCover.style.display = "";
 
             import { ThirdwebSDK } from "https://esm.sh/@thirdweb-dev/sdk@nightly?bundle"
+            let id = 0;
             const w = window;
             w.bridge = {};
             w.bridge.invoke = async (route, payload) => {
               console.log("invoke called", route, payload);
               const sdk = new ThirdwebSDK("goerli");
               const contract = await sdk.getContract("0x2e01763fA0e15e07294D74B63cE4b526B321E389")
-              const all = await contract.erc721.getAll();
-              console.log("all", all);
-              return JSON.stringify(all);
+              const tokenId = JSON.parse(payload).arguments[0];
+              console.log("tokenId", tokenId);
+              const all = await contract.erc721.get(tokenId);
+              return JSON.stringify({ result: all });
             };
 
             const script = document.createElement("script");