Use custom domains for uploading base64 data.

Author: rkistner

demos/yjs-react-supabase-text-collab/database.sql

@@ -1,5 +1,24 @@
 
 -- tables
+
+-- custom app_base64 type, to allow querying and updating binary data as base64
+-- via postgrest/supabase-js
+create domain app_base64 as bytea;
+
+-- For query responses
+CREATE OR REPLACE FUNCTION json(app_base64) RETURNS json AS $$
+  select to_json(encode($1, 'base64'));
+$$ LANGUAGE SQL IMMUTABLE;
+CREATE CAST (app_base64 AS json) WITH FUNCTION json(app_base64) AS IMPLICIT;
+
+-- For uploading
+CREATE OR REPLACE FUNCTION app_base64(json) RETURNS public.app_base64 AS $$
+  -- here we reuse the previous app_uuid(text) function
+  select decode($1 #>> '{}', 'base64');
+$$ LANGUAGE SQL IMMUTABLE;
+
+CREATE CAST (json AS public.app_base64) WITH FUNCTION app_base64(json) AS IMPLICIT;
+
 CREATE TABLE documents(
   id UUID PRIMARY KEY DEFAULT gen_random_uuid(), 
   title VARCHAR(255),
@@ -10,7 +29,7 @@ CREATE TABLE document_updates(
   id UUID PRIMARY KEY DEFAULT gen_random_uuid(), 
   created_at timestamptz DEFAULT now(),
   document_id UUID, 
-  update_data BYTEA
+  update_data app_base64
 );
 
 

demos/yjs-react-supabase-text-collab/src/library/powersync/SupabaseConnector.ts

@@ -95,8 +95,9 @@ export class SupabaseConnector extends BaseObserver<SupabaseConnectorListener> i
 
         if (op.op == UpdateType.PUT && op.table == 'document_updates') {
           updateBatch.push({
-            ...record,
-            id: op.id
+            id: op.id,
+            document_id: op.opData!.document_id,
+            update_data: op.opData!.update_b64
           });
           continue;
         }
@@ -123,7 +124,7 @@ export class SupabaseConnector extends BaseObserver<SupabaseConnectorListener> i
 
       if (updateBatch.length > 0) {
         console.log('inserting batch of size', updateBatch.length);
-        const result = await this.client.rpc('insert_document_updates', { batch: JSON.stringify(updateBatch) });
+        const result = await this.client.from('document_updates').upsert(updateBatch);
         if (result.error) {
           console.error(result.error);
           result.error.message = `Could not update Supabase. Received error: ${result.error.message}`;