lambda-env/apiGateway.js at main · sprocs/lambda-env · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
const getMethodBasedOnRecordEventName = ({ record }) => {
  const { eventName } = record
  switch (eventName) {
    case 'INSERT':
      return 'post'
    case 'MODIFY':
      return 'put'
    case 'REMOVE':
      return 'delete'
  }
}

const getPath = ({ method, record }) => {
  switch (method) {
    case 'post':
      return '/dynamodb'
    default:
      return `/dynamodb/${record.dynamodb.NewImage.id.S}`
  }
}

const mapDynamoDbEventToHttpRequest = ({ event }) => {
  const record = event.Records[0]
  const method = getMethodBasedOnRecordEventName({ record })
  const path = getPath({ method, record })

  return {
    method,
    path,
    headers: {}
  }
}

const mapResponseToDynamoDb = ({
  statusCode,
  body,
  headers,
  isBase64Encoded
}) => {
  return {
    statusCode,
    body,
    headers,
    isBase64Encoded
  }
}

module.exports = {
  mapDynamoDbEventToHttpRequest,
  mapResponseToDynamoDb
}