Add Supabase Connector integration and configuration support

Author: dean-journeyapps

.gitignore

@@ -61,3 +61,5 @@ TestResults/
 *.dylib
 *.dll
 *.so
+
+.env

demos/CommandLine/.env.template

@@ -0,0 +1,3 @@
+SUPABASE_URL=your-supabase-url
+SUPABASE_ANON_KEY=your_anon_key_here
+POWERSYNC_URL=your-powersync-url

demos/CommandLine/CommandLine.csproj

@@ -13,8 +13,10 @@
   </PropertyGroup>
 
    <ItemGroup>
+    <PackageReference Include="Dotenv.Net" Version="3.2.1" />
     <PackageReference Include="Microsoft.Data.Sqlite" Version="9.0.1" />
     <PackageReference Include="Spectre.Console" Version="0.49.1" />
+    <PackageReference Include="supabase" Version="1.1.1" />
 
   </ItemGroup>
 

demos/CommandLine/CommandLine.sln

@@ -0,0 +1,24 @@
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.5.2.0
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CommandLine", "CommandLine.csproj", "{6BB9F16E-3825-DE76-1286-9E5E2406710D}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{6BB9F16E-3825-DE76-1286-9E5E2406710D}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{6BB9F16E-3825-DE76-1286-9E5E2406710D}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{6BB9F16E-3825-DE76-1286-9E5E2406710D}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{6BB9F16E-3825-DE76-1286-9E5E2406710D}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {A5588511-5909-4F05-80EB-09A56805607C}
+	EndGlobalSection
+EndGlobal

demos/CommandLine/Demo.cs

@@ -1,5 +1,6 @@
 namespace CommandLine;
 
+using CommandLine.Utils;
 using PowerSync.Common.Client;
 using Spectre.Console;
 
@@ -16,7 +17,11 @@ static async Task Main()
         });
         await db.Init();
 
-        var connector = new NodeConnector();
+        //var connector = new NodeConnector();
+        var config = new SupabaseConfig();
+        var connector = new SupabaseConnector(config);
+
+        await connector.Login("[email protected]", "Dean1998");
 
         var table = new Table()
             .AddColumn("id")
@@ -47,6 +52,12 @@ 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"]
+        );
+
         var _ = Task.Run(async () =>
          {
              while (running)

demos/CommandLine/Helpers/SupabasePatchHelper.cs

@@ -0,0 +1,34 @@
+namespace CommandLine.Helpers;
+
+using System.Linq.Expressions;
+using Newtonsoft.Json;
+using Supabase.Postgrest.Interfaces;
+using Supabase.Postgrest.Models;
+
+public static class SupabasePatchHelper
+{
+    public static IPostgrestTable<T> ApplySet<T>(
+        IPostgrestTable<T> table,
+        string jsonPropertyName,
+        object value
+    ) where T : BaseModel, new()
+    {
+        // Find the property that matches the JsonProperty name
+        var property = typeof(T)
+            .GetProperties()
+            .FirstOrDefault(p =>
+                p.GetCustomAttributes(typeof(JsonPropertyAttribute), true)
+                .FirstOrDefault() is JsonPropertyAttribute attr &&
+                attr.PropertyName == jsonPropertyName);
+
+        if (property == null)
+            throw new ArgumentException($"'{jsonPropertyName}' is not a valid property on type '{typeof(T).Name}'");
+
+        var parameter = Expression.Parameter(typeof(T), "x");
+        var propertyAccess = Expression.Property(parameter, property.Name);
+        var converted = Expression.Convert(propertyAccess, typeof(object));
+        var lambda = Expression.Lambda<Func<T, object>>(converted, parameter);
+
+        return table.Set(lambda, value);
+    }
+}

demos/CommandLine/Models/List.cs

@@ -0,0 +1,25 @@
+namespace CommandLine.Models;
+
+using Newtonsoft.Json;
+using Supabase.Postgrest.Attributes;
+using Supabase.Postgrest.Models;
+
+[Table("lists")]
+class List : BaseModel
+{
+    [PrimaryKey("id")]
+    [JsonProperty("id")]
+    public string Id { get; set; }
+
+    [Column("created_at")]
+    [JsonProperty("created_at")]
+    public string CreatedAt { get; set; }
+
+    [Column("name")]
+    [JsonProperty("name")]
+    public string Name { get; set; }
+
+    [Column("owner_id")]
+    [JsonProperty("owner_id")]
+    public string OwnerId { get; set; }
+}

demos/CommandLine/Models/Todos.cs

@@ -0,0 +1,41 @@
+namespace CommandLine.Models;
+
+using Newtonsoft.Json;
+using Supabase.Postgrest.Attributes;
+using Supabase.Postgrest.Models;
+
+[Table("todos")]
+class Todo : BaseModel
+{
+    [PrimaryKey("id")]
+    [JsonProperty("id")]
+    public string Id { get; set; }
+
+    [Column("list_id")]
+    [JsonProperty("list_id")]
+    public string ListId { get; set; }
+
+    [Column("created_at")]
+    [JsonProperty("created_at")]
+    public string CreatedAt { get; set; }
+
+    [Column("completed_at")]
+    [JsonProperty("completed_at")]
+    public string CompletedAt { get; set; }
+
+    [Column("description")]
+    [JsonProperty("description")]
+    public string Description { get; set; }
+
+    [Column("created_by")]
+    [JsonProperty("created_by")]
+    public string CreatedBy { get; set; }
+
+    [Column("completed_by")]
+    [JsonProperty("completed_by")]
+    public string CompletedBy { get; set; }
+
+    [Column("completed")]
+    [JsonProperty("completed")]
+    public int Completed { get; set; }
+}

demos/CommandLine/README.md

@@ -1,4 +1,4 @@
-# PowerSync CLI demo app
+# PowerSync CLI Demo App
 
 This demo features a CLI-based table view that stays *live* using a *watch query*, ensuring the data updates in real time as changes occur.
 To run this demo, you need to have one of our Node.js self-host demos ([Postgres](https://github.com/powersync-ja/self-host-demo/tree/main/demos/nodejs) | [MongoDB](https://github.com/powersync-ja/self-host-demo/tree/main/demos/nodejs-mongodb) | [MySQL](https://github.com/powersync-ja/self-host-demo/tree/main/demos/nodejs-mysql)) running, as it provides the PowerSync server that this CLI's PowerSync SDK connects to.
@@ -9,6 +9,28 @@ 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.
 
+## 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:
+
+1. Copy the `.env.template` file to a new `.env` file:
+   ```bash
+   # On Linux/macOS
+   cp .env.template .env
+   
+   # On Windows
+   copy .env.template .env
+   ```
+
+2. Replace the necessary fields in the `.env` file with your Supabase and PowerSync credentials:
+   ```
+   SUPABASE_URL=your_supabase_url
+   SUPABASE_ANON_KEY=your_supabase_anon_key
+   POWERSYNC_URL=your_powersync_url
+   ```
+
+3. Update your connector configuration to use SupabaseConnector instead of NodeConnector
+
 ## Getting Started
 
 In the repo root, run the following to download the PowerSync extension:
@@ -29,4 +51,4 @@ To run the Command-Line interface:
 
 ```bash
 dotnet run Demo
-```
+```

demos/CommandLine/SupabaseConnector.cs

@@ -0,0 +1,167 @@
+namespace CommandLine;
+
+using CommandLine.Helpers;
+using CommandLine.Models;
+using CommandLine.Utils;
+using Newtonsoft.Json;
+using PowerSync.Common.Client;
+using PowerSync.Common.Client.Connection;
+using PowerSync.Common.DB.Crud;
+using Supabase;
+using Supabase.Gotrue;
+using Supabase.Postgrest.Exceptions;
+using Supabase.Postgrest.Interfaces;
+
+public class SupabaseConnector : IPowerSyncBackendConnector
+{
+    private readonly Supabase.Client _supabase;
+    private readonly SupabaseConfig _config;
+    private Session? _currentSession;
+
+    public Session? CurrentSession
+    {
+        get => _currentSession;
+        set
+        {
+            _currentSession = value;
+
+            if (_currentSession?.User?.Id != null)
+            {
+                UserId = _currentSession.User.Id;
+            }
+        }
+    }
+
+    public string UserId { get; private set; } = "";
+
+    public bool Ready { get; private set; }
+
+    public SupabaseConnector(SupabaseConfig config)
+    {
+        _config = config;
+        _supabase = new Supabase.Client(config.SupabaseUrl, config.SupabaseAnonKey, new SupabaseOptions
+        {
+            AutoConnectRealtime = true
+        });
+
+        _ = _supabase.InitializeAsync();
+    }
+
+    public async Task Login(string email, string password)
+    {
+        var response = await _supabase.Auth.SignInWithPassword(email, password);
+        if (response?.User == null || response.AccessToken == null)
+        {
+            throw new Exception("Login failed.");
+        }
+
+        CurrentSession = response;
+    }
+
+    public Task<PowerSyncCredentials?> FetchCredentials()
+    {
+        PowerSyncCredentials? credentials = null;
+
+        var sessionResponse = _supabase.Auth.CurrentSession;
+        if (sessionResponse?.AccessToken != null)
+        {
+            credentials = new PowerSyncCredentials(_config.PowerSyncUrl, sessionResponse.AccessToken);
+        }
+
+        return Task.FromResult(credentials);
+    }
+
+    public async Task UploadData(IPowerSyncDatabase database)
+    {
+        var transaction = await database.GetNextCrudTransaction();
+        if (transaction == null) return;
+
+        try
+        {
+            foreach (var op in transaction.Crud)
+            {
+                switch (op.Op)
+                {
+                    case UpdateType.PUT:
+                        if (op.Table.ToLower().Trim() == "lists")
+                        {
+                            var model = JsonConvert.DeserializeObject<List>(JsonConvert.SerializeObject(op.OpData)) ?? throw new InvalidOperationException("Model is null.");
+                            model.Id = op.Id;
+
+                            await _supabase.From<List>().Upsert(model);
+                        }
+                        else if (op.Table.ToLower().Trim() == "todos")
+                        {
+                            var model = JsonConvert.DeserializeObject<Todo>(JsonConvert.SerializeObject(op.OpData)) ?? throw new InvalidOperationException("Model is null.");
+                            model.Id = op.Id;
+
+                            await _supabase.From<Todo>().Upsert(model);
+                        }
+                        break;
+
+                    case UpdateType.PATCH:
+                        if (op.OpData is null || op.OpData.Count == 0)
+                        {
+                            Console.WriteLine("PATCH skipped: No data to update.");
+                            break;
+                        }
+
+                        if (op.Table.ToLower().Trim() == "lists")
+                        {
+                            IPostgrestTable<List> updateQuery = _supabase
+                            .From<List>()
+                            .Where(x => x.Id == op.Id);
+
+                            foreach (var kvp in op.OpData)
+                            {
+                                updateQuery = SupabasePatchHelper.ApplySet(updateQuery, kvp.Key, kvp.Value);
+                            }
+
+                            _ = await updateQuery.Update();
+                        }
+                        else if (op.Table.ToLower().Trim() == "todos")
+                        {
+                            IPostgrestTable<Todo> updateQuery = _supabase
+                            .From<Todo>()
+                            .Where(x => x.Id == op.Id);
+
+                            foreach (var kvp in op.OpData)
+                            {
+                                updateQuery = SupabasePatchHelper.ApplySet(updateQuery, kvp.Key, kvp.Value);
+                            }
+
+                            _ = await updateQuery.Update();
+                        }
+                        break;
+
+                    case UpdateType.DELETE:
+                        if (op.Table.ToLower().Trim() == "lists")
+                        {
+                            await _supabase
+                            .From<List>()
+                            .Where(x => x.Id == op.Id)
+                            .Delete();
+                        }
+                        else if (op.Table.ToLower().Trim() == "todos")
+                        {
+                            await _supabase
+                            .From<Todo>()
+                            .Where(x => x.Id == op.Id)
+                            .Delete();
+                        }
+                        break;
+
+                    default:
+                        throw new InvalidOperationException("Unknown operation type.");
+                }
+            }
+
+            await transaction.Complete();
+        }
+        catch (PostgrestException ex)
+        {
+            Console.WriteLine($"Error during upload: {ex.Message}");
+            throw;
+        }
+    }
+}