Adjust @configu/ts - ConfiguConfigStore for the Approval Queue fe…

…ature (#344)

ts/packages/browser/src/index.ts

@@ -1,4 +1,9 @@
-export { NoopConfigStore, InMemoryConfigStore, ConfiguConfigStore } from '@configu/ts';
+export {
+  NoopConfigStore,
+  InMemoryConfigStore,
+  ConfiguConfigStore,
+  ConfiguConfigStoreApprovalQueueError,
+} from '@configu/ts';
 
 export * from './stores/LocalForage';
 

ts/packages/node/src/index.ts

@@ -1,4 +1,9 @@
-export { NoopConfigStore, InMemoryConfigStore, ConfiguConfigStore } from '@configu/ts';
+export {
+  NoopConfigStore,
+  InMemoryConfigStore,
+  ConfiguConfigStore,
+  ConfiguConfigStoreApprovalQueueError,
+} from '@configu/ts';
 
 export * from './stores/JsonFile';
 export * from './stores/IniFile';

ts/packages/ts/src/stores/Configu.ts

@@ -9,6 +9,17 @@ export type ConfiguConfigStoreConfiguration = {
   source?: string;
 };
 
+export class ConfiguConfigStoreApprovalQueueError extends Error {
+  readonly queueUrl: string;
+  constructor(protectedSet: string, queueUrl: string) {
+    super(
+      `Your recent upsert to the ${protectedSet} ConfigSet is currently pending in its approval queue, as ${protectedSet} is a "protected set". To proceed with these changes, please review and approve them at ${queueUrl}. If you lack the necessary permissions, reach out to an authorized org member.`,
+    );
+    this.queueUrl = queueUrl;
+    this.name = 'ConfiguConfigStoreApprovalQueueError';
+  }
+}
+
 export class ConfiguConfigStore extends ConfigStore {
   private client: Axios;
   constructor({ credentials, endpoint = `https://api.configu.com`, source = 'sdk' }: ConfiguConfigStoreConfiguration) {
@@ -36,6 +47,11 @@ export class ConfiguConfigStore extends ConfigStore {
   }
 
   async set(configs: Config[]): Promise<void> {
-    await this.client.put('/config', { configs });
+    const response = await this.client.put('/config', { configs });
+    if (response.status === 202) {
+      const protectedSet = response.data.diff.pending[0].set;
+      const queueUrl = `${response.data.queueUrl}?set=${protectedSet}`;
+      throw new ConfiguConfigStoreApprovalQueueError(protectedSet, queueUrl);
+    }
   }
 }