import * as aws from '@pulumi/aws';

const bucket = new aws.s3.Bucket('bucket');

bucket.onObjectCreated(
  'onNewVideo',
  new aws.lambda.CallbackFunction<aws.s3.BucketEvent, void>('onNewVideo', {
    callback: async bucketArgs => {
      console.log('onNewVideo called');
      if (!bucketArgs.Records) {
        return;
      }

      const s3 = new aws.sdk.S3();
      console.log(s3.apiVersions);

      for (const record of bucketArgs.Records) {
        console.log(
          `*** New video: file ${record.s3.object.key} was uploaded at ${record.eventTime}.`
        );
      }
    }
  })
);