Add SyncManager to identity and proxy agent packages

Signed-off-by: Frank Hinek <[email protected]>

packages/agent/src/test-managed-agent.ts

@@ -16,12 +16,12 @@ import { DwnManager } from './dwn-manager.js';
 import { KeyManager } from './key-manager.js';
 import { Web5RpcClient } from './rpc-client.js';
 import { AppDataVault } from './app-data-store.js';
+import { SyncManagerLevel } from './sync-manager.js';
 import { cryptoToPortableKeyPair } from './utils.js';
 import { DidStoreDwn, DidStoreMemory } from './store-managed-did.js';
 import { IdentityManager, ManagedIdentity } from './identity-manager.js';
 import { IdentityStoreDwn, IdentityStoreMemory } from './store-managed-identity.js';
 import { KeyStoreDwn, KeyStoreMemory, PrivateKeyStoreDwn, PrivateKeyStoreMemory } from './store-managed-key.js';
-import { SyncManagerLevel } from './sync-manager.js';
 
 type CreateMethodOptions = {
   agentClass: new (options: any) => Web5ManagedAgent

packages/agent/tests/dwn-manager.spec.ts

@@ -7,14 +7,14 @@ import {
   RecordsRead,
   EventsGetReply,
   EventsGetMessage,
+  MessagesGetReply,
   RecordsReadReply,
   RecordsQueryReply,
   UnionMessageReply,
   MessagesGetMessage,
   RecordsQueryMessage,
   RecordsWriteMessage,
   RecordsDeleteMessage,
-  MessagesGetReply,
   ProtocolsConfigureMessage,
 } from '@tbd54566975/dwn-sdk-js';
 

packages/agent/tests/sync-manager.spec.ts

@@ -43,7 +43,6 @@ describe('SyncManagerLevel', () => {
   describe('with Web5ManagedAgent', () => {
     let alice: ManagedIdentity;
     let aliceDid: PortableDid;
-    // let syncManager: SyncManagerLevel;
     let testAgent: TestManagedAgent;
 
     before(async () => {

packages/agent/tests/utils/test-agent.ts

@@ -1,3 +1,4 @@
+import { Level } from 'level';
 import { Dwn } from '@tbd54566975/dwn-sdk-js';
 import { DidIonMethod, DidKeyMethod, DidResolver } from '@web5/dids';
 import { MessageStoreLevel, DataStoreLevel, EventLogLevel } from '@tbd54566975/dwn-sdk-js/stores';
@@ -44,6 +45,7 @@ type TestAgentOptions = {
   dwnDataStore: DataStoreLevel;
   dwnEventLog: EventLogLevel;
   dwnMessageStore: MessageStoreLevel;
+  syncStore: Level;
 }
 
 export class TestAgent implements Web5ManagedAgent {
@@ -58,12 +60,13 @@ export class TestAgent implements Web5ManagedAgent {
   syncManager: SyncManager;
 
   /**
-   * DWN-related properties.
+   * Store-related properties.
    */
   dwn: Dwn;
   dwnDataStore: DataStoreLevel;
   dwnEventLog: EventLogLevel;
   dwnMessageStore: MessageStoreLevel;
+  syncStore: Level;
 
   constructor(options: TestAgentOptions) {
     this.appData = options.appData;
@@ -87,19 +90,22 @@ export class TestAgent implements Web5ManagedAgent {
     this.dwnDataStore = options.dwnDataStore;
     this.dwnEventLog = options.dwnEventLog;
     this.dwnMessageStore = options.dwnMessageStore;
+    this.syncStore = options.syncStore;
   }
 
   async clearStorage(): Promise<void> {
     this.agentDid = undefined;
     await this.dwnDataStore.clear();
     await this.dwnEventLog.clear();
     await this.dwnMessageStore.clear();
+    await this.syncStore.clear();
   }
 
   async closeStorage(): Promise<void> {
     await this.dwnDataStore.close();
     await this.dwnEventLog.close();
     await this.dwnMessageStore.close();
+    await this.syncStore.close();
   }
 
   static async create(options: CreateMethodOptions = {}): Promise<TestAgent> {
@@ -142,8 +148,9 @@ export class TestAgent implements Web5ManagedAgent {
     // Instantiate an RPC Client.
     const rpcClient = new Web5RpcClient();
 
-    // Instantiate a SyncManager.
-    const syncManager = new SyncManagerLevel({ dataPath: testDataPath('SYNC_STORE') });
+    // Instantiate a custom SyncManager and LevelDB-backed store.
+    const syncStore = new Level(testDataPath('SYNC_STORE'));
+    const syncManager = new SyncManagerLevel({ db: syncStore });
 
     return new TestAgent({
       appData,
@@ -157,7 +164,8 @@ export class TestAgent implements Web5ManagedAgent {
       identityManager,
       keyManager,
       rpcClient,
-      syncManager
+      syncManager,
+      syncStore
     });
   }
 

packages/identity-agent/src/identity-agent.ts

@@ -3,6 +3,7 @@ import type {
   VcResponse,
   DidResponse,
   DwnResponse,
+  SyncManager,
   AppDataStore,
   SendVcRequest,
   SendDidRequest,
@@ -27,6 +28,7 @@ import {
   Web5RpcClient,
   IdentityManager,
   IdentityStoreDwn,
+  SyncManagerLevel,
   PrivateKeyStoreDwn,
   cryptoToPortableKeyPair,
 } from '@web5/agent';
@@ -40,6 +42,7 @@ export type IdentityAgentOptions = {
   identityManager: IdentityManager;
   keyManager: KeyManager;
   rpcClient: DwnRpc;
+  syncManager: SyncManager;
 }
 
 export class IdentityAgent implements Web5ManagedAgent {
@@ -51,6 +54,7 @@ export class IdentityAgent implements Web5ManagedAgent {
   identityManager: IdentityManager;
   keyManager: KeyManager;
   rpcClient: DwnRpc;
+  syncManager: SyncManager;
 
   constructor(options: IdentityAgentOptions) {
     this.agentDid = options.agentDid;
@@ -61,16 +65,21 @@ export class IdentityAgent implements Web5ManagedAgent {
     this.identityManager = options.identityManager;
     this.keyManager = options.keyManager;
     this.rpcClient = options.rpcClient;
+    this.syncManager = options.syncManager;
 
     // Set this agent to be the default agent.
     this.didManager.agent = this;
     this.dwnManager.agent = this;
     this.identityManager.agent = this;
     this.keyManager.agent = this;
+    this.syncManager.agent = this;
   }
 
   static async create(options: Partial<IdentityAgentOptions> = {}): Promise<IdentityAgent> {
-    let { agentDid, appData, didManager, didResolver, dwnManager, identityManager, keyManager, rpcClient } = options;
+    let {
+      agentDid, appData, didManager, didResolver, dwnManager,
+      identityManager, keyManager, rpcClient, syncManager
+    } = options;
 
     if (agentDid === undefined) {
       // An Agent DID was not specified, so set to empty string.
@@ -140,6 +149,12 @@ export class IdentityAgent implements Web5ManagedAgent {
       rpcClient = new Web5RpcClient();
     }
 
+    if (syncManager === undefined) {
+      // A custom SyncManager implementation was not specified, so
+      // instantiate a LevelDB-backed default.
+      syncManager = new SyncManagerLevel();
+    }
+
     // Instantiate the Identity Agent.
     const agent = new IdentityAgent({
       agentDid,
@@ -149,7 +164,8 @@ export class IdentityAgent implements Web5ManagedAgent {
       dwnManager,
       identityManager,
       keyManager,
-      rpcClient
+      rpcClient,
+      syncManager
     });
 
     return agent;