mario/ts-gateway-send-wa
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

formatted and remove response.json

Browse Source
This commit is contained in:
mario
2025-07-06 13:57:40 +07:00
parent 1ae1fd8f8a
commit 438370143a
11 changed files with 10989 additions and 1690 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
.prettierrc Normal file
View File

@@ -0,0 +1,11 @@
{
"semi": true,
"trailingComma": "es5",
"singleQuote": false,
"printWidth": 80,
"tabWidth": 4,
"useTabs": false,
"bracketSpacing": true,
"arrowParens": "avoid",
"endOfLine": "lf"
}

16
config-gw-wa.json
View File

@@ -1,10 +1,8 @@
{ {
"base_url": "https://devluar.aplikasi.web.id/one-api/", "base_url": "https://devcpone.aplikasi.web.id/one-api/",
"schedule": [ "schedule": ["*/2 6-20 * * *"],
"*/2 6-20 * * *" "delay": 5,
], "row_per_batch": 50,
"delay": 5, "startDate": "2023-08-01",
"row_per_batch": 50, "endDate": "2025-12-30"
"startDate": "2023-08-01", }
"endDate": "2025-12-30"
}

9180
dist/gw-wa.js vendored
View File

File diff suppressed because one or more lines are too long

2470
package-lock.json generated
View File

File diff suppressed because it is too large Load Diff

66
package.json
View File

@@ -1,33 +1,35 @@
{ {
"name": "one_send_wa", "name": "one_send_wa",
"version": "1.0.0", "version": "1.0.0",
"description": "", "description": "",
"main": "index.js", "main": "index.js",
"scripts": { "scripts": {
"build": "rimraf build/ && prettier --write source/ && tsc", "build": "rimraf build/ && prettier --write source/ && tsc",
"compile": "cross-env NODE_OPTIONS=--openssl-legacy-provider ncc build build/server.js -m -o dist && move dist\\index.js dist\\gw-wa.js", "format": "prettier --write \"**/*.{ts,js,json}\"",
"start": "node ./dist/gw-wa.js", "format:check": "prettier --check \"**/*.{ts,js,json}\"",
"bcs": "rimraf build/ && prettier --write source/ && tsc && cross-env NODE_OPTIONS=--openssl-legacy-provider ncc build build/server.js -m -o dist && move dist\\index.js dist\\gw-wa.js && node ./dist/gw-wa.js" "compile": "cross-env NODE_OPTIONS=--openssl-legacy-provider ncc build build/server.js -m -o dist && move dist\\index.js dist\\gw-wa.js",
}, "start": "node ./dist/gw-wa.js",
"keywords": [], "bcs": "rimraf build/ && prettier --write source/ && tsc && cross-env NODE_OPTIONS=--openssl-legacy-provider ncc build build/server.js -m -o dist && move dist\\index.js dist\\gw-wa.js && node ./dist/gw-wa.js"
"author": "", },
"license": "ISC", "keywords": [],
"devDependencies": { "author": "",
"@types/dateformat": "^3.0.1", "license": "ISC",
"@types/node-cron": "^3.0.1", "devDependencies": {
"@vercel/ncc": "^0.30.0", "@types/dateformat": "^3.0.1",
"cross-env": "^7.0.3", "@types/node-cron": "^3.0.1",
"nodemon": "^2.0.12", "@vercel/ncc": "^0.30.0",
"prettier": "^2.3.2", "cross-env": "^7.0.3",
"rimraf": "^6.0.1", "nodemon": "^2.0.12",
"ts-node": "^10.2.1", "prettier": "^2.3.2",
"typescript": "^4.4.2" "rimraf": "^6.0.1",
}, "ts-node": "^10.2.1",
"dependencies": { "typescript": "^4.4.2"
"axios": "^0.21.1", },
"axios-curlirize": "^2.0.0", "dependencies": {
"moment": "^2.29.1", "axios": "^0.21.1",
"moment-timezone": "^0.5.34", "axios-curlirize": "^2.0.0",
"node-cron": "^3.0.0" "moment": "^2.29.1",
} "moment-timezone": "^0.5.34",
} "node-cron": "^3.0.0"
}
}

1
response.json
View File

@@ -1 +0,0 @@
{"entry":[{"response":{"etag":"W/\"MTY0NTYxODMxNjU3MzI4MjAwMA\"","lastModified":"2022-02-23T12:11:56.573282+00:00","location":"https://fhir-poc.dto.kemkes.go.id/Ser viceRequest/0f67eb15-5889-420b-9544-dd47544facf0/_history/MTY0NTYxODMxNjU3MzI4MjAwMA","status":"201 Created"}},{"response":{"etag":"W/\"MTY0NTYxODMxNjU3MzI4MjAwMA\" ","lastModified":"2022-02-23T12:11:56.573282+00:00","location":"https://fhir-poc.dto.kemkes.go.id/Specimen/4f0873b5-c8eb-459a-a88f-53bc663c9f5b/_history/MTY0NTYxODM xNjU3MzI4MjAwMA","status":"201 Created"}},{"response":{"etag":"W/\"MTY0NTYxODMxNjU3MzI4MjAwMA\"","lastModified":"2022-02-23T12:11:56.573282+00:00","location":"https ://fhir-poc.dto.kemkes.go.id/Observation/e2f0c4e2-85f8-4b76-9e0f-b37db55174e8/_history/MTY0NTYxODMxNjU3MzI4MjAwMA","status":"201 Created"}},{"response":{"etag":"W/\ "MTY0NTYxODMxNjU3MzI4MjAwMA\"","lastModified":"2022-02-23T12:11:56.573282+00:00","location":"https://fhir-poc.dto.kemkes.go.id/DiagnosticReport/1d18ca84-926f-428a-a be5-d10fe67dcee3/_history/MTY0NTYxODMxNjU3MzI4MjAwMA","status":"201 Created"}}],"resourceType":"Bundle","type":"transaction-response"}

24
source/config/config.ts
View File

