Search basics

package.json

@@ -20,7 +20,7 @@
     "eslint": "^5.15.1"
   },
   "dependencies": {
-    "leetx": "0.0.3",
-    "request": "^2.88.0"
+    "request": "^2.88.0",
+    "torrent-search-api": "^2.0.9"
   }
 }

scripts/makeResponse.js

@@ -1,3 +1,5 @@
+const tsa = require('torrent-search-api')
+tsa.enableProvider('ThePirateBay')
 // Make a response e
 
 //Check if can be responded to
@@ -17,6 +19,15 @@ exports.getPredicate = msg=>{
     return pred.join(" ")
 }
 
-exports.magnet = searchterm=>{
-
+exports.magnet = async searchterm=>{
+    console.log(`Search for:${searchterm}`)
+    let result = await tsa.search(searchterm,5)
+    let resultString=''
+    for(let i=0;i<3;i++){
+        let magnet = await tsa.getMagnet(result[i]) || ' '
+        resultString = resultString + `*${result[i].title.replace(/[\[\]]/g,'')}* - ${magnet}\n`
+    }
+    console.log(resultString)
+    //console.log(await tsa.getMagnet(result[0]))
+    return resultString
 }

scripts/process.js

@@ -1,12 +1,12 @@
 // Obtain a sendMessage Object
 const makeResponse = require('./makeResponse')
 
-module.exports = (messageObject)=>{
+module.exports = async (messageObject)=>{
     if(makeResponse.canRespond(messageObject.text)){
         console.log(makeResponse.getCommand(messageObject.text))
         return {
             "chat_id": messageObject.from.id,
-            "text": makeResponse.getPredicate(messageObject.text),
+            "text": await makeResponse.magnet( makeResponse.getPredicate(messageObject.text)),
             "parse_mode": "Markdown",
             "reply_to_message_id": messageObject.message_id
         }

scripts/respond.js

@@ -3,9 +3,9 @@
 const process = require('./process')
 const request = require('request')
 
-module.exports.call = (base,updateObject)=>{
+module.exports.call = async (base,updateObject)=>{
     if('message' in updateObject){
-        let responseObject = process(updateObject.message)
+        let responseObject = await process(updateObject.message)
         //console.log(process.process(updateObject.message))
         if(responseObject)
         {
@@ -15,7 +15,7 @@ module.exports.call = (base,updateObject)=>{
                 "body":responseObject
             },(err,res,body)=>{
                 if(err) console.log(err)
-                if(body.ok) console.log("Successfully sent")
+                if(body.ok) console.log(`Successfully sent: ${body.result[0].message.text}`)
             })
         }
     }