Add configuration options for Supabase and Node connectors

Author: dean-journeyapps

demos/CommandLine/.env.template

@@ -1,3 +1,9 @@
 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
+# 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=true

demos/CommandLine/Demo.cs

@@ -2,11 +2,11 @@
 
 using CommandLine.Utils;
 using PowerSync.Common.Client;
+using PowerSync.Common.Client.Connection;
 using Spectre.Console;
 
 class Demo
 {
-
     private record ListResult(string id, string name, string owner_id, string created_at);
     static async Task Main()
     {
@@ -17,11 +17,30 @@ static async Task Main()
         });
         await db.Init();
 
-        //var connector = new NodeConnector();
-        var config = new SupabaseConfig();
-        var connector = new SupabaseConnector(config);
+        var config = new Config();
+
+        IPowerSyncBackendConnector connector;
+
+        string connectorUserId = "";
+
+        if (config.UseSupabase)
+        {
+            var supabaseConnector = new SupabaseConnector(config);
+
+            await supabaseConnector.Login(config.SupabaseUsername, config.SupabasePassword);
+
+            connectorUserId = supabaseConnector.UserId;
+
+            connector = supabaseConnector;
+        }
+        else
+        {
+            var nodeConnector = new NodeConnector(config);
+
+            connectorUserId = nodeConnector.UserId;
 
-        await connector.Login("[email protected]", "Dean1998");
+            connector = nodeConnector;
+        }
 
         var table = new Table()
             .AddColumn("id")
@@ -55,7 +74,7 @@ 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" , connector.UserId, "0bf55412-d35b-4814-ade9-daea4865df96"]
+          "UPDATE lists SET name = ?, created_at = datetime() WHERE owner_id = ? and id = ?", ["update CHCHCHCHCH", connectorUserId, "0bf55412-d35b-4814-ade9-daea4865df96"]
         );
 
         var _ = Task.Run(async () =>
@@ -71,7 +90,7 @@ await db.Execute(
                      }
                      else if (key.Key == ConsoleKey.Enter)
                      {
-                         await db.Execute("insert into lists (id, name, owner_id, created_at) values (uuid(), 'New User', ?, datetime())", [connector.UserId]);
+                         await db.Execute("insert into lists (id, name, owner_id, created_at) values (uuid(), 'New User', ?, datetime())", [connectorUserId]);
                      }
                      else if (key.Key == ConsoleKey.Backspace)
                      {

demos/CommandLine/NodeConnector.cs

@@ -10,7 +10,7 @@
 using PowerSync.Common.Client;
 using PowerSync.Common.Client.Connection;
 using PowerSync.Common.DB.Crud;
-
+using CommandLine.Utils;
 
 public class NodeConnector : IPowerSyncBackendConnector
 {
@@ -22,15 +22,15 @@ public class NodeConnector : IPowerSyncBackendConnector
     public string UserId { get; private set; }
     private string? clientId;
 
-    public NodeConnector()
+    public NodeConnector(Config config)
     {
         _httpClient = new HttpClient();
 
         // Load or generate User ID
         UserId = LoadOrGenerateUserId();
 
-        BackendUrl = "http://localhost:6060";
-        PowerSyncUrl = "http://localhost:8080";
+        BackendUrl = config.BackendUrl;
+        PowerSyncUrl = config.PowerSyncUrl;
 
         clientId = null;
     }

demos/CommandLine/SupabaseConnector.cs

@@ -15,7 +15,7 @@ namespace CommandLine;
 public class SupabaseConnector : IPowerSyncBackendConnector
 {
     private readonly Supabase.Client _supabase;
-    private readonly SupabaseConfig _config;
+    private readonly Config _config;
     private Session? _currentSession;
 
     public Session? CurrentSession
@@ -36,7 +36,7 @@ public Session? CurrentSession
 
     public bool Ready { get; private set; }
 
-    public SupabaseConnector(SupabaseConfig config)
+    public SupabaseConnector(Config config)
     {
         _config = config;
         _supabase = new Supabase.Client(config.SupabaseUrl, config.SupabaseAnonKey, new SupabaseOptions

demos/CommandLine/Utils/Config.cs

@@ -1,23 +1,42 @@
-namespace CommandLine.Utils;
-
 using dotenv.net;
 
-public class SupabaseConfig
+namespace CommandLine.Utils;
+
+public class Config
 {
     public string SupabaseUrl { get; set; }
     public string SupabaseAnonKey { get; set; }
     public string PowerSyncUrl { get; set; }
+    public string BackendUrl { get; set; }
+    public string SupabaseUsername { get; set; }
+    public string SupabasePassword { get; set; }
+    public bool UseSupabase { get; set; }
 
-    public SupabaseConfig()
+    public Config()
     {
         DotEnv.Load();
         Console.WriteLine($"Current directory: {Directory.GetCurrentDirectory()}");
+
         // Retrieve the environment variables
         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
+        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;
     }
 }