on [Sreeraj](https://github.com/SVR666) searchX-bot. (task option)

- Stop Duplicates (global and user option)

- Custom upload destination (global, user, and task option)

- Ability to choose token.pickle or service acccount and upload destinations from list with or without buttons (global, user and task option)

- Ability to choose token.pickle or service account and upload destinations from list with or without buttons (global, user and task option)

- Index link support only

for [Bhadoo](https://gitlab.com/GoogleDriveIndex/Google-Drive-Index/-/blob/master/src/worker.js)

- Store RSS data

- Store incompleted task messages

- Store JDownloader settings

- Store config.py file on first build and incase any change occured to it, then next build it will define variables

- Store config.py file on first build and incase any change occurred to it, then next build it will define variables

from config.py instead of database

</details>

**Example**:

- Here I will explain how to use mltb.* which is reference to files you want to work on.

1. First cmd: the input is mltb.mkv so this cmd will work only on mkv videos and the output is mltb.mkv also so all outputs is mkv. `-del` will delete the original media after complete run of the cmd.

2. Second cmd: the input is mltb.video so this cmd will work on all videos and the output is only mltb so the extenstion is same as input files.

2. Second cmd: the input is mltb.video so this cmd will work on all videos and the output is only mltb so the extension is same as input files.

3. Third cmd: the input in mltb.m4a so this cmd will work only on m4a audios and the output is mltb.mp3 so the output extension is mp3.

4. Fourth cmd: the input is mltb.audio so this cmd will work on all audios and the output is mltb.mp3 so the output extension is mp3.

5. FFmpeg Variables in last cmd which is metadata ({title}, {title2}, etc...), you can edit them in usetting

6. Telegram link for small size inputs like photo to set watermark.

- `NAME_SUBSTITUTE` (`Str`): Add word/letter/character/sentense/pattern to remove or replace with other words with sensitive case or without.

- `NAME_SUBSTITUTE` (`Str`): Add word/letter/character/sentence/pattern to remove or replace with other words with sensitive case or without.

**Notes**:

- Before any character you must add `\BACKSLASH`, those are the characters: `\^$.|?*+()[]{}-`

* Example: script/code/s | mirror/leech | tea/ /s | clone | cpu/ | \[mltb\]/mltb | \\text\\/text/s

- Create Sevice Accounts to current project

- Create Service Accounts to current project

- Download Sevice Accounts as accounts folder

- Download Service Accounts as accounts folder

self.is_connected = False

self.error = "JDownloader Credentials not provided!"

return

self.error = "Connecting... Try agin after couple of seconds"

self.error = "Connecting... Try again after couple of seconds"

self._device_name = f"{randint(0, 1000)}@{TgClient.NAME}"

if await path.exists("/JDownloader/logs"):

LOGGER.info(

class RssShutdownException(Exception):

"""This exception should be raised when shutdown is called to stop the montior"""

"""This exception should be raised when shutdown is called to stop the monitor"""

pass

"GDRIVE_ID": "Send Gdrive ID. If you want to use your token.pickle edit using owner/user token from usetting or add mtp: before the id. Example: mtp:F435RGGRDXXXXXX . Timeout: 60 sec",

"INDEX_URL": "Send Index URL. Timeout: 60 sec",

"UPLOAD_PATHS": "Send Dict of keys that have path values. Example: {'path 1': 'remote:rclonefolder', 'path 2': 'gdrive1 id', 'path 3': 'tg chat id', 'path 4': 'mrcc:remote:', 'path 5': b:@username} . Timeout: 60 sec",

"EXCLUDED_EXTENSIONS": "Send exluded extenions separated by space without dot at beginning. Timeout: 60 sec",

"EXCLUDED_EXTENSIONS": "Send excluded extensions separated by space without dot at beginning. Timeout: 60 sec",

"NAME_SUBSTITUTE": r"""Word Subtitions. You can add pattern instead of normal text. Timeout: 60 sec

resutls = await wait_for(gather(*cmds), timeout=60)

if resutls[0][2] != 0:

LOGGER.error(

f"Error while creating sreenshots from video. Path: {video_file}. stderr: {resutls[0][1]}"

f"Error while creating screenshots from video. Path: {video_file}. stderr: {resutls[0][1]}"

)

await rmtree(dirpath, ignore_errors=True)

return False

except:

LOGGER.error(

f"Error while creating sreenshots from video. Path: {video_file}. Error: Timeout some issues with ffmpeg with specific arch!"

f"Error while creating screenshots from video. Path: {video_file}. Error: Timeout some issues with ffmpeg with specific arch!"

)

await rmtree(dirpath, ignore_errors=True)

return False

break

elif duration == lpd:

LOGGER.warning(

f"This file has been splitted with default stream and audio, so you will only see one part with less size from orginal one because it doesn't have all streams and audios. This happens mostly with MKV videos. Path: {f_path}"

f"This file has been splitted with default stream and audio, so you will only see one part with less size from original one because it doesn't have all streams and audios. This happens mostly with MKV videos. Path: {f_path}"

)

break

elif lpd <= 3:

raise DirectDownloadLinkException(f"ERROR: {e.__class__.__name__}") from e

if "url" not in res:

raise DirectDownloadLinkException(

"ERROR: Drive Link not found, Try in your broswer"

"ERROR: Drive Link not found, Try in your browser"

)

if "drive.google.com" in res["url"] or "drive.usercontent.google.com" in res["url"]:

return res["url"]

return drive_link[0]

else:

raise DirectDownloadLinkException(

"ERROR: Drive Link not found, Try in your broswer"

"ERROR: Drive Link not found, Try in your browser"

)

)

return

await query.answer(

"Syncronization Started. JDownloader will get restarted. It takes up to 10 sec!",

"Synchronization Started. JDownloader will get restarted. It takes up to 10 sec!",

show_alert=True,

)

await sync_jdownloader()

await database.update_nzb_config()

elif data[1] == "syncnzb":

await query.answer(

"Syncronization Started. It takes up to 2 sec!", show_alert=True

"Synchronization Started. It takes up to 2 sec!", show_alert=True

)

nzb_options.clear()

await update_nzb_options()

await database.update_nzb_config()

elif data[1] == "syncqbit":

await query.answer(

"Syncronization Started. It takes up to 2 sec!", show_alert=True

"Synchronization Started. It takes up to 2 sec!", show_alert=True

)

qbit_options.clear()

await update_qb_options()

await send_message(message, "This task is not for you!")

return

if not iscoroutinefunction(task.status):

await send_message(message, "The task have finshed the download stage!")

await send_message(message, "The task have finished the download stage!")

return

if await task.status() not in [

MirrorStatus.STATUS_DOWNLOAD,

elif len(msg) in {1, 2}:

msg = f"""Reply to an active Command message which was used to start the download/upload.

if len(args) < 2:

await send_message(

message,

f"{item}. Wrong Input format. Read help message before adding new subcription!",

f"{item}. Wrong Input format. Read help message before adding new subscription!",

)

continue

title = args[0].strip()

if len(args) < 2:

await send_message(

message,

f"{args}. Wrong Input format. You should add number of the items you want to get. Read help message before adding new subcription!",

f"{args}. Wrong Input format. You should add number of the items you want to get. Read help message before adding new subscription!",

)

await update_rss_menu(pre_event)

return