forked from hkc/mastoposter
Compare commits
No commits in common. "a22eac0c6fa0c0f162062628fb70b1391db98f04" and "2e3cd69f6a3453ea50907ec747a93176ab71d48d" have entirely different histories.
a22eac0c6f
...
2e3cd69f6a
|
@ -64,8 +64,8 @@ async def listen(
|
||||||
source: Callable[..., AsyncGenerator[Status, None]],
|
source: Callable[..., AsyncGenerator[Status, None]],
|
||||||
drains: List[FilteredIntegration],
|
drains: List[FilteredIntegration],
|
||||||
user: str,
|
user: str,
|
||||||
/,
|
|
||||||
replies_to_other_accounts_should_not_be_skipped: bool = False,
|
replies_to_other_accounts_should_not_be_skipped: bool = False,
|
||||||
|
/,
|
||||||
**kwargs,
|
**kwargs,
|
||||||
):
|
):
|
||||||
logger.info("Starting listening...")
|
logger.info("Starting listening...")
|
||||||
|
@ -114,10 +114,6 @@ 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:
|
||||||
|
@ -150,20 +146,14 @@ def main():
|
||||||
"wss://{}/api/v1/streaming".format(conf["main"]["instance"]),
|
"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[
|
replies_to_other_accounts_should_not_be_skipped=conf[
|
||||||
"main"
|
"main"
|
||||||
].getboolean(
|
].getboolean(
|
||||||
"replies_to_other_accounts_should_not_be_skipped", False
|
"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=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),
|
||||||
|
|
Loading…
Reference in New Issue