unapplied yapf

mabuelhagag · Aug 5, 2022 · f3359ea · f3359ea
1 parent 5d80264
commit f3359ea
Show file tree

Hide file tree

Showing 45 changed files with 2 additions and 143 deletions.
diff --git a/opwen_email_client/domain/email/attachment.py b/opwen_email_client/domain/email/attachment.py
@@ -5,7 +5,6 @@
 
 
 class AttachmentEncoder(metaclass=ABCMeta):
-
     @abstractmethod
     def encode(self, content: bytes) -> str:
         raise NotImplementedError  # pragma: no cover

diff --git a/opwen_email_client/domain/email/client.py b/opwen_email_client/domain/email/client.py
@@ -9,7 +9,6 @@
 
 
 class EmailServerClient(metaclass=ABCMeta):
-
     @abstractmethod
     def upload(self, resource_id: str, container: str):
         raise NotImplementedError  # pragma: no cover
@@ -20,7 +19,6 @@ def download(self) -> str:
 
 
 class HttpEmailServerClient(EmailServerClient):
-
     def __init__(self, compression: str, endpoint: str, client_id: str):
         self._compression = compression
         self._endpoint = endpoint
@@ -64,7 +62,6 @@ def download(self):
 
 
 class LocalEmailServerClient(EmailServerClient):
-
     def download(self) -> str:
         root = getenv('OPWEN_REMOTE_ACCOUNT_NAME')
         container = getenv('OPWEN_REMOTE_RESOURCE_CONTAINER')

diff --git a/opwen_email_client/domain/email/sql_store.py b/opwen_email_client/domain/email/sql_store.py
@@ -190,7 +190,6 @@ def is_received_by(cls, email_address):
 
 
 class _SqlalchemyEmailStore(EmailStore):
-
     def __init__(self, page_size: int, database_uri: str, restricted=None):
         super().__init__(restricted)
         self._page_size = page_size
@@ -330,7 +329,6 @@ def sent(self, email_address, page):
 
 
 class SqliteEmailStore(_SqlalchemyEmailStore):
