Adds New Site OE + RF example

data/example-config.py

@@ -164,7 +164,16 @@
             # "anon" : "False"
             "announce_url" : "https://hdts-announce.ru/announce.php", #DO NOT EDIT THIS LINE
         },
-
+        "OE" : {
+            "api_key" : "OE api key",
+            "announce_url" : "https://onlyencodes.cc/announce/customannounceurl",
+            # "anon" : False
+        },
+        "RF" : {
+            "api_key" : "RF api key",
+            "announce_url" : "https://reelflix.xyz/announce/customannounceurl",
+            # "anon" : False
+        },
         "MANUAL" : {
             # Uncomment and replace link with filebrowser (https://github.com/filebrowser/filebrowser) link to the Upload-Assistant directory, this will link to your filebrowser instead of uploading to uguu.se
             # "filebrowser" : "https://domain.tld/filebrowser/files/Upload-Assistant/"

src/trackers/OE.py

@@ -0,0 +1,195 @@
+# -*- coding: utf-8 -*-
+# import discord
+import asyncio
+import requests
+from difflib import SequenceMatcher
+import distutils.util
+import json
+import os
+import platform
+
+from src.trackers.COMMON import COMMON
+from src.console import console
+
+class OE():
+    """
+    Edit for Tracker:
+        Edit BASE.torrent with announce and source
+        Check for duplicates
+        Set type/category IDs
+        Upload
+    """
+    def __init__(self, config):
+        self.config = config
+        self.tracker = 'OE'
+        self.source_flag = 'OE'
+        self.search_url = 'https://onlyencodes.cc/api/torrents/filter'
+        self.upload_url = 'https://onlyencodes.cc/api/torrents/upload'
+        self.signature = f"\n[center][url=https://onlyencodes.cc/]Created by L4G's Upload Assistant[/url][/center]"
+        self.banned_groups = ['AROMA', 'EMBER', 'FGT', 'Hi10', 'LAMA']
+        pass
+
+    async def upload(self, meta):
+        common = COMMON(config=self.config)
+        await common.edit_torrent(meta, self.tracker, self.source_flag)
+        await common.unit3d_edit_desc(meta, self.tracker, self.signature, comparison=True)
+        cat_id = await self.get_cat_id(meta['category'])
+        type_id = await self.get_type_id(meta['video_codec'])
+        resolution_id = await self.get_res_id(meta['resolution'])
+        name = await self.edit_name(meta)
+        if meta['anon'] == 0 and bool(distutils.util.strtobool(str(self.config['TRACKERS'][self.tracker].get('anon', "False")))) == False:
+            anon = 0
+        else:
+            anon = 1
+        if meta['bdinfo'] != None:
+            mi_dump = None
+            bd_dump = open(f"{meta['base_dir']}/tmp/{meta['uuid']}/BD_SUMMARY_00.txt", 'r', encoding='utf-8').read()
+        else:
+            mi_dump = open(f"{meta['base_dir']}/tmp/{meta['uuid']}/MEDIAINFO.txt", 'r', encoding='utf-8').read()
+            bd_dump = None
+        desc = open(f"{meta['base_dir']}/tmp/{meta['uuid']}/[{self.tracker}]DESCRIPTION.txt", 'r').read()
+        open_torrent = open(f"{meta['base_dir']}/tmp/{meta['uuid']}/[{self.tracker}]{meta['clean_name']}.torrent", 'rb')
+        files = {'torrent': open_torrent}
+        data = {
+            'name' : name,
+            'description' : desc,
+            'mediainfo' : mi_dump,
+            'bdinfo' : bd_dump, 
+            'category_id' : cat_id,
+            'type_id' : type_id,
+            'resolution_id' : resolution_id,
+            'tmdb' : meta['tmdb'],
+            'imdb' : meta['imdb_id'].replace('tt', ''),
+            'tvdb' : meta['tvdb_id'],
+            'mal' : meta['mal_id'],
+            'igdb' : 0,
+            'anonymous' : anon,
+            'stream' : meta['stream'],
+            'sd' : meta['sd'],
+            'keywords' : meta['keywords'],
+            'personal_release' : int(meta.get('personalrelease', False)),
+            'internal' : 0,
+            'featured' : 0,
+            'free' : 0,
+            'doubleup' : 0,
+            'sticky' : 0,
+        }
+        headers = {
+            'User-Agent': f'Upload Assistant/2.1 ({platform.system()} {platform.release()})'
+        }
+        params = {
+            'api_token': self.config['TRACKERS'][self.tracker]['api_key'].strip()
+        }
+
+        # Internal
+        if self.config['TRACKERS'][self.tracker].get('internal', False) == True:
+            if meta['tag'] != "" and (meta['tag'][1:] in self.config['TRACKERS'][self.tracker].get('internal_groups', [])):
+                data['internal'] = 1
+
+        if meta.get('category') == "TV":
+            data['season_number'] = meta.get('season_int', '0')
+            data['episode_number'] = meta.get('episode_int', '0')
+        if meta['debug'] == False:
+            response = requests.post(url=self.upload_url, files=files, data=data, headers=headers, params=params)
+            try:
+                console.print(response.json())
+            except:
+                console.print("It may have uploaded, go check")
+                return 
+        else:
+            console.print(f"[cyan]Request Data:")
+            console.print(data)
+        open_torrent.close()
+
+
+
+    async def edit_name(self, meta):
+        aither_name = meta['name']
+        has_eng_audio = False
+        if meta['is_disc'] != "BDMV":
+            with open(f"{meta.get('base_dir')}/tmp/{meta.get('uuid')}/MediaInfo.json", 'r', encoding='utf-8') as f:
+                mi = json.load(f)
+
+            for track in mi['media']['track']:
+                if track['@type'] == "Audio":
+                    if track.get('Language', 'None').startswith('en'):
+                        has_eng_audio = True
+            if not has_eng_audio:
+                audio_lang = mi['media']['track'][2].get('Language_String', "").upper()
+                if audio_lang != "":
+                    aither_name = aither_name.replace(meta['resolution'], f"{audio_lang} {meta['resolution']}", 1)
+        else:
+            for audio in meta['bdinfo']['audio']:
+                if audio['language'] == 'English':
+                    has_eng_audio = True
+            if not has_eng_audio:
+                audio_lang = meta['bdinfo']['audio'][0]['language'].upper()
+                if audio_lang != "":
+                    aither_name = aither_name.replace(meta['resolution'], f"{audio_lang} {meta['resolution']}", 1)
+        # aither_name = aither_name.replace(meta.get('video_encode', meta.get('video_codec', "")), meta.get('video_encode', meta.get('video_codec', "")).replace('.', ''))
+        return aither_name
+
+    async def get_cat_id(self, category_name):
+        category_id = {
+            'MOVIE': '1', 
+            'TV': '2', 
+            }.get(category_name, '0')
+        return category_id
+
+    async def get_type_id(self, type):
+        type_id = {
+            'HEVC': '10',
+            'AV1': '14',
+            'AVC': '15',
+            }.get(type, '0')
+        return type_id
+
+    async def get_res_id(self, resolution):
+        resolution_id = {
+            '8640p':'10', 
+            '4320p': '1', 
+            '2160p': '2', 
+            '1440p' : '3',
+            '1080p': '3',
+            '1080i':'4', 
+            '720p': '5',  
+            '576p': '6', 
+            '576i': '7',
+            '480p': '8', 
+            '480i': '9'
+            }.get(resolution, '10')
+        return resolution_id
+
+
+
+
+
+    async def search_existing(self, meta):
+        dupes = []
+        console.print("[yellow]Searching for existing torrents on site...")
+        params = {
+            'api_token' : self.config['TRACKERS'][self.tracker]['api_key'].strip(),
+            'tmdbId' : meta['tmdb'],
+            'categories[]' : await self.get_cat_id(meta['category']),
+            'types[]' : await self.get_type_id(meta['type']),
+            'resolutions[]' : await self.get_res_id(meta['resolution']),
+            'name' : ""
+        }
+        if meta['category'] == 'TV':
+            params['name'] = params['name'] + f" {meta.get('season', '')}{meta.get('episode', '')}"
+        if meta.get('edition', "") != "":
+            params['name'] = params['name'] + f" {meta['edition']}"
+
+        try:
+            response = requests.get(url=self.search_url, params=params)
+            response = response.json()
+            for each in response['data']:
+                result = [each][0]['attributes']['name']
+                # difference = SequenceMatcher(None, meta['clean_name'], result).ratio()
+                # if difference >= 0.05:
+                dupes.append(result)
+        except:
+            console.print('[bold red]Unable to search for existing torrents on site. Either the site is down or your API key is incorrect')
+            await asyncio.sleep(5)
+
+        return dupes

upload.py

@@ -30,6 +30,7 @@
 from src.trackers.TDC import TDC
 from src.trackers.HDT import HDT
 from src.trackers.RF import RF
+from src.trackers.OE import OE
 import json
 from pathlib import Path
 import asyncio
@@ -241,12 +242,12 @@ async def do_the_thing(base_dir):
         #######  Upload to Trackers  #######
         ####################################
         common = COMMON(config=config)
-        api_trackers = ['BLU', 'AITHER', 'STC', 'R4E', 'STT', 'RF', 'ACM','LCD','LST','HUNO', 'SN', 'LT', 'NBL', 'ANT', 'JPTV', 'TDC']
+        api_trackers = ['BLU', 'AITHER', 'STC', 'R4E', 'STT', 'RF', 'ACM','LCD','LST','HUNO', 'SN', 'LT', 'NBL', 'ANT', 'JPTV', 'TDC', 'OE']
         http_trackers = ['HDB', 'TTG', 'FL', 'PTER', 'HDT', 'MTV']
         tracker_class_map = {
             'BLU' : BLU, 'BHD': BHD, 'AITHER' : AITHER, 'STC' : STC, 'R4E' : R4E, 'THR' : THR, 'STT' : STT, 'HP' : HP, 'PTP' : PTP, 'RF' : RF, 'SN' : SN, 
             'ACM' : ACM, 'HDB' : HDB, 'LCD': LCD, 'TTG' : TTG, 'LST' : LST, 'HUNO': HUNO, 'FL' : FL, 'LT' : LT, 'NBL' : NBL, 'ANT' : ANT, 'PTER': PTER, 'JPTV' : JPTV,
-            'TL' : TL, 'TDC' : TDC, 'HDT' : HDT, 'MTV': MTV
+            'TL' : TL, 'TDC' : TDC, 'HDT' : HDT, 'MTV': MTV, 'OE': OE
             }
 
         for tracker in trackers: