mirror of
https://github.com/RYGhub/royalnet.git
synced 2024-11-23 19:44:20 +00:00
Reformat code
This commit is contained in:
parent
0c5e07c6b9
commit
207c2d4dcc
4 changed files with 15 additions and 14 deletions
|
@ -1,14 +1,13 @@
|
||||||
from typing import *
|
|
||||||
|
|
||||||
import logging
|
import logging
|
||||||
import multiprocessing
|
import multiprocessing
|
||||||
import time
|
import time
|
||||||
|
from typing import *
|
||||||
|
|
||||||
import click
|
import click
|
||||||
import toml
|
import toml
|
||||||
|
|
||||||
import royalnet.utils as ru
|
|
||||||
import royalnet.serf as rs
|
import royalnet.serf as rs
|
||||||
|
import royalnet.utils as ru
|
||||||
|
|
||||||
try:
|
try:
|
||||||
import royalnet.serf.telegram as rst
|
import royalnet.serf.telegram as rst
|
||||||
|
@ -124,6 +123,7 @@ def run(config_file: str):
|
||||||
"serf_cfg": serf_cfg,
|
"serf_cfg": serf_cfg,
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
|
|
||||||
processes[f"Serf.{name}"] = ru.RoyalnetProcess(serf_constructor, None)
|
processes[f"Serf.{name}"] = ru.RoyalnetProcess(serf_constructor, None)
|
||||||
log.info(f"Serf.{name}: Enabled")
|
log.info(f"Serf.{name}: Enabled")
|
||||||
|
|
||||||
|
@ -154,6 +154,7 @@ def run(config_file: str):
|
||||||
"constellation_cfg": config["Constellation"],
|
"constellation_cfg": config["Constellation"],
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
|
|
||||||
processes["Constellation"] = ru.RoyalnetProcess(constellation_constructor, None)
|
processes["Constellation"] = ru.RoyalnetProcess(constellation_constructor, None)
|
||||||
|
|
||||||
log.info("Constellation: Enabled")
|
log.info("Constellation: Enabled")
|
||||||
|
|
|
@ -54,15 +54,15 @@ class Config:
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
def from_config(
|
def from_config(
|
||||||
cls, *,
|
cls, *,
|
||||||
name: str,
|
name: str,
|
||||||
address: str,
|
address: str,
|
||||||
port: int,
|
port: int,
|
||||||
secret: str,
|
secret: str,
|
||||||
secure: bool = False,
|
secure: bool = False,
|
||||||
path: str = "/",
|
path: str = "/",
|
||||||
**_,
|
**_,
|
||||||
):
|
):
|
||||||
return cls(
|
return cls(
|
||||||
name=name,
|
name=name,
|
||||||
address=address,
|
address=address,
|
||||||
|
|
|
@ -2,13 +2,13 @@ from .asyncify import asyncify
|
||||||
from .formatters import andformat, underscorize, ytdldateformat, numberemojiformat, ordinalformat
|
from .formatters import andformat, underscorize, ytdldateformat, numberemojiformat, ordinalformat
|
||||||
from .log import init_logging
|
from .log import init_logging
|
||||||
from .multilock import MultiLock
|
from .multilock import MultiLock
|
||||||
|
from .royalnetprocess import RoyalnetProcess
|
||||||
from .royaltyping import JSON
|
from .royaltyping import JSON
|
||||||
from .sentry import init_sentry, sentry_exc, sentry_wrap, sentry_async_wrap
|
from .sentry import init_sentry, sentry_exc, sentry_wrap, sentry_async_wrap
|
||||||
from .sleep_until import sleep_until
|
from .sleep_until import sleep_until
|
||||||
from .strip_tabs import strip_tabs
|
from .strip_tabs import strip_tabs
|
||||||
from .taskslist import TaskList
|
from .taskslist import TaskList
|
||||||
from .urluuid import to_urluuid, from_urluuid
|
from .urluuid import to_urluuid, from_urluuid
|
||||||
from .royalnetprocess import RoyalnetProcess
|
|
||||||
|
|
||||||
__all__ = [
|
__all__ = [
|
||||||
"asyncify",
|
"asyncify",
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
from typing import *
|
|
||||||
import dataclasses
|
import dataclasses
|
||||||
import multiprocessing
|
import multiprocessing
|
||||||
|
from typing import *
|
||||||
|
|
||||||
|
|
||||||
@dataclasses.dataclass()
|
@dataclasses.dataclass()
|
||||||
|
|
Loading…
Reference in a new issue