From a29bca7361c0151803b84b084ad397a02122be79 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kevin=20Midb=C3=B8e?= Date: Sun, 12 Aug 2018 23:59:26 +0200 Subject: [PATCH] Controller now expects three parameters for posting to addMagnet; magnet, name and tmdb_id. --- seasoned_api/src/pirate/pirateRepository.js | 12 +++++++++++- .../src/webserver/controllers/pirate/addMagnet.js | 4 +++- 2 files changed, 14 insertions(+), 2 deletions(-) diff --git a/seasoned_api/src/pirate/pirateRepository.js b/seasoned_api/src/pirate/pirateRepository.js index e0c2e95..9f46493 100644 --- a/seasoned_api/src/pirate/pirateRepository.js +++ b/seasoned_api/src/pirate/pirateRepository.js @@ -3,6 +3,8 @@ const http = require('http'); const { URL } = require('url'); const PythonShell = require('python-shell'); +const establishedDatabase = require('src/database/database'); + function getMagnetFromURL(url) { return new Promise((resolve, reject) => { const options = new URL(url); @@ -66,10 +68,18 @@ async function AddMagnet(magnet) { if (err) { /* eslint-disable no-console */ console.log(err); - reject(Error('Enable to add torrent', err)) + reject(Error('Enable to add torrent', err)) } /* eslint-disable no-console */ console.log('result/error:', err, results); + + database = establishedDatabase; + insert_query = "INSERT INTO requested_torrent(magnet,torrent_name,tmdb_id) \ + VALUES (?,?,?)"; + + let response = await database.run(insert_query, [magnet, name, tmdb_id])); + console.log('Response from requsted_torrent insert: ' + response); + resolve({ success: true }); })); } diff --git a/seasoned_api/src/webserver/controllers/pirate/addMagnet.js b/seasoned_api/src/webserver/controllers/pirate/addMagnet.js index ed6f7a3..e46988a 100644 --- a/seasoned_api/src/webserver/controllers/pirate/addMagnet.js +++ b/seasoned_api/src/webserver/controllers/pirate/addMagnet.js @@ -10,8 +10,10 @@ const PirateRepository = require('src/pirate/pirateRepository'); function addMagnet(req, res) { const magnet = req.body.magnet; + const name = req.body.name; + const tmdb_id = req.body.tmdb_id; - PirateRepository.AddMagnet(magnet) + PirateRepository.AddMagnet(magnet, name, tmdb_id) .then((result) => { res.send(result); })