@@ -1,21 +1,21 @@
import { readFileSync } from "fs"; import { readFileSync } from "fs";
interface IConfig { interface IConfig {
base_url: string; base_url: string;
schedule: string[]; schedule: string[];
delay: number; delay: number;
row_per_batch: number; row_per_batch: number;
startDate: string; startDate: string;
endDate: string; endDate: string;
} }
const j_config = JSON.parse(readFileSync("./config-gw-wa.json").toString()); const j_config = JSON.parse(readFileSync("./config-gw-wa.json").toString());
const config: IConfig = { const config: IConfig = {
base_url: j_config["base_url"], base_url: j_config["base_url"],
schedule: j_config["schedule"], schedule: j_config["schedule"],
delay: j_config["delay"], delay: j_config["delay"],
row_per_batch: j_config["row_per_batch"], row_per_batch: j_config["row_per_batch"],
startDate: j_config["startDate"], startDate: j_config["startDate"],
endDate: j_config["endDate"], endDate: j_config["endDate"],
}; };
export default config; export default config;

64
source/config/logging.ts
View File

@@ -1,48 +1,50 @@
import moment from "moment"; import moment from "moment";
const getTimeStamp = (): string => { const getTimeStamp = (): string => {
const dt = moment().format("yyyy-MM-DD HH:mm:ss"); const dt = moment().format("yyyy-MM-DD HH:mm:ss");
return dt; return dt;
}; };
const info = (namespace: string, message: string, object?: any) => { const info = (namespace: string, message: string, object?: any) => {
if (object) { if (object) {
console.log( console.log(
`[${getTimeStamp()}] [INFO] [${namespace}] [${message}]`, `[${getTimeStamp()}] [INFO] [${namespace}] [${message}]`,
object object
); );
} else { } else {
console.log(`[${getTimeStamp()}] [INFO] [${namespace}] [${message}]`); console.log(`[${getTimeStamp()}] [INFO] [${namespace}] [${message}]`);
} }
}; };
const warning = (namespace: string, message: string, object?: any) => { const warning = (namespace: string, message: string, object?: any) => {
if (object) { if (object) {
console.log( console.log(
`[${getTimeStamp()}] [WARNING] [${namespace}] [${message}]`, `[${getTimeStamp()}] [WARNING] [${namespace}] [${message}]`,
object object
); );
} else { } else {
console.log(`[${getTimeStamp()}] [WARNING] [${namespace}] [${message}]`); console.log(
} `[${getTimeStamp()}] [WARNING] [${namespace}] [${message}]`
);
}
}; };
const error = (namespace: string, message: string, object?: any) => { const error = (namespace: string, message: string, object?: any) => {
if (object) { if (object) {
console.log( console.log(
`[${getTimeStamp()}] [ERROR] [${namespace}] [${message}]`, `[${getTimeStamp()}] [ERROR] [${namespace}] [${message}]`,
object object
); );
} else { } else {
console.log(`[${getTimeStamp()}] [ERROR] [${namespace}] [${message}]`); console.log(`[${getTimeStamp()}] [ERROR] [${namespace}] [${message}]`);
} }
}; };
const delay = (time: number) => new Promise((res) => setTimeout(res, time)); const delay = (time: number) => new Promise(res => setTimeout(res, time));
export default { export default {
info, info,
warning, warning,
error, error,
delay, delay,
}; };

208
source/lib-inject.ts
View File

