feat: get llmo config v2 (#1340)

## Add V2 Customer Config S3 Utilities

Added organization-level customer configuration management functions to
`llmo-config.js`:

- `customerConfigV2Path(organizationId)` - Returns S3 path for
organization configs
- `readCustomerConfigV2(organizationId, s3Client, options)` - Reads
config from S3, returns `null` if not found
- `writeCustomerConfigV2(organizationId, config, s3Client, options)` -
Writes config to S3

All functions follow existing LLMO config patterns with
environment/custom bucket support and comprehensive test coverage.

Co-authored-by: ani hammond <annhammo@MacBookPro.lan>

Author: aniham

packages/spacecat-shared-utils/src/llmo-config.js

@@ -125,3 +125,67 @@ export async function writeConfig(siteId, config, s3Client, options) {
   }
   return { version: res.VersionId };
 }
+
+/**
+ * Gets the S3 path for a V2 customer configuration.
+ * @param {string} organizationId The SpaceCat organization ID.
+ * @returns {string} The S3 key path for the V2 customer config.
+ */
+export function customerConfigV2Path(organizationId) {
+  return `customer-config-v2/${organizationId}/config.json`;
+}
+
+/**
+ * Reads the V2 customer configuration for an organization from S3.
+ * @param {string} organizationId The SpaceCat organization ID.
+ * @param {S3Client} s3Client The S3 client to use for reading the configuration.
+ * @param {object} [options]
+ * @param {string} [options.s3Bucket] Optional S3 bucket name.
+ * @returns {Promise<object|null>} The configuration object or null if not found.
+ * @throws {Error} If reading the configuration fails for reasons other than it not existing.
+ */
+export async function readCustomerConfigV2(organizationId, s3Client, options) {
+  const s3Bucket = options?.s3Bucket || process.env.S3_BUCKET_NAME;
+
+  const getObjectCommand = new GetObjectCommand({
+    Bucket: s3Bucket,
+    Key: customerConfigV2Path(organizationId),
+  });
+
+  try {
+    const res = await s3Client.send(getObjectCommand);
+    const body = res.Body;
+    if (!body) {
+      throw new Error('Customer config V2 body is empty');
+    }
+    const text = await body.transformToString();
+    return JSON.parse(text);
+  } catch (e) {
+    if (e.name === 'NoSuchKey' || e.name === 'NotFound') {
+      return null;
+    }
+    throw e;
+  }
+}
+
+/**
+ * Writes the V2 customer configuration for an organization to S3.
+ * @param {string} organizationId The SpaceCat organization ID.
+ * @param {object} config The customer configuration object to write.
+ * @param {S3Client} s3Client The S3 client to use for writing the configuration.
+ * @param {object} [options]
+ * @param {string} [options.s3Bucket] Optional S3 bucket name.
+ * @returns {Promise<void>}
+ */
+export async function writeCustomerConfigV2(organizationId, config, s3Client, options) {
+  const s3Bucket = options?.s3Bucket || process.env.S3_BUCKET_NAME;
+
+  const putObjectCommand = new PutObjectCommand({
+    Bucket: s3Bucket,
+    Key: customerConfigV2Path(organizationId),
+    Body: JSON.stringify(config, null, 2),
+    ContentType: 'application/json',
+  });
+
+  await s3Client.send(putObjectCommand);
+}

packages/spacecat-shared-utils/test/llmo-config.test.js

@@ -23,6 +23,9 @@ import {
   defaultConfig,
   readConfig,
   writeConfig,
+  customerConfigV2Path,
+  readCustomerConfigV2,
+  writeCustomerConfigV2,
 } from '../src/llmo-config.js';
 
 use(sinonChai);
@@ -200,4 +203,116 @@ describe('llmo-config utilities', () => {
       await expect(writeConfig(siteId, validConfig, s3Client)).rejectedWith('Failed to get version ID after writing LLMO config');
     });
   });
+
+  describe('customerConfigV2Path', () => {
+    it('builds the V2 customer config path', () => {
+      const organizationId = 'test-org-123';
+      expect(customerConfigV2Path(organizationId)).to.equals('customer-config-v2/test-org-123/config.json');
+    });
+  });
+
+  describe('readCustomerConfigV2', () => {
+    const organizationId = 'test-org-456';
+    const validCustomerConfig = { settings: { feature1: true }, limits: { maxUsers: 100 } };
+
+    it('retrieves and parses the customer config from S3', async () => {
+      const body = {
+        transformToString: sinon.stub().resolves(JSON.stringify(validCustomerConfig)),
+      };
+      s3Client.send.resolves({ Body: body });
+
+      const result = await readCustomerConfigV2(organizationId, s3Client);
+
+      expect(result).deep.equals(validCustomerConfig);
+      expect(s3Client.send).calledOnce;
+      const command = s3Client.send.firstCall.args[0];
+      expect(command).instanceOf(GetObjectCommand);
+      expect(command.input.Bucket).equals('default-test-bucket');
+      expect(command.input.Key).equals('customer-config-v2/test-org-456/config.json');
+      expect(body.transformToString).calledOnce;
+    });
+
+    it('uses provided bucket when options are set', async () => {
+      const body = {
+        transformToString: sinon.stub().resolves(JSON.stringify(validCustomerConfig)),
+      };
+      s3Client.send.resolves({ Body: body });
+
+      await readCustomerConfigV2(organizationId, s3Client, {
+        s3Bucket: 'custom-org-bucket',
+      });
+
+      const command = s3Client.send.firstCall.args[0];
+      expect(command.input.Bucket).equals('custom-org-bucket');
+    });
+
+    it('returns null when the config does not exist (NoSuchKey)', async () => {
+      const error = new Error('Missing key');
+      error.name = 'NoSuchKey';
+      s3Client.send.rejects(error);
+
+      const result = await readCustomerConfigV2(organizationId, s3Client);
+
+      expect(result).to.be.null;
+    });
+
+    it('returns null when the config does not exist (NotFound)', async () => {
+      const error = new Error('Not found');
+      error.name = 'NotFound';
+      s3Client.send.rejects(error);
+
+      const result = await readCustomerConfigV2(organizationId, s3Client);
+
+      expect(result).to.be.null;
+    });
+
+    it('re-throws unexpected S3 errors', async () => {
+      s3Client.send.rejects(new Error('S3 Service Error'));
+
+      await expect(readCustomerConfigV2(organizationId, s3Client)).rejectedWith('S3 Service Error');
+    });
+
+    it('throws when the S3 object body is missing', async () => {
+      s3Client.send.resolves({});
+
+      await expect(readCustomerConfigV2(organizationId, s3Client)).rejectedWith('Customer config V2 body is empty');
+    });
+
+    it('throws when the S3 object body cannot be parsed as JSON', async () => {
+      const body = {
+        transformToString: sinon.stub().resolves('invalid json content'),
+      };
+      s3Client.send.resolves({ Body: body });
+
+      await expect(readCustomerConfigV2(organizationId, s3Client)).rejectedWith(SyntaxError);
+    });
+  });
+
+  describe('writeCustomerConfigV2', () => {
+    const organizationId = 'test-org-789';
+    const customerConfig = { settings: { feature2: false }, limits: { maxProjects: 50 } };
+
+    it('writes the customer config to the default S3 bucket', async () => {
+      s3Client.send.resolves({});
+
+      await writeCustomerConfigV2(organizationId, customerConfig, s3Client);
+
+      expect(s3Client.send).calledOnce;
+      const command = s3Client.send.firstCall.args[0];
+      expect(command).instanceOf(PutObjectCommand);
+      expect(command.input.Bucket).equals('default-test-bucket');
+      expect(command.input.Key).equals('customer-config-v2/test-org-789/config.json');
+      expect(command.input.Body).equals(JSON.stringify(customerConfig, null, 2));
+      expect(command.input.ContentType).equals('application/json');
+    });
+
+    it('writes the customer config to a provided bucket', async () => {
+      s3Client.send.resolves({});
+
+      await writeCustomerConfigV2(organizationId, customerConfig, s3Client, { s3Bucket: 'custom-org-bucket' });
+
+      const command = s3Client.send.firstCall.args[0];
+      expect(command.input.Bucket).equals('custom-org-bucket');
+    });
+  });
 });