1
0
Fork 0

Add an '--no-skip-replies' argument to override replies_to_other_accounts_should_not_be_skipped option

This commit is contained in:
Vftdan 2024-07-01 18:37:12 +02:00
parent 3076544e38
commit a22eac0c6f
Signed by: vftdan
GPG Key ID: 5D49CE378C2B20C7
1 changed files with 15 additions and 5 deletions

View File

@ -114,6 +114,10 @@ def main():
"--single-status", nargs="?", type=str, "--single-status", nargs="?", type=str,
help="process single status and exit" help="process single status and exit"
) )
parser.add_argument(
"--no-skip-replies", action="store_true",
help="override replies_to_other_accounts_should_not_be_skipped to true"
)
args = parser.parse_args() args = parser.parse_args()
if not args.config: if not args.config:
@ -146,14 +150,20 @@ def main():
"wss://{}/api/v1/streaming".format(conf["main"]["instance"]), "wss://{}/api/v1/streaming".format(conf["main"]["instance"]),
) )
replies_to_other_accounts_should_not_be_skipped = conf[
"main"
].getboolean(
"replies_to_other_accounts_should_not_be_skipped", False
)
if args.no_skip_replies:
replies_to_other_accounts_should_not_be_skipped = True
source = websocket_source source = websocket_source
source_params = dict( source_params = dict(
url=url, url=url,
replies_to_other_accounts_should_not_be_skipped=conf[ replies_to_other_accounts_should_not_be_skipped=(
"main" replies_to_other_accounts_should_not_be_skipped),
].getboolean(
"replies_to_other_accounts_should_not_be_skipped", False
),
reconnect=conf["main"].getboolean("auto_reconnect", False), reconnect=conf["main"].getboolean("auto_reconnect", False),
reconnect_delay=conf["main"].getfloat("reconnect_delay", 1.0), reconnect_delay=conf["main"].getfloat("reconnect_delay", 1.0),
connect_timeout=conf["main"].getfloat("connect_timeout", 60.0), connect_timeout=conf["main"].getfloat("connect_timeout", 60.0),