Method build

src/batch-write.ts:32–50

()

  }

  build(): BatchWriteCommandInput {
    const puts = this.batchWriteItems.filter((p): p is Put => p instanceof Put)
    const deletes = this.batchWriteItems.filter((p): p is Delete => p instanceof Delete)
    const tableNames = [...puts, ...deletes].map(p => p.tableName).filter((v, i, a) => a.indexOf(v) === i)

    const input: BatchWriteCommandInput = {
      RequestItems: tableNames.reduce((acc, tableName) => {
        const putRequests = puts.filter(p => p.tableName === tableName).map(p => { return { PutRequest: { Item: p.build().Item } } })
        const deleteRequests = deletes.filter(p => p.tableName === tableName).map(p => { return { DeleteRequest: { Key: p.key } } })
        acc[tableName] = [...putRequests, ...deleteRequests]
        return acc
      }, {} as { [key: string]: WriteRequest[] })
    }

    if (this.returnConsumedCapacity) input.ReturnConsumedCapacity = this.returnConsumedCapacity
    if (this.returnItemCollectionMetrics) input.ReturnItemCollectionMetrics = this.returnItemCollectionMetrics

    return input
  }
}