Controller now expects three parameters for posting to addMagnet; magnet, name and tmdb_id.

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

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