- "use strict";
- var path = require("path");
- var express = require("express");
- var bodyParser = require("body-parser");
- var cors = require("cors");
- var fs = require("fs");
- var CronJob = require("cron").CronJob;
- var xmlparser = require('express-xml-bodyparser');
- var cluster = require("cluster")
- var os = require("os")
- global.appRoot = path.resolve(__dirname);
- global.ipAdd = [];
- var logger = require("./helpers/logger");
- var config = require("./helpers/contours/config");
- var utils = require("./helpers/assists/utils");
- const grafana = require("./grafana");
- //swagger
- const swaggerUi = require('swagger-ui-express');
- const swaggerSpec = require('./gates/Swagger/swaggerDoc'); // Path to your swagger.js file
- const specs = require('./');
- const { worker } = require("shortid");
- var app = express();
- var corsOptions = {
- credentials: true,
- };
- // guests - client apps connected to this service bridge sockets
- global.guests = [];
- // Initialize HTTPS server
- var options = {
- key: fs.readFileSync("./stuffs/store/niyogin_in.key"),
- cert: fs.readFileSync("./stuffs/store/niyogin_in.pem"),
- ca: fs.readFileSync("./stuffs/store/ca_niyogin_in.pem"),
- };
- var http;
- var isHTTPS = config.gateways.server.https;
- var numOfCpus = os.cpus().length;
- logger.info('Number of cpu are ', numOfCpus);
- if (cluster.isMaster) {
- logger.info(`Primary process ${process.pid} is running`);
- for (let i = 0; i < numOfCpus; i++) {
- cluster.fork();
- }
- cluster.on('exit', (worker, code, signal) => {
- logger.info(`worker ${process.pid} died`);
- })
- } else {
- if (isHTTPS) http = require("https").createServer(options, app);
- else http = require("http").Server(app);
- http.listen(config.gateways.server.port, function () {
- logger.info("Opening the Gates" + (isHTTPS ? " securely" : "") + " with '" + config.env + "' settings...");
- console.log("Opening the Gates" + (isHTTPS ? " securely" : "") + " with '" + config.env + "' settings...");
- console.log("Initialization Done. Gates open on %s port.", config.gateways.server.port);
- });
- http.timeout = 0;
- logger.info(`worker ${process.pid} started`)
- }
- // Initialize socket io
- var io =
- require("socket.io")(http);
- require("./gates/plugs")(io);
- //require('./gatekeepers/ckyc').readExcel(null);
- // Make socket io available to all the routers
- app.use(cors(corsOptions), function (req, res, next) {
- req.io = io;
- next();
- });
- app.use((req, res, next) => {
- let allowedMethods = ["GET", "PUT", "POST", "OPTIONS"];
- if (!allowedMethods.includes(req.method)) {
- res.status(405).send({ error: "Method not allowed" });
- return;
- }
- next();
- });
- // Grafana
- // Old Code
- // const collectDefaultMetrics = client.collectDefaultMetrics;
- // collectDefaultMetrics({ register: client.register });
- // const reqResTime = new client.Histogram({
- // name: "http_express_req_res_time",
- // help: "Gives details on request response time",
- // labelNames: ["method", "route", "status_code"],
- // buckets: [1, 50, 100, 200, 400, 500, 800, 1000, 2000]
- // });
- // const totalReqCounter = new client.Counter({
- // name: "total_req",
- // help: "Gives total requests"
- // });
- // const ublEvents = new client.Gauge({
- // name: "ublEvents",
- // help: "For ubl events from partnerships",
- // labelNames: ["event", "status_code"],
- // });
- // app.use(responseTime((req, res, time) => {
- // totalReqCounter.inc();
- // if (req && req.body && req.body.event) {
- // let eventType = req.body.event;
- // let statusType = res.statusCode || 500;
- // ublEvents.set({ event: eventType, status_code: statusType }, time);
- // }
- // else {
- // reqResTime.labels({
- // method: req.method,
- // route: req.url,
- // status_code: res.statusCode
- // }).observe(time);
- // }
- // }));
- // app.get('/metrics', async (req, res) => {
- // res.setHeader('Content-Type', client.register.contentType);
- // const metrics = await client.register.metrics();
- // res.send(metrics);
- // });
- //app.use(bodyParser.json());
- //app.use(bodyParser.urlencoded({ extended: true }));
- app.use(bodyParser.json({ limit: "50mb" }));
- app.use(bodyParser.urlencoded({ extended: true, limit: "50mb" }));
- app.use(express.json());
- app.use(xmlparser());
- grafana(app);
- // 3 gates - sweeps, sails and sways
- app.use(config.gateways.gates.root + config.gateways.gates.version + config.gateways.gates.sweeps.root, require("./gates/sweeps"));
- app.use(config.gateways.gates.root + config.gateways.gates.version2 + config.gateways.gates.sweeps.root, require("./gates/sweeps2"));
- app.use(config.gateways.gates.root + config.gateways.gates.version + config.gateways.gates.sails.root, require("./gates/sails"));
- app.use(config.gateways.gates.root + config.gateways.gates.version2 + config.gateways.gates.sails.root, require("./gates/sails2"));
- app.use(config.gateways.gates.root + config.gateways.gates.version + config.gateways.gates.sways.root, require("./gates/sways"));
- // Expose store static location over HTTPS, if required.
- app.use(config.gateways.gates.root + config.gateways.gates.store, express.static(path.join(__dirname, config.constants.storeLocation)));
- // Serve Swagger UI with custom CSS
- app.use('/api-docs', swaggerUi.serve, swaggerUi.setup(swaggerSpec, {
- customCssUrl: '/swagger-ui.css', // URL path to your custom CSS file
- }));
- // Serve the logo image
- app.get('/logo.png', (req, res) => {
- res.sendFile(path.join(__dirname, 'gates', 'Swagger', 'Niyogin_Logo_Blue.png'));
- });
- app.get('/swagger-ui.css', (req, res) => {
- res.sendFile(path.join(__dirname, 'gates', 'Swagger', 'swagger-ui.css')); // Adjust the path to your CSS file accordingly
- });
- //app.use('/api-docs', swaggerUi.serve, swaggerUi.setup(swaggerSpec, { customCss: '.swagger-ui .topbar { background-color: #1e90ff; }' }));
- // app.use('/api-docs', swaggerUi.serve, swaggerUi.setup(swaggerSpec, { security: [{ basicAuth: [] }] }));//FOR UI BLOCK
- new CronJob('0 6 * * * ', function () {
- require('./cron').AubankTokens()
- }, null, true, 'Asia/Kolkata');
- // new CronJob('*/5 * * * * *', function() {
- // require('./cron').odsDataToIDD()
- // }, null, true, 'America/Los_Angeles');
- new CronJob('25 13 * * *', function () {
- require('./cron').pendingNotifications()
- }, null, true, 'Asia/Kolkata')
- // new CronJob('0 * * * * *', function() {
- // require('./cron').customerDataToCRM()
- // }, null, true, 'America/Los_Angeles');
- // new CronJob('1 1 1 * * *', function() {
- // require('./cron').customerAccCreationInCRM()
- // }, null, true, 'America/Los_Angeles');
- // new CronJob('1 6 2 * * *', function() {
- // require('./cron').partnerAccCreationInCRM()
- // }, null, true, 'America/Los_Angeles');
- // new CronJob('1 10 2 * * *', function() {
- // require('./cron').loanAccCreationInCRM()
- // }, null, true, 'America/Los_Angeles');
- // require('./cron').udaanCustomerOnboarding()
- // new CronJob('0 59 * * * *', function () {
- // require('./cron').udaanCustomerOnboarding()
- // }, null, true, 'America/Los_Angeles');
- //require('./gatekeepers/iserveu').bulkPartnerOnboard({ phone: ["8718812502", "9830354542"] })
- // require("./cron").reportLOA();
- //new CronJob(
- // "0 05 6 * * *",
- // function () {
- // require("./cron").customerCoAppAccCreationInCRM();
- // },
- // null,
- // true,
- // "Asia/Kolkata"
- //);
- //new CronJob(
- // "0 0 6 * * *",
- // function () {
- // require("./cron").uploadSettlementData();
- // },
- // null,
- // true,
- // "Asia/Kolkata"
- //);
- //new CronJob(
- // "0 10 6 * * *",
- // function () {
- // require("./cron").uploadSettlementDataPayU();
- // },
- // null,
- // true,
- // "Asia/Kolkata"
- //);
- //new CronJob(
- // "0 15 6 * * *",
- // function () {
- // require("./cron").setSSLCertificate();
- // },
- // null,
- // true,
- // "Asia/Kolkata"
- //);
- //new CronJob(
- // "0 20 6 * * *",
- // function () {
- // require("./cron").uploadSettlementDataOfICICI();
- // },
- // null,
- // true,
- // "Asia/Kolkata"
- //);
- //new CronJob(
- // "0 25 6 * * *",
- // function () {
- // require("./cron").uploadDomainResellerTransactions();
- // },
- // null,
- // true,
- // "Asia/Kolkata"
- //);
- //new CronJob(
- // "0 0 7 * * *",
- // function () {
- // require("./cron").sendDomainResellerMails();
- // require("./cron").sendShiprocketBalanceMails();
- // },
- // null,
- // true,
- // "Asia/Kolkata"
- //);
- //new CronJob(
- // "0 0 14 * * *",
- // function () {
- // require("./cron").sendDomainResellerMails();
- // require("./cron").sendShiprocketBalanceMails();
- // },
- // null,
- // true,
- // "Asia/Kolkata"
- //);
- //new CronJob(
- // "0 0 20 * * *",
- // function () {
- // require("./cron").sendDomainResellerMails();
- // require("./cron").sendShiprocketBalanceMails();
- // },
- // null,
- // true,
- // "Asia/Kolkata"
- //);
- // require("./gatekeepers/udaan").index();
- // require("./gatekeepers/udaan").loanRepaymentMain();
- // require(`./gatekeepers/cibilService`).storeCibilReport();
- //require(`./gatekeepers/ckyc`).getLegalCustData("2");
- // require(`./gatekeepers/ckyc`).getLegalCustData("4");
- // require(`./gatekeepers/ckyc`).getLegalCustData("5");
- // require(`./gatekeepers/ckyc`).getLegalCustData("7");
- // require(`./gatekeepers/ckyc`).getLegalCustData("3");
- //require(`./gatekeepers/ckyc`).getCustomerData();
- // new CronJob(
- // "0 */4 * * *",
- // function () {
- // logger.info("Running CRON for CKYC");
- // require(`./gatekeepers/ckyc`).getLegalCustData();
- // },
- // null,
- // true,
- // "Asia/Kolkata"
- // );
- new CronJob(
- "00 01 * * *",
- function () {
- logger.info("Starting loadAllLeadsNew")
- console.log("Starting loadAllLeadsNew")
- logger.info("Triggered daily LSQ DATA loader");
- // require("./cron").loadAllLeads();
- require("./cron").loadAllLeadsNew()
- console.log("Completed daily LSQ DATA loader")
- logger.info("Daily LSQ loader succeeded.");
- },
- null,
- true,
- "Asia/Kolkata"
- );
- // require("./cron").loadAllLeadsNew()
- // new CronJob(
- // "0 6 * * *",
- // function () {
- // logger.info("Running CRON for Capital Trust");
- // require("./cron").getCapitalTrustReport();
- // },
- // null,
- // true,
- // "Asia/Kolkata"
- // );
- // new CronJob(
- // "30 6 * * *",
- // function () {
- // logger.info("Running CRON for Capital Trust");
- // require("./cron").getLOSReport();
- // },
- // null,
- // true,
- // "Asia/Kolkata"
- // );
- // new CronJob(
- // "0 20 * * *",
- // function () {
- // logger.info("Running CRON for Citi Bank Disbursements");
- // require("./gatekeepers/citiBank").citiManualDisbursement();
- // },
- // null,
- // true,
- // "Asia/Kolkata"
- // );
- module.exports = app;
[text] kela
Viewer
*** This page was generated with the meta tag "noindex, nofollow". This happened because you selected this option before saving or the system detected it as spam. This means that this page will never get into the search engines and the search bot will not crawl it. There is nothing to worry about, you can still share it with anyone.
Editor
You can edit this paste and save as new:
File Description
- kela
- Paste Code
- 19 Apr-2024
- 11 Kb
You can Share it:
Latest Code Pastes