update docs

README.md

@@ -54,6 +54,7 @@ Options:
   --port <int>                         The process will listen on this port for any HTTP and Prometheus metrics requests (default: 9102, env: PORT)
   --metrics-labels [string...]         To apply generic labels to all default metrics (ex: --labels foo=bar) (default: {}, env: METRICS_LABELS)
   --collect-default-metrics <boolean>  Collect default metrics (default: false, env: COLLECT_DEFAULT_METRICS)
+  --headers [string...]                Set headers that will be sent on every requests (ex: --headers X-HEADER=headerA) (default: [], env: HEADERS)
   --verbose                            Enable verbose logging (default: false, env: VERBOSE)
   -h, --help                           display help for command
 ```
@@ -62,18 +63,19 @@ Options:
 
 ```js
 import pkg from "./package.json" assert { type: "json" };
-import { commander, setup, prometheus, http } from "substreams-sink";
+import { commander, setup, prometheus, http, logger } from "substreams-sink";
 
 // Setup CLI using Commander
 const program = commander.program(pkg);
 const command = commander.run(program, pkg);
+logger.setName(pkg.name);
 
 // Custom Prometheus Counters
 const customCounter = prometheus.registerCounter("custom_counter");
 
 command.action(async (options: commander.RunOptions) => {
   // Setup sink for Block Emitter
-  const {emitter} = await setup(options, pkg);
+  const {emitter} = await setup(options);
 
   // Stream Blocks
   emitter.on("anyMessage", (message, cursor, clock) => {
@@ -87,6 +89,8 @@ command.action(async (options: commander.RunOptions) => {
   http.listen(options);
 
   // Start streaming
-  emitter.start();
+  await emitter.start();
+  http.server.close();
 })
+program.parse();
 ```