index.ts

// tslint:disable-next-line:no-reference
/// <reference path="./untyped.d.ts" />

import * as amqp from 'amqplib'
import * as cluster from 'cluster'
import * as deepFreeze from 'deep-freeze'
import * as dotenv from 'dotenv'
import sandRequire = require('sand-require')
import { runInNewContext } from 'vm'

dotenv.config()

const queue = process.env.AMQP_QUEUE as string
const open = amqp.connect(process.env.AMQP_ENDPOINT as string)

open.then((conn) => conn.createChannel()).then((ch) => {
  ch.assertQueue(queue).then((ok) => {
    ch.consume(queue, (msg) => {
      if (msg) {
        ch.ack(msg)
        try {
          const message = JSON.parse(msg.content.toString())
          runInNewContext(message.code, {
            payload: deepFreeze(message.payload),
            console: Object.freeze({ ...console }),
            http: sandRequire('http'),
            https: sandRequire('https'),
          }, { filename: 'sandboxed.js', timeout: 1e5, displayErrors: true })
        } catch (err) {
          console.warn.apply(console, err)
        }
      }
    })
  })
}).catch(console.warn)