init commit config based is done REST endpoints to come

Author: Phara0h

.gitignore

@@ -0,0 +1,2 @@
+package-lock.json
+node_modules

README.nbs

@@ -0,0 +1,41 @@
+# Fasquest
+A fast node request model, works very similar to `request` module but way faster and no dependencies + it works in the browser!
+
+### Install
+```
+npm install fasquest
+```
+
+### Basic Node Example
+```js
+const Fasquest = require('fasquest');
+
+var options = {
+  uri: 'http://127.0.0.1/',
+  resolveWithFullResponse: true
+}
+
+Fasquest.request(options).then(res=>{
+  console.log('hey look I got a response')
+})
+
+
+```
+
+### Basic Web Example
+```js
+import Fasquest from "fasquest";
+var options = {
+  uri: 'http://127.0.0.1/',
+  resolveWithFullResponse: true
+}
+
+await Fasquest.request(options);
+
+
+```
+
+
+## Changelog
+
+{{doc1}}

changelog-template.hbs

@@ -0,0 +1,30 @@
+### Changelog
+
+All notable changes to this project will be documented in this file. Dates are displayed in UTC.
+
+{{#each releases}}
+  {{#if href}}
+    ###{{#unless major}}#{{/unless}} [{{title}}]({{href}})
+  {{else}}
+    #### {{title}}
+  {{/if}}
+
+  {{#if tag}}
+    > {{niceDate}}
+  {{/if}}
+
+  {{#if summary}}
+    {{summary}}
+  {{/if}}
+
+  {{#each merges}}
+    - {{{message}}}{{#if href}} [`#{{id}}`]({{href}}){{/if}}
+  {{/each}}
+  {{#each fixes}}
+    - {{{commit.subject}}}{{#each fixes}}{{#if href}} [`#{{id}}`]({{href}}){{/if}}{{/each}}
+  {{/each}}
+  {{#each commits}}
+    - {{#if breaking}}**Breaking change:** {{/if}}{{{subject}}}{{#if href}} [`{{shorthash}}`]({{href}}){{/if}}
+  {{/each}}
+
+{{/each}}

package.json

@@ -0,0 +1,39 @@
+{
+  "name": "sky-puppy",
+  "version": "0.1.0",
+  "description": "A easy to use reliable health checking service with Prometheus export",
+  "main": "./src/index.js",
+  "scripts": {
+    "start": "node src/index.js",
+    "test": "SKY_PUPPY_CONFIG_PATH=./test node src/index.js",
+    "version": "auto-changelog -l false --sort-commits date-desc --package --hide-credit --template changelog-template.hbs -p && mdsquash -i  CHANGELOG.md && git add -A CHANGELOG.md && git add -A README.md",
+    "postversion": "git push &&  git push --tags && npm publish"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/Phara0h/sky-puppy.git"
+  },
+  "keywords": [
+    "prometheus",
+    "health",
+    "check",
+    "request",
+    "service"
+  ],
+  "author": "Phara0h",
+  "license": "GPL-3.0-or-later",
+  "bugs": {
+    "url": "https://github.com/Phara0h/sky-puppy/issues"
+  },
+  "homepage": "https://github.com/Phara0h/sky-puppy#readme",
+  "dependencies": {
+    "auto-changelog": "^2.2.0",
+    "fasquest": "^2.4.0",
+    "fastify": "^2.15.3",
+    "jsdoc-to-markdown": "^6.0.1",
+    "mdsquash": "^1.0.5",
+    "nbars": "^1.0.1",
+    "nstats": "^2.1.5",
+    "postgen": "^4.1.5"
+  }
+}

src/alerts.js

@@ -0,0 +1,141 @@
+const fs = require('fs');
+var fasquest = require('fasquest');
+const client = {
+  https: require('https'),
+  http: require('http'),
+};
+fasquest.agent = {
+  http: new client.http.Agent({
+    keepAlive: false
+  }),
+  https: new client.https.Agent({
+    keepAlive: false
+  })
+};
+class Alerts {
+  constructor(stats,config,nbars) {
+
+    this.nbars = nbars;
+    this.alerters = {}
+    this.alerts_status = {}
+    this.alerts = {
+      down: {},
+      healthy: {},
+      unhealthy: {},
+      unhealthy_status: {},
+      unhealthy_response_time: {}
+    }
+    this.stats = stats;
+    this.config = config;
+
+    var alertersKeys = Object.keys(this.config.alerters);
+
+    for (var i = 0; i < alertersKeys.length; i++) {
+      this.addAlerter(alertersKeys[i],{...this.config.getAlerter(alertersKeys[i])});
+    }
+
+  }
+
+  addAlerter(name,alerter) {
+    if(!this.config.getAlerter(name)) {
+      this.config.addAlerter(name,alerter);
+    }
+
+    var nAlerter = {
+      name,
+      request: {
+        ...alerter
+      }
+    }
+
+    nAlerter.request.method = nAlerter.request.method || 'GET';
+    nAlerter.request.timeout = Math.round((nAlerter.request.timeout || 60)*1000);
+    nAlerter.request.resolveWithFullResponse = true;
+    nAlerter.request.simple = false;
+
+
+    if(!nAlerter.request.headers) {
+      nAlerter.request.headers = {};
+    }
+    nAlerter.request.headers['User-Agent'] = `Sky-Puppy / ${this.config.skypuppy.version} (Health Check Service)`
+
+    this.alerters[name] = nAlerter;
+  }
+
+  async _checkStatus(alert,service,type) {
+    if(service.status.up === type) {
+
+      if(this.alerts_status[service.name] != null && this.alerts_status[service.name] === type) {
+        return;
+      }
+      // check if status has changed
+      if(!this.alerts[alert.type][service.name]) {
+        this.alerts[alert.type][service.name] = {status:{...service.status,count: {...service.status.count}}}
+        this.alerts[alert.type][service.name].status.count[alert.type]--;
+      }
+
+      if((service.status.count[alert.type] - this.alerts[alert.type][service.name].status.count[alert.type]) >= (alert.for || 1) && !this.alerts[alert.type][service.name].alerted) {
+        this.alerts[alert.type][service.name].alerted = true;
+        await this._send_alert(alert,service);
+          return;
+      }
+
+    } else {
+      this.alerts[alert.type][service.name] = null;
+    }
+  }
+
+
+
+  async alert(service) {
+    if(service.config.alerts) {
+      for (var i = 0; i < service.config.alerts.length; i++) {
+        switch(service.config.alerts[i].type) {
+          case "down":
+          await this._checkStatus(service.config.alerts[i],service,-1);
+          break;
+          case "unhealthy":
+          case "unhealthy_status":
+          case "unhealthy_response_time":
+          await this._checkStatus(service.config.alerts[i],service,0);
+          break;
+          case "healthy":
+          await this._checkStatus(service.config.alerts[i],service,1);
+          break;
+        }
+      }
+    }
+  }
+
+  async _send_alert(alert,service) {
+    var overrides = alert.overrides || {};
+    var request = {...this.alerters[alert.alerter].request, ...overrides}
+      if(request.body) {
+      request.body = this.nbars.transform(
+        request.json ? JSON.stringify(request.body) : request.body,
+        {
+          alert_type: alert.type,
+          service_name: service.name,
+          timestamp: new Date().toISOString() ,
+          last_unhealthy_total_duration: service.status.last_unhealthy_total_duration || 'Unknown',
+          last_healthy_total_duration:  service.status.last_healthy ? (Number(process.hrtime.bigint() - service.status.last_healthy) / 1000000000).toFixed(2) : 'Unknown'
+        }
+      )
+
+      if(request.json) {
+        request.body = JSON.parse(request.body)
+      }
+    }
+    //console.log(request.body)
+    this.alerts_status[service.name] = service.status.up
+
+    try {
+      await fasquest.request(JSON.parse(JSON.stringify(request)));
+    } catch (e) {
+      console.log(e)
+    }
+
+  }
+
+}
+module.exports = Alerts;

src/config.js

@@ -0,0 +1,74 @@
+const fs = require('fs');
+var path = require('path');
+class Config {
+  constructor(config) {
+    this.version = require(path.dirname(require.main.filename)+'/../package.json').version;
+    try {
+      this.path = path.resolve(process.env.SKY_PUPPY_CONFIG_PATH || './') + '/sky-puppy-config.json';
+      this.settings = JSON.parse(fs.readFileSync(this.path));
+    } catch (e) {
+      this.path = path.dirname('./') + '/sky-puppy-config.json';
+      this.settings = {};
+      console.log('Error loading config. Creating and using default one at ' + this.path);
+      this.saveConfig();
+    }
+    if(!this.alerters) {
+      this.settings.alerters = {};
+    }
+
+    if(!this.services) {
+      this.settings.services = {};
+    }
+
+    this.settings.skypuppy = this.settings.skypuppy || {
+      version: this.version
+    }
+  }
+
+  addService(name,service) {
+    try {
+      this.services[name] = service;
+      this.saveConfig();
+      return this.services[name];
+    } catch (e) {
+      return null;
+    }
+  }
+
+  addAlerter(name,service) {
+    try {
+      this.alerters[name] = service;
+      this.saveConfig();
+      return this.alerters[name];
+    } catch (e) {
+      return null;
+    }
+  }
+
+  getService(name) {
+    return this.services[name];
+  }
+  getAlerter(name) {
+    return this.alerters[name];
+  }
+
+  get services() {
+    return this.settings.services;
+  }
+
+  get alerters() {
+    return this.settings.alerters;
+  }
+
+  get skypuppy() {
+    return this.settings.skypuppy;
+  }
+
+
+
+  saveConfig() {
+    console.log('Saving Config');
+    fs.writeFileSync(this.path, JSON.stringify(this.settings, null, 4));
+  }
+}
+module.exports = Config;