-
Notifications
You must be signed in to change notification settings - Fork 4
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
New Materialized View about JobSuccess (#80)
* new materialized view jobSuccess * fix about last materialized view * v1 generateJobs * seeds test ok * generateJobs v2 * build needed * sequelize close * adjustement * builded * change about date format Materialized View * index added to job table * fix [skip ci] * Materialized View jobSuccess updated to jobStatsByDay [skip ci] * coalesce materialized view [skip ci] * incoherence retryJob with jobStatus * build needed * fix * test updated + new pubsub link for retryJob [skip ci] * first changes about new worker structure * New ping/pong additionnal subscriptions * fundation workerUpdate * workerUpdate on * workerMonitor works with DB * getNewClient updated to welcome subscription * Ping ok now return workers status + type added * package.json ok * Model jobSuccessRating added --------- Co-authored-by: janfi <janfi@users.noreply.github.com>
- Loading branch information
Showing
54 changed files
with
4,102 additions
and
2,533 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,17 @@ | ||
| { | ||
| "development": { | ||
| "dialect": "sqlite", | ||
| "storage": "data/main.db", | ||
| "logging": false | ||
| }, | ||
| "production": { | ||
| "dialect": "sqlite", | ||
| "storage": "data/main.db", | ||
| "logging": false | ||
| }, | ||
| "test": { | ||
| "dialect": "sqlite", | ||
| "storage": ":memory:", | ||
| "logging": false | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,10 @@ | ||
| "use strict"; | ||
| exports.__esModule = true; | ||
| exports.jobSuccessRating = void 0; | ||
| function jobSuccessRating(models) { | ||
| return { | ||
| model: models.jobSuccessRating, | ||
| actions: ['list', 'count'] | ||
| }; | ||
| } | ||
| exports.jobSuccessRating = jobSuccessRating; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,14 +1,31 @@ | ||
| "use strict"; | ||
| exports.__esModule = true; | ||
| function WorkerMonitoringConfiguration(types, models) { | ||
| exports.workerMonitoring = void 0; | ||
| var pinged_1 = require("./workerMonitoring/subscriptions/pinged"); | ||
| var ponged_1 = require("./workerMonitoring/subscriptions/ponged"); | ||
| var ping_1 = require("./workerMonitoring/mutations/ping"); | ||
| var pong_1 = require("./workerMonitoring/mutations/pong"); | ||
| var workerMonitoringUpdated_1 = require("./workerMonitoring/subscriptions/workerMonitoringUpdated"); | ||
| var workerMonitorUpdate_1 = require("./workerMonitoring/mutations/workerMonitorUpdate"); | ||
| function workerMonitoring(models, pubSubInstance) { | ||
| return { | ||
| model: models.workerMonitoring, | ||
| actions: ['list'], | ||
| list: { | ||
| before: function (findOptions) { | ||
| return findOptions; | ||
| } | ||
| }, | ||
| additionalMutations: { | ||
| ping: (0, ping_1.ping)(pubSubInstance), | ||
| pong: (0, pong_1.pong)(pubSubInstance), | ||
| workerMonitoringUpdate: (0, workerMonitorUpdate_1.workerMonitorUpdate)(pubSubInstance, models) | ||
| }, | ||
| additionalSubscriptions: { | ||
| pinged: (0, pinged_1.pinged)(pubSubInstance), | ||
| ponged: (0, ponged_1.ponged)(pubSubInstance), | ||
| workerMonitoringUpdated: (0, workerMonitoringUpdated_1.workerMonitorUpdated)(pubSubInstance) | ||
| } | ||
| }; | ||
| } | ||
| exports["default"] = WorkerMonitoringConfiguration; | ||
| exports.workerMonitoring = workerMonitoring; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,62 @@ | ||
| "use strict"; | ||
| var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
| function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); } | ||
| return new (P || (P = Promise))(function (resolve, reject) { | ||
| function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } } | ||
| function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } } | ||
| function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); } | ||
| step((generator = generator.apply(thisArg, _arguments || [])).next()); | ||
| }); | ||
| }; | ||
| var __generator = (this && this.__generator) || function (thisArg, body) { | ||
| var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g; | ||
| return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g; | ||
| function verb(n) { return function (v) { return step([n, v]); }; } | ||
| function step(op) { | ||
| if (f) throw new TypeError("Generator is already executing."); | ||
| while (g && (g = 0, op[0] && (_ = 0)), _) try { | ||
| if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t; | ||
| if (y = 0, t) op = [op[0] & 2, t.value]; | ||
| switch (op[0]) { | ||
| case 0: case 1: t = op; break; | ||
| case 4: _.label++; return { value: op[1], done: false }; | ||
| case 5: _.label++; y = op[1]; op = [0]; continue; | ||
| case 7: op = _.ops.pop(); _.trys.pop(); continue; | ||
| default: | ||
| if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; } | ||
| if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; } | ||
| if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; } | ||
| if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; } | ||
| if (t[2]) _.ops.pop(); | ||
| _.trys.pop(); continue; | ||
| } | ||
| op = body.call(thisArg, _); | ||
| } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; } | ||
| if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true }; | ||
| } | ||
| }; | ||
| exports.__esModule = true; | ||
| exports.ping = void 0; | ||
| var type_1 = require("../type"); | ||
| function ping(pubSubInstance) { | ||
| var _this = this; | ||
| return { | ||
| type: type_1.successType, | ||
| description: 'Ping the server.', | ||
| args: {}, | ||
| resolve: function () { return __awaiter(_this, void 0, void 0, function () { | ||
| return __generator(this, function (_a) { | ||
| try { | ||
| pubSubInstance.publish('Pinged', { success: true }); | ||
| return [2 /*return*/, { success: true }]; | ||
| } | ||
| catch (error) { | ||
| console.error('Une erreur est survenue lors du ping:', error); | ||
| return [2 /*return*/, { success: false }]; | ||
| } | ||
| return [2 /*return*/]; | ||
| }); | ||
| }); } | ||
| }; | ||
| } | ||
| exports.ping = ping; |
Oops, something went wrong.