How to use the @xviz/io.XVIZProviderFactory.addProviderClass function in @xviz/io

To help you get started, we’ve selected a few @xviz/io examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

github uber / xviz / test / modules / server / xviz-server.spec.js View on Github external
} 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;
github uber / xviz / examples / converters / ros / common / setup-custom-provider.js View on Github external
if (data) {
      config = JSON.parse(data);
    }
  }

  const rosbagProviderConfig = {
    ...config,
    // topicConfig
    // mapping

    // logger

    BagClass: VoyagerBag,
    ros2xvizFactory
  };
  XVIZProviderFactory.addProviderClass(ROSBAGProvider, rosbagProviderConfig);
}
github uber / xviz / modules / server / src / cmds / server.js View on Github external
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}`);
  });
}