@@ -4,131 +4,131 @@ import logging from "./config/logging";
import { NAME_SPACE } from "./server"; import { NAME_SPACE } from "./server";
export const getListOutbox = async ( export const getListOutbox = async (
statusOutbox: string, statusOutbox: string,
startDate: string, startDate: string,
endDate: string endDate: string
) => { ) => {
const url = config.base_url + "mockup/sendwa/sendwa/listoutbox"; const url = config.base_url + "mockup/sendwa/sendwa/listoutbox";
logging.info(NAME_SPACE, "\t INFO : " + url); logging.info(NAME_SPACE, "\t INFO : " + url);
logging.info(NAME_SPACE, "\t INFO Status Outbox: " + statusOutbox); logging.info(NAME_SPACE, "\t INFO Status Outbox: " + statusOutbox);
logging.info(NAME_SPACE, "\t INFO Start Date: " + startDate); logging.info(NAME_SPACE, "\t INFO Start Date: " + startDate);
logging.info(NAME_SPACE, "\t INFO End Date: " + endDate); logging.info(NAME_SPACE, "\t INFO End Date: " + endDate);
try { try {
const resp = await axios.post( const resp = await axios.post(
url, url,
{ {
statusOutbox: statusOutbox, statusOutbox: statusOutbox,
startDate: startDate, startDate: startDate,
endDate: endDate, endDate: endDate,
}, },
{ {
headers: { "Content-Type": "application/json; charset=UTF-8" }, headers: { "Content-Type": "application/json; charset=UTF-8" },
responseType: "text", responseType: "text",
} }
); );
const jresp = const jresp =
typeof resp.data === "string" ? JSON.parse(resp.data) : resp.data; typeof resp.data === "string" ? JSON.parse(resp.data) : resp.data;
return jresp; return jresp;
} catch (e) { } catch (e) {
if (axios.isAxiosError(e)) { if (axios.isAxiosError(e)) {
logging.error(NAME_SPACE, "Error di lib inject catch axios"); logging.error(NAME_SPACE, "Error di lib inject catch axios");
logging.error(NAME_SPACE, e.response?.data.toString()); logging.error(NAME_SPACE, e.response?.data.toString());
} else if (e instanceof Error) { } else if (e instanceof Error) {
logging.error(NAME_SPACE, "Error di instance of error"); logging.error(NAME_SPACE, "Error di instance of error");
logging.error(NAME_SPACE, e.message); logging.error(NAME_SPACE, e.message);
}
} }
}
}; };
export const sendToQontak = async (param: any) => { export const sendToQontak = async (param: any) => {
const url = config.base_url + "mockup/sendwa/sendwa/QontakSendMsg"; const url = config.base_url + "mockup/sendwa/sendwa/QontakSendMsg";
logging.info(NAME_SPACE, "\t INFO : " + url); logging.info(NAME_SPACE, "\t INFO : " + url);
logging.info(NAME_SPACE, "\t INFO Payload: " + JSON.stringify(param)); logging.info(NAME_SPACE, "\t INFO Payload: " + JSON.stringify(param));
try { try {
const resp = await axios.post(url, param, { const resp = await axios.post(url, param, {
headers: { "Content-Type": "application/json; charset=UTF-8" }, headers: { "Content-Type": "application/json; charset=UTF-8" },
responseType: "text", responseType: "text",
}); });
const statusResp = resp.data.status; const statusResp = resp.data.status;
logging.info( logging.info(
NAME_SPACE, NAME_SPACE,
"\t INFO Resp Qontak: " + JSON.stringify(statusResp) "\t INFO Resp Qontak: " + JSON.stringify(statusResp)
); );
if (statusResp != "OK") { if (statusResp != "OK") {
logging.error( logging.error(
NAME_SPACE, NAME_SPACE,
"\t Error Qontak: " + JSON.stringify(resp.data) "\t Error Qontak: " + JSON.stringify(resp.data)
); );
}
return statusResp;
} catch (e) {
if (axios.isAxiosError(e)) {
logging.error(NAME_SPACE, "Error di lib inject catch axios");
logging.error(NAME_SPACE, e.response?.data.toString());
} else if (e instanceof Error) {
logging.error(NAME_SPACE, "Error di instance of error");
logging.error(NAME_SPACE, e.message);
}
} }
return statusResp;
} catch (e) {
if (axios.isAxiosError(e)) {
logging.error(NAME_SPACE, "Error di lib inject catch axios");
logging.error(NAME_SPACE, e.response?.data.toString());
} else if (e instanceof Error) {
logging.error(NAME_SPACE, "Error di instance of error");
logging.error(NAME_SPACE, e.message);
}
}
}; };
export const uploadFileCdn = async (param: any) => { export const uploadFileCdn = async (param: any) => {
const url = config.base_url + "mockup/sendwa/sendwa/uploadfile"; const url = config.base_url + "mockup/sendwa/sendwa/uploadfile";
logging.info(NAME_SPACE, "\t INFO : " + url); logging.info(NAME_SPACE, "\t INFO : " + url);
logging.info(NAME_SPACE, "\t INFO Payload: " + JSON.stringify(param)); logging.info(NAME_SPACE, "\t INFO Payload: " + JSON.stringify(param));
try { try {
const resp = await axios.post(url, param, { const resp = await axios.post(url, param, {
headers: { "Content-Type": "application/json; charset=UTF-8" }, headers: { "Content-Type": "application/json; charset=UTF-8" },
responseType: "text", responseType: "text",
}); });
const statusResp = resp.data.status; const statusResp = resp.data.status;
logging.info( logging.info(
NAME_SPACE, NAME_SPACE,
"\t INFO Resp Upload: " + JSON.stringify(statusResp) "\t INFO Resp Upload: " + JSON.stringify(statusResp)
); );
return statusResp; return statusResp;
} catch (e) { } catch (e) {
if (axios.isAxiosError(e)) { if (axios.isAxiosError(e)) {
logging.error(NAME_SPACE, "Error di lib inject catch axios"); logging.error(NAME_SPACE, "Error di lib inject catch axios");
logging.error(NAME_SPACE, e.response?.data.toString()); logging.error(NAME_SPACE, e.response?.data.toString());
} else if (e instanceof Error) { } else if (e instanceof Error) {
logging.error(NAME_SPACE, "Error di instance of error"); logging.error(NAME_SPACE, "Error di instance of error");
logging.error(NAME_SPACE, e.message); logging.error(NAME_SPACE, e.message);
}
} }
}
}; };
export const changeStatusOutbox = async (param: any) => { export const changeStatusOutbox = async (param: any) => {
const url = config.base_url + "mockup/sendwa/sendwa/changeStatusOutbox"; const url = config.base_url + "mockup/sendwa/sendwa/changeStatusOutbox";
logging.info(NAME_SPACE, "\t INFO : " + url); logging.info(NAME_SPACE, "\t INFO : " + url);
logging.info(NAME_SPACE, "\t INFO Payload: " + JSON.stringify(param)); logging.info(NAME_SPACE, "\t INFO Payload: " + JSON.stringify(param));
try { try {
const resp = await axios.post(url, param, { const resp = await axios.post(url, param, {
headers: { "Content-Type": "application/json; charset=UTF-8" }, headers: { "Content-Type": "application/json; charset=UTF-8" },
responseType: "text", responseType: "text",
}); });
const statusResp = resp.data.status; const statusResp = resp.data.status;
logging.info( logging.info(
NAME_SPACE, NAME_SPACE,
"\t INFO Resp Change Status: " + JSON.stringify(statusResp) "\t INFO Resp Change Status: " + JSON.stringify(statusResp)
); );
return statusResp; return statusResp;
} catch (e) { } catch (e) {
if (axios.isAxiosError(e)) { if (axios.isAxiosError(e)) {
logging.error(NAME_SPACE, "Error di lib inject catch axios"); logging.error(NAME_SPACE, "Error di lib inject catch axios");
logging.error(NAME_SPACE, e.response?.data.toString()); logging.error(NAME_SPACE, e.response?.data.toString());
} else if (e instanceof Error) { } else if (e instanceof Error) {
logging.error(NAME_SPACE, "Error di instance of error"); logging.error(NAME_SPACE, "Error di instance of error");
logging.error(NAME_SPACE, e.message); logging.error(NAME_SPACE, e.message);
}
} }
}
}; };

457
source/server.ts
View File

