Compare commits

..

6 Commits

Author SHA1 Message Date
a586069305 1.0.20 2018-11-05 23:29:01 +01:00
8a8c4efcbb fix(core): update 2018-11-05 23:29:01 +01:00
dbb5843f52 1.0.19 2018-11-05 23:25:53 +01:00
d021e934b9 fix(readme): update 2018-11-05 23:25:53 +01:00
3bd8ebb29d 1.0.18 2018-11-04 21:21:34 +01:00
2429e7b7c1 fix(core): update 2018-11-04 21:21:34 +01:00
6 changed files with 108 additions and 10 deletions

2
package-lock.json generated
View File

@ -1,6 +1,6 @@
{ {
"name": "@mojoio/logdna", "name": "@mojoio/logdna",
"version": "1.0.17", "version": "1.0.20",
"lockfileVersion": 1, "lockfileVersion": 1,
"requires": true, "requires": true,
"dependencies": { "dependencies": {

View File

@ -1,6 +1,6 @@
{ {
"name": "@mojoio/logdna", "name": "@mojoio/logdna",
"version": "1.0.17", "version": "1.0.20",
"private": false, "private": false,
"description": "anunoffical package for the logdna api", "description": "anunoffical package for the logdna api",
"main": "dist/index.js", "main": "dist/index.js",

68
readme.md Normal file
View File

@ -0,0 +1,68 @@
# logdna
anunoffical package for the logdna api
## Availabililty
[![npm](https://mojoio.gitlab.io/assets/repo-button-npm.svg)](https://www.npmjs.com/package/@mojoio/logdna)
[![git](https://mojoio.gitlab.io/assets/repo-button-git.svg)](https://GitLab.com/mojoio/logdna)
[![git](https://mojoio.gitlab.io/assets/repo-button-mirror.svg)](https://github.com/mojoio/logdna)
[![docs](https://mojoio.gitlab.io/assets/repo-button-docs.svg)](https://mojoio.gitlab.io/logdna/)
## Status for master
[![build status](https://GitLab.com/mojoio/logdna/badges/master/build.svg)](https://GitLab.com/mojoio/logdna/commits/master)
[![coverage report](https://GitLab.com/mojoio/logdna/badges/master/coverage.svg)](https://GitLab.com/mojoio/logdna/commits/master)
[![npm downloads per month](https://img.shields.io/npm/dm/@mojoio/logdna.svg)](https://www.npmjs.com/package/@mojoio/logdna)
[![Known Vulnerabilities](https://snyk.io/test/npm/@mojoio/logdna/badge.svg)](https://snyk.io/test/npm/@mojoio/logdna)
[![TypeScript](https://img.shields.io/badge/TypeScript-2.x-blue.svg)](https://nodejs.org/dist/latest-v6.x/docs/api/)
[![node](https://img.shields.io/badge/node->=%206.x.x-blue.svg)](https://nodejs.org/dist/latest-v6.x/docs/api/)
[![JavaScript Style Guide](https://img.shields.io/badge/code%20style-standard-brightgreen.svg)](http://standardjs.com/)
## Usage
Use TypeScript for best in class instellisense.
This package is an unofficial package for the logdna. It comes with the following festures:
* aggregates logs that require the same uri query parameters and sends them as bundle. This ensures the correct order of logs
* resends logs that failed to send.
* supports smartlog messages and the smartlog ecosystem
```typescript
import { ILogPackage } from '@pushrocks/smartlog-interfaces'
import { LogdnaAccount, LogdnaMessage } from '@mojoio/logdna';
// lets create a logDnaAccount
const logDnaAccount = new LogdnaAccount(process.env.LOGDNA_APIKEY);
// lets create a smartlog message (smartlog normally takes care of creating those objects)
const smartlogPackage: ILogPackage = {
timestamp: Date.now(),
type: 'log',
level: 'info',
context: {
company: 'Lossless GmbH',
companyunit: 'lossless.cloud',
containerName: 'ci-mojoio-logdna',
environment: 'test',
runtime: 'node',
zone: 'shipzone'
},
message: 'this is an awesome log message sent by the tapbundle test'
};
const logDnaMessage = LogdnaMessage.fromSmartLogPackage(smartlogPackage);
logDnaAccount.sendLogDnaMessage(logDnaMessage);
// alternatively simply send the smartlogPackage
// creation of the LogdnaMessage is done for you
logDnaAccount.sendSmartlogPackage(smartlogPackage)
// most of the above funtions return promises should you want to wait for a log to be fully sent
```
For further information read the linked docs at the top of this README.
> MIT licensed | **©** [Lossless GmbH](https://lossless.gmbh)
| By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy.html)
[![repo-footer](https://mojoio.gitlab.io/assets/repo-footer.svg)](https://mojo.io)

View File

@ -2,6 +2,7 @@ import { expect, tap } from '@pushrocks/tapbundle';
import * as logdna from '../ts/index'; import * as logdna from '../ts/index';
import { Qenv } from '@pushrocks/qenv'; import { Qenv } from '@pushrocks/qenv';
import { ILogPackage } from '@pushrocks/smartlog-interfaces';
const testQenv = new Qenv('./', './.nogit'); const testQenv = new Qenv('./', './.nogit');
@ -33,4 +34,28 @@ tap.test('should send the message', async () => {
await testLogDnaAccount.sendLogDnaMessage(testLogMessage); await testLogDnaAccount.sendLogDnaMessage(testLogMessage);
}); });
tap.test('should send in order', async () => {
let i = 1;
while (i < 21) {
const testSmartlogMessage: ILogPackage = {
timestamp: Date.now(),
type: 'log',
level: 'info',
context: {
company: 'Lossless GmbH',
companyunit: 'lossless.cloud',
containerName: 'ci-mojoio-logdna',
environment: 'test',
runtime: 'node',
zone: 'shipzone'
},
message: `this is an awesome log message sent by the tapbundle test #${i}`
};
testLogDnaAccount.sendSmartlogPackage(testSmartlogMessage);
i++;
}
})
tap.start(); tap.start();

View File

@ -41,7 +41,7 @@ export class LogAggregator {
private async sendAggregatedLogs(logCandidate: ILogCandidate) { private async sendAggregatedLogs(logCandidate: ILogCandidate) {
this.logObjectMap.remove(logCandidate); this.logObjectMap.remove(logCandidate);
// lets post the message to logdna // lets post the message to logdna
await plugins.smartrequest.postJson(`${this.baseUrl}${logCandidate.urlIdentifier}&now=${Date.now()}` , { const response = await plugins.smartrequest.postJson(`${this.baseUrl}${logCandidate.urlIdentifier}&now=${Date.now()}` , {
headers: { headers: {
Authorization: this.createBasicAuth(), Authorization: this.createBasicAuth(),
charset: 'UTF-8' charset: 'UTF-8'
@ -50,5 +50,8 @@ export class LogAggregator {
lines: logCandidate.logLines lines: logCandidate.logLines
} }
}); });
if(response.statusCode !== 200) {
console.log(response.body);
}
} }
} }

View File

@ -26,17 +26,20 @@ export class LogdnaAccount {
const lm = logdnaMessageArg; const lm = logdnaMessageArg;
const euc = encodeURIComponent; const euc = encodeURIComponent;
// let construct the request uri const uriHostname = euc(lm.options.hostname);
const requestUrlWithParams = `?hostname=${euc(lm.options.hostname)}&mac=${euc( const uriMac = euc(lm.options.mac);
lm.options.mac const uriIp = euc(lm.options.ip);
)}&ip=1${euc(lm.options.ip)}&tags=${euc( const uriTags = euc(
(() => { (() => {
return lm.options.tags.reduce((reduced, newItem) => { return lm.options.tags.reduce((reduced, newItem) => {
return `${reduced},${newItem}`; return `${reduced},${newItem}`;
}); });
})() })()
)}`; );
// let construct the request uri
const requestUrlWithParams = `?hostname=${uriHostname}&mac=${uriMac}&ip=1${uriIp}&tags=${uriTags}`;
const logLine = { const logLine = {
timestamp: lm.options.timestamp, timestamp: lm.options.timestamp,
line: lm.options.line, line: lm.options.line,
@ -47,7 +50,6 @@ export class LogdnaAccount {
}; };
this.logAggregator.addLog(requestUrlWithParams, logLine); this.logAggregator.addLog(requestUrlWithParams, logLine);
} }
/** /**