cli list aggregators

Author: ponachte

cli/README.md

@@ -112,6 +112,14 @@ agg register-user                 # register and add aggregator to config
 agg register-user --set-active    # also set it as the active aggregator
 ```
 
+#### `list`
+
+List all registered aggregators.
+
+```bash
+agg list
+```
+
 #### `agg set-active <id>`
 
 Set the active aggregator by its ID.

cli/src/cli.ts

@@ -21,6 +21,15 @@ program
     await main({ setActive: opts.setActive });
   });
 
+program
+  .command("list")
+  .description("List all available aggregators")
+  .action(() => {
+    console.log("List of available aggregators:");
+    for (const agg of Object.keys(config.aggregators))
+      console.log(`\t-> ${agg}`);
+  });
+
 program
   .command("set-active <id>")
   .description("Set the active aggregator")
@@ -113,7 +122,7 @@ program
   .command("reset")
   .description("Remove all aggregators and unset the active aggregator")
   .action(() => {
-    updateConfig({ aggregators: {}, activeAggregator: null });
+    updateConfig({ aggregators: {}, activeAggregator: null }, ["aggregators"]);
     console.log("✅ All aggregators removed and active aggregator unset.");
   });
 

cli/src/config.ts

@@ -11,24 +11,38 @@ if (existsSync(CONFIG_PATH)) {
 
 export const config: Config = deepMerge(defaults, userConfig) as Config;
 
-function deepMerge(target: any, source: any): any {
+function deepMerge(target: any, source: any, replaceKeys: string[] = []) {
   const result = { ...target };
+
   for (const key of Object.keys(source ?? {})) {
-    if (source[key] && typeof source[key] === "object" && !Array.isArray(source[key])) {
-      result[key] = deepMerge(target[key] ?? {}, source[key]);
-    } else {
+    if (replaceKeys.includes(key)) {
       result[key] = source[key];
+      continue;
+    }
+
+    const sourceVal = source[key];
+
+    if (
+      sourceVal &&
+      typeof sourceVal === "object" &&
+      !Array.isArray(sourceVal)
+    ) {
+      result[key] = deepMerge(target[key] ?? {}, sourceVal, replaceKeys);
+    } else {
+      result[key] = sourceVal;
     }
   }
+
   return result;
 }
 
-export function updateConfig(updates: any) {
+
+export function updateConfig(updates: any, replaceKeys: string[] = []) {
   const current = existsSync(CONFIG_PATH)
     ? JSON.parse(readFileSync(CONFIG_PATH, "utf-8"))
     : {};
 
-  const merged = deepMerge(current, updates);
+  const merged = deepMerge(current, updates, replaceKeys);
 
   writeFileSync(CONFIG_PATH, JSON.stringify(merged, null, 2));
 }