Compare commits
1 Commits
develop
...
01c234782e
Author | SHA1 | Date | |
---|---|---|---|
01c234782e |
14
src/index.ts
14
src/index.ts
@ -59,7 +59,7 @@ async function initSonar() {
|
||||
}
|
||||
`
|
||||
);
|
||||
logger.info(`Authenticated to Sonar as '${user.me.name}'`);
|
||||
logger.info(`Authenticated to Sonar as '${user.me.name}'.`);
|
||||
return sonar;
|
||||
}
|
||||
|
||||
@ -88,11 +88,11 @@ async function initRingCentralSDK() {
|
||||
platform.on(platform.events.refreshError, async (err) => {
|
||||
logger.error("Refresh token error:", err);
|
||||
await login();
|
||||
logger.info("RingCentral re-authentication successful");
|
||||
logger.info("RingCentral re-authentication successful.");
|
||||
});
|
||||
|
||||
await login();
|
||||
logger.info("Authenticated to RingCentral");
|
||||
logger.info("Authenticated to RingCentral.");
|
||||
|
||||
return sdk;
|
||||
}
|
||||
@ -101,7 +101,7 @@ async function initDB() {
|
||||
const db = knex(knexConfig);
|
||||
if (!process.env.DB_SKIP_MIGRATIONS) {
|
||||
await db.migrate.latest();
|
||||
logger.info("Database migrations run successfully");
|
||||
logger.info("Database migrations run successfully.");
|
||||
}
|
||||
return db;
|
||||
}
|
||||
@ -114,13 +114,12 @@ async function main() {
|
||||
const rcsdk = await initRingCentralSDK();
|
||||
const db = await initDB();
|
||||
|
||||
logger.info("Starting");
|
||||
|
||||
logger.info("Starting ticketizer...");
|
||||
const intervals = ticketize(sonar, rcsdk, db, getTicketizeConfig());
|
||||
|
||||
["SIGINT", "SIGTERM", "SIGQUIT"].forEach((sig) => {
|
||||
process.on(sig, async () => {
|
||||
logger.info(`Caught ${sig}, shutting down...`);
|
||||
logger.info(`\nCaught ${sig}, shutting down...`);
|
||||
const results = await Promise.allSettled(
|
||||
intervals.map((interval) => interval.clear())
|
||||
);
|
||||
@ -131,7 +130,6 @@ async function main() {
|
||||
logger.error(result.reason);
|
||||
}
|
||||
});
|
||||
await rcsdk.logout();
|
||||
process.exit(errors ? 1 : 0);
|
||||
});
|
||||
});
|
||||
|
@ -340,7 +340,7 @@ export function ticketize(
|
||||
* @param firstRun whether this is the first run
|
||||
*/
|
||||
async function fetchAndStoreNewVoicemails(firstRun = false) {
|
||||
logger.verbose("Checking for new voicemails");
|
||||
logger.info("Checking for new voicemails");
|
||||
const extensions = await getValidRCExtensions();
|
||||
return Promise.all(
|
||||
extensions.map((extension) =>
|
||||
|
11
src/util.ts
11
src/util.ts
@ -1,17 +1,10 @@
|
||||
import PhoneNumber from "awesome-phonenumber";
|
||||
import winston, { format } from "winston";
|
||||
import winston from "winston";
|
||||
|
||||
export const DEBUG = !!process.env.DEBUG;
|
||||
export const logger = winston.createLogger({
|
||||
level: DEBUG ? "debug" : process.env.LOG_LEVEL ?? "info",
|
||||
transports: [new winston.transports.Console()],
|
||||
format: format.combine(
|
||||
format.errors({ stack: true }),
|
||||
format.printf(
|
||||
({ level, message, stack }) =>
|
||||
`${level}: ${message}${stack ? "\n" + stack : ""}`
|
||||
)
|
||||
),
|
||||
transports: [new winston.transports.()],
|
||||
});
|
||||
|
||||
export function getNationalNumber(input: string) {
|
||||
|
Reference in New Issue
Block a user