Added channel helpers for realtime in the client sdks

src/SDK/Language/Android.php

@@ -120,6 +120,11 @@ public function getFiles(): array
                 'destination'   => '/library/src/main/java/{{ sdk.namespace | caseSlash }}/ID.kt',
                 'template'      => '/android/library/src/main/java/io/package/ID.kt.twig',
             ],
+            [
+                'scope'         => 'default',
+                'destination'   => '/library/src/main/java/{{ sdk.namespace | caseSlash }}/Channel.kt',
+                'template'      => '/android/library/src/main/java/io/package/Channel.kt.twig',
+            ],
             [
                 'scope'         => 'default',
                 'destination'   => '/library/src/main/java/{{ sdk.namespace | caseSlash }}/Query.kt',

src/SDK/Language/Apple.php

@@ -70,6 +70,11 @@ public function getFiles(): array
                 'destination'   => '/Sources/{{ spec.title | caseUcfirst}}/ID.swift',
                 'template'      => 'swift/Sources/ID.swift.twig',
             ],
+            [
+                'scope'         => 'default',
+                'destination'   => '/Sources/{{ spec.title | caseUcfirst}}/Channel.swift',
+                'template'      => 'apple/Sources/Channel.swift.twig',
+            ],
             [
                 'scope'         => 'default',
                 'destination'   => '/Sources/{{ spec.title | caseUcfirst}}/Query.swift',

src/SDK/Language/Flutter.php

@@ -80,6 +80,11 @@ public function getFiles(): array
                 'destination'   => '/lib/id.dart',
                 'template'      => 'dart/lib/id.dart.twig',
             ],
+            [
+                'scope'         => 'default',
+                'destination'   => '/lib/channel.dart',
+                'template'      => 'flutter/lib/channel.dart.twig',
+            ],
             [
                 'scope'         => 'default',
                 'destination'   => '/lib/query.dart',
@@ -295,6 +300,11 @@ public function getFiles(): array
                 'destination'   => '/test/role_test.dart',
                 'template'      => 'dart/test/role_test.dart.twig',
             ],
+            [
+                'scope'         => 'default',
+                'destination'   => '/test/channel_test.dart',
+                'template'      => 'flutter/test/src/channel_test.dart.twig',
+            ],
             [
                 'scope'         => 'default',
                 'destination'   => '/test/src/cookie_manager_test.dart',

src/SDK/Language/ReactNative.php

@@ -60,6 +60,11 @@ public function getFiles(): array
                 'destination'   => 'src/id.ts',
                 'template'      => 'react-native/src/id.ts.twig',
             ],
+            [
+                'scope'         => 'default',
+                'destination'   => 'src/channel.ts',
+                'template'      => 'react-native/src/channel.ts.twig',
+            ],
             [
                 'scope'         => 'default',
                 'destination'   => 'src/query.ts',

src/SDK/Language/Web.php

@@ -80,6 +80,11 @@ public function getFiles(): array
                 'destination'   => 'src/id.ts',
                 'template'      => 'web/src/id.ts.twig',
             ],
