var express  = require('express');
var router   = express.Router();
// var mongoose = require('../models/mongoose');
const config = require('../config');

// Redis
const Redis  = require('ioredis');
var redis_client = new Redis(config.redis_connection);

// routes that end with jobs
// ----------------------------------------------------
// These are redis-based queries
// route to return all current requests (GET http://localhost:3000/api/requests)
router.route('/jobs/submit')

  // add a request for a process to launch (accessed at PUT api/requests)
  .put(function(req, res) {

    let request = req.body.request;

    // Add _id to process is not present
    if (! request.process._id) {
      request.process._id = new mongoose.mongo.ObjectId();
    }

    console.log(request);

    redis_client.lpush('RAPD_JOBS', JSON.stringify(request), function(err, queue_length) {
      if (err) {
        console.error(err);
        res.status(500).json({
          success: false,
          error: err
        });
      } else {
        console.log('Job added to RAPD_JOBS queue length:', queue_length);
        res.status(200).json({
          success: true,
          queue_length: queue_length
        });
      }
    });
  }); // End .put(function(req,res) {

module.exports = router;

var express  = require('express');
var router   = express.Router();
// var mongoose = require('../models/mongoose');
const config = require('../config');

// Redis
const Redis  = require('ioredis');
var redis_client = new Redis(config.redis_connection);

// routes that end with jobs
// ----------------------------------------------------
// These are redis-based queries
// route to return all current requests (GET http://localhost:3000/api/requests)
router.route('/jobs/submit')

  // add a request for a process to launch (accessed at PUT api/requests)
  .put(function(req, res) {

    let request = req.body.request;

    console.log(request);

    redis_client.lpush('RAPD_JOBS', JSON.stringify(request), function(err, queue_length) {
      if (err) {
        console.error(err);
        res.status(500).json({
          success: false,
          error: err
        });
      } else {
        console.log('Job added to RAPD_JOBS queue length:', queue_length);
        res.status(200).json({
          success: true,
          queue_length: queue_length
        });
      }
    });
  }); // End .put(function(req,res) {

module.exports = router;

--- 
+++ 
@@ -17,11 +17,6 @@
   .put(function(req, res) {
 
     let request = req.body.request;
-
-    // Add _id to process is not present
-    if (! request.process._id) {
-      request.process._id = new mongoose.mongo.ObjectId();
-    }
 
     console.log(request);
 
Add the ObjectId to a job request that is missing it
