Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
} from './common-test-helpers';
import {XVIZProviderFactory} from '@xviz/io';
import {
ScenarioProvider,
XVIZProviderRequestHandler,
XVIZProviderHandler,
XVIZSessionContext,
XVIZServerMiddlewareStack,
XVIZServer,
XVIZWebsocketSender
} from '@xviz/server';
import {XVIZ_FORMAT} from '@xviz/io';
XVIZProviderFactory.addProviderClass(ScenarioProvider);
// Test this flow:
// Connect
// send start
// get metadata
// send transform_log
// get 2 state_updates
// get done
tape('XVIZServer#simple flow', t => {
const testCase = {
path: '/foo',
params: {bar: '1'}
};
let wss = null;
if (data) {
config = JSON.parse(data);
}
}
const rosbagProviderConfig = {
...config,
// topicConfig
// mapping
// logger
BagClass: VoyagerBag,
ros2xvizFactory
};
XVIZProviderFactory.addProviderClass(ROSBAGProvider, rosbagProviderConfig);
}
const logger = {
log: (...msg) => log.log(...msg)(),
error: (...msg) => log(0, ...msg)(),
warn: (...msg) => log.log(1, ...msg)(),
info: (...msg) => log.log(1, ...msg)(),
verbose: (...msg) => log.log(2, ...msg)()
};
const options = {
...args,
logger
};
if (args.scenarios) {
XVIZProviderFactory.addProviderClass(ScenarioProvider);
}
const handler = new XVIZProviderHandler(XVIZProviderFactory, options);
const wss = new XVIZServer([handler], options, () => {
logger.log(`Listening on port ${wss.server.address().port}`);
});
}