Create an instance of Mock:
const NatsMock = require('./');
const options = {
maxReconnectAttempts: -1,
reconnectTimeWait: 250,
url: 'nats://localhost:4222',
group: 'natsMock',
requestTimeout: 100,
};
const mock = new NatsMock(options);
or attach to existed Tasu instance
const Nats = require('tasu');
const NatsMock = require('./');
const options = {
maxReconnectAttempts: -1,
reconnectTimeWait: 250,
url: 'nats://localhost:4222',
group: 'natsMock',
requestTimeout: 100,
};
const nats=new Nats(options);
const mock = new NatsMock(nats);
ensure that it's connected to NATS server
await mock.connected();
set up onetime mock
const onceMock = mock.once('mockTest.once')
.req({a: 1, b: 2})
.res({result: true});
or persistent one
const persistMock = mock.persist('mockTest.once')
.req({a: 1, b: 2})
.res({result: true});
Passing exact object (compared using lodash.isEqual
)
const persistMock = mock.persist('mockTest.once')
.req({a: 1, b: 2})
.res({result: true});
Passing function
const persistMock = mock.persist('mockTest.once')
.req((data)=> data.someField === 'some value')
.res({result: true});
Passing async function
const persistMock = mock.persist('mockTest.once')
.req((data)=> await someAsyncFunction(data))
.res({result: true});
.res({result: true, value: 'some value'});
assert.isOk(onceMock.isDone());
assert.equal(persistMock.numOfCalls, 2);
if you have other questions: @see tests.js