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