61 lines
2.1 KiB
JavaScript
61 lines
2.1 KiB
JavaScript
|
"use strict";
|
||
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
||
|
|
exports.ApiLogAppender = void 0;
|
||
|
|
const axios_1 = require("axios");
|
||
|
|
const log_message_1 = require("./log-message");
|
||
|
|
class ApiLogAppender {
|
||
|
|
constructor(apiEndpoint, authToken, threshold) {
|
||
|
|
this.apiEndpoint = apiEndpoint;
|
||
|
|
this.authToken = authToken;
|
||
|
|
this.batchSize = 10;
|
||
|
|
this.minimumTimePassedInSec = 60;
|
||
|
|
this.maximumTimePassedInSec = 120;
|
||
|
|
this.threshold = log_message_1.LogLevel.ALL;
|
||
|
|
this.http = axios_1.default.create();
|
||
|
|
this.msgBuffer = [];
|
||
|
|
this.lastSent = 0;
|
||
|
|
this.checkPost = () => {
|
||
|
|
const now = Date.now();
|
||
|
|
const min = this.lastSent + this.minimumTimePassedInSec * 1000;
|
||
|
|
const max = this.lastSent + this.maximumTimePassedInSec * 1000;
|
||
|
|
if ((this.msgBuffer.length >= this.batchSize && min < now) ||
|
||
|
|
(this.msgBuffer.length > 0 && max < now)) {
|
||
|
|
this.doPost();
|
||
|
|
}
|
||
|
|
setTimeout(this.checkPost, Math.max(10000, this.minimumTimePassedInSec * 1000));
|
||
|
|
};
|
||
|
|
setTimeout(this.checkPost, 1000);
|
||
|
|
if (threshold) {
|
||
|
|
this.threshold = threshold;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
appendMessage(msg) {
|
||
|
|
if (this.threshold && msg.level < this.threshold) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
this.msgBuffer.push({
|
||
|
|
level: log_message_1.LogLevel[msg.level],
|
||
|
|
message: typeof msg.message === 'string'
|
||
|
|
? msg.message
|
||
|
|
: JSON.stringify(msg.message),
|
||
|
|
scope: msg.scope,
|
||
|
|
stacktrace: msg.stacktrace,
|
||
|
|
timestamp: msg.timestamp.toISOString()
|
||
|
|
});
|
||
|
|
}
|
||
|
|
doPost() {
|
||
|
|
if (this.msgBuffer.length > 0 && this.authToken) {
|
||
|
|
this.http.post(this.apiEndpoint, this.msgBuffer, {
|
||
|
|
headers: {
|
||
|
|
'Content-Type': 'application/json',
|
||
|
|
Authorization: `Bearer ${this.authToken}`
|
||
|
|
}
|
||
|
|
});
|
||
|
|
this.lastSent = Date.now();
|
||
|
|
this.msgBuffer = [];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
exports.ApiLogAppender = ApiLogAppender;
|
||
|
|
exports.default = ApiLogAppender;
|