'use strict'
|
|
// This test is complicated. It must simulate a server sending an unsolicited,
|
// or a mismatched, message in order to force the client's internal message
|
// tracker to try and find a corresponding sent message that does not exist.
|
// In order to do that, we need to set a high test timeout and wait for the
|
// error message to be logged.
|
|
const tap = require('tap')
|
const ldapjs = require('../')
|
const { SearchResultEntry } = require('@ldapjs/messages')
|
const server = ldapjs.createServer()
|
const SUFFIX = ''
|
|
tap.timeout = 10000
|
|
server.bind(SUFFIX, (res, done) => {
|
res.end()
|
return done()
|
})
|
|
server.search(SUFFIX, (req, res, done) => {
|
const result = new SearchResultEntry({
|
objectName: `dc=${req.scopeName}`
|
})
|
|
// Respond to the search request with a matched response.
|
res.send(result)
|
res.end()
|
|
// After a short delay, send ANOTHER response to the client that will not
|
// be matched by the client's internal tracker.
|
setTimeout(
|
() => {
|
res.send(result)
|
res.end()
|
done()
|
},
|
100
|
)
|
})
|
|
tap.beforeEach(t => {
|
return new Promise((resolve, reject) => {
|
server.listen(0, '127.0.0.1', (err) => {
|
if (err) return reject(err)
|
|
t.context.logMessages = []
|
t.context.logger = {
|
child () { return this },
|
debug () {},
|
error (...args) {
|
t.context.logMessages.push(args)
|
},
|
trace () {}
|
}
|
|
t.context.url = server.url
|
t.context.client = ldapjs.createClient({
|
url: [server.url],
|
timeout: 5,
|
log: t.context.logger
|
})
|
|
resolve()
|
})
|
})
|
})
|
|
tap.afterEach(t => {
|
return new Promise((resolve, reject) => {
|
t.context.client.destroy()
|
server.close((err) => {
|
if (err) return reject(err)
|
resolve()
|
})
|
})
|
})
|
|
tap.test('handle null messages', t => {
|
const { client, logMessages } = t.context
|
|
// There's no way to get an error from the client when it has received an
|
// unmatched response from the server. So we need to poll our logger instance
|
// and detect when the corresponding error message has been logged.
|
const timer = setInterval(
|
() => {
|
if (logMessages.length > 0) {
|
t.equal(
|
logMessages.some(msg => msg[1] === 'unmatched server message received'),
|
true
|
)
|
clearInterval(timer)
|
t.end()
|
}
|
},
|
100
|
)
|
|
client.search('dc=test', (error) => {
|
t.error(error)
|
})
|
})
|
