Can show data syncs between demos.

Author: Chriztiaan

demos/TodoSQLite/Constants.cs

@@ -18,7 +18,7 @@ public class NodeConnector : IPowerSyncBackendConnector
 
     public string BackendUrl { get; }
     public string PowerSyncUrl { get; }
-    public string UserId { get; private set; }
+    public string UserId { get; }
     private string? clientId;
 
     public NodeConnector()
@@ -37,7 +37,7 @@ public NodeConnector()
     public string LoadOrGenerateUserId()
     {
 
-        return "78bb787c-ff0b-41b2-a297-6a7701648f4a";
+        return "8ba3ec38-6cc8-449c-88c0-9275987ea5d2";
     }
 
     public async Task<PowerSyncCredentials?> FetchCredentials()

demos/TodoSQLite/Data/NodeConnector.cs

@@ -1,11 +1,7 @@
-using System.IO;
-using Microsoft.Extensions.Logging;
-using Microsoft.Maui.Storage;
-using Newtonsoft.Json;
+using Microsoft.Extensions.Logging;
 using PowerSync.Common.Client;
 using PowerSync.Common.MDSQLite;
 using PowerSync.Maui.SQLite;
-using SQLite;
 using TodoSQLite.Models;
 
 namespace TodoSQLite.Data;
@@ -15,20 +11,20 @@ public class PowerSyncData
     private PowerSyncDatabase _db;
     private ILogger _logger;
 
-    private record ListResult(string id, string name, string owner_id, string created_at);
-    private record TodoResult(string id, string list_id, string description, string created_at, string completed_at, string created_by, string completed_by, int completed);
+    public string UserId { get; set; } = "";
 
+    
     async Task Init()
     {
         if (_db != null) return;
-        
+
         ILoggerFactory loggerFactory = LoggerFactory.Create(builder =>
         {
             builder.AddConsole();
             builder.SetMinimumLevel(LogLevel.Trace);
         });
         _logger = loggerFactory.CreateLogger("PowerSyncLogger");
-        
+
         var dbPath = Path.Combine(FileSystem.AppDataDirectory, "mydb.db");
         var factory = new MAUISQLiteDBOpenFactory(new MDSQLiteOpenFactoryOptions()
         {
@@ -42,130 +38,54 @@ async Task Init()
         });
         await _db.Init();
 
-        // var nodeConnector = new NodeConnector();
-        // await _db.Connect(nodeConnector);
+        var nodeConnector = new NodeConnector();
+        UserId = nodeConnector.UserId;
+        await _db.Connect(nodeConnector);
     }
 
     // List operations
     public async Task<List<TodoList>> GetListsAsync()
     {
         await Init();
-        var results = await _db.GetAll<ListResult>("SELECT * FROM lists ORDER BY created_at DESC");
-        return results.Select(r => new TodoList
-        {
-            ID = r.id,
-            Name = r.name,
-            OwnerId = r.owner_id,
-            CreatedAt = r.created_at
-        }).ToList();
-    }
-
-    public async Task<TodoList> GetListAsync(string id)
-    {
-        await Init();
-        var result = await _db.GetAll<ListResult>("SELECT * FROM lists WHERE id = ?", [id.ToString()]);
-        var list = result.FirstOrDefault();
-        if (list == null) return null;
-
-        return new TodoList
-        {
-            ID = list.id,
-            Name = list.name,
-            OwnerId = list.owner_id,
-            CreatedAt = list.created_at
-        };
+        var results = await _db.GetAll<TodoList>("SELECT * FROM lists ORDER BY created_at DESC");
+        return results.ToList();
     }
 
-    public async Task<int> SaveListAsync(TodoList list)
+    public async Task SaveListAsync(TodoList list)
     {
         await Init();
         if (list.ID != "")
         {
             await _db.Execute(
                 "UPDATE lists SET name = ?, owner_id = ? WHERE id = ?",
-                [list.Name, list.OwnerId, list.ID.ToString()]);
-            return 1;
+                [list.Name, UserId, list.ID]);
         }
         else
         {
             await _db.Execute(
                 "INSERT INTO lists (id, name, owner_id, created_at) VALUES (uuid(), ?, ?, ?)",
-                [list.Name, list.OwnerId, DateTime.UtcNow.ToString("o")]);
-            return 1;
+                [list.Name, UserId, DateTime.UtcNow.ToString("o")]);
         }
     }
 
-    public async Task<int> DeleteListAsync(TodoList list)
+    public async Task DeleteListAsync(TodoList list)
     {
         await Init();
-        string listId = list.ID.ToString();
+        var listId = list.ID;
         // First delete all todo items in this list
         await _db.Execute("DELETE FROM todos WHERE list_id = ?", [listId]);
         await _db.Execute("DELETE FROM lists WHERE id = ?", [listId]);
-        return 1;
     }