+            [
+                'scope'         => 'default',
+                'destination'   => 'src/channel.ts',
+                'template'      => 'web/src/channel.ts.twig',
+            ],
             [
                 'scope'         => 'default',
                 'destination'   => 'src/query.ts',

templates/android/library/src/main/java/io/package/Channel.kt.twig

@@ -0,0 +1,261 @@
+package {{ sdk.namespace | caseDot }}
+
+// Marker interfaces for type safety
+public interface _Root
+public interface _Database
+public interface _Collection
+public interface _Document
+public interface _TablesDB
+public interface _Table
+public interface _Row
+public interface _Bucket
+public interface _File
+public interface _Func
+public interface _Execution
+public interface _Team
+public interface _Membership
+public interface _Resolved
+
+// Union type for actionable channels
+typealias Actionable = _Document
+
+/**
+ * Helper for normalizing IDs
+ */
+private fun normalize(id: String): String {
+    val trimmed = id.trim()
+    return if (trimmed.isEmpty()) "*" else trimmed
+}
+
+/**
+ * Channel class with generic type parameter for type-safe method chaining
+ */
+class Channel<out T> private constructor(
+    private val segments: List<String>
+) {
+    /**
+     * Internal helper to transition to next state with segment and ID
+     * Public for extension function access
+     */
+    fun <N> next(segment: String, id: String = "*"): Channel<N> {
+        return Channel(segments + listOf(segment, normalize(id)))
+    }
+
+    /**
+     * Internal helper for terminal actions (no ID segment)
+     * Public for extension function access
+     */
+    fun resolve(action: String): Channel<_Resolved> {
+        return Channel(segments + listOf(action))
+    }
+
+    /**
+     * Convert channel to string representation
+     */
+    override fun toString(): String = segments.joinToString(".")
+
+    companion object {
+        fun database(id: String = "*"): Channel<_Database> =
+            Channel(listOf("databases", normalize(id)))
+
+        fun tablesdb(id: String = "*"): Channel<_TablesDB> =
+            Channel(listOf("tablesdb", normalize(id)))
+
+        fun bucket(id: String = "*"): Channel<_Bucket> =
+            Channel(listOf("buckets", normalize(id)))
+
+        fun function(id: String = "*"): Channel<_Func> =
+            Channel(listOf("functions", normalize(id)))
+
+        fun team(id: String = "*"): Channel<_Team> =
+            Channel(listOf("teams", normalize(id)))
+
+        fun membership(id: String = "*"): Channel<_Membership> =
+            Channel(listOf("memberships", normalize(id)))
+
+        fun account(userId: String = ""): String {
+            val id = normalize(userId)
+            return if (id == "*") "account" else "account.$id"
+        }
+
+        // Global events
+        const val documents = "documents"
+        const val rows = "rows"
+        const val files = "files"
+        const val executions = "executions"
+    }
+}
+
+// --- DATABASE ROUTE ---
+// Extension functions restricted by receiver type
+
+/**
+ * Only available on Channel<_Database>
+ */
+fun Channel<_Database>.collection(id: String = "*"): Channel<_Collection> =
+    this.next("collections", id)
+
+/**
+ * Only available on Channel<_Collection>
+ */
+fun Channel<_Collection>.document(id: String = "*"): Channel<_Document> =
+    this.next("documents", id)
+
+// --- TABLESDB ROUTE ---
+
+/**
+ * Only available on Channel<_TablesDB>
+ */
+fun Channel<_TablesDB>.table(id: String = "*"): Channel<_Table> =
+    this.next("tables", id)
+
+/**
+ * Only available on Channel<_Table>
+ */
+fun Channel<_Table>.row(id: String = "*"): Channel<_Row> =
+    this.next("rows", id)
+
+// --- BUCKET ROUTE ---
+
+/**
+ * Only available on Channel<_Bucket>
+ */
+fun Channel<_Bucket>.file(id: String = "*"): Channel<_File> =
+    this.next("files", id)
+
+// --- FUNCTION ROUTE ---
+
+/**
+ * Only available on Channel<_Func>
+ */
+fun Channel<_Func>.execution(id: String = "*"): Channel<_Execution> =
+    this.next("executions", id)
+
+// --- TERMINAL ACTIONS ---
+// Restricted to Actionable types (_Document, _Row, _File, _Execution, _Team, _Membership)
+
+/**
+ * Only available on Channel<_Document>
+ */
+@JvmName("createDocument")
+fun Channel<_Document>.create(): Channel<_Resolved> =
+    this.resolve("create")
+
+/**
+ * Only available on Channel<_Document>
+ */
+@JvmName("updateDocument")
+fun Channel<_Document>.update(): Channel<_Resolved> =
+    this.resolve("update")
+
+/**
+ * Only available on Channel<_Document>
+ */
+@JvmName("deleteDocument")
+fun Channel<_Document>.delete(): Channel<_Resolved> =
+    this.resolve("delete")
+
+/**
+ * Only available on Channel<_Row>
+ */
+@JvmName("createRow")
+fun Channel<_Row>.create(): Channel<_Resolved> =
+    this.resolve("create")
+
+/**
+ * Only available on Channel<_Row>
+ */
+@JvmName("updateRow")
+fun Channel<_Row>.update(): Channel<_Resolved> =
+    this.resolve("update")
+
+/**
+ * Only available on Channel<_Row>
+ */
+@JvmName("deleteRow")
+fun Channel<_Row>.delete(): Channel<_Resolved> =
+    this.resolve("delete")
+
+/**
+ * Only available on Channel<_File>
+ */
+@JvmName("createFile")
+fun Channel<_File>.create(): Channel<_Resolved> =
+    this.resolve("create")
+
+/**
+ * Only available on Channel<_File>
+ */
+@JvmName("updateFile")
+fun Channel<_File>.update(): Channel<_Resolved> =
+    this.resolve("update")
+
+/**
+ * Only available on Channel<_File>
+ */
+@JvmName("deleteFile")
+fun Channel<_File>.delete(): Channel<_Resolved> =
+    this.resolve("delete")
+
+/**
+ * Only available on Channel<_Execution>
+ */
+@JvmName("createExecution")
+fun Channel<_Execution>.create(): Channel<_Resolved> =
+    this.resolve("create")
+
+/**
+ * Only available on Channel<_Execution>
+ */
+@JvmName("updateExecution")
+fun Channel<_Execution>.update(): Channel<_Resolved> =
+    this.resolve("update")
+
+/**
+ * Only available on Channel<_Execution>
+ */
+@JvmName("deleteExecution")
+fun Channel<_Execution>.delete(): Channel<_Resolved> =
+    this.resolve("delete")
+
+/**
+ * Only available on Channel<_Team>
+ */
+@JvmName("createTeam")
+fun Channel<_Team>.create(): Channel<_Resolved> =
+    this.resolve("create")
+
+/**
+ * Only available on Channel<_Team>
+ */
+@JvmName("updateTeam")
+fun Channel<_Team>.update(): Channel<_Resolved> =
+    this.resolve("update")
+
+/**
+ * Only available on Channel<_Team>
+ */
+@JvmName("deleteTeam")
+fun Channel<_Team>.delete(): Channel<_Resolved> =
+    this.resolve("delete")
+
+/**
+ * Only available on Channel<_Membership>
+ */
+@JvmName("createMembership")
+fun Channel<_Membership>.create(): Channel<_Resolved> =
+    this.resolve("create")
+
+/**
+ * Only available on Channel<_Membership>
+ */
+@JvmName("updateMembership")
+fun Channel<_Membership>.update(): Channel<_Resolved> =
+    this.resolve("update")
+
+/**
+ * Only available on Channel<_Membership>
+ */
+@JvmName("deleteMembership")
+fun Channel<_Membership>.delete(): Channel<_Resolved> =
+    this.resolve("delete")

templates/android/library/src/main/java/io/package/services/Realtime.kt.twig

@@ -2,6 +2,7 @@ package {{ sdk.namespace | caseDot }}.services
 
 import {{ sdk.namespace | caseDot }}.Service
 import {{ sdk.namespace | caseDot }}.Client
+import {{ sdk.namespace | caseDot }}.Channel
 import {{ sdk.namespace | caseDot }}.exceptions.{{ spec.title | caseUcfirst }}Exception
 import {{ sdk.namespace | caseDot }}.extensions.forEachAsync
 import {{ sdk.namespace | caseDot }}.extensions.fromJson
@@ -109,6 +110,27 @@ class Realtime(client: Client) : Service(client), CoroutineScope {
         else -> 60000L
     }
 
+    /**
+     * Convert channel value to string
+     * All Channel instances have toString() method
+     */
+    private fun channelToString(channel: Any): String {
+        return when {
+            channel is String -> channel
+            channel is Channel<*> -> channel.toString()
+            else -> channel.toString()
+        }
+    }
+
+    fun subscribe(
+        vararg channels: Channel<*>,
+        callback: (RealtimeResponseEvent<Any>) -> Unit,
+    ) = subscribe(
+        channels = channels.map { channelToString(it) }.toTypedArray(),
+        Any::class.java,
+        callback
+    )
+
     fun subscribe(
         vararg channels: String,
         callback: (RealtimeResponseEvent<Any>) -> Unit,
@@ -118,6 +140,18 @@ class Realtime(client: Client) : Service(client), CoroutineScope {
         callback
     )
 
+    fun <T> subscribe(
+        vararg channels: Channel<*>,
+        payloadType: Class<T>,
+        callback: (RealtimeResponseEvent<T>) -> Unit,
+    ): RealtimeSubscription {
+        return subscribe(
+            channels = channels.map { channelToString(it) }.toTypedArray(),
+            payloadType = payloadType,
+            callback = callback
+        )
+    }
+
     fun <T> subscribe(
         vararg channels: String,
         payloadType: Class<T>,