Przeglądaj źródła

Add final type hint to synapse.server. (#15035)

tags/v1.78.0rc1
Patrick Cloke 1 rok temu
committed by GitHub
rodzic
commit
733531ee3e
Nie znaleziono w bazie danych klucza dla tego podpisu ID klucza GPG: 4AEE18F83AFDEB23
7 zmienionych plików z 11 dodań i 12 usunięć
  1. +1
    -0
      changelog.d/15035.misc
  2. +0
    -3
      mypy.ini
  3. +1
    -1
      synapse/handlers/room.py
  4. +5
    -7
      synapse/server.py
  5. +2
    -0
      synapse/storage/_base.py
  6. +1
    -0
      synapse/storage/database.py
  7. +1
    -1
      synapse/storage/databases/main/events.py

+ 1
- 0
changelog.d/15035.misc Wyświetl plik

@@ -0,0 +1 @@
Improve type hints.

+ 0
- 3
mypy.ini Wyświetl plik

@@ -53,9 +53,6 @@ warn_unused_ignores = False
[mypy-synapse.util.caches.treecache]
disallow_untyped_defs = False

[mypy-synapse.server]
disallow_untyped_defs = False

[mypy-synapse.storage.database]
disallow_untyped_defs = False



+ 1
- 1
synapse/handlers/room.py Wyświetl plik

@@ -1076,7 +1076,7 @@ class RoomCreationHandler:
state_map: MutableStateMap[str] = {}
# current_state_group of last event created. Used for computing event context of
# events to be batched
current_state_group = None
current_state_group: Optional[int] = None

def create_event_dict(etype: str, content: JsonDict, **kwargs: Any) -> JsonDict:
e = {"type": etype, "content": content}


+ 5
- 7
synapse/server.py Wyświetl plik

@@ -21,7 +21,7 @@
import abc
import functools
import logging
from typing import TYPE_CHECKING, Any, Callable, Dict, List, Optional, TypeVar, cast
from typing import TYPE_CHECKING, Callable, Dict, List, Optional, TypeVar, cast

from twisted.internet.interfaces import IOpenSSLContextFactory
from twisted.internet.tcp import Port
@@ -144,10 +144,10 @@ if TYPE_CHECKING:
from synapse.handlers.saml import SamlHandler


T = TypeVar("T", bound=Callable[..., Any])
T = TypeVar("T")


def cache_in_self(builder: T) -> T:
def cache_in_self(builder: Callable[["HomeServer"], T]) -> Callable[["HomeServer"], T]:
"""Wraps a function called e.g. `get_foo`, checking if `self.foo` exists and
returning if so. If not, calls the given function and sets `self.foo` to it.

@@ -166,7 +166,7 @@ def cache_in_self(builder: T) -> T:
building = [False]

@functools.wraps(builder)
def _get(self):
def _get(self: "HomeServer") -> T:
try:
return getattr(self, depname)
except AttributeError:
@@ -185,9 +185,7 @@ def cache_in_self(builder: T) -> T:

return dep

# We cast here as we need to tell mypy that `_get` has the same signature as
# `builder`.
return cast(T, _get)
return _get


class HomeServer(metaclass=abc.ABCMeta):


+ 2
- 0
synapse/storage/_base.py Wyświetl plik

@@ -37,6 +37,8 @@ class SQLBaseStore(metaclass=ABCMeta):
per data store (and not one per physical database).
"""

db_pool: DatabasePool

def __init__(
self,
database: DatabasePool,


+ 1
- 0
synapse/storage/database.py Wyświetl plik

@@ -499,6 +499,7 @@ class DatabasePool:
"""

_TXN_ID = 0
engine: BaseDatabaseEngine

def __init__(
self,


+ 1
- 1
synapse/storage/databases/main/events.py Wyświetl plik

@@ -306,7 +306,7 @@ class PersistEventsStore:

# The set of event_ids to return. This includes all soft-failed events
# and their prev events.
existing_prevs = set()
existing_prevs: Set[str] = set()

def _get_prevs_before_rejected_txn(
txn: LoggingTransaction, batch: Collection[str]


Ładowanie…
Anuluj
Zapisz