otf-frontend/server/src/agenda/agenda.js

   1 /*  Copyright (c) 2019 AT&T Intellectual Property.                             #\r
   2 #                                                                              #\r
   3 #   Licensed under the Apache License, Version 2.0 (the "License");            #\r
   4 #   you may not use this file except in compliance with the License.           #\r
   5 #   You may obtain a copy of the License at                                    #\r
   6 #                                                                              #\r
   7 #       http://www.apache.org/licenses/LICENSE-2.0                             #\r
   8 #                                                                              #\r
   9 #   Unless required by applicable law or agreed to in writing, software        #\r
  10 #   distributed under the License is distributed on an "AS IS" BASIS,          #\r
  11 #   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   #\r
  12 #   See the License for the specific language governing permissions and        #\r
  13 #   limitations under the License.                                             #\r
  14 ##############################################################################*/\r
  15 \r
  16 \r
  17 const logger = require('../lib/logger');\r
  18 const Agenda = require('agenda');\r
  19 const mongoData = require('config').mongo;\r
  20 const jobTypes = ['test-execution-job'];\r
  21 const agenda = new Agenda({\r
  22         db: {\r
  23                 address: mongoData.connectionString,\r
  24                 collection: 'agenda'\r
  25         },\r
  26         sort: {\r
  27                 nextRunAt: 1\r
  28         }\r
  29 });\r
  30 \r
  31 module.exports = {\r
  32         agenda: agenda,\r
  33         initializeAgenda: function () {\r
  34                 // Load all job types\r
  35                 jobTypes.forEach(type => {\r
  36                         require('./jobs/' + type)(agenda);\r
  37                 });\r
  38 \r
  39                 // Wait for the db connection to be established before starting agenda (sync).\r
  40                 agenda.on('ready', function () {\r
  41                         logger.debug('Agenda successfully established a connection to MongoDB.');\r
  42                         agenda.start();\r
  43                         // agenda.processEvery('0.001 seconds');\r
  44                 });\r
  45 \r
  46                 async function graceful () {\r
  47                         await agenda.stop();\r
  48                         process.exit(0);\r
  49                 }\r
  50 \r
  51                 process.on('SIGTERM', graceful);\r
  52                 process.on('SIGINT', graceful);\r
  53         }\r
  54 };\r