feat: add sourceBus()

Author: bosschaert

packages/helix-shared-storage/src/storage.js

@@ -85,7 +85,7 @@ function sanitizeKey(keyOrPath) {
   return keyOrPath;
 }
 
-const BUCKET_KEYS = ['config', 'code', 'content', 'media'];
+const BUCKET_KEYS = ['config', 'code', 'content', 'media', 'source'];
 
 export function parseBucketNames(bucketNames) {
   if (!bucketNames) {
@@ -800,6 +800,13 @@ export class HelixStorage {
     return this.bucket(this._bucketMap.media);
   }
 
+  /**
+   * @returns {Bucket}
+   */
+  sourceBus(disableR2 = false) {
+    return this.bucket(this._bucketMap.source, disableR2);
+  }
+
   /**
    * @returns {Bucket}
    */

packages/helix-shared-storage/test/storage.test.js

@@ -115,6 +115,7 @@ describe('Storage test', () => {
       config: 'helix-config-bus',
       content: 'helix-content-bus',
       media: 'helix-media-bus',
+      source: 'helix-source-bus',
     });
   });
 
@@ -124,6 +125,7 @@ describe('Storage test', () => {
       config: 'bucket-02',
       content: 'bucket-03',
       media: 'bucket-04',
+      source: 'bucket-05',
     };
     assert.deepStrictEqual(parseBucketNames(JSON.stringify(map)), map);
   });
@@ -134,6 +136,7 @@ describe('Storage test', () => {
       config: 'bucket-02',
       content: 'bucket-03',
       media: 'bucket-04',
+      source: 'bucket-05',
     };
     storage = new HelixStorage({
       region: AWS_REGION,
@@ -198,6 +201,10 @@ describe('Storage test', () => {
     assert.strictEqual(storage.configBus().bucket, 'helix-config-bus');
   });
 
+  it('can get the source-bus', () => {
+    assert.strictEqual(storage.sourceBus().bucket, 'helix-source-bus');
+  });
+
   it('can get an object', async () => {
     nock('https://helix-code-bus.s3.fake.amazonaws.com')
       .get('/foo?x-id=GetObject')