125 lines
3.1 KiB
TypeScript
125 lines
3.1 KiB
TypeScript
import { LOGGING_DIR, SECRETS_FILE } from "./config";
|
|
import { readFileSync } from "fs";
|
|
import BN from "bn.js";
|
|
import winston, { format } from "winston";
|
|
import "winston-daily-rotate-file";
|
|
const { combine, timestamp, printf } = format;
|
|
import fs from "fs";
|
|
import { Dir } from "./exchange/types";
|
|
// Logging
|
|
if (
|
|
LOGGING_DIR &&
|
|
!fs.existsSync(LOGGING_DIR) &&
|
|
process.env.ENVIRONMENT === "prod"
|
|
) {
|
|
fs.mkdirSync(LOGGING_DIR);
|
|
}
|
|
|
|
const logFormat = printf(({ level, message, timestamp }) => {
|
|
return `${timestamp} ${level}: ${message}`;
|
|
});
|
|
|
|
export const logger = winston.createLogger({
|
|
level: "silly",
|
|
format: combine(timestamp(), logFormat),
|
|
transports: [
|
|
new winston.transports.Console({
|
|
format: winston.format.simple(),
|
|
level: "info",
|
|
}),
|
|
],
|
|
});
|
|
|
|
if (process.env.ENVIRONMENT === "prod") {
|
|
logger.add(
|
|
new winston.transports.DailyRotateFile({
|
|
dirname: LOGGING_DIR,
|
|
filename: "remote_js_server-ERROR-%DATE%.log",
|
|
datePattern: "YYYY-MM-DD-HH",
|
|
maxSize: "200m",
|
|
maxFiles: "1",
|
|
utc: true,
|
|
level: "error",
|
|
})
|
|
);
|
|
logger.add(
|
|
new winston.transports.DailyRotateFile({
|
|
dirname: LOGGING_DIR,
|
|
filename: "remote_js_server-INFO-%DATE%.log",
|
|
datePattern: "YYYY-MM-DD-HH",
|
|
maxSize: "200m",
|
|
maxFiles: "3",
|
|
utc: true,
|
|
level: "info",
|
|
})
|
|
);
|
|
logger.add(
|
|
new winston.transports.DailyRotateFile({
|
|
dirname: LOGGING_DIR,
|
|
filename: "remote_js_server-DEBUG-%DATE%.log",
|
|
datePattern: "YYYY-MM-DD-HH",
|
|
maxSize: "200m",
|
|
maxFiles: "3",
|
|
utc: true,
|
|
})
|
|
);
|
|
}
|
|
|
|
class MorganStream {
|
|
write(text: string) {
|
|
logger.info(text.replace(/\n$/, ""));
|
|
}
|
|
}
|
|
export const morganStream = new MorganStream();
|
|
|
|
export const getKeys = (keys: string[]): any[] => {
|
|
const allSecrets = JSON.parse(readFileSync(SECRETS_FILE, "utf-8"));
|
|
const secrets: string[] = [];
|
|
for (const key of keys) {
|
|
secrets.push(allSecrets[key]);
|
|
}
|
|
return secrets;
|
|
};
|
|
|
|
export const getUnixTs = (): number => {
|
|
return new Date().getTime() / 1000;
|
|
};
|
|
|
|
export function sleep(time: number): Promise<void> {
|
|
return new Promise((resolve) => setTimeout(resolve, time));
|
|
}
|
|
|
|
export function divideBnToNumber(numerator: BN, denominator: BN): number {
|
|
const quotient = numerator.div(denominator).toNumber();
|
|
const rem = numerator.umod(denominator);
|
|
const gcd = rem.gcd(denominator);
|
|
return quotient + rem.div(gcd).toNumber() / denominator.div(gcd).toNumber();
|
|
}
|
|
|
|
export class DirUtil {
|
|
public static buySell = (dir: Dir): "buy" | "sell" => {
|
|
return dir === 1 ? "buy" : "sell";
|
|
};
|
|
|
|
public static parse = (raw: string | bigint | Dir): Dir => {
|
|
if (raw === Dir.B) {
|
|
return Dir.B;
|
|
} else if (raw === Dir.S) {
|
|
return Dir.S;
|
|
} else if (
|
|
typeof raw === "string" &&
|
|
["bid", "buy", "b", "create", "long"].includes(raw.toLowerCase())
|
|
) {
|
|
return Dir.B;
|
|
} else if (
|
|
typeof raw === "string" &&
|
|
["ask", "sell", "sale", "a", "s", "redeem", "short"].includes(
|
|
raw.toLowerCase()
|
|
)
|
|
) {
|
|
return Dir.S;
|
|
}
|
|
throw TypeError(`Cannot parse Dir from ${raw}`);
|
|
};
|
|
}
|