mastoposter/__main__.py

@@ -64,8 +64,8 @@ async def listen(
     source: Callable[..., AsyncGenerator[Status, None]],
     drains: List[FilteredIntegration],
     user: str,
-    /,
     replies_to_other_accounts_should_not_be_skipped: bool = False,
+    /,
     **kwargs,
 ):
     logger.info("Starting listening...")
@@ -114,10 +114,6 @@ def main():
         "--single-status", nargs="?", type=str,
         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()
 
     if not args.config:
@@ -150,20 +146,14 @@ def main():
         "wss://{}/api/v1/streaming".format(conf["main"]["instance"]),
     )
 
+    source = websocket_source
+    source_params = dict(
+        url=url,
         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_params = dict(
-        url=url,
-        replies_to_other_accounts_should_not_be_skipped=(
-                replies_to_other_accounts_should_not_be_skipped),
+        ),
         reconnect=conf["main"].getboolean("auto_reconnect", False),
         reconnect_delay=conf["main"].getfloat("reconnect_delay", 1.0),
         connect_timeout=conf["main"].getfloat("connect_timeout", 60.0),