@@ -3,277 +3,296 @@ import logging from "./config/logging";
import * as Xcron from "node-cron"; import * as Xcron from "node-cron";
import { import {
getListOutbox, getListOutbox,
sendToQontak, sendToQontak,
uploadFileCdn, uploadFileCdn,
changeStatusOutbox, changeStatusOutbox,
} from "./lib-inject"; } from "./lib-inject";
export const NAME_SPACE = "SENT RESULT VIA WA"; export const NAME_SPACE = "Gateway Send WA";
const VERSION = "1.0"; const VERSION = "1.1";
let isRunning = false; let isRunning = false;
logging.info(NAME_SPACE, "Starting. Ver:", `${VERSION}`); logging.info(NAME_SPACE, "Starting. Ver:", `${VERSION}`);
const on_init = async () => { const on_init = async () => {
logging.info( logging.info(
NAME_SPACE, NAME_SPACE,
"-------------------- ON INIT START --------------------" "-------------------- ON INIT START --------------------"
); );
await main("N"); await main("N");
await main("E"); await main("E");
await main("R"); await main("R");
logging.info( logging.info(
NAME_SPACE, NAME_SPACE,
"-------------------- ON INIT END --------------------" "-------------------- ON INIT END --------------------"
); );
}; };
on_init(); on_init();
async function main(status: string) { async function main(status: string) {
if (isRunning) { if (isRunning) {
logging.info(NAME_SPACE, "Process is running. Skip this run."); logging.info(NAME_SPACE, "Process is running. Skip this run.");
return; return;
} }
isRunning = true; isRunning = true;
try { try {
logging.info(NAME_SPACE, "Process is running. Start to get list outbox."); logging.info(
let outboxs = await getLists(status);
/* Pesan minta diproses kirim */
if (status == "N") {
logging.info(NAME_SPACE, "GET Processed (N) Message");
for (let i = 0; i < outboxs.length; i++) {
let outbox = outboxs[i];
// logging.info(NAME_SPACE, "\t Detail: ", outbox);
let retry = outbox.XWaOutboxIsRetry;
/* Jika fileUrl masih 0, maka panggil upload file */
if (outbox.fileUrl == null) {
let resp = uploadFile(outbox);
logging.info(NAME_SPACE, "\t Uploading File to CDN: ", resp);
logging.info(NAME_SPACE, "\t wait 2s \t");
await delay(2000);
if ((await resp) == "OK") {
logging.info(NAME_SPACE, "\t File Uploaded");
let response = sentMsg(outbox, status, retry);
logging.info(NAME_SPACE, "\t wait 4s \t");
await delay(4000);
logging.info(NAME_SPACE, "\t Resp Qontak: ", response);
} else {
// Change Status ke Error
changeStatus(outbox, "E", retry);
}
} else {
// Jika fileUrl sudah ada maka langsung kirim file
let response = sentMsg(outbox, status, retry);
logging.info(NAME_SPACE, "\t wait 4s \t");
await delay(4000);
logging.info(NAME_SPACE, "\t Resp Qontak: ", response);
}
}
} else if (status == "E") {
/* Pesan Eror < 5x retry */
logging.info(NAME_SPACE, "GET Error (E) Message");
for (let i = 0; i < outboxs.length; i++) {
let outbox = outboxs[i];
// logging.info(NAME_SPACE, "\t Detail: ", outbox);
let retry = outbox.XWaOutboxIsRetry;
if (retry >= 5) {
logging.info(
NAME_SPACE, NAME_SPACE,
"\t Retry count more than 5. Skip this message." "Process is running. Start to get list outbox."
); );
continue;
} else {
retry++;
if (outbox.fileUrl == null) { let outboxs = await getLists(status);
let resp = uploadFile(outbox);
logging.info(NAME_SPACE, "\t Uploading File to CDN: ", resp);
logging.info(NAME_SPACE, "\t wait 2s \t");
await delay(2000);
if ((await resp) == "OK") { /* Pesan minta diproses kirim */
logging.info(NAME_SPACE, "\t File Uploaded"); if (status == "N") {
logging.info(NAME_SPACE, "GET Processed (N) Message");
let response = sentMsg(outbox, status, retry); for (let i = 0; i < outboxs.length; i++) {
let outbox = outboxs[i];
// logging.info(NAME_SPACE, "\t Detail: ", outbox);
let retry = outbox.XWaOutboxIsRetry;
logging.info(NAME_SPACE, "\t wait 4s \t"); /* Jika fileUrl masih 0, maka panggil upload file */
await delay(4000); if (outbox.fileUrl == null) {
let resp = uploadFile(outbox);
logging.info(
NAME_SPACE,
"\t Uploading File to CDN: ",
resp
);
logging.info(NAME_SPACE, "\t wait 2s \t");
await delay(2000);
logging.info(NAME_SPACE, "\t Resp Qontak: ", response); if ((await resp) == "OK") {
} else { logging.info(NAME_SPACE, "\t File Uploaded");
changeStatus(outbox, "E", retry);
let response = sentMsg(outbox, status, retry);
logging.info(NAME_SPACE, "\t wait 4s \t");
await delay(4000);
logging.info(NAME_SPACE, "\t Resp Qontak: ", response);
} else {
// Change Status ke Error
changeStatus(outbox, "E", retry);
}
} else {
// Jika fileUrl sudah ada maka langsung kirim file
let response = sentMsg(outbox, status, retry);
logging.info(NAME_SPACE, "\t wait 4s \t");
await delay(4000);
logging.info(NAME_SPACE, "\t Resp Qontak: ", response);
}
}
} else if (status == "E") {
/* Pesan Eror < 5x retry */
logging.info(NAME_SPACE, "GET Error (E) Message");
for (let i = 0; i < outboxs.length; i++) {
let outbox = outboxs[i];
// logging.info(NAME_SPACE, "\t Detail: ", outbox);
let retry = outbox.XWaOutboxIsRetry;
if (retry >= 5) {
logging.info(
NAME_SPACE,
"\t Retry count more than 5. Skip this message."
);
continue;
} else {
retry++;
if (outbox.fileUrl == null) {
let resp = uploadFile(outbox);
logging.info(
NAME_SPACE,
"\t Uploading File to CDN: ",
resp
);
logging.info(NAME_SPACE, "\t wait 2s \t");
await delay(2000);
if ((await resp) == "OK") {
logging.info(NAME_SPACE, "\t File Uploaded");
let response = sentMsg(outbox, status, retry);
logging.info(NAME_SPACE, "\t wait 4s \t");
await delay(4000);
logging.info(
NAME_SPACE,
"\t Resp Qontak: ",
response
);
} else {
changeStatus(outbox, "E", retry);
}
} else {
let response = sentMsg(outbox, status, retry);
logging.info(NAME_SPACE, "\t wait 4s \t");
await delay(4000);
logging.info(NAME_SPACE, "\t Resp Qontak: ", response);
}
}
}
} else if (status == "R") {
logging.info(NAME_SPACE, "GET Rejected (R) Message");
for (let i = 0; i < outboxs.length; i++) {
let outbox = outboxs[i];
// logging.info(NAME_SPACE, "\t Detail: ", outbox);
let retry = outbox.XWaOutboxIsRetry;
/* Jika fileUrl masih 0, maka panggil upload file */
if (outbox.fileUrl == null) {
let resp = uploadFile(outbox);
logging.info(
NAME_SPACE,
"\t Uploading File to CDN: ",
resp
);
logging.info(NAME_SPACE, "\t wait 2s \t");
await delay(2000);
if ((await resp) == "OK") {
logging.info(NAME_SPACE, "\t File Uploaded");
let response = sentMsg(outbox, status, retry);
logging.info(NAME_SPACE, "\t wait 4s \t");
await delay(4000);
logging.info(NAME_SPACE, "\t Resp Qontak: ", response);
} else {
// Change Status ke Error
changeStatus(outbox, "E", retry);
}
} else {
// Jika fileUrl sudah ada maka langsung kirim file
let response = sentMsg(outbox, status, retry);
logging.info(NAME_SPACE, "\t wait 4s \t");
await delay(4000);
logging.info(NAME_SPACE, "\t Resp Qontak: ", response);
}
} }
} else {
let response = sentMsg(outbox, status, retry);
logging.info(NAME_SPACE, "\t wait 4s \t");
await delay(4000);
logging.info(NAME_SPACE, "\t Resp Qontak: ", response);
}
} }
}
} else if (status == "R") {
logging.info(NAME_SPACE, "GET Rejected (R) Message");
for (let i = 0; i < outboxs.length; i++) { logging.info(NAME_SPACE, "End Job Get Order");
let outbox = outboxs[i]; isRunning = false;
// logging.info(NAME_SPACE, "\t Detail: ", outbox); } catch (e) {
let retry = outbox.XWaOutboxIsRetry; isRunning = false;
if (e instanceof Error) {
/* Jika fileUrl masih 0, maka panggil upload file */ logging.error(NAME_SPACE, e.message);
if (outbox.fileUrl == null) {
let resp = uploadFile(outbox);
logging.info(NAME_SPACE, "\t Uploading File to CDN: ", resp);
logging.info(NAME_SPACE, "\t wait 2s \t");
await delay(2000);
if ((await resp) == "OK") {
logging.info(NAME_SPACE, "\t File Uploaded");
let response = sentMsg(outbox, status, retry);
logging.info(NAME_SPACE, "\t wait 4s \t");
await delay(4000);
logging.info(NAME_SPACE, "\t Resp Qontak: ", response);
} else {
// Change Status ke Error
changeStatus(outbox, "E", retry);
}
} else { } else {
// Jika fileUrl sudah ada maka langsung kirim file logging.error(NAME_SPACE, "Unknown");
let response = sentMsg(outbox, status, retry);
logging.info(NAME_SPACE, "\t wait 4s \t");
await delay(4000);
logging.info(NAME_SPACE, "\t Resp Qontak: ", response);
} }
}
} }
logging.info(NAME_SPACE, "End Job Get Order");
isRunning = false;
} catch (e) {
isRunning = false;
if (e instanceof Error) {
logging.error(NAME_SPACE, e.message);
} else {
logging.error(NAME_SPACE, "Unknown");
}
}
} }
async function getLists(status: string) { async function getLists(status: string) {
const statusOutbox = status; const statusOutbox = status;
// const statusOutbox = config.statusOutbox; // const statusOutbox = config.statusOutbox;
const startDate = config.startDate; const startDate = config.startDate;
const endDate = config.endDate; const endDate = config.endDate;
var resp = await getListOutbox(statusOutbox, startDate, endDate); var resp = await getListOutbox(statusOutbox, startDate, endDate);
if (resp["status"] != "OK") { if (resp["status"] != "OK") {
logging.error(NAME_SPACE, "\t Error get outbox data", resp); logging.error(NAME_SPACE, "\t Error get outbox data", resp);
logging.error(NAME_SPACE, "\t Error: ", resp); logging.error(NAME_SPACE, "\t Error: ", resp);
} else { } else {
logging.info( logging.info(
NAME_SPACE, NAME_SPACE,
"\t Success get order data found ", "\t Success get order data found ",
resp.data.length resp.data.length
); );
} }
const result = const result =
typeof resp.data === "string" ? JSON.parse(resp.data) : resp.data; typeof resp.data === "string" ? JSON.parse(resp.data) : resp.data;
return result; return result;
} }
async function sentMsg(item: any, status: string, retry: number) { async function sentMsg(item: any, status: string, retry: number) {
let payload = { let payload = {
orderID: item.orderID, orderID: item.orderID,
orderDate: item.orderDate, orderDate: item.orderDate,
patientDOB: item.patientDOB, patientDOB: item.patientDOB,
patientName: item.patientName, patientName: item.patientName,
patientHp: item.patientHp, patientHp: item.patientHp,
corpName: item.CorporateName, corpName: item.CorporateName,
fileName: item.fileName, fileName: item.fileName,
statusOutbox: status, statusOutbox: status,
retryOutbox: retry, retryOutbox: retry,
sendWaID: item.sendWaID, sendWaID: item.sendWaID,
}; };
// return payload; // return payload;
/* Axios for POST to the WA API */ /* Axios for POST to the WA API */
var response = await sendToQontak(payload); // Response "OK" var response = await sendToQontak(payload); // Response "OK"
return response; return response;
} }
async function uploadFile(item: any) { async function uploadFile(item: any) {
let payload = { let payload = {
fileName: item.fileName, fileName: item.fileName,
rptUrl: item.localUrl, rptUrl: item.localUrl,
mime: "application/pdf", mime: "application/pdf",
XWaOutboxID: item.sendWaID, XWaOutboxID: item.sendWaID,
}; };
// return payload; // return payload;
var response = await uploadFileCdn(payload); // Response "OK" var response = await uploadFileCdn(payload); // Response "OK"
return response; return response;
} }
async function changeStatus(item: any, status: string, retry: number) { async function changeStatus(item: any, status: string, retry: number) {
let payload = { let payload = {
toStatus: status, toStatus: status,
XWaOutboxID: item.sendWaID, XWaOutboxID: item.sendWaID,
retry: retry, retry: retry,
}; };
// return payload; // return payload;
var response = await changeStatusOutbox(payload); var response = await changeStatusOutbox(payload);
return response; return response;
} }
async function delay(ms: number) { async function delay(ms: number) {
return new Promise((resolve) => setTimeout(resolve, ms)); return new Promise(resolve => setTimeout(resolve, ms));
} }
function elseif(arg0: boolean) { function elseif(arg0: boolean) {
throw new Error("Function not implemented."); throw new Error("Function not implemented.");
} }
for (const sched of config.schedule) { for (const sched of config.schedule) {
Xcron.schedule( Xcron.schedule(
sched, sched,
async () => { async () => {
logging.info( logging.info(
NAME_SPACE, NAME_SPACE,
" -------------------- ON INIT SCHEDULE --------------------" " -------------------- ON INIT SCHEDULE --------------------"
); );
await main("N"); await main("N");
await main("E"); await main("E");
await main("R"); await main("R");
logging.info( logging.info(
NAME_SPACE, NAME_SPACE,
"-------------------- END SCHEDULE--------------------" "-------------------- END SCHEDULE--------------------"
); );
}, },
{ {
timezone: "Asia/Jakarta", timezone: "Asia/Jakarta",
} }
); );
} }

