fix(realtime): use 'event' instead of 'events' in postgres_changes protocol (#1339)

Co-authored-by: Leonardo Santiago <leonardo.ribeiro.santiago@gmail.com>

Author: alexwhitmore

src/realtime/src/realtime/_async/channel.py

@@ -236,7 +236,7 @@ def on_join_push_ok(payload: ReplyPostgresChanges):
 
                         if (
                             server_binding
-                            and server_binding.events == postgres_callback.event
+                            and server_binding.event == postgres_callback.event
                             and server_binding.schema_ == postgres_callback.schema
                             and server_binding.table == postgres_callback.table
                             and server_binding.filter == postgres_callback.filter

src/realtime/src/realtime/message.py

@@ -36,8 +36,8 @@ class JoinMessage(BaseModel):
 
 class PostgresRowChange(BaseModel):
     id: int
-    events: RealtimePostgresChangesListenEvent
-    table: str
+    event: RealtimePostgresChangesListenEvent
+    table: Optional[str] = None
     schema_: Optional[str] = Field(alias="schema", default=None)
     filter: Optional[str] = None
 

src/realtime/src/realtime/types.py

@@ -147,9 +147,11 @@ def __call__(self, payload: PostgresChangesPayload) -> None:
 
     @property
     def binding_filter(self) -> dict[str, Optional[str]]:
-        binding = {"events": self.event, "table": self.table}
+        binding: dict[str, Optional[str]] = {"event": self.event}
         if self.schema:
             binding["schema"] = self.schema
+        if self.table:
+            binding["table"] = self.table
         if self.filter:
             binding["filter"] = self.filter
         return binding