Some metrics

index.js

@@ -1,6 +1,7 @@
 import express from "express";
 import expressPromiseRouter from "express-promise-router";
 import config from "exp-config";
+import assert from "assert";
 
 import { init } from "./lib/recipe-repo.js";
 import buildLogger from "./lib/logger.js";
@@ -17,6 +18,9 @@ export function route(key, fn) {
 }
 
 export function start({ recipes, triggers, startServer = true }) {
+
+  assert(config.appName, "appName must be set in config");
+
   const router = expressPromiseRouter();
   const app = express();
   app.use(express.json());

lib/message-handler.js

@@ -5,6 +5,7 @@ import publishMessage, { rejectMessage } from "./publish-message.js";
 import resumeMessage from "./resume-message.js";
 import buildContext from "./context.js";
 import jobStorage from "./job-storage/index.js";
+import metrics from "./metrics.js";
 
 const maxResumeCount = config.maxResumeCount || 10;
 
@@ -40,6 +41,9 @@ export default async function messageHandler(recipeMap, req, res) {
     logger.error(`Got message without key ${messageId}`);
     return res.status(400).send();
   }
+
+  metrics.messages.inc();
+
   logger.info(`incoming message ${JSON.stringify(messageData)}`);
   const parts = key.split(".");
   const suffix = parts.pop();
@@ -89,6 +93,7 @@ export default async function messageHandler(recipeMap, req, res) {
     try {
       const result = await unrecoverableHandler(message, context);
       const data = appendData(message.data, result);
+      metrics.unrecoverableMessages.inc();
       await publishMessage({ ...message, data }, { key: `${key}.processed`, correlationId, parentCorrelationId });
     } catch (err) {
       return res.status(500).send();
@@ -109,6 +114,7 @@ export default async function messageHandler(recipeMap, req, res) {
         // TODO: should we delete the job that was stored here
       }
     }
+    metrics.processedSequences.inc();
     return res.status(200).send();
   }
 
@@ -163,10 +169,12 @@ export default async function messageHandler(recipeMap, req, res) {
     if (error.rejected) {
       logger.error(`Rejected message with correlationId: ${correlationId}. Error: ${error}. Message: ${message}`);
       await rejectMessage({ ...message, error: { message: error.extraMessage } }, { key });
+      metrics.rejectedMessages.inc();
       return res.status(200).send();
     }
     if (error.retry) {
       logger.info(`Retrying message ${messageId}`);
+      metrics.retriedMessages.inc();
       return res.status(400).send();
     }
     if (error.unrecoverable) {

lib/metrics.js

@@ -0,0 +1,36 @@
+import config from "exp-config";
+import { pushClient, cloudRunResourceProvider } from "@bonniernews/gcp-push-metrics";
+
+import buildLogger from "./logger.js";
+
+const client = pushClient({ logger: buildLogger(), resourceProvider: cloudRunResourceProvider });
+const { appName } = config;
+
+const labels = {
+  bnNamespace: [],
+  appName: [],
+  path: [],
+};
+
+export default {
+  messages: client.counter({
+    name: `lu_${appName}_messages`,
+    ...labels,
+  }),
+  rejectedMessages: client.counter({
+    name: `lu_${appName}_rejected`,
+    ...labels,
+  }),
+  retriedMessages: client.counter({
+    name: `lu_${appName}_retried`,
+    ...labels,
+  }),
+  unrecoverableMessages: client.counter({
+    name: `lu_${appName}_unrecoverable`,
+    ...labels,
+  }),
+  processedSequences: client.counter({
+    name: `lu_${appName}_processed`,
+    ...labels,
+  }),
+};

package.json

@@ -34,7 +34,8 @@
     "google-auth-library": "^8.7.0",
     "joi": "^17.7.0",
     "pino": "^8.7.0",
-    "uuid": "^9.0.0"
+    "uuid": "^9.0.0",
+    "@bonniernews/gcp-push-metrics": "^3.1.0"
   },
   "devDependencies": {
     "@bonniernews/lu-test": "^4.0.0",
@@ -57,6 +58,9 @@
     "lib": "lib",
     "test": "test"
   },
+  "overrides": {
+    "google-gax@<3.6.1": "^3.6.1"
+  },
   "keywords": [
     "pubsub"
   ],