logdna/ts/logdna.logdnaaccount.ts

89 lines
2.2 KiB
TypeScript
Raw Normal View History

2018-11-01 17:13:34 +00:00
import * as plugins from './logdna.plugins';
import { LogdnaMessage } from './logdna.classes.logmessage';
import { ILogPackage, ILogDestination } from '@pushrocks/smartlog-interfaces';
2018-11-01 17:13:34 +00:00
/**
* the main logdna account
*/
export class LogdnaAccount {
2018-11-03 22:31:26 +00:00
private apiKey: string;
private baseUrl = 'https://logs.logdna.com/logs/ingest';
2018-11-01 17:13:34 +00:00
/**
* Create basic authentication
*/
2018-11-03 22:31:26 +00:00
private createBasicAuth() {
2018-11-01 17:13:34 +00:00
const userNamePasswordString = `${this.apiKey}:`;
return `Basic ${plugins.smartstring.base64.encode(userNamePasswordString)}`;
}
/**
*
* @param apiKeyArg
*/
constructor(apiKeyArg: string) {
this.apiKey = apiKeyArg;
}
/**
* sends a logmessage
* async, so it returns a Promise. In most cases it does not make sense to wait for it though.
*/
public async sendLogDnaMessage(logdnaMessageArg: LogdnaMessage) {
const lm = logdnaMessageArg;
const euc = encodeURIComponent;
2018-11-02 18:12:16 +00:00
2018-11-02 12:57:14 +00:00
// let construct the request uri
2018-11-02 18:12:16 +00:00
const requestUrlWithParams = `${this.baseUrl}?hostname=${euc(lm.options.hostname)}&mac=${euc(
lm.options.mac
)}&ip=1${euc(lm.options.ip)}&now=${Date.now()}`;
const requestBodyObject = {
lines: [
{
line: lm.options.line,
app: lm.options.app,
level: lm.options.level,
env: lm.options.env,
meta: lm.options.meta,
tags: (() => {
return lm.options.tags.reduce((reduced, newItem) => {
return `${reduced},${newItem}`;
});
})()
}
]
};
2018-11-03 13:17:29 +00:00
// console.log(requestBodyObject);
2018-11-02 18:12:16 +00:00
2018-11-02 12:57:14 +00:00
// lets post the message to logdna
2018-11-01 17:13:34 +00:00
await plugins.smartrequest.postJson(requestUrlWithParams, {
headers: {
2018-11-02 18:12:16 +00:00
Authorization: this.createBasicAuth(),
charset: 'UTF-8'
2018-11-01 17:13:34 +00:00
},
2018-11-02 18:12:16 +00:00
requestBody: requestBodyObject
2018-11-01 17:13:34 +00:00
});
}
2018-11-03 22:31:26 +00:00
/**
* convenience function for smartlog
*/
2018-11-04 13:56:25 +00:00
public async sendSmartlogPackage (smartlogPackageArg: ILogPackage) {
2018-11-03 22:31:26 +00:00
this.sendLogDnaMessage(LogdnaMessage.fromSmartLogPackage(smartlogPackageArg));
}
/**
* returns a smartlog compatible log destination
*/
2018-11-04 14:25:27 +00:00
public get smartlogDestination (): ILogDestination {
return {
handleLog: (logPackageArg) => {
this.sendSmartlogPackage(logPackageArg);
}
};
}
2018-11-01 17:13:34 +00:00
}