Add connect-timeout config option

Also reformatting because I forgot

config.ini

@@ -32,12 +32,20 @@ user = auto
 # address bar while you have that list open)
 list = 1
 
+# Allow replies to be boosted as well
+# By default replies will be ignores unless it's a reply to your post
+# replies_to_other_accounts_should_not_be_skipped = yes
+
 # Should we automatically reconnect to the streaming socket?
 # That option exists because it's not really a big deal when crossposter runs
 # as a service and restarts automatically by the service manager.
 auto-reconnect = yes
 reconnect-delay = 1.0
 
+# Change websocket connection opening timeout.
+# It may be useful when initial server connection may take a long time.
+connect-timeout = 60.0
+
 # Number of retries in case request fails. Applies globally
 # Can be changed on per-module basis
 http-retries = 5

mastoposter/__init__.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from asyncio import gather
 from configparser import ConfigParser
 from logging import getLogger

mastoposter/__main__.py

@@ -64,6 +64,7 @@ async def listen(
     source: Callable[..., AsyncGenerator[Status, None]],
     drains: List[FilteredIntegration],
     user: str,
+    replies_to_other_accounts_should_not_be_skipped: bool = False,
     /,
     **kwargs,
 ):
@@ -93,7 +94,7 @@ async def listen(
         if (
             status.in_reply_to_account_id is not None
             and status.in_reply_to_account_id != user
-        ):
+        ) and not replies_to_other_accounts_should_not_be_skipped:
             logger.info(
                 "Skipping post %s because it's a reply to another person",
                 status.uri,
@@ -147,8 +148,14 @@ def main():
             modules,
             user_id,
             url=url,
+            replies_to_other_accounts_should_not_be_skipped=conf[
+                "main"
+            ].getboolean(
+                "replies_to_other_accounts_should_not_be_skipped", False
+            ),
             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),
             list=conf["main"]["list"],
             access_token=conf["main"]["token"],
         )

mastoposter/filters/__init__.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from logging import getLogger
 from typing import List
 

mastoposter/filters/base.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from abc import ABC, abstractmethod
 from configparser import ConfigParser, SectionProxy
 from typing import ClassVar, Dict, NamedTuple, Type

mastoposter/filters/boost.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from configparser import SectionProxy
 from fnmatch import fnmatch
 from typing import List

mastoposter/filters/combined.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from configparser import ConfigParser, SectionProxy
 from typing import Callable, ClassVar, Dict, List, Sequence
 from mastoposter.filters.base import BaseFilter, FilterInstance

mastoposter/filters/media.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from configparser import SectionProxy
 from typing import Literal, Set
 from mastoposter.filters.base import BaseFilter

mastoposter/filters/mention.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from configparser import SectionProxy
 from re import Pattern, compile as regexp
 from typing import ClassVar, Set

mastoposter/filters/spoiler.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from configparser import SectionProxy
 from re import Pattern, compile as regexp
 from mastoposter.filters.base import BaseFilter

mastoposter/filters/text.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from configparser import SectionProxy
 from re import Pattern, compile as regexp
 from typing import Optional, Set

mastoposter/filters/visibility.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from configparser import SectionProxy
 from typing import Set
 from mastoposter.filters.base import BaseFilter

mastoposter/integrations/__init__.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from typing import List, NamedTuple
 from mastoposter.filters.base import FilterInstance
 

mastoposter/integrations/base.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from abc import ABC, abstractmethod
 from configparser import SectionProxy
 from typing import Optional

mastoposter/integrations/discord/__init__.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from configparser import SectionProxy
 from logging import getLogger
 from typing import List, Optional
@@ -51,9 +52,11 @@ class DiscordIntegration(BaseIntegration):
                 "content": content,
                 "username": username,
                 "avatar_url": avatar_url,
-                "embeds": [embed.asdict() for embed in embeds]
+                "embeds": (
-                if embeds is not None
+                    [embed.asdict() for embed in embeds]
-                else [],
+                    if embeds is not None
+                    else []
+                ),
             }
 
             logger.debug("Executing webhook with %r", json)

mastoposter/integrations/discord/types.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from dataclasses import asdict, dataclass
 from datetime import datetime
 from typing import Any, Callable, Dict, List, Optional

mastoposter/integrations/telegram.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from configparser import SectionProxy
 from dataclasses import dataclass
 from logging import getLogger

mastoposter/sources.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from asyncio import exceptions, sleep
 from json import loads
 from logging import getLogger
@@ -23,7 +24,8 @@ logger = getLogger("sources")
 
 
 async def websocket_source(
-    url: str, reconnect: bool = False, reconnect_delay: float = 1.0, **params
+    url: str, reconnect: bool = False, reconnect_delay: float = 1.0,
+    connect_timeout: float = 60.0, **params
 ) -> AsyncGenerator[Status, None]:
     from websockets.client import connect
     from websockets.exceptions import WebSocketException
@@ -36,7 +38,7 @@ async def websocket_source(
     while True:
         try:
             logger.info("attempting to connect to %s", public_url)
-            async with connect(url, open_timeout=60) as ws:
+            async with connect(url, open_timeout=connect_timeout) as ws:
                 logger.info("Connected to WebSocket")
                 while (msg := await ws.recv()) is not None:
                     event = loads(msg)

mastoposter/text/__init__.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from typing import Callable, Iterable, Literal, Optional
 from bs4.element import Tag, PageElement
 

mastoposter/text/html.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from bs4 import NavigableString
 from mastoposter.text import (
     nodes_process,

mastoposter/types.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from dataclasses import dataclass, field, fields
 from datetime import datetime
 from typing import Any, Callable, Optional, List, Literal, TypeVar

mastoposter/utils.py

@@ -12,6 +12,7 @@ but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 """
+
 from configparser import ConfigParser
 from logging import getLogger