Implement crdt

Author: HalidOdat

.github/workflows/release.yml .github/workflows/build.yml.github/workflows/release.yml renamed to .github/workflows/build.yml

@@ -1,9 +1,15 @@
-name: Publish Release
+name: build
 on:
   release:
     types: [published]
 
-  workflow_dispatch:
+  push:
+    branches:
+      - main
+
+  pull_request:
+    branches:
+      - main
 
 env:
   JAVA_VERSION: 17
@@ -56,6 +62,7 @@ jobs:
           tar -czvf mapping.tar.gz --directory=app/build/reproducible/mapping mapping
 
       - name: Sign APKs
+        if: github.event_name == 'release'
         env:
           KEYSTORE: ${{ secrets.KEYSTORE }}
           KEYALIAS: ${{ secrets.KEYALIAS }}
@@ -77,7 +84,20 @@ jobs:
           done
           rm keystore.p12
 
+      - name: Upload artifacts (workflow run)
+        if: github.event_name != 'release'
+        uses: actions/upload-artifact@v4
+        with:
+          name: stride-artifacts
+          path: |
+            app-armeabi-v7a-release.apk
+            app-arm64-v8a-release.apk
+            app-x86_64-release.apk
+            app-release.apk
+            mapping.tar.gz
+
       - name: Upload Arifact armeabi-v7a
+        if: github.event_name == 'release'
         uses: svenstaro/upload-release-action@v2
         with:
           repo_token: ${{ secrets.GITHUB_TOKEN }}
@@ -86,6 +106,7 @@ jobs:
           tag: ${{ github.ref }}
 
       - name: Upload Arifact arm64-v8a
+        if: github.event_name == 'release'
         uses: svenstaro/upload-release-action@v2
         with:
           repo_token: ${{ secrets.GITHUB_TOKEN }}
@@ -94,6 +115,7 @@ jobs:
           tag: ${{ github.ref }}
 
       - name: Upload Arifact x86_64
+        if: github.event_name == 'release'
         uses: svenstaro/upload-release-action@v2
         with:
           repo_token: ${{ secrets.GITHUB_TOKEN }}
@@ -102,6 +124,7 @@ jobs:
           tag: ${{ github.ref }}
 
       - name: Upload Arifact Universal
+        if: github.event_name == 'release'
         uses: svenstaro/upload-release-action@v2
         with:
           repo_token: ${{ secrets.GITHUB_TOKEN }}
@@ -110,6 +133,7 @@ jobs:
           tag: ${{ github.ref }}
 
       - name: Upload Arifact Mapping
+        if: github.event_name == 'release'
         uses: svenstaro/upload-release-action@v2
         with:
           repo_token: ${{ secrets.GITHUB_TOKEN }}

Cargo.lock

@@ -2,6 +2,8 @@
 resolver = "3"
 members = [
   "crates/core",
+  "crates/crdt",
+  "crates/serialization",
   "crates/logging",
   "crates/database",
   "crates/backend",
@@ -28,6 +30,8 @@ description = "An extensible task menagment application that uses git as it's da
 [workspace.dependencies]
 # Repository Crates
 stride_core = { version = "~0.1.0", path = "crates/core", default-features = false }
+stride_crdt = { version = "~0.1.0", path = "crates/crdt" }
+stride_serialize = { version = "~0.1.0", path = "crates/serialization" }
 stride_logging = { version = "~0.1.0", path = "crates/logging" }
 stride_database = { version = "~0.1.0", path = "crates/database" }
 stride_backend = { version = "~0.1.0", path = "crates/backend" }
@@ -84,6 +88,7 @@ clap = { version = "4.5.54", features = ["derive"] }
 url = { version = "2.5.8", features = ["serde"] }
 thiserror = "2.0.18"
 indoc = "2.0.7"
+vint64 = "=1.0.1"
 
 [profile.release]
 # strip = "debug"

Cargo.toml

@@ -109,10 +109,7 @@ class PluginManagerBloc extends Bloc<PluginManagerEvent, PluginManagerState> {
       if (error.isOutOfFuelTrapCode()) {
         final pluginName = error.pluginName();
         if (pluginName != null) {
-          disable(
-            pluginName,
-            reason: 'plugin exceeded computation limit',
-          );
+          disable(pluginName, reason: 'plugin exceeded computation limit');
 
           logBloc.add(
             LogErrorEvent(
@@ -149,7 +146,7 @@ class PluginManagerBloc extends Bloc<PluginManagerEvent, PluginManagerState> {
                 TaskAddEvent(
                   task: task.copyWith(
                     // Make sure to give a new UUID that what the plugin provided.
-                    uuid: UuidValue.fromString(const Uuid().v7()),
+                    id: UuidValue.fromString(const Uuid().v7()),
                   ),
                 ),
               );
@@ -168,21 +165,23 @@ class PluginManagerBloc extends Bloc<PluginManagerEvent, PluginManagerState> {
                 ty == NetworkRequestType.get_,
                 'expected network request to have GET method',
               );
-              http.get(Uri.parse(host)).then(
-                (value) async {
-                  await pm.emit(
-                    pluginName: pluginName,
-                    event: HostEvent.networkResponse(
-                      host: host,
-                      content: value.bodyBytes,
-                    ),
+              http
+                  .get(Uri.parse(host))
+                  .then(
+                    (value) async {
+                      await pm.emit(
+                        pluginName: pluginName,
+                        event: HostEvent.networkResponse(
+                          host: host,
+                          content: value.bodyBytes,
+                        ),
+                      );
+                    },
+                    onError: (error) {
+                      // TODO: Log error/notify
+                      print(error);
+                    },
                   );
-                },
-                onError: (error) {
-                  // TODO: Log error/notify
-                  print(error);
-                },
-              );
           }
         case PluginAction_Disable(:final pluginName, :final reason):
           logBloc.add(

app/lib/blocs/plugin_manager_bloc.dart

@@ -137,7 +137,7 @@ class TaskBloc extends Bloc<TaskEvent, TaskState> {
 
     on<TaskRemoveEvent>((event, emit) async {
       if (event.task.status == TaskStatus.deleted) {
-        await repository()?.purgeTaskById(id: event.task.uuid);
+        await repository()?.purgeTaskById(id: event.task.id);
       } else {
         await repository()?.updateTask(
           task: event.task.copyWith(status: TaskStatus.deleted),