Merge pull request #18 from afgallo/feature/sns-endpoint

Add Endpoint Option for Local Development

lib/adapter/sns-adapter.js

@@ -5,12 +5,23 @@ module.exports = exports = class SNSAdapter {
 
   constructor(options = {}) {
     let credentials = null
+    let endpoint = null
+    options.region = options.region || 'us-east-1'
 
     if (options.awsAccessKey && options.awsSecretKey) {
       credentials = { accessKeyId: options.awsAccessKey, secretAccessKey: options.awsSecretKey }
     }
 
-    this.#snsClient = options.snsClient || new SNSClient({ region: options.region || 'us-east-1', credentials })
+    if (options.endpoint) {
+      endpoint = options.endpoint // Only used in local development
+    }
+
+    this.#snsClient = options.snsClient || new SNSClient({ region: options.region, credentials, endpoint })
+  }
+
+  // Getter for snsClient - mostly for unit testing
+  get getSNSClient() {
+    return this.#snsClient
   }
 
   async publish(topicArn, message, options = {}) {

test/sns-adapter.test.js

@@ -88,4 +88,19 @@ describe('SNSAdapter', () => {
 
     consoleErrorStub.restore()
   })
+
+  it('creates a new SNSAdapter with a custom endpoint', async () => {
+    const endpoint = 'http://localhost:4575' // LocalStack SNS endpoint for local testing
+    const customSNSAdapter = new SNSAdapter({ endpoint })
+
+    expect(customSNSAdapter).to.exist()
+    expect(customSNSAdapter).to.be.an.instanceof(SNSAdapter)
+
+    // Check that the SNSClient was created with the correct endpoint
+    const client = customSNSAdapter.getSNSClient
+    const actualEndpoint = await client.config.endpoint()
+
+    expect(actualEndpoint.hostname).to.equal('localhost')
+    expect(actualEndpoint.port).to.equal(4575)
+  })
 })