feat(e2e-tests): add tests for POST 'api/submit'

Author: prabalsingh24

test/e2e/SubmitScenario.spec.ts

@@ -0,0 +1,213 @@
+import app from '../../src/server';
+import DB from '../../src/models';
+import express = require('express');
+import { Router } from 'express';
+import * as utils from '../utils/utils';
+
+
+const chai = require('chai');
+const chaiHttp = require('chai-http');
+
+chai.use(chaiHttp);
+const {expect} = chai;
+
+const APIKEY = '7718330d2794406c980bdbded6c9dc1d';
+const source = `
+          #include <iostream>
+          using namespace std;
+          int main () {
+              char in[20];
+              cin>>in;
+              cout<<in;
+              return 0;
+          }`;
+const testcases = [
+    {
+        id: 1,
+        stdin: 'https://minio.cb.lk/public/input',
+        stdout: 'https://minio.cb.lk/public/input'
+    },
+    {
+        id: 2,
+        stdin: 'https://minio.cb.lk/public/input',
+        stdout: 'https://minio.cb.lk/public/input'
+    }
+];
+const expectedResult = 'Success';
+
+
+function delay(ms: number) {
+    return new Promise( resolve => setTimeout(resolve, ms) );
+}
+
+describe('POST api/submissions', () => {
+    before(async () => {
+        await DB.apikeys.bulkCreate([
+            {id: 1, key: APIKEY, whitelist_domains: ['*'], whitelist_ips: ['*']}
+        ]);
+        await DB.langs.bulkCreate([
+            {lang_slug: 'cpp', lang_name: 'C++', lang_version: '11'}
+        ]);
+        await utils.setupMockQueue();
+
+    });
+    after(utils.truncateTables);
+
+    it('should throw 403 error if API Key is absent', async () => {
+        const res = await chai.request(app).post(`/api/submissions`);
+
+        expect(res.status).to.equal(403);
+        expect(res.body.message).to.equal('No API Key in request');
+    });
+
+    it('should throw 404 error if GET request is made', async () => {
+        const res = await chai.request(app).get(`/api/submissions`).set({
+            Authorization: 'Bearer 7718330d2794406c980bdbded6c9dc1d',
+            Accept: 'application/json'
+        });
+
+        expect(res.status).to.equal(404);
+    });
+
+    it('should throw 400 error if correct params are not sent along with the POST request', async () => {
+        const res = await chai.request(app).post(`/api/submissions`).set({
+            Authorization: 'Bearer 7718330d2794406c980bdbded6c9dc1d',
+            Accept: 'application/json'
+        }).send({});
+
+        expect(res.status).to.equal(400);
+        expect(res.body.err.message).to.equal('"lang" is required');
+    });
+
+    it('should throw error for incorrect language', async () => {
+        const params = {
+            source: (new Buffer(source).toString('base64')),
+            lang: 'prabal',
+            mode: 'sync',
+            timelimit: 1,
+            testcases
+        };
+
+        const res = await chai.request(app).post(`/api/submissions`).set({
+            Authorization: 'Bearer 7718330d2794406c980bdbded6c9dc1d',
+            Accept: 'application/json'
+        }).send(params);
+
+        // TODO WRONG, didn't throw error
+        expect(res.body.result).to.equal(expectedResult);
+        expect(res.status).to.equal(200);
+    });
+
+    it('should throw error for source missing', async () => {
+        const params = {
+            lang: 'prabal',
+            mode: 'sync',
+            timelimit: 1,
+            testcases
+        };
+
+        const res = await chai.request(app).post(`/api/submissions`).set({
+            Authorization: 'Bearer 7718330d2794406c980bdbded6c9dc1d',
+            Accept: 'application/json'
+        }).send(params);
+
+        expect(res.status).to.equal(400);
+        expect(res.body.err.message).to.equal('"source" is required');
+    });
+
+    it('should throw 400 error for incorrect mode ', async () => {
+        const params = {
+            source: (new Buffer(source).toString('base64')),
+            lang: 'cpp',
+            mode: 'incorrect',
+            timelimit: 1,
+            testcases
+        };
+
+        const res = await chai.request(app).post(`/api/submissions`).set({
+            Authorization: 'Bearer 7718330d2794406c980bdbded6c9dc1d',
+            Accept: 'application/json'
+        }).send(params);
+
+        expect(res.status).to.equal(400);
+        expect(res.body.err.message).to.equal('"mode" must be one of [sync, callback, poll]');
+    });
+
+    it('should return correct result in sync mode ', async () => {
+        const params = {
+            source: (new Buffer(source).toString('base64')),
+            lang: 'cpp',
+            mode: 'sync',
+            timelimit: 1,
+            testcases
+        };
+
+        const res = await chai.request(app).post(`/api/submissions`).set({
+            Authorization: 'Bearer 7718330d2794406c980bdbded6c9dc1d',
+            Accept: 'application/json'
+        }).send(params);
+
+        expect(res.body.result).to.equal(expectedResult);
+        expect(res.status).to.equal(200);
+    });
+
+
+    it('should return correct submission.id in poll mode', async () => {
+        const params = {
+            source: (new Buffer(source).toString('base64')),
+            lang: 'cpp',
+            mode: 'poll',
+            timelimit: 1,
+            testcases
+        };
+
+        const res = await chai.request(app).post(`/api/submissions`).set({
+            Authorization: 'Bearer 7718330d2794406c980bdbded6c9dc1d',
+            Accept: 'application/json'
+        }).send(params);
+
+
+        // there is a delay of 1000 for onSuccess, so setting 2000ms delay here.
+        await delay(2000);
+        const submission = await DB.submissions.findById(res.body.id);
+
+        expect(res.body.id).to.exist;
+        expect(res.status).to.equal(200);
+        expect(submission.results.result).to.equal(expectedResult);
+    });
+
+    it('should return id and send result to callback url in callback mode', async () => {
+        const params = {
+            source: (new Buffer(source).toString('base64')),
+            lang: 'cpp',
+            mode: 'callback',
+            callback: 'http://localhost:2405',
+            timelimit: 1,
+            testcases
+        };
+
+        const res = await chai.request(app).post(`/api/submissions`).set({
+            Authorization: 'Bearer 7718330d2794406c980bdbded6c9dc1d',
+            Accept: 'application/json'
+        }).send(params);
+
+        let resultFromCallBack;
+
+        // Mock server for callback
+        const app2 = express();
+        app2.use(express.json());
+        const router = Router();
+        app2.listen(2405, () => {
+            router.post('/', (req, res) => {
+                resultFromCallBack = req.body;
+            });
+            app2.use('/', router);
+        });
+
+        await delay(2000);
+
+        expect(res.body.id).to.exist;
+        expect(res.status).to.equal(200);
+        expect(resultFromCallBack.result).to.equal(expectedResult);
+    });
+});