Refactor Supabase integration: update .env.template, refactor models, and enhance configuration handling

Author: dean-journeyapps

demos/CommandLine/.env.template

@@ -1,9 +1,25 @@
-SUPABASE_URL=your-supabase-url
-SUPABASE_ANON_KEY=your_anon_key_here
-POWERSYNC_URL=your-powersync-url
-BACKEND_URL=your-backend-url
-SUPABASE_USERNAME=your-supabase-username
-SUPABASE_PASSWORD=your-supabase-password
+# PowerSync server URL
+POWERSYNC_URL=http://localhost:8080
+
 # Set to true if you want to use Supabase as the backend
-# Set to false if you want to use the Powersync backend
-USE_SUPABASE=false
+# Set to false if you want to use the PowerSync self-hosted backend
+USE_SUPABASE=false
+
+# --- Supabase Connector Settings ---
+# These values are used only if USE_SUPABASE=true
+
+# Supabase project URL
+SUPABASE_URL=http://localhost:54321
+
+# Supabase anon key (public client access)
+SUPABASE_ANON_KEY=your_anon_key_here
+
+# Supabase credentials for an already existing user (used for login)
+SUPABASE_USERNAME=your_supabase_email@example.com
+SUPABASE_PASSWORD=your_supabase_password
+
+# --- PowerSync Backend Settings ---
+# These values are used only if USE_SUPABASE=false
+
+# URL of your PowerSync self-hosted backend
+BACKEND_URL=http://localhost:6060

demos/CommandLine/Demo.cs

@@ -27,6 +27,7 @@ static async Task Main()
         {
             var supabaseConnector = new SupabaseConnector(config);
 
+            // Ensure this user already exists
             await supabaseConnector.Login(config.SupabaseUsername, config.SupabasePassword);
 
             connectorUserId = supabaseConnector.UserId;
@@ -71,12 +72,6 @@ static async Task Main()
             }
         });
 
-        // await db.Execute("insert into lists (id, name, owner_id, created_at) values (uuid(), 'New User33', ?, datetime())", [connector.UserId]);
-
-        await db.Execute(
-          "UPDATE lists SET name = ?, created_at = datetime() WHERE owner_id = ? and id = ?", ["update CHCHCHCHCH", connectorUserId, "0bf55412-d35b-4814-ade9-daea4865df96"]
-        );
-
         var _ = Task.Run(async () =>
          {
              while (running)
@@ -118,7 +113,6 @@ await db.Execute(
             }
         });
 
