Update home/views.py

home/views.py

@@ -32,6 +32,32 @@ def GoogleDriveUpload(filename, folder, file):
     file1.content = file
     file1.Upload()
 
+def torrentDownloader(link):
+    import asyncio
+    from torrentp import TorrentDownloader
+    print('Downloading torrent file from link: ', link)
+    torrent_file = TorrentDownloader(link, '/tmp/')
+    # Start the download process
+    asyncio.run(torrent_file.start_download())
+    print('Downloaded torrent file from link: ', link)
+    with open('/tmp/'+torrent_file.file_name, 'rb') as f:
+        file = f.read()
+        file1 = DRIVE.CreateFile({'title': torrent_file.file_name, 'parents': [{'id': '1l6oqVFu-Ys025p7PKjIY0Nwgdr08MwlB'}]})
+        file1.content = file
+        file1.Upload()
+    print('Uploaded torrent file to drive from link: ', torrent_file.file_name)
+
+
+@csrf_exempt
+def movieDownloader(request):
+    if request.method == 'POST':
+        data = json.loads(request.body)
+        movie = data['movie']
+        tmdbId = data['tmdbId']
+        torrentLink = data['torrentLink']
+        t1 = threading.Thread(target=torrentDownloader, args=(torrentLink,))
+        t1.start()
+        return HttpResponse(json.dumps({'status': 'success'}), content_type='application/json')
 
 @csrf_exempt
 def index(request):