by default observe all known feeds

src/cli.ts

@@ -51,19 +51,18 @@ cli.command("oracle").action(async (name) => {
   feeder.start()
 })
 
-cli.command("observe <name>").action(async (name) => {
+cli.command("observe").action(async (name?: string) => {
   let deploy = loadJSONFile<AggregatorDeployFile>(process.env.DEPLOY_FILE!)
 
-  const aggregatorInfo = deploy.aggregators[name]
-  if (!aggregatorInfo) {
-    throw new Error(`Cannot find aggregator: ${name}`)
-  }
+  for (let [name, aggregatorInfo] of Object.entries(deploy.aggregators)) {
     const observer = new AggregatorObserver(aggregatorInfo.pubkey, conn)
 
     let agg = await Aggregator.load(aggregatorInfo.pubkey)
 
+    log.debug("observe aggregator", { name })
+
     function printAnswer(answer: Answer) {
-    console.log({
+      log.info("update", {
         description: aggregatorInfo.config.description,
         decimals: aggregatorInfo.config.decimals,
         roundID: answer.roundID.toString(),
@@ -73,10 +72,15 @@ cli.command("observe <name>").action(async (name) => {
       })
     }
 
+    async function go() {
       printAnswer(agg.answer)
       for await (let answer of observer.answers()) {
         printAnswer(answer)
       }
+    }
+
+    go()
+  }
 })
 
 cli.parse(process.argv)