fix(sync): update array sync module for new wire types and Encryption API

- Add `producer_id`, `epoch`, and `seq` fields (all zero) to
  `ArrayDeltaMsg` constructions in tests for inbound delta handling.
- Add `applied_seq` and `AckStatus::Applied` to `ArrayAckMsg`
  construction in `ack_sender`.
- Update internal test calls to `PagedbStorageDefault::open` to pass
  `Encryption::Plaintext` to match the new storage open signature.

Author: farhan-syah

nodedb-lite/src/sync/array/ack_sender.rs

@@ -85,6 +85,8 @@ async fn send_acks<S: StorageEngine>(
             array: array.clone(),
             replica_id: replica_id.as_u64(),
             ack_hlc_bytes: ack_hlc.to_bytes(),
+            applied_seq: 0,
+            status: nodedb_types::sync::wire::AckStatus::Applied,
         };
 
         let frame = match nodedb_types::sync::wire::SyncFrame::try_encode(

nodedb-lite/src/sync/array/catchup.rs

@@ -234,14 +234,28 @@ mod tests {
         let target_hlc = hlc(42_000);
 
         {
-            let storage = Arc::new(PagedbStorageDefault::open(&path).await.unwrap());
+            let storage = Arc::new(
+                PagedbStorageDefault::open(
+                    &path,
+                    crate::storage::encryption::Encryption::Plaintext,
+                )
+                .await
+                .unwrap(),
+            );
             let tracker = CatchupTracker::load(Arc::clone(&storage)).await.unwrap();
             tracker.record("arr", target_hlc).await.unwrap();
             assert_eq!(tracker.last_seen("arr"), target_hlc);
         }
 
         {
-            let storage = Arc::new(PagedbStorageDefault::open(&path).await.unwrap());
+            let storage = Arc::new(
+                PagedbStorageDefault::open(
+                    &path,
+                    crate::storage::encryption::Encryption::Plaintext,
+                )
+                .await
+                .unwrap(),
+            );
             let tracker = CatchupTracker::load(storage).await.unwrap();
             assert_eq!(
                 tracker.last_seen("arr"),

nodedb-lite/src/sync/array/inbound/delta.rs

@@ -95,6 +95,9 @@ mod tests {
         let msg = ArrayDeltaMsg {
             array: "arr".into(),
             op_payload: payload,
+            producer_id: 0,
+            epoch: 0,
+            seq: 0,
         };
         let outcome = inbound.handle_delta(&msg).unwrap();
         assert_eq!(outcome, InboundOutcome::Applied);
@@ -133,6 +136,9 @@ mod tests {
         let msg = ArrayDeltaMsg {
             array: "arr".into(),
             op_payload: payload.clone(),
+            producer_id: 0,
+            epoch: 0,
+            seq: 0,
         };
 
         // First application — should be Applied.
@@ -143,6 +149,9 @@ mod tests {
         let msg2 = ArrayDeltaMsg {
             array: "arr".into(),
             op_payload: payload,
+            producer_id: 0,
+            epoch: 0,
+            seq: 0,
         };
         let o2 = inbound.handle_delta(&msg2).unwrap();
         assert_eq!(o2, InboundOutcome::Idempotent);
@@ -157,6 +166,9 @@ mod tests {
         let msg = ArrayDeltaMsg {
             array: "unknown_arr".into(),
             op_payload: payload,
+            producer_id: 0,
+            epoch: 0,
+            seq: 0,
         };
         let outcome = inbound.handle_delta(&msg).unwrap();
         assert!(
@@ -201,6 +213,9 @@ mod tests {
         let msg = ArrayDeltaMsg {
             array: "arr".into(),
             op_payload: payload,
+            producer_id: 0,
+            epoch: 0,
+            seq: 0,
         };
         let outcome = inbound.handle_delta(&msg).unwrap();
         assert!(

nodedb-lite/src/sync/array/op_log_store.rs

@@ -446,15 +446,29 @@ mod tests {
         let path = dir.path().join("op_log_test.pagedb");
 
         {
-            let storage = Arc::new(PagedbStorageDefault::open(&path).await.unwrap());
+            let storage = Arc::new(
+                PagedbStorageDefault::open(
+                    &path,
+                    crate::storage::encryption::Encryption::Plaintext,
+                )
+                .await
+                .unwrap(),
+            );
             let log = KvOpLogStore::new(Arc::clone(&storage));
             log.append(&make_op("arr", 10)).unwrap();
             log.append(&make_op("arr", 20)).unwrap();
         }
 
         // Reopen the same file.
         {
-            let storage = Arc::new(PagedbStorageDefault::open(&path).await.unwrap());
+            let storage = Arc::new(
+                PagedbStorageDefault::open(
+                    &path,
+                    crate::storage::encryption::Encryption::Plaintext,
+                )
+                .await
+                .unwrap(),
+            );
             let log = KvOpLogStore::new(storage);
             assert_eq!(log.len().unwrap(), 2);
             let ops: Vec<_> = log

nodedb-lite/src/sync/array/pending.rs

@@ -266,14 +266,28 @@ mod tests {
         let path = dir.path().join("pending_test.pagedb");
 
         {
-            let storage = Arc::new(PagedbStorageDefault::open(&path).await.unwrap());
+            let storage = Arc::new(
+                PagedbStorageDefault::open(
+                    &path,
+                    crate::storage::encryption::Encryption::Plaintext,
+                )
+                .await
+                .unwrap(),
+            );
             let q = PendingQueue::new(storage);
             q.enqueue(&make_op(5)).await.unwrap();
             q.enqueue(&make_op(15)).await.unwrap();
         }
 
         {
-            let storage = Arc::new(PagedbStorageDefault::open(&path).await.unwrap());
+            let storage = Arc::new(
+                PagedbStorageDefault::open(
+                    &path,
+                    crate::storage::encryption::Encryption::Plaintext,
+                )
+                .await
+                .unwrap(),
+            );
             let q = PendingQueue::new(storage);
             assert_eq!(q.len().await.unwrap(), 2);
             let ops = q.drain_batch(usize::MAX).await.unwrap();

nodedb-lite/src/sync/array/schema_registry.rs

@@ -302,14 +302,28 @@ mod tests {
 
         let schema_hlc;
         {
-            let storage = Arc::new(PagedbStorageDefault::open(&path).await.unwrap());
+            let storage = Arc::new(
+                PagedbStorageDefault::open(
+                    &path,
+                    crate::storage::encryption::Encryption::Plaintext,
+                )
+                .await
+                .unwrap(),
+            );
             let replica = Arc::new(ReplicaState::load_or_init(&*storage).await.unwrap());
             let reg = SchemaRegistry::new(Arc::clone(&storage), Arc::clone(&replica));
             schema_hlc = reg.put_schema("arr", &simple_schema("arr")).await.unwrap();
         }
 
         {
-            let storage = Arc::new(PagedbStorageDefault::open(&path).await.unwrap());
+            let storage = Arc::new(
+                PagedbStorageDefault::open(
+                    &path,
+                    crate::storage::encryption::Encryption::Plaintext,
+                )
+                .await
+                .unwrap(),
+            );
             let replica = Arc::new(ReplicaState::load_or_init(&*storage).await.unwrap());
             let reg = SchemaRegistry::load(Arc::clone(&storage), replica)
                 .await