realtime updates in skills

Author: atharvadeosthale

templates/agent-skills/dart.md.twig

@@ -260,16 +260,19 @@ await teams.delete(teamId: '[TEAM_ID]');
 ```dart
 final realtime = Realtime(client);
 
-final subscription = realtime.subscribe(['tablesdb.[DATABASE_ID].tables.[TABLE_ID].rows']);
+// Subscribe to row changes
+final subscription = realtime.subscribe([
+    Channel.tablesdb('[DATABASE_ID]').table('[TABLE_ID]').row(),
+]);
 subscription.stream.listen((response) {
     print(response.events);   // e.g. ['tablesdb.*.tables.*.rows.*.create']
     print(response.payload);  // the affected resource
 });
 
 // Subscribe to multiple channels
 final multi = realtime.subscribe([
-    'tablesdb.[DATABASE_ID].tables.[TABLE_ID].rows',
-    'buckets.[BUCKET_ID].files',
+    Channel.tablesdb('[DATABASE_ID]').table('[TABLE_ID]').row(),
+    Channel.bucket('[BUCKET_ID]').file(),
 ]);
 
 // Cleanup

templates/agent-skills/kotlin.md.twig

@@ -284,17 +284,22 @@ teams.delete(teamId = "[TEAM_ID]")
 ### Real-time Subscriptions (client-side)
 
 ```kotlin
+import io.{{ spec.title | caseLower }}.Channel
+
 val realtime = Realtime(client)
 
-val subscription = realtime.subscribe("tablesdb.[DATABASE_ID].tables.[TABLE_ID].rows") { response ->
+// Subscribe to row changes
+val subscription = realtime.subscribe(
+    Channel.tablesdb("[DATABASE_ID]").table("[TABLE_ID]").row()
+) { response ->
     println(response.events)   // e.g. ["tablesdb.*.tables.*.rows.*.create"]
     println(response.payload)  // the affected resource
 }
 
 // Subscribe to multiple channels
 val multi = realtime.subscribe(
-    "tablesdb.[DATABASE_ID].tables.[TABLE_ID].rows",
-    "buckets.[BUCKET_ID].files"
+    Channel.tablesdb("[DATABASE_ID]").table("[TABLE_ID]").row(),
+    Channel.bucket("[BUCKET_ID]").file()
 ) { response -> /* ... */ }
 
 // Cleanup

templates/agent-skills/swift.md.twig

@@ -230,19 +230,22 @@ try await teams.delete(teamId: "[TEAM_ID]")
 ```swift
 let realtime = Realtime(client)
 
-let subscription = realtime.subscribe(channels: ["tablesdb.[DATABASE_ID].tables.[TABLE_ID].rows"]) { response in
+// Subscribe to row changes
+let subscription = try await realtime.subscribe(channels: [
+    Channel.tablesdb("[DATABASE_ID]").table("[TABLE_ID]").row()
+]) { response in
     print(response.events)   // e.g. ["tablesdb.*.tables.*.rows.*.create"]
     print(response.payload)  // the affected resource
 }
 
 // Subscribe to multiple channels
-let multi = realtime.subscribe(channels: [
-    "tablesdb.[DATABASE_ID].tables.[TABLE_ID].rows",
-    "buckets.[BUCKET_ID].files",
+let multi = try await realtime.subscribe(channels: [
+    Channel.tablesdb("[DATABASE_ID]").table("[TABLE_ID]").row(),
+    Channel.files(),
 ]) { response in /* ... */ }
 
 // Cleanup
-subscription.close()
+try await subscription.close()
 ```
 
 **Available channels:**

templates/agent-skills/typescript.md.twig

@@ -422,25 +422,33 @@ await teams.delete({ teamId: '[TEAM_ID]' });
 ### Real-time Subscriptions (client-side)
 
 ```typescript
+import { Realtime, Channel } from '{{ spec.title | caseLower }}';
+
+const realtime = new Realtime(client);
+
 // Subscribe to row changes
-const unsubscribe = client.subscribe('tablesdb.[DATABASE_ID].tables.[TABLE_ID].rows', (response) => {
-    console.log(response.events);   // e.g. ['tablesdb.*.tables.*.rows.*.create']
-    console.log(response.payload);  // the affected resource
-});
+const subscription = await realtime.subscribe(
+    Channel.tablesdb('[DATABASE_ID]').table('[TABLE_ID]').row(),
+    (response) => {
+        console.log(response.events);   // e.g. ['tablesdb.*.tables.*.rows.*.create']
+        console.log(response.payload);  // the affected resource
+    }
+);
 
-// Subscribe to file changes
-client.subscribe('buckets.[BUCKET_ID].files', (response) => {
-    console.log(response.payload);
-});
+// Subscribe to a specific row
+await realtime.subscribe(
+    Channel.tablesdb('[DATABASE_ID]').table('[TABLE_ID]').row('[ROW_ID]'),
+    (response) => { /* ... */ }
+);
 
 // Subscribe to multiple channels
-client.subscribe([
-    'tablesdb.[DATABASE_ID].tables.[TABLE_ID].rows',
-    'buckets.[BUCKET_ID].files',
+await realtime.subscribe([
+    Channel.tablesdb('[DATABASE_ID]').table('[TABLE_ID]').row(),
+    Channel.bucket('[BUCKET_ID]').file(),
 ], (response) => { /* ... */ });
 
 // Unsubscribe
-unsubscribe();
+await subscription.close();
 ```
 
 **Available channels:**