feat: Add support for Google PubSub (#199)

docs/install.md

@@ -38,6 +38,7 @@ All processes require the following variables:
 - KMS-related variables:
   - `KMS_ADAPTER` (required; e.g., `AWS`, `GCP`).
   - Any other variable required by the specific adapter in use. Refer to the [`@relaycorp/webcrypto-kms` documentation](https://www.npmjs.com/package/@relaycorp/webcrypto-kms).
+- `CE_TRANSPORT` (default: `ce-http-binary`): The [`@relaycorp/cloudevents-transport`](https://www.npmjs.com/package/@relaycorp/cloudevents-transport) transport to use. Each transport has its own set of environment variables.
 
 ## Example with Knative
 

package.json

@@ -19,6 +19,7 @@
     "@fastify/routes": "^5.1.0",
     "@fastify/type-provider-json-schema-to-ts": "^2.2.2",
     "@peculiar/webcrypto": "^1.4.3",
+    "@relaycorp/cloudevents-transport": "^1.3.0",
     "@relaycorp/dnssec": "^1.11.4",
     "@relaycorp/pino-cloud": "^1.0.28",
     "@relaycorp/veraid": "^1.14.2",

src/awala/routes/awala.routes.spec.ts

@@ -21,6 +21,7 @@ import { CE_ID } from '../../testUtils/eventing/stubs.js';
 import { INCOMING_SERVICE_MESSAGE_TYPE } from '../../events/incomingServiceMessage.event.js';
 import { postEvent } from '../../testUtils/eventing/cloudEvents.js';
 import type { MemberKeyImportRequest } from '../../schemas/awala.schema.js';
+import { Emitter } from '../../utilities/eventing/Emitter.js';
 
 const mockProcessMemberKeyImportToken = mockSpy(
   jest.fn<() => Promise<Result<undefined, MemberPublicKeyImportProblemType>>>(),
@@ -268,6 +269,7 @@ describe('Awala routes', () => {
       expect(mockProcessMemberKeyImportToken).toHaveBeenCalledOnceWith(
         AWALA_PEER_ID,
         importRequest,
+        expect.any(Emitter),
         { logger: expect.anything(), dbConnection: server.mongoose },
       );
     });
@@ -319,6 +321,7 @@ describe('Awala routes', () => {
       expect(mockProcessMemberKeyImportToken).toHaveBeenCalledOnceWith(
         AWALA_PEER_ID,
         importRequest,
+        expect.any(Emitter),
         {
           logger: expect.anything(),
           dbConnection: server.mongoose,