-
         // Start live updating table
         await AnsiConsole.Live(panel)
             .StartAsync(async ctx =>

demos/CommandLine/Models/List.cs demos/CommandLine/Models/Supabase/List.csdemos/CommandLine/Models/List.cs renamed to demos/CommandLine/Models/Supabase/List.cs

@@ -1,9 +1,11 @@
-namespace CommandLine.Models;
 
 using Newtonsoft.Json;
 using Supabase.Postgrest.Attributes;
 using Supabase.Postgrest.Models;
 
+namespace CommandLine.Models.Supabase;
+
+#pragma warning disable CS8618 // Non-nullable field must contain a non-null value when exiting constructor. Consider adding the 'required' modifier or declaring as nullable.
 [Table("lists")]
 class List : BaseModel
 {

demos/CommandLine/Models/Todos.cs …mos/CommandLine/Models/Supabase/Todos.csdemos/CommandLine/Models/Todos.cs renamed to demos/CommandLine/Models/Supabase/Todos.cs demos/CommandLine/Models/Todos.cs renamed to demos/CommandLine/Models/Supabase/Todos.cs

@@ -1,9 +1,11 @@
-namespace CommandLine.Models;
 
 using Newtonsoft.Json;
 using Supabase.Postgrest.Attributes;
 using Supabase.Postgrest.Models;
 
+namespace CommandLine.Models.Supabase;
+
+#pragma warning disable CS8618 // Non-nullable field must contain a non-null value when exiting constructor. Consider adding the 'required' modifier or declaring as nullable.
 [Table("todos")]
 class Todo : BaseModel
 {

demos/CommandLine/README.md

@@ -9,6 +9,10 @@ Changes made to the backend's source DB or to the self-hosted web UI will be syn
 
 This essentially uses anonymous authentication. A random user ID is generated and stored in local storage. The backend returns a valid token which is not linked to a specific user. All data is synced to all users.
 
+> **Note for Supabase users:**  
+> If you are using `USE_SUPABASE=true`, this demo expects a valid, **already existing Supabase user**.  
+> You must provide their credentials via the `.env` file using `SUPABASE_USERNAME` and `SUPABASE_PASSWORD`.
+
 ## Connection Options
 
 By default, this demo uses the NodeConnector for connecting to the PowerSync server. However, you can swap this out with the SupabaseConnector if needed

demos/CommandLine/SupabaseConnector.cs

@@ -1,7 +1,7 @@
 namespace CommandLine;
 
 using CommandLine.Helpers;
-using CommandLine.Models;
+using CommandLine.Models.Supabase;
 using CommandLine.Utils;
 using Newtonsoft.Json;
 using PowerSync.Common.Client;

demos/CommandLine/Utils/Config.cs

@@ -2,6 +2,7 @@
 
 namespace CommandLine.Utils;
 
+#pragma warning disable CS8618 // Non-nullable field must contain a non-null value when exiting constructor. Consider adding the 'required' modifier or declaring as nullable.
 public class Config
 {
     public string SupabaseUrl { get; set; }
@@ -17,26 +18,34 @@ public Config()
         DotEnv.Load();
         Console.WriteLine($"Current directory: {Directory.GetCurrentDirectory()}");
 
-        // Retrieve the environment variables (Not all of these are required)
-        SupabaseUrl = Environment.GetEnvironmentVariable("SUPABASE_URL")
-                      ?? throw new InvalidOperationException("SUPABASE_URL environment variable is not set.");
-        SupabaseAnonKey = Environment.GetEnvironmentVariable("SUPABASE_ANON_KEY")
-                          ?? throw new InvalidOperationException("SUPABASE_ANON_KEY environment variable is not set.");
-        PowerSyncUrl = Environment.GetEnvironmentVariable("POWERSYNC_URL")
-                       ?? throw new InvalidOperationException("POWERSYNC_URL environment variable is not set.");
-        BackendUrl = Environment.GetEnvironmentVariable("BACKEND_URL")
-                      ?? throw new InvalidOperationException("BACKEND_URL environment variable is not set.");
-        SupabaseUsername = Environment.GetEnvironmentVariable("SUPABASE_USERNAME")
-                           ?? throw new InvalidOperationException("SUPABASE_USERNAME environment variable is not set.");
-        SupabasePassword = Environment.GetEnvironmentVariable("SUPABASE_PASSWORD")
-                           ?? throw new InvalidOperationException("SUPABASE_PASSWORD environment variable is not set.");
-
-        // Parse boolean value
+        // Parse boolean value first
         string useSupabaseStr = Environment.GetEnvironmentVariable("USE_SUPABASE") ?? "false";
         if (!bool.TryParse(useSupabaseStr, out bool useSupabase))
         {
             throw new InvalidOperationException("USE_SUPABASE environment variable is not a valid boolean.");
         }
         UseSupabase = useSupabase;
+
+        Console.WriteLine("Use Supabase: " + UseSupabase);
+
+        PowerSyncUrl = GetRequiredEnv("POWERSYNC_URL");
+
+        if (UseSupabase)
+        {
+            SupabaseUrl = GetRequiredEnv("SUPABASE_URL");
+            SupabaseAnonKey = GetRequiredEnv("SUPABASE_ANON_KEY");
+            SupabaseUsername = GetRequiredEnv("SUPABASE_USERNAME");
+            SupabasePassword = GetRequiredEnv("SUPABASE_PASSWORD");
+        }
+        else
+        {
+            BackendUrl = GetRequiredEnv("BACKEND_URL");
+        }
+    }
+
+    private static string GetRequiredEnv(string key)
+    {
+        return Environment.GetEnvironmentVariable(key)
+               ?? throw new InvalidOperationException($"{key} environment variable is not set.");
     }
 }