CPbgnipM

1export const logAtheneEvent = (event: types.AtheneEvent) => {
2  const kinesis = new Kinesis({
3    apiVersion: '2013-12-02',
4    region: awsRegion,
5    accessKeyId: access_key,
6    secretAccessKey: secret_key,
7    sessionToken: session_token
8  });
9  console.log(kinesis);
10  const eventData = event;
11  const currentTimestamp = Date();
12  const partitionKey = event.targetUser;
13  const kinesisParams: PutRecordInput = {
14    Data: JSON.stringify(eventData),
15    PartitionKey: partitionKey,
16    StreamName: streamName
17  };
18
19  const kinesisPromise = new Promise((resolve, reject) => {
20    const request = kinesis.putRecord(kinesisParams, (error, response) => {
21      console.log(error);
22      console.log(response);
23      console.log('test');
24      if (error) {
25        console.log('ERROR: ', error);
26        reject(error);
27      } else {
28        console.log('Response: ', response);
29        resolve(response);
30      }
31    });
32    console.log('Request: ', request);
33  });
34
35  kinesisPromise.then((resolution) => {
36    console.log('Resolved: ', resolution);
37    return resolution;
38  }).catch((rejection) => {
39    console.log('ERROR: ', rejection);
40    return rejection;
41  });
42
43};