-
     def __init__(self, page_size: int, database_path: str, restricted=None):
         super().__init__(
             page_size=page_size,

diff --git a/opwen_email_client/domain/email/store.py b/opwen_email_client/domain/email/store.py
@@ -9,7 +9,6 @@
 
 
 class EmailStore(metaclass=ABCMeta):
-
     def __init__(self, restricted: Optional[Dict[str, Set[str]]] = None):
         self._restricted = restricted or {}
 

diff --git a/opwen_email_client/domain/email/sync.py b/opwen_email_client/domain/email/sync.py
@@ -28,7 +28,6 @@
 
 
 class Sync(metaclass=ABCMeta):
-
     @abstractmethod
     def upload(self, items: Iterable[T], users: Iterable[User]) -> Iterable[str]:
         raise NotImplementedError  # pragma: no cover

diff --git a/opwen_email_client/domain/email/user_store.py b/opwen_email_client/domain/email/user_store.py
@@ -10,7 +10,6 @@
 
 
 class User(UserMixin):
-
     @property
     @abstractmethod
     def id(self) -> Union[str, int]:
@@ -38,7 +37,6 @@ def active(self) -> bool:
 
 
 class UserStore(metaclass=ABCMeta):
-
     def __init__(self, read: UserReadStore, write: UserWriteStore) -> None:
         self.r = read
         self.w = write

diff --git a/opwen_email_client/util/serialization.py b/opwen_email_client/util/serialization.py
@@ -11,7 +11,6 @@
 
 
 class Serializer(metaclass=ABCMeta):
-
     @abstractmethod
     def serialize(self, obj: T, type_: str = '') -> bytes:
         raise NotImplementedError  # pragma: no cover

diff --git a/opwen_email_client/util/wtforms.py b/opwen_email_client/util/wtforms.py
@@ -17,7 +17,6 @@
 
 
 class CronSchedule:
-
     def __init__(self, message=None):
         self.message = message
 
@@ -34,7 +33,6 @@ def __call__(self, form, field, message=None):
 
 
 class Emails(Regexp):
-
     def __init__(self, email_address_delimiter, message=None):
         self.validate_hostname = HostnameValidation(require_tld=True)
         self.email_address_delimiter = email_address_delimiter
@@ -87,7 +85,6 @@ def _to_safe_html(cls, data: Optional[str]) -> str:
 
 
 class SuffixedStringField(StringField):
-
     def __init__(self, suffix: str = '', *args, **kwargs):
         super().__init__(*args, **kwargs)
         self._suffix = suffix

diff --git a/opwen_email_client/webapp/actions.py b/opwen_email_client/webapp/actions.py
@@ -33,7 +33,6 @@
 
 
 class SyncEmails(object):
-
     def __init__(self, email_store: EmailStore, email_sync: Sync, user_store: UserStore, log: Logger):
         self._email_store = email_store
         self._email_sync = email_sync
@@ -98,7 +97,6 @@ def __call__(self):
 
 
 class RestartApp(object):
-
     def __init__(self, restart_paths: Mapping[str, str]):
         self._restart_paths = restart_paths
 
@@ -110,7 +108,6 @@ def __call__(self):
 
 
 class RestartAppComponent(object):
-
     def __init__(self, restart_path: str):
         self._restart_path = restart_path
 
@@ -132,7 +129,6 @@ def __call__(self):
 
 
 class SendWelcomeEmail(object):
-
     def __init__(self, to: str, time, email_store: EmailStore):
         self._to = to
         self._time = time
@@ -235,7 +231,6 @@ def __call__(self):
 
 
 class ClientRegister(object):
-
     def __init__(self, client_name: str, access_token: str, path: str, logger: Logger):
         self._client_name = client_name
         self._github_access_token = access_token

diff --git a/opwen_email_client/webapp/config.py b/opwen_email_client/webapp/config.py
@@ -56,8 +56,7 @@ class i8n(object):
     USER_PROMOTED = _('The user now is an administrator.')
     ALREADY_PROMOTED = _('The user already is an administrator.')
     ADMIN_CANNOT_BE_SUSPENDED = _("Administrators can't be suspended.")
-    ADMIN_PASSWORD_CANNOT_BE_RESET = _("Administrator password can't be "
-                                       "reset.")
+    ADMIN_PASSWORD_CANNOT_BE_RESET = _("Administrator password can't be " "reset.")
     PASSWORD_CHANGED_BY_ADMIN = _('Password was reset by administrator to: ')
     SAME_PASSWORD = _(' Your new password must be different than your previous password.')
 

diff --git a/opwen_email_client/webapp/forms/settings.py b/opwen_email_client/webapp/forms/settings.py
@@ -77,7 +77,6 @@ def _update_sync_schedule(self) -> bool:
 
     @classmethod
     def _update_config(cls, env_key: str, value: str):
-
         def is_env(line):
             return line.startswith('{}='.format(env_key))
 

diff --git a/opwen_email_client/webapp/jinja.py b/opwen_email_client/webapp/jinja.py
@@ -48,7 +48,6 @@ def render_body(email: dict) -> str:
 
 @app.context_processor
 def _inject_format_last_login():
-
     def format_last_login(user, current_user) -> str:
         if not user.last_login_at:
             return ''

diff --git a/opwen_email_client/webapp/login.py b/opwen_email_client/webapp/login.py
@@ -55,7 +55,6 @@ class _Role(_db.Model, RoleMixin):
 
 
 class FlaskLoginUserStore(UserStore):
-
     def __init__(self):
         store = SQLAlchemyUserDatastore(_db, _User, _Role)
         super().__init__(read=store, write=store)

diff --git a/opwen_email_client/webapp/session.py b/opwen_email_client/webapp/session.py
@@ -32,7 +32,6 @@ def get_current_language(cls) -> str:
 
 
 def track_history(func):
-
     @wraps(func)
     def history_tracker(*args, **kwargs):
         Session.store_last_visited_url()

diff --git a/opwen_email_server/actions.py b/opwen_email_server/actions.py
@@ -35,7 +35,6 @@
 
 
 class _Action(ABC, LogMixin):
-
     def __call__(self, *args, **kwargs) -> Response:
         try:
             return self._action(*args, **kwargs)
@@ -54,7 +53,6 @@ def _action(self):  # type: ignore
 
 
 class SendOutboundEmails(_Action):
-
     def __init__(self, email_storage: AzureObjectStorage, send_email: SendSendgridEmail):
 
         self._email_storage = email_storage
@@ -72,7 +70,6 @@ def _action(self, resource_id):  # type: ignore
 
 
 class StoreInboundEmails(_Action):
-
     def __init__(self,
                  raw_email_storage: AzureTextStorage,
                  email_storage: AzureObjectStorage,
@@ -117,7 +114,6 @@ def _store_inbound_email(self, email: dict) -> str:
 
 
 class _IndexEmailForMailbox(_Action):
-
     def __init__(self, email_storage: AzureObjectStorage, mailbox_storage: AzureTextStorage):
         self._email_storage = email_storage
         self._mailbox_storage = mailbox_storage
@@ -161,7 +157,6 @@ def _get_pivot(self, email: dict) -> Iterable[str]:
 
 
 class StoreWrittenClientEmails(_Action):
-
     def __init__(self, client_storage: AzureObjectsStorage, email_storage: AzureObjectStorage,
                  user_storage: AzureObjectStorage, next_task: Callable[[str], None]):
 
@@ -220,7 +215,6 @@ def _decode_attachments(cls, email: dict) -> dict:
 
 
 class ReceiveInboundEmail(_Action):
-
     def __init__(self, auth: Auth, raw_email_storage: AzureTextStorage, next_task: Callable[[str], None]):
         self._auth = auth
         self._raw_email_storage = raw_email_storage
@@ -250,7 +244,6 @@ def _new_email_id(cls, email: str) -> str:
 
 
 class ProcessServiceEmail(_Action):
-
     def __init__(self,
                  raw_email_storage: AzureTextStorage,
                  email_storage: AzureObjectStorage,
@@ -295,7 +288,6 @@ def _action(self, resource_id):  # type: ignore
 
 
 class DownloadClientEmails(_Action):
-
     def __init__(self, auth: Auth, client_storage: AzureObjectsStorage, email_storage: AzureObjectStorage,
                  pending_storage: AzureTextStorage):
 
@@ -354,7 +346,6 @@ def _mark_emails_as_delivered(self, domain: str, email_ids: Iterable[str]) -> No
 
 
 class UploadClientEmails(_Action):
-
     def __init__(self, auth: Auth, next_task: Callable[[str], None]):
         self._auth = auth
         self._next_task = next_task
@@ -374,7 +365,6 @@ def _action(self, client_id, upload_info):  # type: ignore
 
 
 class RegisterClient(_Action):
-
     def __init__(self, auth: Auth, client_storage: AzureObjectsStorage, setup_mailbox: Callable[[str, str], None],
                  setup_mx_records: Callable[[str], None], client_id_source: Callable[[], str]):
         self._auth = auth
@@ -396,7 +386,6 @@ def _action(self, domain, owner):  # type: ignore
 
 
 class CreateClient(_Action):
-
     def __init__(self, auth: Auth, task: Callable[[str, str], None]):
         self._auth = auth
         self._task = task
@@ -415,7 +404,6 @@ def _action(self, client, user, **auth_args):  # type: ignore
 
 
 class ListClients(_Action):
-
     def __init__(self, auth: Auth):
         self._auth = auth
 
@@ -429,7 +417,6 @@ def _action(self, **auth_args):  # type: ignore
 
 
 class GetClient(_Action):
-
     def __init__(self, auth: Auth, client_storage: AzureObjectsStorage):
         self._auth = auth
         self._client_storage = client_storage
@@ -457,7 +444,6 @@ def _action(self, domain, user, **auth_args):  # type: ignore
 
 
 class DeleteClient(_Action):
-
     def __init__(self, auth: Auth, delete_mailbox: Callable[[str, str], None], delete_mx_records: Callable[[str], None],
                  mailbox_storage: AzureTextStorage, pending_storage: AzureTextStorage,
                  user_storage: AzureObjectStorage):
@@ -496,7 +482,6 @@ def _delete_index(cls, storage: Union[AzureTextStorage, AzureObjectStorage], dom
 
 
 class CalculateNumberOfUsersMetric(_Action):
-
     def __init__(self, auth: Auth, user_storage: AzureObjectStorage):
         self._auth = auth
         self._user_storage = user_storage
@@ -513,7 +498,6 @@ def _action(self, domain, user, **auth_args):  # type: ignore
 
 
 class CalculatePendingEmailsMetric(_Action):
-
     def __init__(self, auth: Auth, pending_storage: AzureTextStorage):
         self._auth = auth
         self._pending_storage = pending_storage

diff --git a/opwen_email_server/integration/webapp.py b/opwen_email_server/integration/webapp.py
@@ -32,13 +32,11 @@
 
 
 class AzureRole:
-
     def __init__(self):
         raise NotImplementedError
 
 
 class AzureUser(User):
-
     def __init__(self, **data):
         super().__setattr__('_data', data)
 
@@ -76,7 +74,6 @@ def is_admin(self) -> bool:
 
 
 class AzureUserStore(UserStore, UserReadStore, UserWriteStore):
-
     def __init__(self, user_storage: AzureObjectStorage):
         UserReadStore.__init__(self, user_model=AzureUser, role_model=AzureRole)
         UserWriteStore.__init__(self, db=None)
@@ -130,7 +127,6 @@ def _path_for(cls, email: str) -> str:
 
 
 class AzureEmailStore(EmailStore, LogMixin):
-
     def __init__(self, email_storage: AzureObjectStorage, mailbox_storage: AzureTextStorage,
                  pending_storage: AzureTextStorage, send_email: Callable[[str], None]):
         super().__init__(restricted=None)
@@ -243,7 +239,6 @@ def _mark_read(self, email_address: str, uids: Iterable[str]):
 
 
 class NoSync(Sync):
-
     def upload(self, items: Iterable, users: Iterable[User]) -> Iterable[str]:
         return []
 
@@ -252,7 +247,6 @@ def download(self) -> Iterable:
 
 
 class AzureIoc:
-
     @cached_property
     def email_store(self):
         return AzureEmailStore(

diff --git a/opwen_email_server/mailers/echo.py b/opwen_email_server/mailers/echo.py
@@ -7,7 +7,6 @@
 
 
 class EchoEmailFormatter(LogMixin):
-
     def __init__(self, now: Callable[[], datetime] = datetime.utcnow):
         self._now = now
 

diff --git a/opwen_email_server/mailers/wikipedia.py b/opwen_email_server/mailers/wikipedia.py
@@ -16,7 +16,6 @@
 
 
 class WikipediaEmailFormatter(LogMixin):
-
     def __init__(self,
                  languages_getter: Callable[[], dict] = languages,
                  language_setter: Callable[[str], None] = set_lang,