Implemented unit tests

0xvj · 0xvj · commit c75e18596a2a · 2022-08-20T18:16:29.000+05:30
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -4,7 +4,7 @@
   "description": "API for videoodyssee frontend",
   "main": "server.js",
   "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1"
+    "test": "jest --silent"
   },
   "repository": {
     "type": "git",
@@ -24,6 +24,11 @@
     "express": "^4.18.1",
     "morgan": "^1.10.0",
     "sequelize": "^6.21.3",
-    "sqlite3": "^5.0.11"
+    "sqlite3": "^5.0.11",
+    "supertest": "^6.2.4"
+  },
+  "devDependencies": {
+    "axios-mock-adapter": "^1.21.2",
+    "jest": "^28.1.3"
   }
 }
diff --git a/routes/pipeline.js b/routes/pipeline.js
@@ -24,7 +24,7 @@ router.post('/trigger', async (req, res, next) => {
 
         if (!title || !event || !language || !date || !url || !name || !email)
             throw { err_message: "Missing some required fields !", err_code: 406 }
-        
+        req.body.status = "pending";
         video = await db.Video.create(req.body);
         const response = await funcs.triggerPipeline(video.dataValues);
         if (response.status != 202)
diff --git a/server.js b/server.js
@@ -24,6 +24,11 @@ app.use((err, req, res, next) => {
 	else return funcs.sendError(res, err.err_message || err, err.err_code);
 });
 
-app.listen(process.env.PORT,()=>{
+const server = app.listen(process.env.PORT,()=>{
     console.log(`Listening at port ${process.env.PORT}`);
-})
+})
+
+module.exports = {
+	app,
+	server,
+}
diff --git a/tests/funcs.test.js b/tests/funcs.test.js
@@ -0,0 +1,22 @@
+require('dotenv').config()
+const { triggerPipeline, instance } = require('../utils/funcs');
+const MockAdapter = require("axios-mock-adapter");
+const mock = new MockAdapter(instance);
+mock.onPost().reply(209, {
+    message: 'Request to schedule pipeline processing-pipeline accepted'
+});
+
+
+
+it("triggerPipeline function", async () => {
+    const data = {
+        id: 1,
+        title: 'title',
+        subtitle: 'subtile',
+        url: 'http://techslides.com/demos/sample-videos/small.mp4',
+        name: 'vijay',
+        email: 'vijay@gmail.com'
+    }
+    const response = await triggerPipeline(data);
+    expect(response.data.message).toContain('accepted');
+});
diff --git a/tests/routes.test.js b/tests/routes.test.js
@@ -0,0 +1,41 @@
+const { app, server } = require('../server');
+const request = require('supertest');
+require('dotenv').config()
+const { instance } = require('../utils/funcs');
+const MockAdapter = require("axios-mock-adapter");
+const { response } = require('express');
+const mock = new MockAdapter(instance);
+mock.onPost().reply(209, {
+    message: 'Request to schedule pipeline processing-pipeline accepted'
+});
+
+
+
+describe('API routes', function () {
+    afterAll(done => {
+        server.close();
+        done();
+    });
+
+    it('triggers pipeline', async function () {
+        const res = await request(app)
+            .post('/pipeline/trigger')
+            .set('Accept', 'application/json')
+            .set('Content-Type', 'application/json')
+            .send({
+                title: 'title',
+                event:'Freifunk summit',
+                date:'21-01-2022',
+                language:'German',
+                subtitle: 'subtile',
+                url: 'http://techslides.com/demos/sample-videos/small.mp4',
+                name: 'vijay',
+                email: 'vijay@gmail.com'
+            });
+        expect(res.body.message).toContain('accepted');
+
+    });
+
+
+
+});
diff --git a/utils/funcs.js b/utils/funcs.js
@@ -61,4 +61,5 @@ module.exports ={
     sendError,
     sendSuccess,
 	triggerPipeline,
+    instance,
 }

Original file line number	Diff line number	Diff line change
`@@ -61,4 +61,5 @@ module.exports ={`
`61`	`61`	`sendError,`
`62`	`62`	`sendSuccess,`
`63`	`63`	`triggerPipeline,`
	`64`	`+ instance,`
`64`	`65`	`}`