182
tsconfig.json
View File

@@ -1,101 +1,101 @@
{ {
"compilerOptions": { "compilerOptions": {
/* Visit https://aka.ms/tsconfig.json to read more about this file */ /* Visit https://aka.ms/tsconfig.json to read more about this file */
/* Projects */ /* Projects */
// "incremental": true, /* Enable incremental compilation */ // "incremental": true, /* Enable incremental compilation */
// "composite": true, /* Enable constraints that allow a TypeScript project to be used with project references. */ // "composite": true, /* Enable constraints that allow a TypeScript project to be used with project references. */
// "tsBuildInfoFile": "./", /* Specify the folder for .tsbuildinfo incremental compilation files. */ // "tsBuildInfoFile": "./", /* Specify the folder for .tsbuildinfo incremental compilation files. */
// "disableSourceOfProjectReferenceRedirect": true, /* Disable preferring source files instead of declaration files when referencing composite projects */ // "disableSourceOfProjectReferenceRedirect": true, /* Disable preferring source files instead of declaration files when referencing composite projects */
// "disableSolutionSearching": true, /* Opt a project out of multi-project reference checking when editing. */ // "disableSolutionSearching": true, /* Opt a project out of multi-project reference checking when editing. */
// "disableReferencedProjectLoad": true, /* Reduce the number of projects loaded automatically by TypeScript. */ // "disableReferencedProjectLoad": true, /* Reduce the number of projects loaded automatically by TypeScript. */
/* Language and Environment */ /* Language and Environment */
"target": "ESNext", /* Set the JavaScript language version for emitted JavaScript and include compatible library declarations. */ "target": "ESNext" /* Set the JavaScript language version for emitted JavaScript and include compatible library declarations. */,
// "lib": [], /* Specify a set of bundled library declaration files that describe the target runtime environment. */ // "lib": [], /* Specify a set of bundled library declaration files that describe the target runtime environment. */
// "jsx": "preserve", /* Specify what JSX code is generated. */ // "jsx": "preserve", /* Specify what JSX code is generated. */
// "experimentalDecorators": true, /* Enable experimental support for TC39 stage 2 draft decorators. */ // "experimentalDecorators": true, /* Enable experimental support for TC39 stage 2 draft decorators. */
// "emitDecoratorMetadata": true, /* Emit design-type metadata for decorated declarations in source files. */ // "emitDecoratorMetadata": true, /* Emit design-type metadata for decorated declarations in source files. */
// "jsxFactory": "", /* Specify the JSX factory function used when targeting React JSX emit, e.g. 'React.createElement' or 'h' */ // "jsxFactory": "", /* Specify the JSX factory function used when targeting React JSX emit, e.g. 'React.createElement' or 'h' */
// "jsxFragmentFactory": "", /* Specify the JSX Fragment reference used for fragments when targeting React JSX emit e.g. 'React.Fragment' or 'Fragment'. */ // "jsxFragmentFactory": "", /* Specify the JSX Fragment reference used for fragments when targeting React JSX emit e.g. 'React.Fragment' or 'Fragment'. */
// "jsxImportSource": "", /* Specify module specifier used to import the JSX factory functions when using `jsx: react-jsx*`.` */ // "jsxImportSource": "", /* Specify module specifier used to import the JSX factory functions when using `jsx: react-jsx*`.` */
// "reactNamespace": "", /* Specify the object invoked for `createElement`. This only applies when targeting `react` JSX emit. */ // "reactNamespace": "", /* Specify the object invoked for `createElement`. This only applies when targeting `react` JSX emit. */
// "noLib": true, /* Disable including any library files, including the default lib.d.ts. */ // "noLib": true, /* Disable including any library files, including the default lib.d.ts. */
// "useDefineForClassFields": true, /* Emit ECMAScript-standard-compliant class fields. */ // "useDefineForClassFields": true, /* Emit ECMAScript-standard-compliant class fields. */
/* Modules */ /* Modules */
"module": "commonjs", /* Specify what module code is generated. */ "module": "commonjs" /* Specify what module code is generated. */,
// "rootDir": "./", /* Specify the root folder within your source files. */ // "rootDir": "./", /* Specify the root folder within your source files. */
// "moduleResolution": "node", /* Specify how TypeScript looks up a file from a given module specifier. */ // "moduleResolution": "node", /* Specify how TypeScript looks up a file from a given module specifier. */
// "baseUrl": "./", /* Specify the base directory to resolve non-relative module names. */ // "baseUrl": "./", /* Specify the base directory to resolve non-relative module names. */
// "paths": {}, /* Specify a set of entries that re-map imports to additional lookup locations. */ // "paths": {}, /* Specify a set of entries that re-map imports to additional lookup locations. */
// "rootDirs": [], /* Allow multiple folders to be treated as one when resolving modules. */ // "rootDirs": [], /* Allow multiple folders to be treated as one when resolving modules. */
// "typeRoots": [], /* Specify multiple folders that act like `./node_modules/@types`. */ // "typeRoots": [], /* Specify multiple folders that act like `./node_modules/@types`. */
// "types": [], /* Specify type package names to be included without being referenced in a source file. */ // "types": [], /* Specify type package names to be included without being referenced in a source file. */
// "allowUmdGlobalAccess": true, /* Allow accessing UMD globals from modules. */ // "allowUmdGlobalAccess": true, /* Allow accessing UMD globals from modules. */
// "resolveJsonModule": true, /* Enable importing .json files */ // "resolveJsonModule": true, /* Enable importing .json files */
// "noResolve": true, /* Disallow `import`s, `require`s or `<reference>`s from expanding the number of files TypeScript should add to a project. */ // "noResolve": true, /* Disallow `import`s, `require`s or `<reference>`s from expanding the number of files TypeScript should add to a project. */
/* JavaScript Support */ /* JavaScript Support */
// "allowJs": true, /* Allow JavaScript files to be a part of your program. Use the `checkJS` option to get errors from these files. */ // "allowJs": true, /* Allow JavaScript files to be a part of your program. Use the `checkJS` option to get errors from these files. */
// "checkJs": true, /* Enable error reporting in type-checked JavaScript files. */ // "checkJs": true, /* Enable error reporting in type-checked JavaScript files. */
// "maxNodeModuleJsDepth": 1, /* Specify the maximum folder depth used for checking JavaScript files from `node_modules`. Only applicable with `allowJs`. */ // "maxNodeModuleJsDepth": 1, /* Specify the maximum folder depth used for checking JavaScript files from `node_modules`. Only applicable with `allowJs`. */
/* Emit */ /* Emit */
// "declaration": true, /* Generate .d.ts files from TypeScript and JavaScript files in your project. */ // "declaration": true, /* Generate .d.ts files from TypeScript and JavaScript files in your project. */
// "declarationMap": true, /* Create sourcemaps for d.ts files. */ // "declarationMap": true, /* Create sourcemaps for d.ts files. */
// "emitDeclarationOnly": true, /* Only output d.ts files and not JavaScript files. */ // "emitDeclarationOnly": true, /* Only output d.ts files and not JavaScript files. */
// "sourceMap": true, /* Create source map files for emitted JavaScript files. */ // "sourceMap": true, /* Create source map files for emitted JavaScript files. */
// "outFile": "./", /* Specify a file that bundles all outputs into one JavaScript file. If `declaration` is true, also designates a file that bundles all .d.ts output. */ // "outFile": "./", /* Specify a file that bundles all outputs into one JavaScript file. If `declaration` is true, also designates a file that bundles all .d.ts output. */
"outDir": "./build", /* Specify an output folder for all emitted files. */ "outDir": "./build" /* Specify an output folder for all emitted files. */,
// "removeComments": true, /* Disable emitting comments. */ // "removeComments": true, /* Disable emitting comments. */
// "noEmit": true, /* Disable emitting files from a compilation. */ // "noEmit": true, /* Disable emitting files from a compilation. */
// "importHelpers": true, /* Allow importing helper functions from tslib once per project, instead of including them per-file. */ // "importHelpers": true, /* Allow importing helper functions from tslib once per project, instead of including them per-file. */
// "importsNotUsedAsValues": "remove", /* Specify emit/checking behavior for imports that are only used for types */ // "importsNotUsedAsValues": "remove", /* Specify emit/checking behavior for imports that are only used for types */
// "downlevelIteration": true, /* Emit more compliant, but verbose and less performant JavaScript for iteration. */ // "downlevelIteration": true, /* Emit more compliant, but verbose and less performant JavaScript for iteration. */
// "sourceRoot": "", /* Specify the root path for debuggers to find the reference source code. */ // "sourceRoot": "", /* Specify the root path for debuggers to find the reference source code. */
// "mapRoot": "", /* Specify the location where debugger should locate map files instead of generated locations. */ // "mapRoot": "", /* Specify the location where debugger should locate map files instead of generated locations. */
// "inlineSourceMap": true, /* Include sourcemap files inside the emitted JavaScript. */ // "inlineSourceMap": true, /* Include sourcemap files inside the emitted JavaScript. */
// "inlineSources": true, /* Include source code in the sourcemaps inside the emitted JavaScript. */ // "inlineSources": true, /* Include source code in the sourcemaps inside the emitted JavaScript. */
// "emitBOM": true, /* Emit a UTF-8 Byte Order Mark (BOM) in the beginning of output files. */ // "emitBOM": true, /* Emit a UTF-8 Byte Order Mark (BOM) in the beginning of output files. */
// "newLine": "crlf", /* Set the newline character for emitting files. */ // "newLine": "crlf", /* Set the newline character for emitting files. */
// "stripInternal": true, /* Disable emitting declarations that have `@internal` in their JSDoc comments. */ // "stripInternal": true, /* Disable emitting declarations that have `@internal` in their JSDoc comments. */
// "noEmitHelpers": true, /* Disable generating custom helper functions like `__extends` in compiled output. */ // "noEmitHelpers": true, /* Disable generating custom helper functions like `__extends` in compiled output. */
// "noEmitOnError": true, /* Disable emitting files if any type checking errors are reported. */ // "noEmitOnError": true, /* Disable emitting files if any type checking errors are reported. */
// "preserveConstEnums": true, /* Disable erasing `const enum` declarations in generated code. */ // "preserveConstEnums": true, /* Disable erasing `const enum` declarations in generated code. */
// "declarationDir": "./", /* Specify the output directory for generated declaration files. */ // "declarationDir": "./", /* Specify the output directory for generated declaration files. */
/* Interop Constraints */ /* Interop Constraints */
// "isolatedModules": true, /* Ensure that each file can be safely transpiled without relying on other imports. */ // "isolatedModules": true, /* Ensure that each file can be safely transpiled without relying on other imports. */
// "allowSyntheticDefaultImports": true, /* Allow 'import x from y' when a module doesn't have a default export. */ // "allowSyntheticDefaultImports": true, /* Allow 'import x from y' when a module doesn't have a default export. */
"esModuleInterop": true, /* Emit additional JavaScript to ease support for importing CommonJS modules. This enables `allowSyntheticDefaultImports` for type compatibility. */ "esModuleInterop": true /* Emit additional JavaScript to ease support for importing CommonJS modules. This enables `allowSyntheticDefaultImports` for type compatibility. */,
// "preserveSymlinks": true, /* Disable resolving symlinks to their realpath. This correlates to the same flag in node. */ // "preserveSymlinks": true, /* Disable resolving symlinks to their realpath. This correlates to the same flag in node. */
"forceConsistentCasingInFileNames": true, /* Ensure that casing is correct in imports. */ "forceConsistentCasingInFileNames": true /* Ensure that casing is correct in imports. */,
/* Type Checking */ /* Type Checking */
"strict": true, /* Enable all strict type-checking options. */ "strict": true /* Enable all strict type-checking options. */,
// "noImplicitAny": true, /* Enable error reporting for expressions and declarations with an implied `any` type.. */ // "noImplicitAny": true, /* Enable error reporting for expressions and declarations with an implied `any` type.. */
// "strictNullChecks": true, /* When type checking, take into account `null` and `undefined`. */ // "strictNullChecks": true, /* When type checking, take into account `null` and `undefined`. */
// "strictFunctionTypes": true, /* When assigning functions, check to ensure parameters and the return values are subtype-compatible. */ // "strictFunctionTypes": true, /* When assigning functions, check to ensure parameters and the return values are subtype-compatible. */
// "strictBindCallApply": true, /* Check that the arguments for `bind`, `call`, and `apply` methods match the original function. */ // "strictBindCallApply": true, /* Check that the arguments for `bind`, `call`, and `apply` methods match the original function. */
// "strictPropertyInitialization": true, /* Check for class properties that are declared but not set in the constructor. */ // "strictPropertyInitialization": true, /* Check for class properties that are declared but not set in the constructor. */
// "noImplicitThis": true, /* Enable error reporting when `this` is given the type `any`. */ // "noImplicitThis": true, /* Enable error reporting when `this` is given the type `any`. */
// "useUnknownInCatchVariables": true, /* Type catch clause variables as 'unknown' instead of 'any'. */ // "useUnknownInCatchVariables": true, /* Type catch clause variables as 'unknown' instead of 'any'. */
// "alwaysStrict": true, /* Ensure 'use strict' is always emitted. */ // "alwaysStrict": true, /* Ensure 'use strict' is always emitted. */
// "noUnusedLocals": true, /* Enable error reporting when a local variables aren't read. */ // "noUnusedLocals": true, /* Enable error reporting when a local variables aren't read. */
// "noUnusedParameters": true, /* Raise an error when a function parameter isn't read */ // "noUnusedParameters": true, /* Raise an error when a function parameter isn't read */
// "exactOptionalPropertyTypes": true, /* Interpret optional property types as written, rather than adding 'undefined'. */ // "exactOptionalPropertyTypes": true, /* Interpret optional property types as written, rather than adding 'undefined'. */
// "noImplicitReturns": true, /* Enable error reporting for codepaths that do not explicitly return in a function. */ // "noImplicitReturns": true, /* Enable error reporting for codepaths that do not explicitly return in a function. */
// "noFallthroughCasesInSwitch": true, /* Enable error reporting for fallthrough cases in switch statements. */ // "noFallthroughCasesInSwitch": true, /* Enable error reporting for fallthrough cases in switch statements. */
// "noUncheckedIndexedAccess": true, /* Include 'undefined' in index signature results */ // "noUncheckedIndexedAccess": true, /* Include 'undefined' in index signature results */
// "noImplicitOverride": true, /* Ensure overriding members in derived classes are marked with an override modifier. */ // "noImplicitOverride": true, /* Ensure overriding members in derived classes are marked with an override modifier. */
// "noPropertyAccessFromIndexSignature": true, /* Enforces using indexed accessors for keys declared using an indexed type */ // "noPropertyAccessFromIndexSignature": true, /* Enforces using indexed accessors for keys declared using an indexed type */
// "allowUnusedLabels": true, /* Disable error reporting for unused labels. */ // "allowUnusedLabels": true, /* Disable error reporting for unused labels. */
// "allowUnreachableCode": true, /* Disable error reporting for unreachable code. */ // "allowUnreachableCode": true, /* Disable error reporting for unreachable code. */
/* Completeness */ /* Completeness */
// "skipDefaultLibCheck": true, /* Skip type checking .d.ts files that are included with TypeScript. */ // "skipDefaultLibCheck": true, /* Skip type checking .d.ts files that are included with TypeScript. */
"skipLibCheck": true /* Skip type checking all .d.ts files. */ "skipLibCheck": true /* Skip type checking all .d.ts files. */
}, },
"exclude": ["./node_modules/"] "exclude": ["./node_modules/"]
} }