fix: publish rust loro-protocol 0.3.0

Author: zxch3n

.github/workflows/release-please.yml

@@ -28,7 +28,7 @@ jobs:
 
   publish:
     needs: release
-    if: ${{ needs.release.outputs.releases_created }}
+    if: ${{ needs.release.outputs.releases_created == 'true' || github.event_name == 'workflow_dispatch' }}
     runs-on: ubuntu-latest
     permissions:
       contents: read
@@ -85,3 +85,34 @@ jobs:
           # Publish only the unpublished ones in topo order
           echo "Publishing: $filters"
           pnpm -r $filters publish --access public --no-git-checks
+
+      - name: Setup Rust
+        uses: dtolnay/rust-toolchain@stable
+
+      - name: Test Rust loro-protocol crate
+        working-directory: rust
+        run: cargo test -p loro-protocol
+
+      - name: Publish Rust loro-protocol crate to crates.io
+        working-directory: rust/loro-protocol
+        env:
+          CARGO_REGISTRY_TOKEN: ${{ secrets.CARGO_REGISTRY_TOKEN }}
+        run: |
+          set -euo pipefail
+          name=$(cargo metadata --no-deps --format-version 1 | jq -r '.packages[0].name')
+          version=$(cargo metadata --no-deps --format-version 1 | jq -r '.packages[0].version')
+
+          if curl -fsSL \
+            -H "User-Agent: loro-dev/protocol release workflow" \
+            "https://crates.io/api/v1/crates/$name/$version" > /dev/null; then
+            echo "Already published: $name@$version"
+            exit 0
+          fi
+
+          if [ -z "${CARGO_REGISTRY_TOKEN:-}" ]; then
+            echo "CARGO_REGISTRY_TOKEN is required to publish $name@$version"
+            exit 1
+          fi
+
+          echo "Publishing: $name@$version"
+          cargo publish

.release-please-manifest.json

@@ -1,5 +1,6 @@
 {
   "packages/loro-adaptors": "0.6.1",
   "packages/loro-protocol": "0.3.0",
-  "packages/loro-websocket": "0.6.2"
+  "packages/loro-websocket": "0.6.2",
+  "rust/loro-protocol": "0.3.0"
 }

release-please-config.json

@@ -9,6 +9,10 @@
     "packages/loro-protocol": {
       "release-type": "node"
     },
+    "rust/loro-protocol": {
+      "release-type": "rust",
+      "package-name": "loro-protocol"
+    },
     "packages/loro-websocket": {
       "release-type": "node"
     },

rust/Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "loro-protocol"
-version = "0.1.0"
+version = "0.3.0"
 edition = "2021"
 description = "Rust implementation of the Loro Syncing Protocol encoder/decoder"
 license = "MIT"

rust/loro-protocol/Cargo.toml

@@ -22,6 +22,8 @@ pub enum CrdtType {
     YjsAwareness,
     /// "%ELO" (End-to-End Encrypted Loro)
     Elo,
+    /// "%FLO"
+    Flock,
 }
 
 impl CrdtType {
@@ -33,6 +35,7 @@ impl CrdtType {
             CrdtType::Yjs => *b"%YJS",
             CrdtType::YjsAwareness => *b"%YAW",
             CrdtType::Elo => *b"%ELO",
+            CrdtType::Flock => *b"%FLO",
         }
     }
 
@@ -44,6 +47,7 @@ impl CrdtType {
             b"%YJS" => Some(CrdtType::Yjs),
             b"%YAW" => Some(CrdtType::YjsAwareness),
             b"%ELO" => Some(CrdtType::Elo),
+            b"%FLO" => Some(CrdtType::Flock),
             _ => None,
         }
     }

rust/loro-protocol/src/protocol.rs

@@ -23,6 +23,22 @@ fn snapshot_join_request() {
     assert_eq!(hex, "0x254c4f5209726f6f6d2d3132333400030a141e0328323c");
 }
 
+#[test]
+fn snapshot_flock_join_request() {
+    let msg = ProtocolMessage::JoinRequest {
+        crdt: CrdtType::Flock,
+        room_id: "room-1234".to_string(),
+        auth: vec![10, 20, 30],
+        version: vec![40, 50, 60],
+    };
+    let encoded = encode(&msg).unwrap();
+    assert_eq!(
+        to_hex(&encoded),
+        "0x25464c4f09726f6f6d2d3132333400030a141e0328323c"
+    );
+    assert_eq!(decode(&encoded).unwrap(), msg);
+}
+
 #[test]
 fn snapshot_join_response_read() {
     // exports[`encoding snapshots > JoinResponseOk read 1`]

rust/loro-protocol/tests/js_snapshots.rs

@@ -14,7 +14,7 @@ name = "loro_websocket_client"
 path = "src/lib.rs"
 
 [dependencies]
-loro-protocol = { version = "0.1.0", path = "../loro-protocol" }
+loro-protocol = { version = "0.3.0", path = "../loro-protocol" }
 tokio = { version = "1", features = ["rt", "macros", "net", "time", "sync"] }
 tokio-tungstenite = "0.27"
 futures-util = { version = "0.3", default-features = false, features = ["sink"] }

rust/loro-websocket-client/Cargo.toml

@@ -630,6 +630,7 @@ impl Hash for RoomKey {
             CrdtType::Yjs => 3,
             CrdtType::YjsAwareness => 4,
             CrdtType::Elo => 5,
+            CrdtType::Flock => 6,
         };
         tag.hash(state);
         self.room.hash(state);

rust/loro-websocket-client/src/lib.rs

@@ -14,7 +14,7 @@ name = "loro_websocket_server"
 path = "src/lib.rs"
 
 [dependencies]
-loro-protocol = { version = "0.1.0", path = "../loro-protocol" }
+loro-protocol = { version = "0.3.0", path = "../loro-protocol" }
 tokio = { version = "1", features = ["rt", "macros", "net", "sync", "time"] }
 tokio-tungstenite = "0.27"
 futures-util = { version = "0.3", default-features = false, features = ["sink"] }