index.js

export default fixtureServereMiddleware;

import { URL } from "url";

import _ from "lodash";
import bodyParser from "body-parser";
import cachimo from "cachimo";
import { Router } from "express";
import fixtures from "@octokit/fixtures";
import Log from "console-log-level";

import additions from "./lib/additions.js";
import proxy from "./lib/proxy.js";

import DEFAULTS from "./lib/defaults.js";

function fixtureServereMiddleware(options) {
  const middleware = Router();

  const state = _.defaults(_.clone(options), DEFAULTS);

  if (!state.fixturesUrl) {
    state.fixturesUrl = `http://localhost:${state.port}`;
  }

  state.cachimo = cachimo;
  state.log = Log({
    level: state.logLevel === "silent" ? "fatal" : state.logLevel,
  });

  middleware.post("/fixtures", bodyParser.json(), (request, response) => {
    const id = Math.random().toString(36).substr(2);
    const requestedFixture = state.fixtures[request.body.scenario];

    if (!requestedFixture) {
      return response.status(400).json({
        error: `Scenario "${request.body.scenario}" not found`,
      });
    }

    const mock = fixtures.mock(requestedFixture, (fixture) =>
      additions(state, { id, fixture })
    );

    cachimo
      .put(id, mock, state.ttl)
      .then(() => {
        state.log.debug(
          `Deleted fixtures "${id}" (${mock.pending().length} pending)`
        );
      })
      // throws error if key was deleted before timeout, safe to ignore
      .catch(() => {});

    const path = new URL(requestedFixture[0].scope).hostname + "/" + id;
    response.status(201).json({
      id,
      url: new URL(path, state.fixturesUrl).href,
    });
  });

  // load proxies for all unique scope URLs in fixtures
  _.chain(state.fixtures)
    .values()
    .flatten()
    .map("scope")
    .uniq()
    // remove default ports for http / https, they cause problems for the proxy
    .map((url) => url.replace(/:(80|443)$/, ""))
    .forEach((target) => middleware.use(proxy(state, { target })))
    .value();

  return middleware;
}