add athena from function

Author: John Gilbert - Home

src/from/athena.js

@@ -101,104 +101,3 @@ export const fromAthena = (event, options = {}) => fromSqs(event)
     event: JSON.parse(uow.record.body),
   }))
   .map(faulty(toEventEnvelope));
-
-// // uow.record.s3.s3.object.key.match(opt.pk || /table=(\d+)\/year=(\d+)\/month=(\d+)\/day=(\d+)\/hour=(\d+)\/minute=(\d+)/),
-
-// export const decodeKey = (key) => decodeURIComponent(key)
-//   .split('/')
-//   .reduce((a, c, i, r) => {
-//     if (c.includes('=')) {
-//       const [k, v] = c.split('=');
-//       return {
-//         ...a,
-//         [k]: v,
-//       };
-//     } else if (c.includes('.')) {
-//       const [k, v] = c.split('.');
-//       return {
-//         ...a,
-//         file: k,
-//         contentType: v, // TODO .metadata ???
-//       };
-//     } else if (r[r.length - 1] === c) {
-//       return {
-//         ...a,
-//         file: c,
-//       };
-//     } else {
-//       return {
-//         ...a,
-//         prefix: [...a.prefix, c],
-//       };
-//     }
-//   }, {
-//     prefix: [],
-//   });
-
-// export const buildS3PartitionKey = (key, level = 1) => key.split('/').slice(0, -level).join('/');
-
-// export const mapPartition = (uow) => ({
-//   event: {
-//     id: uow.record.sqs.messageId, // `${uow.record.s3.s3.object.key}-${uow.record.s3.s3.object.eTag}`, // sequencer
-//     type: uow.record.s3.eventName,
-//     timestamp: (new Date(uow.record.s3.eventTime)).getTime(),
-//     partitionKey: buildS3PartitionKey(decodeURIComponent(uow.record.s3.s3.object.key)),
-//     //   tags: {
-//     //     // account
-//     //     // region
-//     //   },
-//     notification: {
-//       type: uow.record.s3.eventName,
-//       bucket: uow.record.s3.s3.bucket.name,
-//       key: decodeURIComponent(uow.record.s3.s3.object.key),
-//       partition: decodeKey(uow.record.s3.s3.object.key),
-//     },
-//     raw: uow.record.s3,
-//   },
-// });
-
-// export const mapJobRequest = (uow) => ({
-//   getJobRequest: {
-//     Bucket: uow.record.s3.s3.bucket.name,
-//     Key: uow.record.s3.s3.object.key,
-//     VersionId: uow.record.s3.s3.object.versionId,
-//   },
-// });
-
-// export const fromS3 = (event, options = {}) => fromSqsSnsS3(event)
-//   .map((uow) => ({
-//     ...uow,
-//     isJob: uow.record.s3.s3.object.key.includes('/jobs/'),
-//   }))
-//   .map((uow) => ({
-//     ...uow,
-//     ...(!uow.isJob && mapPartition(uow)),
-//     ...(uow.isJob && mapJobRequest(uow)),
-//   }))
-//   .through(getObjectFromS3({
-//     id: 'handler:fromS3',
-//     getRequestField: 'getJobRequest',
-//     getResponseField: 'getJobResponse',
-//     additionalClientOpts: {
-//       followRegionRedirects: true,
-//     },
-//     ...options,
-//   }))
-//   .map(faulty((uow) => {
-//     if (!uow.getJobResponse) return uow;
-
-//     const job = JSON.parse(Buffer.from(uow.getJobResponse.Body));
-//     return ({
-//       ...uow,
-//       event: {
-//         id: uow.record.sqs.messageId,
-//         type: job.type,
-//         timestamp: (new Date(uow.record.s3.eventTime)).getTime(),
-//         job: {
-//           id: uow.record.s3.s3.object.versionId,
-//           ...job,
-//         },
-//         raw: uow.event,
-//       },
-//     });
-//   }));