-
-    // Todo item operations
     public async Task<List<TodoItem>> GetItemsAsync(string listId)
     {
         await Init();
-        var results = await _db.GetAll<TodoResult>(
+        var results = await _db.GetAll<TodoItem>(
             "SELECT * FROM todos WHERE list_id = ? ORDER BY created_at DESC", [listId]);
 
-        return results.Select(r => new TodoItem
-        {
-            ID = r.id,
-            ListId = r.list_id,
-            Description = r.description,
-            CreatedAt = r.created_at,
-            CompletedAt = r.completed_at,
-            CreatedBy = r.created_by,
-            CompletedBy = r.completed_by,
-            Completed = r.completed == 1
-        }).ToList();
-    }
-
-    public async Task<List<TodoItem>> GetItemsNotDoneAsync(string listId)
-    {
-        await Init();
-        var results = await _db.GetAll<TodoResult>(
-            "SELECT * FROM todos WHERE list_id = ? AND completed = 0 ORDER BY created_at DESC",
-            [listId]);
-
-        return results.Select(r => new TodoItem
-        {
-            ID = r.id,
-            ListId = r.list_id,
-            Description = r.description,
-            CreatedAt = r.created_at,
-            CompletedAt = r.completed_at,
-            CreatedBy = r.created_by,
-            CompletedBy = r.completed_by,
-            Completed = r.completed == 1
-        }).ToList();
-    }
-
-    public async Task<TodoItem> GetItemAsync(string id)
-    {
-        await Init();
-        var results = await _db.GetAll<TodoResult>("SELECT * FROM todos WHERE id = ?", [id.ToString()]);
-        var todo = results.FirstOrDefault();
-        if (todo == null) return null;
-
-        return new TodoItem
-        {
-            ID = todo.id,
-            ListId = todo.list_id,
-            Description = todo.description,
-            CreatedAt = todo.created_at,
-            CompletedAt = todo.completed_at,
-            CreatedBy = todo.created_by,
-            CompletedBy = todo.completed_by,
-            Completed = todo.completed == 1
-        };
+        return results.ToList();
     }
 
-    public async Task<int> SaveItemAsync(TodoItem item)
+    public async Task SaveItemAsync(TodoItem item)
     {
         await Init();
         if (item.ID != "")
@@ -174,32 +94,33 @@ await _db.Execute(
                 @"UPDATE todos 
                   SET description = ?, completed = ?, completed_at = ?, completed_by = ?
                   WHERE id = ?",
-                [item.Description,
-                item.Completed ? 1 : 0,
-                item.CompletedAt,
-                item.CompletedBy,
-                item.ID.ToString()]);
-            return 1;
+                [
+                    item.Description,
+                    item.Completed ? 1 : 0,
+                    item.CompletedAt,
+                    UserId,
+                    item.ID
+                ]);
         }
         else
         {
             await _db.Execute(
                 @"INSERT INTO todos 
                   (id, list_id, description, created_at, completed, created_by)
                   VALUES (uuid(), ?, ?, ?, ?, ?)",
-                [item.ListId,
-                item.Description,
-                item.CreatedAt,
-                item.Completed ? 1 : 0,
-                item.CreatedBy]);
-            return 1;
+                [
+                    item.ListId,
+                    item.Description,
+                    item.CreatedAt,
+                    item.Completed ? 1 : 0,
+                    UserId
+                ]);
         }
     }
 
-    public async Task<int> DeleteItemAsync(TodoItem item)
+    public async Task DeleteItemAsync(TodoItem item)
     {
         await Init();
-        await _db.Execute("DELETE FROM todos WHERE id = ?", [item.ID.ToString()]);
-        return 1;
+        await _db.Execute("DELETE FROM todos WHERE id = ?", [item.ID]);
     }
 }

demos/TodoSQLite/Data/PowerSyncData.cs

@@ -1,16 +1,30 @@
-using SQLite;
+using Newtonsoft.Json;
 
 namespace TodoSQLite.Models;
 
 public class TodoItem
 {
-    [PrimaryKey]
+    [JsonProperty("id")]
     public string ID { get; set; } = "";
+    
+    [JsonProperty("list_id")]
     public string ListId { get; set; }
+    
+    [JsonProperty("created_at")]
     public string CreatedAt { get; set; } = DateTime.UtcNow.ToString("o");
+    
+    [JsonProperty("completed_at")]
     public string CompletedAt { get; set; }
+    
+    [JsonProperty("description")]
     public string Description { get; set; }
+    
+    [JsonProperty("created_by")]
     public string CreatedBy { get; set; }
+    
+    [JsonProperty("completed_by")]
     public string CompletedBy { get; set; }
+    
+    [JsonProperty("completed")]
     public bool Completed { get; set; }
 }

demos/TodoSQLite/Models/TodoItem.cs

@@ -1,12 +1,18 @@
-using SQLite;
+using Newtonsoft.Json;
 
 namespace TodoSQLite.Models;
 
 public class TodoList
 {
-    [PrimaryKey]
+    [JsonProperty("id")]
     public string ID { get; set; } = "";
+    
+    [JsonProperty("created_at")]
     public string CreatedAt { get; set; } = DateTime.UtcNow.ToString("o");
+    
+    [JsonProperty("name")]
     public string Name { get; set; }
+    
+    [JsonProperty("owner_id")]
     public string OwnerId { get; set; }
 } 

demos/TodoSQLite/Models/TodoList.cs

@@ -33,8 +33,7 @@ private async void OnAddClicked(object sender, EventArgs e)
             var todo = new TodoItem 
             { 
                 Description = description,
-                ListId = _list.ID.ToString(),
-                CreatedBy = "user" // TODO: Replace with actual user ID
+                ListId = _list.ID
             };
             await _database.SaveItemAsync(todo);
             TodoItemsCollection.ItemsSource = await _database.GetItemsAsync(_list.ID);
@@ -64,7 +63,6 @@ private async void OnCheckBoxChanged(object sender, CheckedChangedEventArgs e)
         {
             todo.Completed = e.Value;
             todo.CompletedAt = e.Value ? DateTime.UtcNow.ToString("o") : null;
-            todo.CompletedBy = e.Value ? "user" : null; // TODO: Replace with actual user ID
             await _database.SaveItemAsync(todo);
         }
     }