new submission flow complete

Signed-off-by: Tathagat Thapliyal <tathagat.thapliyal@gmail.com>

Author: tathagat2006

package.json

@@ -39,6 +39,7 @@
     "build": "tsc",
     "prestart": "npm run build",
     "start": "./wait-for-it.sh ${AMQP_HOST}:${AMQP_PORT} -- node dist/taskmaster.js",
+    "dev": "NODE_PATH=dist nodemon dist/taskmaster.js",
     "test": "docker build . -t codingblocks/judge-taskmaster && mocha --timeout 10000 --exit --require ts-node/register test/**/*.ts",
     "test.parallel": "mocha-parallel-tests --timeout 10000 --exit --require ts-node/register test/**/*.ts",
     "cover": "nyc npm test"

src/taskmaster.ts

@@ -26,15 +26,17 @@ amqp.connect(`amqp://${config.AMQP.USER}:${config.AMQP.PASS}@${config.AMQP.HOST}
     channel.assertQueue(jobQ);
     channel.consume(jobQ, async (msg) => {
       try {
-        const payload = JSON.parse(msg.content.toString())
+        const payload = JSON.parse(msg.content.toString())      
+
         let job
         if (payload.testcases) {
           job = new SubmitJob(payload)
         } else {
           job = new RunJob(payload)
         }
+                
         const jobResult = await execute(job)
-        
+      
         // TODO
         channel.sendToQueue(successQ, (new Buffer(JSON.stringify(jobResult))))
         channel.ack(msg)

src/tasks/index.ts

@@ -10,7 +10,7 @@ import { RunJob, SubmitJob, Job } from "./job";
 export function execute(job: RunJob): Promise<RunResult>
 export function execute(job: SubmitJob): Promise<SubmissionResult>
 export async function execute (job: Job) {
-  // Create RUNBOX
+  // Create RUNBOX  
   rm('-rf', config.RUNBOX.DIR)
   mkdir('-p', config.RUNBOX.DIR)
   const currentJobDir = path.join(config.RUNBOX.DIR, job.id.toString())

src/tasks/submission.ts

@@ -33,8 +33,7 @@ class SubmissionScenario implements Scenario {
 
     return Promise.all(job.testcases.map(async testcase => {
       const rootDir = path.join(testCasesDir, '' + testcase.id)
-      mkdir('-p', rootDir)
-      console.log(rootDir)
+      mkdir('-p', rootDir)      
       const input = await download(testcase.input, path.join(rootDir, 'stdin'))
       const output = await download(testcase.output, path.join(rootDir, 'stdout'))
     }))