Split to a Grafana Service

.devcontainer/devcontainer.json

@@ -18,5 +18,13 @@
 	"mounts": [
 		"source=${localWorkspaceFolderBasename}-node_modules,target=${containerWorkspaceFolder}/node_modules,type=volume"
 	],
-	"postCreateCommand": "sudo chown node node_modules"
+	"postCreateCommand": "sudo chown node node_modules",
+	"customizations": {
+		"vscode": {
+			"extensions": [
+				"esbenp.prettier-vscode",
+				"GitHub.copilot"
+			]
+		}
+	}
 }

.husky/pre-commit

@@ -1,4 +1,4 @@
 #!/bin/sh
 . "$(dirname "$0")/_/husky.sh"
 
-npm test
+npm test -- --forbid-only --forbid-pending

.husky/pre-push

@@ -1,4 +1,4 @@
 #!/bin/sh
 . "$(dirname "$0")/_/husky.sh"
 
-npm test
+npm test -- --forbid-only --forbid-pending

package.json

@@ -1,7 +1,7 @@
 {
   "name": "hubot-grafana",
   "description": "Query Grafana dashboards",
-  "version": "5.1.2",
+  "version": "6.0.0",
   "author": "Stephen Yeargin <[email protected]>",
   "license": "MIT",
   "keywords": [
@@ -39,7 +39,7 @@
   },
   "main": "index.js",
   "scripts": {
-    "test": "mocha \"test/**/*.js\" --reporter spec",
+    "test": "mocha \"test/**/*.js\" --reporter spec --no-experiemental-fetch --timeout 200",
     "test-with-coverage": "nyc --reporter=text mocha \"test/**/*.js\" --reporter spec",
     "bootstrap": "script/bootstrap",
     "prepare": "husky install",
@@ -49,7 +49,8 @@
     "src/**/*.js",
     "CONTRIBUTING.md",
     "LICENSE",
-    "index.js"
+    "index.js",
+    "types.d.ts"
   ],
   "volta": {
     "node": "18.19.0"

src/Bot.js

@@ -0,0 +1,101 @@
+const { Adapter } = require('./adapters/Adapter');
+const { GrafanaService } = require('./service/GrafanaService');
+const { GrafanaClient } = require('./grafana-client');
+
+/**
+ * The bot brings the Adapter and the Grafana Service together.
+ * It can be used for uploading charts and sending responses out.
+ */
+class Bot {
+  /**
+   * Represents the Bot class.
+   * @constructor
+   * @param {Hubot.Robot} robot - The robot instance.
+   */
+  constructor(robot) {
+    /** @type {Adapter} */
+    this.adapter = new Adapter(robot);
+
+    /** @type {Hubot.Log} */
+    this.logger = robot.logger;
+  }
+
+  /**
+   * Creates a new Grafana service based on the provided message.
+   * @param {Hubot.Response} context - The context object.
+   * @returns {GrafanaService|null} - The created Grafana service or null if the client is not available.
+   */
+  createService(context) {
+
+    const robot = context.robot;
+    let host = process.env.HUBOT_GRAFANA_HOST;
+    let apiKey = process.env.HUBOT_GRAFANA_API_KEY;
+
+    if (process.env.HUBOT_GRAFANA_PER_ROOM === '1') {
+      const room = this.getRoom(context);
+      host = robot.brain.get(`grafana_host_${room}`);
+      apiKey = robot.brain.get(`grafana_api_key_${room}`);
+    }
+
+    if (host == null) {
+      this.sendError('No Grafana endpoint configured.', context);
+      return null;
+    }
+
+    let client = new GrafanaClient(robot.http, robot.logger, host, apiKey);
+    return new GrafanaService(client);
+  }
+
+  /**
+   * Sends a dashboard chart.
+   *
+   * @param {Hubot.Response} context - The context object.
+   * @param {DashboardChart} dashboard - The dashboard object.
+   * @returns {Promise<void>} - A promise that resolves when the chart is sent.
+   */
+  async sendDashboardChart(context, dashboard) {
+    if (!this.adapter.isUploadSupported()) {
+      this.adapter.responder.send(context, dashboard.title, dashboard.imageUrl, dashboard.grafanaChartLink);
+      return;
+    }
+
+    const service = this.createService(context);
+    if (service == null) return;
+
+    /** @type {DownloadedFile|null} */
+    let file = null;
+
+    try {
+      file = await service.client.download(dashboard.imageUrl);
+    } catch (err) {
+      this.sendError(err, context);
+      return;
+    }
+
+    this.logger.debug(`Uploading file: ${file.body.length} bytes, content-type[${file.contentType}]`);
+    this.adapter.uploader.upload(context, dashboard.title || 'Image', file, dashboard.grafanaChartLink);
+  }
+
+  /**
+   * *Sends an error message.
+   * @param {string} message the error message.
+   * @param {Hubot.Response} context The context.
+   */
+  sendError(message, context) {
+    context.robot.logger.error(message);
+    context.send(message);
+  }
+
+  /**
+   * Gets the room from the context.
+   * @param {Hubot.Response} context The context.
+   * @returns {string}
+   */
+  getRoom(context) {
+    // placeholder for further adapter support (i.e. MS Teams) as then room also
+    // contains thread conversation id
+    return context.envelope.room;
+  }
+}
+
+exports.Bot = Bot;

src/adapters/Adapter.js

@@ -11,6 +11,13 @@ const { RocketChatUploader } = require('./implementations/RocketChatUploader');
 const { TelegramUploader } = require('./implementations/TelegramUploader');
 const { SlackUploader } = require('./implementations/SlackUploader');
 
+/**
+ * The override responder is used to override the default responder.
+ * This can be used to inject a custom responder to influence the message formatting.
+ * @type {Responder|null}
+ */
+let overrideResponder = null;
+
 /**
  * The Adapter will hide away platform specific details for file upload and
  * response messages. When an S3 bucket is configured, it will always take
@@ -53,6 +60,11 @@ class Adapter {
    */
   /** @type {Responder} */
   get responder() {
+
+    if(overrideResponder){
+      return overrideResponder;
+    }
+
     if (/slack/i.test(this.robot.adapterName)) {
       return new SlackResponder();
     }
@@ -66,7 +78,7 @@ class Adapter {
     return new Responder();
   }
 
-   /**
+  /**
    * The responder is responsible for doing a (platform specific) upload.
    * If an upload is not supported, the method will throw an error.
    */
@@ -80,7 +92,7 @@ class Adapter {
       case 'slack':
         return new SlackUploader(this.robot, this.robot.logger);
       case 'telegram':
-        return new TelegramUploader()
+        return new TelegramUploader();
     }
 
     throw new Error(`Upload not supported for '${this.robot.adapterName}'`);
@@ -95,4 +107,19 @@ class Adapter {
   }
 }
 
+/**
+ * Overrides the responder.
+ * @param {Responder} responder The responder to use.
+ */
+exports.setResponder = function(responder) {
+  overrideResponder = responder;
+}
+
+/**
+ * Clears the override responder.
+ */
+exports.clearResponder = function() {
+  overrideResponder = null;
+}
+
 exports.Adapter = Adapter;