Tweak claimchecked s3 keys.

Author: petermyers

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "aws-lambda-stream",
-  "version": "1.0.27",
+  "version": "1.0.28",
   "description": "Create stream processors with AWS Lambda functions.",
   "keywords": [
     "aws",

package.json

@@ -9,7 +9,11 @@ import { now } from '../utils/time';
 const formatKey = (event) => {
   const d = new Date(now());
   // region/claimchecks/YYYY/MM/DD/HH/id
-  return `${process.env.AWS_REGION}/claimchecks/${d.getUTCFullYear()}/${d.getUTCMonth()}/${d.getUTCDate()}/${d.getUTCHours()}/${event.id}`;
+  return `${process.env.AWS_REGION}/claimchecks/${d.getUTCFullYear()}/${String(
+    d.getUTCMonth() + 1,
+  ).padStart(2, '0')}/${String(d.getUTCDate()).padStart(2, '0')}/${String(
+    d.getUTCHours(),
+  ).padStart(2, '0')}/${event.id}`;
 };
 
 export const toClaimcheckEvent = (event, bucket) => ({

src/sinks/claimcheck.js

@@ -57,13 +57,14 @@ describe('sinks/claimcheck.js', () => {
         expect(spy).to.not.have.been.called;
         expect(collected[1]).to.deep.equal([
           {
-            publishRequestEntry: { // size = 39
-              Detail: '{"id":"3","s3":{"bucket":"event-lake-s3","key":"us-west-2/claimchecks/2024/8/20/17/3"}}',
+            publishRequestEntry: {
+              Detail:
+                '{"id":"3","s3":{"bucket":"event-lake-s3","key":"us-west-2/claimchecks/2024/09/20/17/3"}}',
             },
             putClaimcheckRequest: {
               Bucket: 'event-lake-s3',
-              Key: 'us-west-2/claimchecks/2024/8/20/17/3',
-              Body: '{\"id\":\"3\",\"body\":\"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx\"}',
+              Key: 'us-west-2/claimchecks/2024/09/20/17/3',
+              Body: '{"id":"3","body":"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"}',
             },
           },
         ]);