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',
@@ -290,6 +295,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,137 @@
+package {{ sdk.namespace | caseDot }}
+
+// The result of building the channel.
+class ResolvedChannel(private val value: String) {
+    override fun toString(): String {
+        return value
+    }
+}
+
+// Helper for normalizing IDs
+private fun normalize(id: String): String {
+    val trimmed = id.trim()
+    return if (trimmed.isEmpty()) "*" else trimmed
+}
+
+// Interface for actionable channels
+interface Actionable {
+    val channel: String
+    fun create(): ResolvedChannel
+    fun update(): ResolvedChannel
+    fun delete(): ResolvedChannel
+}
+
+interface IDatabase {
+    fun collection(id: String = "*"): ICollection
+}
+
+interface ICollection {
+    fun document(id: String = "*"): IDocument
+}
+
+interface IDocument : Actionable
+
+interface ITablesDB {
+    fun table(id: String = "*"): ITable
+}
+
+interface ITable {
+    fun row(id: String = "*"): IRow
+}
+
+interface IRow : Actionable
+
+interface IBucket {
+    fun file(id: String = "*"): IFile
+}
+
+interface IFile : Actionable
+
+interface IFunction {
+    fun execution(id: String = "*"): IExecution
+}
+
+interface IExecution : Actionable
+
+private class ChannelBuilder(
+    private val segments: List<String>
+) : IDatabase, ICollection, IDocument,
+    ITablesDB, ITable, IRow,
+    IBucket, IFile,
+    IFunction, IExecution, Actionable {
+
+    companion object {
+        fun start(segments: List<String>) = ChannelBuilder(segments)
+    }
+
+    private fun next(segment: String, id: String): ChannelBuilder {
+        return ChannelBuilder(segments + listOf(segment, normalize(id)))
+    }
+
+    override fun collection(id: String): ICollection =
+        next("collections", id)
+
+    override fun document(id: String): IDocument =
+        next("documents", id)
+
+    override fun table(id: String): ITable =
+        next("tables", id)
+
+    override fun row(id: String): IRow =
+        next("rows", id)
+
+    override fun file(id: String): IFile =
+        next("files", id)
+
+    override fun execution(id: String): IExecution =
+        next("executions", id)
+
+    override val channel: String
+        get() = segments.joinToString(".")
+
+    override fun create(): ResolvedChannel =
+        ResolvedChannel("$channel.create")
+
+    override fun update(): ResolvedChannel =
+        ResolvedChannel("$channel.update")
+
+    override fun delete(): ResolvedChannel =
+        ResolvedChannel("$channel.delete")
+
+    override fun toString(): String = channel
+}
+
+class Channel private constructor() {
+
+    companion object {
+
+        fun database(id: String = "*"): IDatabase =
+            ChannelBuilder.start(listOf("databases", normalize(id)))
+
+        fun tablesdb(id: String = "*"): ITablesDB =
+            ChannelBuilder.start(listOf("tablesdb", normalize(id)))
+
+        fun buckets(id: String = "*"): IBucket =
+            ChannelBuilder.start(listOf("buckets", normalize(id)))
+
+        fun functions(id: String = "*"): IFunction =
+            ChannelBuilder.start(listOf("functions", normalize(id)))
+
+        fun teams(id: String = "*"): Actionable =
+            ChannelBuilder.start(listOf("teams", normalize(id)))
+
+        fun memberships(id: String = "*"): Actionable =
+            ChannelBuilder.start(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"
+    }
+}

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

@@ -2,6 +2,8 @@ package {{ sdk.namespace | caseDot }}.services
 
 import {{ sdk.namespace | caseDot }}.Service
 import {{ sdk.namespace | caseDot }}.Client
+import {{ sdk.namespace | caseDot }}.Actionable
+import {{ sdk.namespace | caseDot }}.ResolvedChannel
 import {{ sdk.namespace | caseDot }}.exceptions.{{ spec.title | caseUcfirst }}Exception
 import {{ sdk.namespace | caseDot }}.extensions.forEachAsync
 import {{ sdk.namespace | caseDot }}.extensions.fromJson
@@ -109,6 +111,30 @@ class Realtime(client: Client) : Service(client), CoroutineScope {
         else -> 60000L
     }
 
+    /**
+     * Convert channel value to string
+     * Checks if it's an Actionable instance (use .channel),
+     * then ResolvedChannel (use .toString()),
+     * otherwise treats as string
+     */
+    private fun channelToString(channel: Any): String {
+        return when {
+            channel is String -> channel
+            channel is Actionable -> channel.channel
+            channel is ResolvedChannel -> channel.toString()
+            else -> channel.toString()
+        }
+    }
+
+    fun subscribe(
+        vararg channels: Any,
+        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 +144,18 @@ class Realtime(client: Client) : Service(client), CoroutineScope {
         callback
     )
 
+    fun <T> subscribe(
+        vararg channels: Any,
+        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>,