added records to the SNS action (#44)

added records to the SNS action for further usage

README.md

@@ -224,13 +224,15 @@ export const handler = router.handler({
                 // a regex to match the content of the SNS-Subject:
                 subject: /.*/,
                 // Attention: the message is JSON-stringified
-                action: (sns, context) => service.doSomething(JSON.parse(sns.Message))
+                action: (sns, context, records) => service.doSomething(JSON.parse(sns.Message))
             }
         ]
     }
 })
 ```
 
+The *records* parameter contains `SNSEventRecord[]`. An exampe event structure can be found [here](lib/event-examples/sns.json). For example you can parse now the  [message attributes of the SNS](https://docs.aws.amazon.com/sns/latest/dg/sns-message-attributes.html) or reads the topic arn of SNS. 
+
 ## SQS to Lambda Integrations
 
 For handling calls in Lambdas initiated from AWS-SQS you can use the following code snippet:
@@ -378,15 +380,14 @@ Increase version in **package.json** (using [semantic version syntax](https://se
 Thats all.
 
 ## Release History
-* 0.8.3
-   * added records to the SQS action for further processing
+* unreleased
+   * added records to the SQS (#43) and SNS (#44) action for further processing
 * 0.8.2
    * added support for Open API parameter definitions e.g.: /section/{id}
 * 0.8.1
    * fix: changed ProxyIntegrationEvent body type to be generic but defaults to unknown
    * fix: changed @types/aws-lambda from devDependency to dependency
    * **breaking**: error response objects (thrown or rejected) now need to set `statusCode` instead of `status` (consistent with response)
-  
 * 0.7.1
    * code style cleanup
    * fix: hosted package on npmjs should now worked

lib/sns.ts

@@ -1,11 +1,11 @@
-import { Context, SNSEvent, SNSMessage } from 'aws-lambda'
+import { Context, SNSEvent, SNSMessage, SNSEventRecord } from 'aws-lambda'
 import { ProcessMethod } from './EventProcessor'
 
 export type SnsEvent = SNSEvent
 
 export interface SnsRoute {
   subject: RegExp
-  action: (sns: SNSMessage, context: Context) => Promise<any> | any
+  action: (sns: SNSMessage, context: Context, records: SNSEventRecord[]) => Promise<any> | any
 }
 
 export interface SnsConfig {
@@ -29,7 +29,7 @@ export const process: ProcessMethod<SnsConfig, SnsEvent, Context, any> = (snsCon
   for (const routeConfig of snsConfig.routes) {
     if (routeConfig.subject instanceof RegExp) {
       if (routeConfig.subject.test(sns.Subject)) {
-        const result = routeConfig.action(sns, context)
+        const result = routeConfig.action(sns, context, event.Records)
         return result || {}
       }
     } else {

test/sns.test.ts

@@ -3,7 +3,7 @@ import { process as sns, SnsConfig, SnsEvent } from '../lib/sns'
 describe('sns.processor', () => {
   const context = {} as any
 
-  it('context should be pass through', () => {
+  it('context and records should be pass through', () => {
     const actionSpy = jasmine.createSpy('action')
 
     const context = { bla: 'blup' } as any
@@ -12,7 +12,7 @@ describe('sns.processor', () => {
 
     sns(snsCfg, event, context)
 
-    expect(actionSpy).toHaveBeenCalledWith(event.Records[0].Sns, context)
+    expect(actionSpy).toHaveBeenCalledWith(event.Records[0].Sns, context, event.Records)
   })
 
   it('should ignore event if it is no SNS event', () => {