36 lines
924 B
TypeScript
36 lines
924 B
TypeScript
|
import NatsAdaptor from "../src/adaptors/nats";
|
||
|
|
import { Message } from "../src/messages";
|
||
|
|
import Service from "../src/service";
|
||
|
|
|
||
|
|
let srv!: Service;
|
||
|
|
|
||
|
|
const serviceName = "test-service";
|
||
|
|
const adaptorName = "nats";
|
||
|
|
const subject = "test";
|
||
|
|
|
||
|
|
const dataExpected = "hello world";
|
||
|
|
const statusCodeExpected = 200;
|
||
|
|
|
||
|
|
beforeEach(() => {
|
||
|
|
srv = new Service(serviceName);
|
||
|
|
});
|
||
|
|
|
||
|
|
afterEach(async () => {
|
||
|
|
await srv.stop();
|
||
|
|
});
|
||
|
|
|
||
|
|
test('nats adaptor', async () => {
|
||
|
|
srv.addAdaptor(adaptorName, new NatsAdaptor({ servers: ['127.0.0.1:4222'] }));
|
||
|
|
srv.subscribe(adaptorName, subject, async (msg: Message<string>) => {
|
||
|
|
return {data: msg.data, statusCode: statusCodeExpected};
|
||
|
|
});
|
||
|
|
|
||
|
|
await srv.listen();
|
||
|
|
|
||
|
|
const res = await srv.request(adaptorName, {service: serviceName, subject: subject, data: dataExpected});
|
||
|
|
|
||
|
|
expect(res.data).toBe(dataExpected);
|
||
|
|
expect(res.statusCode).toBe(statusCodeExpected);
|
||
|
|
});
|
||
|
|
|