node-srt/spec/srt_spec.js
2020-06-24 12:18:01 +02:00

57 lines
No EOL
1.8 KiB
JavaScript

const { SRT } = require('../index.js');
describe("SRT library", () => {
it("exposes constants", () => {
expect(SRT.ERROR).toEqual(-1);
expect(SRT.INVALID_SOCK).toEqual(-1);
});
it("can create an SRT socket", () => {
const srt = new SRT();
const socket = srt.createSocket();
expect(socket).not.toEqual(SRT.ERROR);
});
it("can create an SRT socket for sending data", () => {
const srt = new SRT();
const socket = srt.createSocket(true);
expect(socket).not.toEqual(SRT.ERROR);
});
it("can get socket state", () => {
const srt = new SRT();
const socket = srt.createSocket();
const state = srt.getSockState(socket);
expect(state).toEqual(SRT.SRTS_INIT);
});
it("can set SRT sockopt SRTO_MSS", () => {
const srt = new SRT();
const socket = srt.createSocket();
const result = srt.setSockOpt(socket, SRT.SRTO_MSS, 1052);
expect(result).not.toEqual(SRT.ERROR);
const value = srt.getSockOpt(socket, SRT.SRTO_MSS);
expect(value).toEqual(1052);
});
it("can set SRT socket in non-blocking mode", () => {
const srt = new SRT();
const socket = srt.createSocket();
const result = srt.setSockOpt(socket, SRT.SRTO_RCVSYN, false);
expect(result).not.toEqual(SRT.ERROR);
const value = srt.getSockOpt(socket, SRT.SRTO_RCVSYN);
expect(value).toEqual(false);
});
it("can setup non-blocking event poll", () => {
const srt = new SRT();
const socket = srt.createSocket();
srt.setSockOpt(socket, SRT.SRTO_RCVSYN, false);
srt.bind(socket, "0.0.0.0", 1234);
srt.listen(socket, 10);
const epid = srt.epollCreate();
srt.epollAddUsock(epid, socket, SRT.EPOLL_IN | SRT.EPOLL_ERR);
const events = srt.epollUWait(epid, 500);
expect(events.length).toEqual(0);
});
});