സുപാബേസ് പോസ്റ്റ്ഗ്രെസ് അഡാപ്റ്റർ

-- Table
CREATE TABLE public.locations (
  id uuid DEFAULT gen_random_uuid() PRIMARY KEY,
  user_id uuid REFERENCES auth.users NOT NULL DEFAULT auth.uid(),
  latitude double precision NOT NULL,
  longitude double precision NOT NULL,
  accuracy double precision,
  speed double precision,
  timestamp timestamptz NOT NULL,
  is_moving boolean,
  created_at timestamptz DEFAULT now()
);
 
ALTER TABLE public.locations ENABLE ROW LEVEL SECURITY;
 
CREATE POLICY "Users insert their own locations" ON public.locations
  FOR INSERT WITH CHECK (auth.uid() = user_id);
 
-- RPC function: receives the batch as a jsonb array and inserts each row.
-- (The exact field names come from Tracelet's sync payload — see the
--  Tracelet Sync docs for the payload schema.)
CREATE OR REPLACE FUNCTION public.insert_tracelet_locations(payload jsonb)
RETURNS void
LANGUAGE sql
SECURITY INVOKER
AS $$
  INSERT INTO public.locations (latitude, longitude, accuracy, speed, timestamp, is_moving)
  SELECT
    (e->'coords'->>'latitude')::double precision,
    (e->'coords'->>'longitude')::double precision,
    (e->'coords'->>'accuracy')::double precision,
    (e->'coords'->>'speed')::double precision,
    (e->>'timestamp')::timestamptz,
    (e->>'is_moving')::boolean
  FROM jsonb_array_elements(payload) AS e;
$$;

import 'package:supabase_flutter/supabase_flutter.dart';
 
void main() async {
  WidgetsFlutterBinding.ensureInitialized();
  await Supabase.initialize(
    url: 'https://xyzcompany.supabase.co',
    anonKey: 'public-anon-key',
  );
  runApp(const MyApp());
}

import 'package:tracelet_supabase/tracelet_supabase.dart';
import 'package:tracelet/tracelet.dart';
 
const supabaseUrl = 'https://xyzcompany.supabase.co';
const supabaseAnonKey = 'public-anon-key';
 
// 1. Keep the Supabase session token fresh in the background (resolves 401s).
await TraceletSupabase.configureTokenRefresh(anonKey: supabaseAnonKey);
 
// 2. Build the native HTTP config. Provide EITHER rpcFunction OR edgeFunction.
final httpConfig = TraceletSupabase.buildHttpConfig(
  supabaseUrl: supabaseUrl,
  anonKey: supabaseAnonKey,
  rpcFunction: 'insert_tracelet_locations', // ...or: edgeFunction: 'tracelet-ingest'
  // autoSync: true, batchSync: true, maxBatchSize: 250 are the defaults
);
 
// 3. Start Tracelet with the adapter's HTTP config.
await Tracelet.ready(Config(
  geo: const GeoConfig(distanceFilter: 50),
  http: httpConfig,
));
await Tracelet.start();