import
  preshr,
  procedure,
  sideEffect,
  sideEffectOnQueue
} from "@preshr/core";

preshr.get("/", opts, (request, respond) => {
  const [fileSize] = procedure(() =>
    fs.appendFileSync("log.txt", JSON.stringify(request.json()))
  );

  sideEffect(() => email.send("test", "[email protected]"));

  // Add job to queue with options (job type, repeatable)
  sideEffectOnQueue('image-processing', options, () =>
    imageAndText.render("background-image.jpg", "Hello World")
  );

  // Straight forward response with object syntax
  respond({
    payload: {
      status: "Completed",
      fileSize
    },
    contentType: 'json'
    statusCode: 200
  })

});

presher.queue('image-creation', {
  // Processors are sandboxed *processes*
  // that cannot crash the worker and utilise
  // multiple cores
  processor: '/path/to/my/processor.js',
  // Global job completed on any worker for this queue
  completed: (jobId) => console.log(`${jobId} completed`)
  options: {
    // Rate limiting queues
    limiter: {
      max: 1000,
      duration: 5000
    }
  }
})

presher.queue('video-comppression', {
  // It's be great if these queue processors
  // could be greated in a folder and then
  // webpacked as entry points out, so we can
  // write ES6 everywhere, and also a centralised config
  processor: '/path/to/video/processor.js'
})

preshr.start({
  port: 3000,
  // Preshr will support clustering out of the box
  clustering: {
    workers: 4,       // Number of workers (defaults to cpu count)
    lifetime: 10000,  // ms to keep cluster alive (Infinity)
    grace: 4000,
  },
});