All files / lib proxy.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
'use strict';
 
// Modules
const _ = require('lodash');
const url = require('url');
 
/*
 * Helper to normalize routes into arrays
 */
const normalizeRoutes = (routes = {}) => _(routes)
  .map((data, key) => _.merge({}, data, {key}))
  .value();
 
/*
 * Helper to map redirects to upstreams
 */
const getUpstream = (route, routes) => {
  // If we already have an upstream then WE GOOD!
  if (route.type === 'upstream') return route;
  // If redirect then map to the upstream to which it refers
  else if (route.type === 'redirect') {
    const upstream = _.find(routes, {key: route.to});
    return _.merge({}, route, {type: upstream.type, upstream: upstream.upstream});
  // Otherwise return nothing
  } else {
    return {};
  }
};
 
/*
 * Helper to map a route to a lando proxy
 */
const getProxyMiddlewares = route => {
  // Let's add in some middleware
  route.middlewares = [
    {name: 'platform', key: 'headers.customrequestheaders.X-Client-IP', value: 'host.docker.internal'},
    {name: 'platform', key: 'headers.customrequestheaders.X-Original-Route', value: route.href},
  ];
  // And special ones just for https
  if (route.protocol === 'https:') {
    route.middlewares.push({
      name: 'platform-secured',
      key: 'headers.customrequestheaders.X-Client-SSL',
      value: 'on',
    });
  }
  return route;
};
 
/*
 * Helper to map parsed platform config into related Lando things
 */
exports.getLandoProxyRoutes = (routes = {}, supported = []) => _(normalizeRoutes(routes))
  // Map redirects to upstreams
  .map(route => getUpstream(route, normalizeRoutes(routes)))
  // Remove blank entries
  .compact()
  // Parse to lando things
  .map(route => _.merge({}, url.parse(route.key), {service: route.upstream.split(':')[0]}))
  // Filter unsupported upstreams
  .filter(route => _.includes(_.map(supported, 'name'), route.service))
  // Merge in port data
  .map(route => _.merge({}, route, _.find(supported, {name: route.service})))
  // Add port to data
  .map(route => ({service: route.service, config: getProxyMiddlewares(route)}))
  // Group by service
  .groupBy('service')
  // Map to lando proxy config
  .map((entries, service) => ([service, _.map(entries, 'config')]))
  // objectify
  .fromPairs()
  // Return
  .value();