Add explicit session id & implicit Execute (Batch)

Author: 0xFirekeeper

Thirdweb.Console/Program.cs

@@ -69,9 +69,31 @@
 );
 Console.WriteLine($"Response 3: {response3.Message}");
 
-// // Execute, this directly sends transactions
-// var receipt = await nebula.Execute("Send a valueless transaction to my wallet!", wallet: myWallet, context: new NebulaContext(chainIds: new List<BigInteger> { myChain }));
-// Console.WriteLine($"Receipt: {JsonConvert.SerializeObject(receipt, Formatting.Indented)}");
+// Execute, this directly sends transactions
+var executionResult = await nebula.Execute("Send 0 ETH to vitalik.eth", wallet: myWallet, context: new NebulaContext(chainIds: new List<BigInteger> { myChain }));
+if (executionResult.TransactionReceipts != null && executionResult.TransactionReceipts.Count > 0)
+{
+    Console.WriteLine($"Receipt: {executionResult.TransactionReceipts[0]}");
+}
+else
+{
+    Console.WriteLine($"Message: {executionResult.Message}");
+}
+
+// Batch execute
+var batchExecutionResult = await nebula.Execute(
+    new List<NebulaChatMessage> { new("Send 0 ETH to vitalik.eth", NebulaChatRole.User), new("Are you sure?", NebulaChatRole.Assistant), new("Yes", NebulaChatRole.User) },
+    wallet: myWallet,
+    context: new NebulaContext(chainIds: new List<BigInteger> { myChain })
+);
+if (batchExecutionResult.TransactionReceipts != null && batchExecutionResult.TransactionReceipts.Count > 0)
+{
+    Console.WriteLine($"Receipts: {JsonConvert.SerializeObject(batchExecutionResult.TransactionReceipts, Formatting.Indented)}");
+}
+else
+{
+    Console.WriteLine($"Message: {batchExecutionResult.Message}");
+}
 
 #endregion
 

Thirdweb/Thirdweb.AI/ThirdwebNebula.cs

@@ -71,19 +71,28 @@ internal ThirdwebNebula(ThirdwebClient client)
         this.FeedbackClient = new FeedbackClient(httpClient);
     }
 
-    public static async Task<ThirdwebNebula> Create(ThirdwebClient client, string model = Constants.NEBULA_DEFAULT_MODEL)
+    public static async Task<ThirdwebNebula> Create(ThirdwebClient client, string model = Constants.NEBULA_DEFAULT_MODEL, string sessionId = null)
     {
         var nebula = new ThirdwebNebula(client);
-        var session = await nebula.Sessions.CreateSessionAsync(
-            new CreateSessionParams()
-            {
-                ModelName = model,
-                Title = $"Thirdweb .NET SDK (v{Constants.VERSION}) | Nebula {model} Session | Client ID: {client.ClientId}",
-                IsPublic = false
-            }
-        );
-        nebula.SessionId = session.Id;
-        return nebula;
+
+        if (!string.IsNullOrWhiteSpace(sessionId))
+        {
+            nebula.SessionId = sessionId;
+            return nebula;
+        }
+        else
+        {
+            var session = await nebula.Sessions.CreateSessionAsync(
+                new CreateSessionParams()
+                {
+                    ModelName = model,
+                    Title = $"Thirdweb .NET SDK (v{Constants.VERSION}) | Nebula {model} Session | Client ID: {client.ClientId}",
+                    IsPublic = false
+                }
+            );
+            nebula.SessionId = session.Id;
+            return nebula;
+        }
     }
 
     public async Task<NebulaChatResult> Chat(string message, IThirdwebWallet wallet = null, NebulaContext context = null)
@@ -169,6 +178,41 @@ public async Task<NebulaExecuteResult> Execute(string message, IThirdwebWallet w
         }
     }
 
+    public async Task<NebulaExecuteResult> Execute(List<NebulaChatMessage> messages, IThirdwebWallet wallet, NebulaContext context = null)
+    {
+        if (messages == null || messages.Count == 0 || messages.Any(m => string.IsNullOrWhiteSpace(m.Message)))
+        {
+            throw new ArgumentException("Messages cannot be null or empty.", nameof(messages));
+        }
+
+        if (wallet == null)
+        {
+            throw new ArgumentException("Wallet cannot be null.", nameof(wallet));
+        }
+
+        var contextFiler = await PrepareContextFilter(wallet, context);
+        var result = await this.ExecuteClient.ExecuteBatchAsync(
+            new ChatParamsMultiMessages()
+            {
+                SessionId = this.SessionId,
+                Messages = messages.Select(prompt => new ChatMessage() { Content = prompt.Message, Role = prompt.Role.ToString().ToLower() }).ToList(),
+                ContextFilter = contextFiler,
+                ExecuteConfig = new ExecuteConfig() { Mode = "client", SignerWalletAddress = await wallet.GetAddress() }
+            }
+        );
+
+        var transactions = await PrepareTransactions(wallet, result.Actions);
+        if (transactions == null || transactions.Count == 0)
+        {
+            return new NebulaExecuteResult() { Message = result.Message };
+        }
+        else
+        {
+            var receipts = await Task.WhenAll(transactions.Select(ThirdwebTransaction.SendAndWaitForTransactionReceipt));
+            return new NebulaExecuteResult() { Message = result.Message, TransactionReceipts = receipts.ToList() };
+        }
+    }
+
     private static async Task<ContextFilter> PrepareContextFilter(IThirdwebWallet wallet, NebulaContext context)
     {
         context ??= new NebulaContext();