feat(realtime): realtime major overhaul

flake.nix

@@ -34,6 +34,7 @@
       pkgs.uv
       pkgs.gnumake
       pkgs.docker
+      pkgs.postgresql_15
     ];
     workspace = uv2nix.lib.workspace.loadWorkspace { workspaceRoot = ./.; };
 
@@ -47,11 +48,14 @@
 
     pyproject-overlay = pkgs: final: prev: {
       ruamel-yaml-clib = prev.ruamel-yaml-clib.overrideAttrs (old: {
-        nativeBuildInputs = old.nativeBuildInputs ++ [
-          (final.resolveBuildSystem {
+        nativeBuildInputs = old.nativeBuildInputs ++ (final.resolveBuildSystem {
             setuptools = [];
-          })
-        ];
+        });
+      });
+      urwid-readline = prev.urwid-readline.overrideAttrs (old: {
+        nativeBuildInputs = old.nativeBuildInputs ++ (final.resolveBuildSystem {
+            setuptools = [];
+        });
       });
       pyiceberg = prev.pyiceberg.overrideAttrs (old: {
         buildInputs = (old.buildInputs or []) ++ [ final.poetry-core ];
@@ -61,12 +65,9 @@
           sed -i '1i from Cython.Build import cythonize' setup.py
           sed -i 's/ext_modules=[pyroaring_module]/ext_modules=[cythonize(pyroaring_module)]/' setup.py
         '';
-        nativeBuildInputs = old.nativeBuildInputs ++ [
-          (final.resolveBuildSystem {
+        nativeBuildInputs = old.nativeBuildInputs ++ [final.cython] ++ (final.resolveBuildSystem {
             setuptools = [];
-          })
-          final.cython
-        ];
+          });
       });
     };
 

src/realtime/infra/supabase/migrations/20240810125543_init.sql

@@ -14,6 +14,11 @@ CREATE POLICY "Allow authenticated access" ON "public"."todos" AS permissive
         USING (TRUE)
         WITH CHECK (TRUE);
 
+CREATE POLICY "authenticated can receive broadcast" ON "realtime"."messages"
+FOR ALL
+TO AUTHENTICATED
+USING (TRUE);
+
 ALTER publication supabase_realtime
     ADD TABLE todos;
 
@@ -26,3 +31,27 @@ create table messages (
 
 -- enable realtime on messages table
 alter publication supabase_realtime add table messages;
+
+-- Grant API access to tables for anon and authenticated roles.
+-- Required since Supabase no longer grants public schema access by default
+-- (see https://github.com/orgs/supabase/discussions/45329).
+GRANT ALL ON TABLE public.todos TO anon, authenticated;
+GRANT ALL ON TABLE public.messages TO anon, authenticated;
+
+-- Grant sequence usage for tables with generated identity primary keys
+GRANT USAGE, SELECT ON SEQUENCE public.messages_id_seq TO anon, authenticated;
+
+CREATE OR replace FUNCTION public.send_realtime(
+    topic text,
+    event text,
+    payload jsonb,
+    private boolean default True
+)
+RETURNS void
+LANGUAGE SQL
+SECURITY DEFINER
+AS $$
+    SELECT realtime.send(payload, event, topic, private);
+$$;
+
+GRANT EXECUTE ON FUNCTION public.send_realtime(text,text,jsonb,boolean) TO anon, authenticated, service_role;

src/realtime/pyproject.toml

@@ -12,11 +12,13 @@ maintainers = [
 license = "MIT"
 readme = "README.md"
 repository = "https://github.com/supabase/supabase-py"
-requires-python = ">=3.9"
+requires-python = ">=3.10"
 dependencies = [
   "websockets >=11,<16",
   "typing-extensions >=4.14.0",
   "pydantic (>=2.11.7,<3.0.0)",
+  "pytest-asyncio>=0.21.0",
+  "yarl>=1.22.0",
 ]
 
 [project.urls]
@@ -32,6 +34,7 @@ tests = [
   "pytest-cov >= 6.2.1",
   "python-dotenv >= 1.1.1",
   "pytest-asyncio >= 1.0.0",
+  "pudb>=2025.1.5",
 ]
 lints = [
   "ruff >= 0.12.1",
@@ -68,11 +71,10 @@ ignore = ["F401", "F403", "F841", "E712", "E501", "E402", "UP006", "UP035"]
 keep-runtime-typing = true
 
 [tool.pytest.ini_options]
-asyncio_mode = "strict"
-asyncio_default_fixture_loop_scope = "function"
+asyncio_mode = "auto"
 
 [tool.mypy]
-python_version = "3.9"
+python_version = "3.10"
 check_untyped_defs = true
 allow_redefinition = true
 

src/realtime/src/realtime/__init__.py

@@ -5,13 +5,9 @@
 
 from realtime.version import __version__
 
-from ._async.channel import AsyncRealtimeChannel
-from ._async.client import AsyncRealtimeClient
-from ._async.presence import AsyncRealtimePresence
-from ._sync.channel import SyncRealtimeChannel
-from ._sync.client import SyncRealtimeClient
-from ._sync.presence import SyncRealtimePresence
+from .channel import RealtimeChannel
+from .client import RealtimeClient
 from .exceptions import *
 from .message import *
-from .transformers import *
+from .presence import RealtimePresence
 from .types import *