Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix: optin to websockets for the mediator live mode as an experiment,… (
#199)
- Loading branch information
1 parent
11cc07c
commit 5fe7f33
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,225 @@ | ||
| /** | ||
| * @jest-environment node | ||
| */ | ||
| import chai from "chai"; | ||
| import chaiAsPromised from "chai-as-promised"; | ||
| import SinonChai from "sinon-chai"; | ||
| import { Apollo, BasicMediatorHandler, Castor, ConnectionsManager, MediatorStore, Pluto } from "../../src"; | ||
| import { Curve, KeyTypes, Mercury, Service, ServiceEndpoint } from "../../src/domain"; | ||
| import { MercuryStub } from "./mocks/MercuryMock"; | ||
| import { AgentCredentials } from "../../src/prism-agent/Agent.Credentials"; | ||
| import { AgentOptions } from "../../src/prism-agent/types"; | ||
|
|
||
| chai.use(SinonChai); | ||
| chai.use(chaiAsPromised); | ||
|
|
||
| const store: MediatorStore = null as any; | ||
| const mercury: Mercury = new MercuryStub(); | ||
|
|
||
| const apollo = new Apollo(); | ||
| const castor = new Castor(apollo) | ||
| const pluto: Pluto = null as any; | ||
| const agentCredentials: AgentCredentials = null as any; | ||
|
|
||
|
|
||
| async function createBasicMediationHandler( | ||
| ConnectionsManager: any, | ||
| BasicMediatorHandler: any, | ||
| services: Service[], | ||
| options?: AgentOptions | ||
| ): Promise< | ||
| { | ||
| manager: ConnectionsManager, | ||
| handler: BasicMediatorHandler | ||
| } | ||
| > { | ||
|
|
||
| const seed = apollo.createRandomSeed().seed; | ||
| const keypair = apollo.createPrivateKey({ | ||
| type: KeyTypes.EC, | ||
| curve: Curve.SECP256K1, | ||
| seed: Buffer.from(seed.value).toString("hex"), | ||
| }); | ||
| const mediatorDID = await castor.createPrismDID(keypair.publicKey(), services); | ||
| const handler = new BasicMediatorHandler( | ||
| mediatorDID, | ||
| mercury, | ||
| store | ||
| ); | ||
| handler.mediator = { | ||
| hostDID: mediatorDID, | ||
| routingDID: mediatorDID, | ||
| mediatorDID: mediatorDID | ||
| } | ||
| const manager = new ConnectionsManager( | ||
| castor, | ||
| mercury, | ||
| pluto, | ||
| agentCredentials, | ||
| handler, | ||
| [], | ||
| options | ||
| ) | ||
| return { | ||
| manager, | ||
| handler | ||
| } | ||
| } | ||
|
|
||
|
|
||
| describe("ConnectionsManager tests", () => { | ||
|
|
||
| beforeEach(() => { | ||
| jest.mock('isows', () => ({ | ||
| WebSocket: jest.fn(() => ({ | ||
| addEventListener: jest.fn(), | ||
| send: jest.fn(), | ||
| close: jest.fn(), | ||
| })), | ||
| })); | ||
| }) | ||
|
|
||
| afterEach(() => { | ||
| jest.restoreAllMocks(); | ||
| }); | ||
|
|
||
| it("Should use websockets if the mediator's did endpoint uri contains ws or wss and agent options have the opt in", async () => { | ||
| const services = [ | ||
| new Service( | ||
| "#didcomm-1", | ||
| ["DIDCommMessaging"], | ||
| new ServiceEndpoint("ws://localhost:12346") | ||
| ) | ||
| ]; | ||
| const ConnectionsManager = jest.requireActual('../../src/prism-agent/connectionsManager/ConnectionsManager').ConnectionsManager; | ||
| const BasicMediatorHandler = jest.requireMock('../../src/prism-agent/mediator/BasicMediatorHandler').BasicMediatorHandler; | ||
| const { manager, handler } = await createBasicMediationHandler( | ||
| ConnectionsManager, | ||
| BasicMediatorHandler, | ||
| services, | ||
| { | ||
| experiments: { | ||
| liveMode: true | ||
| } | ||
| } | ||
| ); | ||
| const listenUnread = jest.spyOn(handler, 'listenUnreadMessages') | ||
| expect(manager).toHaveProperty('withWebsocketsExperiment', true); | ||
| await manager.startFetchingMessages(1) | ||
| expect(listenUnread).toHaveBeenCalled(); | ||
|
|
||
| manager.stopFetchingMessages() | ||
| }) | ||
|
|
||
| it("Should not use websockets even if the mediator's did endpoint uri contains ws or wss if the agent options don't have the opt-in", async () => { | ||
| const services = [ | ||
| new Service( | ||
| "#didcomm-1", | ||
| ["DIDCommMessaging"], | ||
| new ServiceEndpoint("ws://localhost:12346") | ||
| ) | ||
| ]; | ||
| const ConnectionsManager = jest.requireActual('../../src/prism-agent/connectionsManager/ConnectionsManager').ConnectionsManager; | ||
| const BasicMediatorHandler = jest.requireMock('../../src/prism-agent/mediator/BasicMediatorHandler').BasicMediatorHandler; | ||
| const { manager, handler } = await createBasicMediationHandler( | ||
| ConnectionsManager, | ||
| BasicMediatorHandler, | ||
| services | ||
| ); | ||
| const listenUnread = jest.spyOn(handler, 'listenUnreadMessages') | ||
| expect(manager).toHaveProperty('withWebsocketsExperiment', false); | ||
|
|
||
| await manager.startFetchingMessages(1) | ||
|
|
||
| expect(listenUnread).not.toHaveBeenCalled() | ||
| manager.stopFetchingMessages() | ||
| }) | ||
|
|
||
| it("Should not use websockets even if the mediator's did endpoint uri contains ws or wss if the agent options don't have the opt-in 1", async () => { | ||
| const services = [ | ||
| new Service( | ||
| "#didcomm-1", | ||
| ["DIDCommMessaging"], | ||
| new ServiceEndpoint("ws://localhost:12346") | ||
| ) | ||
| ]; | ||
| const ConnectionsManager = jest.requireActual('../../src/prism-agent/connectionsManager/ConnectionsManager').ConnectionsManager; | ||
| const BasicMediatorHandler = jest.requireMock('../../src/prism-agent/mediator/BasicMediatorHandler').BasicMediatorHandler; | ||
| const { manager, handler } = await createBasicMediationHandler( | ||
| ConnectionsManager, | ||
| BasicMediatorHandler, | ||
| services, | ||
| { | ||
| experiments: { | ||
|
|
||
| } | ||
| } | ||
| ); | ||
| const listenUnread = jest.spyOn(handler, 'listenUnreadMessages') | ||
| expect(manager).toHaveProperty('withWebsocketsExperiment', false); | ||
|
|
||
| await manager.startFetchingMessages(1) | ||
|
|
||
| expect(listenUnread).not.toHaveBeenCalled() | ||
| manager.stopFetchingMessages() | ||
| }) | ||
|
|
||
| it("Should not use websockets even if the mediator's did endpoint uri contains ws or wss if the agent options don't have the opt-in 2", async () => { | ||
| const services = [ | ||
| new Service( | ||
| "#didcomm-1", | ||
| ["DIDCommMessaging"], | ||
| new ServiceEndpoint("ws://localhost:12346") | ||
| ) | ||
| ]; | ||
| const ConnectionsManager = jest.requireActual('../../src/prism-agent/connectionsManager/ConnectionsManager').ConnectionsManager; | ||
| const BasicMediatorHandler = jest.requireMock('../../src/prism-agent/mediator/BasicMediatorHandler').BasicMediatorHandler; | ||
| const { manager, handler } = await createBasicMediationHandler( | ||
| ConnectionsManager, | ||
| BasicMediatorHandler, | ||
| services, | ||
| { | ||
| experiments: { | ||
| liveMode: false | ||
| } | ||
| } | ||
| ); | ||
| const listenUnread = jest.spyOn(handler, 'listenUnreadMessages') | ||
| expect(manager).toHaveProperty('withWebsocketsExperiment', false); | ||
|
|
||
| await manager.startFetchingMessages(1) | ||
|
|
||
| expect(listenUnread).not.toHaveBeenCalled() | ||
| manager.stopFetchingMessages() | ||
| }) | ||
|
|
||
| it("Should not use websockets if the mediator'd did endpoint uri does not contain ws or wss for more than the agent has opted in", async () => { | ||
| const services = [ | ||
| new Service( | ||
| "#didcomm-1", | ||
| ["DIDCommMessaging"], | ||
| new ServiceEndpoint("http://localhost:12346") | ||
| ) | ||
| ]; | ||
| const ConnectionsManager = jest.requireActual('../../src/prism-agent/connectionsManager/ConnectionsManager').ConnectionsManager; | ||
| const BasicMediatorHandler = jest.requireMock('../../src/prism-agent/mediator/BasicMediatorHandler').BasicMediatorHandler; | ||
| const { manager, handler } = await createBasicMediationHandler( | ||
| ConnectionsManager, | ||
| BasicMediatorHandler, | ||
| services, | ||
| { | ||
| experiments: { | ||
| liveMode: true | ||
| } | ||
| } | ||
| ); | ||
| const listenUnread = jest.spyOn(handler, 'listenUnreadMessages') | ||
| expect(manager).toHaveProperty('withWebsocketsExperiment', true); | ||
|
|
||
| await manager.startFetchingMessages(1) | ||
|
|
||
| expect(listenUnread).not.toHaveBeenCalled() | ||
| manager.stopFetchingMessages() | ||
| }) | ||
|
|
||
| }) |
Oops, something went wrong.
5fe7f33There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
JUnit