Skip to content

Commit

Permalink
edited test cases to use new error handling logic
Browse files Browse the repository at this point in the history
  • Loading branch information
@adnanrahic
adnanrahic committed Aug 17, 2020
1 parent 4a6b73c commit 376cde5
Showing 1 changed file with 27 additions and 27 deletions.
54 changes: 27 additions & 27 deletions test/test.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -297,14 +297,14 @@ describe('Logsene persistance ', function () {
this.timeout(70000)
try {
process.env.LOGSENE_DISK_BUFFER_INTERVAL = 2000
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './mocha-test')
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './mocha-test', { silent: true })
var url = logsene.url
logsene.diskBuffer(true, './mocha-test')
logsene.setUrl('http://notreachable.test')
logsene.db.once('removed', function (event) {
done()
})
logsene.on('error', function (err) {
logsene.on('x-logsene-error', function (err) {
if (err) {
logsene.setUrl(url)
}
Expand All @@ -322,8 +322,8 @@ describe('Logsene persistance ', function () {

describe('Logsene log ', function () {
it('should not throw circular reference error', function (done) {
var logsene = new Logsene(token, 'test')
logsene.on('error', console.log)
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './mocha-test', { silent: true })
logsene.on('x-logsene-error', console.log)
function Foo () {
this.abc = 'Hello'
this.circular = this
Expand All @@ -341,9 +341,9 @@ describe('Logsene log ', function () {
}
})
it('should limit message field size, and remove originalLine when too large', function (done) {
var logsene = new Logsene(token, 'test')
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './mocha-test', { silent: true })
// logsene.MAX_MESSAGE_FIELD_SIZE=5
logsene.on('error', console.log)
logsene.on('x-logsene-error', console.log)
var longMessage = Buffer.alloc(logsene.maxMessageFieldSize * 2)
longMessage = longMessage.fill('1').toString()
try {
Expand All @@ -367,7 +367,7 @@ describe('Logsene log ', function () {
it('logs have default fields message, @timestamp, os.host, os.host.host_ip + custom fields', function (done) {
this.timeout(20000)
try {
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL)
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './mocha-test', { silent: true })
// check for all required fields!
logsene.once('logged', function (event) {
if (!event.msg.testField ||
Expand All @@ -383,7 +383,7 @@ describe('Logsene log ', function () {
}
}
})
logsene.once('error', function (event) {
logsene.once('x-logsene-error', function (event) {
done(event)
})
logsene.log('info', 'test', { '_id': 'testID', testField: 'Test custom field ' })
Expand All @@ -394,7 +394,7 @@ describe('Logsene log ', function () {
it('leading _ in field names are removed, dots are replaced with _', function (done) {
this.timeout(20000)
try {
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL)
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './mocha-test', { silent: true })
// check for all required fields!
logsene.once('logged', function (event) {
if (!event.msg.test_test) {
Expand All @@ -405,7 +405,7 @@ describe('Logsene log ', function () {
}
}
})
logsene.once('error', function (event) {
logsene.once('x-logsene-error', function (event) {
done(event)
})
logsene.log('info', 'test', { '_test.test': 'test' })
Expand All @@ -417,7 +417,7 @@ describe('Logsene log ', function () {
this.timeout(20000)
try {
process.env.LOGSENE_REMOVE_FIELDS = 'a.b.c,x'
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL)
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './mocha-test', { silent: true })
// check for all required fields!
logsene.once('logged', function (event) {
delete process.env.LOGSENE_REMOVE_FIELDS
Expand All @@ -427,7 +427,7 @@ describe('Logsene log ', function () {
done()
}
})
logsene.once('error', function (event) {
logsene.once('x-logsene-error', function (event) {
done(event)
})
logsene.log('info', 'test', { a: { b: {c: 'toBeRemoved'}, x: 1 }})
Expand All @@ -440,7 +440,7 @@ describe('Logsene log ', function () {
var logCount = 1001
var counter = 0
try {
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL)
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './mocha-test', { silent: true })
// check for all required fields!
logsene.on('logged', function (event) {
if (!event.msg.message ||
Expand All @@ -459,11 +459,11 @@ describe('Logsene log ', function () {
done(new Error(`Too many log events received. Expected ${logCount}, received ${counter}.`))
}
})
logsene.once('error', function (event) {
logsene.once('x-logsene-error', function (event) {
console.log(event)
done(event)
})
logsene.on('error', console.log)
logsene.on('x-logsene-error', console.log)
for (var i = 0; i < logCount; i++) {
logsene.log('info', 'test message ' + i, { testField: 'Test custom field ' + i, counter: i })
}
Expand All @@ -479,7 +479,7 @@ describe('Logsene log ', function () {
var conflictCounter = 0
mappingConflicts = totalConflicts
try {
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL)
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './mocha-test', { silent: true })
// check for all required fields!
logsene.on('logged', function (event) {
if (!event.msg.message || !event.msg['@timestamp'] || !event.msg.severity ||
Expand All @@ -498,7 +498,7 @@ describe('Logsene log ', function () {
logCounter += event.count
logReceived()
})
logsene.on('error', function (event) {
logsene.on('x-logsene-error', function (event) {
conflictCounter++
logReceived()
})
Expand All @@ -513,13 +513,13 @@ describe('Logsene log ', function () {
this.timeout(20000)
try {
httpStatusToReturn = 501
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL)
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './mocha-test', { silent: true })
// logsene.once('log', function (event) {
// this should not happen in this test case
// done(event)
// })

logsene.once('error', function (event) {
logsene.once('x-logsene-error', function (event) {
// this is the error event we expect
// reset to 200 for next test ...
httpStatusToReturn = 200
Expand All @@ -540,8 +540,8 @@ describe('Logsene log ', function () {
this.timeout(20000)
try {
httpStatusToReturn = 403 // code to generate "403, Application limit reached"
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL)
logsene.once('error', function (event) {
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './mocha-test', { silent: true })
logsene.once('x-logsene-error', function (event) {
// this is the error event we expect
// reset to 200 for next test ...
httpStatusToReturn = 200
Expand All @@ -562,8 +562,8 @@ describe('Logsene log ', function () {
this.timeout(20000)
try {
httpStatusToReturn = 400 // code to generate "400, Application not found"
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './')
logsene.once('error', function (event) {
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './', { silent: true })
logsene.once('x-logsene-error', function (event) {
// this is the error event we expect
// reset to 200 for next test ...
httpStatusToReturn = 200
Expand All @@ -584,8 +584,8 @@ describe('Logsene log ', function () {
this.timeout(20000)
try {
httpStatusToReturn = 400 // code to generate "400, Application not found"
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './')
logsene.once('error', function () {})
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './', { silent: true })
logsene.once('x-logsene-error', function () {})
logsene.once('fileNotStored', function (event) {
// this is the error event we expect
// reset to 200 for next test ...
Expand All @@ -603,9 +603,9 @@ describe('Logsene log ', function () {
try {
var errorCounter = 0
httpStatusToReturn = 501
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL)
var logsene = new Logsene(token, 'test', process.env.LOGSENE_URL, './mocha-test', { silent: true })
var hu = process.memoryUsage().rss
logsene.on('error', function (event) {
logsene.on('x-logsene-error', function (event) {
// console.log(process.memoryUsage())
var diff = (process.memoryUsage().rss - hu) / 1024 / 1024
// console.log(hu/1024/1024)
Expand Down

0 comments on commit 376cde5

Please sign in to comment.