Supabase sync

[Ashraf-Ali-aa]

Is your feature request related to a problem? Please describe.
A clear and concise description of what the problem is. Ex. I'm always frustrated when [...]

I wanted to use Tinybase with supabase live updates so that I could use one backend and develop a local first app.

Describe the solution you'd like
A clear and concise description of what you want to happen.

Add support to persist data from supabase

Describe alternatives you've considered
A clear and concise description of any alternative solutions or features you've considered.

Tinybase already supports postgres so the implementation should be mostly handled

Additional context
Add any other context or screenshots about the feature request here.

[Ashraf-Ali-aa]

I am not sure if this could would work

import type {
  DatabaseChangeListener,
  DatabasePersisterConfig,
} from '../../@types/persisters/index.d.ts';
import type { SupabaseClient } from '@supabase/supabase-js';
import type {
  PostgresPersister,
  createPostgresPersister as createPostgresPersisterDecl,
} from '../../@types/persisters/persister-postgres/index.d.ts';
import type { MergeableStore } from '../../@types/mergeable-store/index.d.ts';
import type { Store } from '../../@types/store/index.d.ts';
import { createCustomPostgreSqlPersister } from '../common/database/postgresql.ts';

export const createSupabasePersister = (async (
  store: Store | MergeableStore,
  supabase: SupabaseClient,
  configOrStoreTableName?: DatabasePersisterConfig | string,
  onSqlCommand?: (sql: string, params?: any[]) => void,
  onIgnoredError?: (error: any) => void,
): Promise<PostgresPersister> => {
  const channel = typeof configOrStoreTableName === 'string' 
    ? configOrStoreTableName 
    : (configOrStoreTableName?.tableName || 'tinybase_store');

  return createCustomPostgreSqlPersister(
    store,
    configOrStoreTableName,
    async (sql: string, params?: any[]) => {
      const { data, error } = await supabase.rpc('execute_sql', {
        sql_query: sql,
        params: params
      });
      
      if (error) throw error;
      return data;
    },
    async (channelName: string, listener: DatabaseChangeListener) => {
      const subscription = supabase
        .channel(channelName)
        .on('postgres_changes', 
          { event: '*', schema: 'public', table: channel },
          (payload) => listener(payload.new)
        )
        .subscribe();
      
      return subscription;
    },
    async (subscription) => {
      try {
        await supabase.removeChannel(subscription);
      } catch (e) {
        onIgnoredError?.(e);
      }
    },
    onSqlCommand,
    onIgnoredError,
    () => Promise.resolve(),
    3,
    supabase,
    'getSupabase',
  ) as PostgresPersister;
}) as typeof createPostgresPersisterDecl;