Merge branch 'submission_pipeline' of https://github.com/coding-blocks/judge-taskmaster into submission_pipeline

Author: jatinkatyal13

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'))
     }))

test/runScenario.spec.ts

@@ -3,7 +3,7 @@ import { mkdir, rm } from 'shelljs'
 import RunScenario from '../src/tasks/run'
 import config = require('../config.js')
 import * as path from 'path'
-import { RunJob } from '../src/types/job'
+import { RunJob } from '../src/tasks/job'
 import * as fs from 'fs'
 
 describe('Run Scenario', () => {

test/submission/submit.c.spec.ts

@@ -0,0 +1,36 @@
+import { execute } from '../../src/tasks/'
+import { expect } from 'chai'
+import { SubmitJob } from '../../src/tasks/job'
+import { SubmissionResult } from '../../src/types/result'
+
+describe('submit - c', () => {
+  it('.c file submits correctly', async () => {
+    const source = `
+    #include <stdio.h>
+    int main () {
+        char in[10];
+        scanf("%s", in);
+        printf("Hello %s", in);
+        return 0;
+    }
+  `
+
+    const submitResult = await execute(new SubmitJob({
+      id: 1,
+      lang: 'c',
+      source: (new Buffer(source)).toString('base64'),
+      testcases: [{
+        id: 1,
+        input: 'https://minio.cb.lk/public/input',
+        output: 'https://minio.cb.lk/public/output'
+      }]
+    }))
+
+    console.log(submitResult)
+
+    // assertions
+    expect(submitResult.testcases[0].result).to.eq('Success')
+    expect(submitResult.testcases[0].score).to.eq(100)
+  })
+})
+

test/submission/submit.cpp.spec.ts

@@ -1,5 +1,5 @@
-import {execute} from '../../src/tasks/'
-import {expect} from 'chai'
+import { execute } from '../../src/tasks/'
+import { expect } from 'chai'
 import { SubmitJob } from '../../src/tasks/job'
 import { SubmissionResult } from '../../src/types/result'
 
@@ -15,21 +15,22 @@ describe('submit - cpp', () => {
           return 0;
       }`
 
-    const submitResult = <SubmissionResult>await execute(new SubmitJob({
+    const submitResult = await execute(new SubmitJob({
       id: 1,
       lang: 'cpp',
       source: (new Buffer(source)).toString('base64'),
-      testcases: [{ 
-        id: 1, 
-        input: 'https://minio.cb.lk/public/input', 
-        output: 'https://minio.cb.lk/public/output' 
+      testcases: [{
+        id: 1,
+        input: 'https://minio.cb.lk/public/input',
+        output: 'https://minio.cb.lk/public/output'
       }]
     }))
-    
+
     console.log(submitResult)
 
     // assertions
-    expect(1).to.eq(1)
+    expect(submitResult.testcases[0].result).to.eq('Success')
+    expect(submitResult.testcases[0].score).to.eq(100)
   })
 })
 

test/submission/submit.csharp.spec.ts

@@ -0,0 +1,34 @@
+import { execute } from '../../src/tasks/'
+import { expect } from 'chai'
+import { SubmitJob } from '../../src/tasks/job'
+import { SubmissionResult } from '../../src/types/result'
+
+describe('submit - csharp', () => {
+  it('.cs file submits correctly', async () => {
+    const source = `
+    using System;
+    public class HelloWorld {
+      static public void Main () {
+        Console.WriteLine ("Hello " + Console.ReadLine());
+      }
+    }
+    `
+    const submitResult = await execute(new SubmitJob({
+      id: 1,
+      lang: 'csharp',
+      source: (new Buffer(source)).toString('base64'),
+      testcases: [{
+        id: 1,
+        input: 'https://minio.cb.lk/public/input',
+        output: 'https://minio.cb.lk/public/output'
+      }]
+    }))
+
+    console.log(submitResult)
+
+    //assertion
+    expect(submitResult.testcases[0].result).to.eq('Success')
+    expect(submitResult.testcases[0].score).to.eq(100)
+
+  })
+})

test/submission/submit.java8.spec.ts

@@ -0,0 +1,37 @@
+import { execute } from '../../src/tasks/'
+import { expect } from 'chai'
+import { SubmitJob } from '../../src/tasks/job'
+import { SubmissionResult } from '../../src/types/result'
+
+describe('submit - java8', () => {
+  it('.java file submits correctly (java8)', async () => {
+    const source = `
+    import java.util.Scanner;
+    public class Main {
+      public static void main(String[] args) {
+        Scanner in = new Scanner(System.in);
+        String input = in.next();
+        System.out.println("Hello " + input);
+      }
+    }
+  `
+
+    const submitResult = await execute(new SubmitJob({
+      id: 1,
+      lang: 'java8',
+      source: (new Buffer(source)).toString('base64'),
+      testcases: [{
+        id: 1,
+        input: 'https://minio.cb.lk/public/input',
+        output: 'https://minio.cb.lk/public/output'
+      }]
+    }))
+
+    console.log(submitResult)
+
+    // assertions
+    expect(submitResult.testcases[0].result).to.eq('Success')
+    expect(submitResult.testcases[0].score).to.eq(100)
+  })
+})
+

test/submission/submit.nodejs10.spec.ts

@@ -0,0 +1,38 @@
+import { execute } from '../../src/tasks/'
+import { expect } from 'chai'
+import { SubmitJob } from '../../src/tasks/job'
+import { SubmissionResult } from '../../src/types/result'
+
+describe('submit - nodejs10', () => {
+  it('.js file submits correctly (nodejs10)', async () => {
+    const source = `
+    const readline = require('readline');
+    const rl = readline.createInterface({
+      input: process.stdin,
+      output: process.stdout,
+      terminal: false
+    });
+    rl.on('line', function (line) {
+      console.log("Hello " + line);
+    })
+  `
+
+    const submitResult = await execute(new SubmitJob({
+      id: 1,
+      lang: 'nodejs10',
+      source: (new Buffer(source)).toString('base64'),
+      testcases: [{
+        id: 1,
+        input: 'https://minio.cb.lk/public/input',
+        output: 'https://minio.cb.lk/public/output'
+      }]
+    }))
+
+    console.log(submitResult)
+
+    // assertions
+    expect(submitResult.testcases[0].result).to.eq('Success')
+    expect(submitResult.testcases[0].score).to.eq(100)
+  })
+})
+