branch: dev (WIP)

config.py

@@ -7,6 +7,8 @@ class GenkaiEraConfig(BaseSettings):
     IS_CI: int = 0
     IS_TEST: int = 0
 
+    DISCORD_TOKEN: str
+
     POSTGRES_HOST: str
     POSTGRES_PORT: str
     POSTGRES_DB_NAME: str = "genkaiera"

main.py

@@ -0,0 +1,14 @@
+import asyncio
+
+from src.di.container import container
+from src.infrastructure.message.client import MessageClientInterface
+
+
+async def main() -> None:
+    client: MessageClientInterface = container.get(MessageClientInterface)
+
+    await client.start()
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

pyproject.toml

@@ -16,6 +16,7 @@ sqlalchemy = "^2.0.25"
 asyncpg = "^0.29.0"
 alembic = "^1.13.1"
 python-dotenv = "^1.0.0"
+discord = "^2.3.2"
 
 [tool.poetry.group.dev.dependencies]
 mypy = "^1.8.0"

script/load_env.py

@@ -19,7 +19,7 @@ def parse_0_or_1_envvar(name: str) -> bool:
 
         except (ValueError, TypeError):
             raise RuntimeError(
-                "RuntimeError: the value of the CI environment variable must be an integer with value 0 or 1."
+                "the value of the CI environment variable must be an integer with value 0 or 1."
             )
 
         else:
@@ -35,8 +35,8 @@ def load_dotenv() -> None:
 
     except ImportError:
         raise RuntimeError(
-            "RuntimeError: failed to import 'dotenv'.\n"
-            "Please install python-dotenv to use this command."
+            "failed to import 'dotenv'.\n"
+            "please install python-dotenv to use this command."
         )
 
     envfiles_to_load: list[str]

script/run_command.py

@@ -44,7 +44,7 @@ def execute_command(command_list: list[str]) -> None:
 
     if (proc.returncode is None) or (proc.returncode != 0):
         raise CommandError(
-            f"Error in command execution with return code: {proc.returncode}"
+            f"error in command execution with return code: {proc.returncode}"
         )
 
 

src/adapter/repository/member.py

@@ -0,0 +1,34 @@
+from abc import abstractmethod
+from typing import Generic
+
+from src.adapter.repository.abc import Repository
+from src.adapter.type import RawSessionType
+from src.domain.member.entity import Member
+from src.domain.server.value import ServerIdentifier
+from src.domain.user.value import UserIdentifier
+
+
+class MemberRepository(Repository, Generic[RawSessionType]):
+    @abstractmethod
+    async def save(
+        self,
+        member: Member,
+    ) -> Member:
+        raise NotImplementedError()
+
+    @abstractmethod
+    async def get_latest_by_server_id_and_user_id(
+        self,
+        server_id: ServerIdentifier,
+        user_id: UserIdentifier,
+    ) -> Member:
+        raise NotImplementedError()
+
+    @abstractmethod
+    async def get_history_by_server_id_and_user_id(
+        self,
+        server_id: ServerIdentifier,
+        user_id: UserIdentifier,
+        limit: int,
+    ) -> list[Member]:
+        raise NotImplementedError()

src/adapter/repository/server.py

@@ -0,0 +1,31 @@
+from abc import abstractmethod
+from typing import Generic
+
+from src.adapter.repository.abc import Repository
+from src.adapter.type import RawSessionType
+from src.domain.server.entity import Server
+from src.domain.server.value import ServerIdentifier
+
+
+class ServerRepository(Repository, Generic[RawSessionType]):
+    @abstractmethod
+    async def save(
+        self,
+        server: Server,
+    ) -> Server:
+        raise NotImplementedError()
+
+    @abstractmethod
+    async def get_latest_by_id(
+        self,
+        server_id: ServerIdentifier,
+    ) -> Server:
+        raise NotImplementedError()
+
+    @abstractmethod
+    async def get_history_by_id(
+        self,
+        server_id: ServerIdentifier,
+        limit: int,
+    ) -> list[Server]:
+        raise NotImplementedError()

src/adapter/repository/user.py

@@ -0,0 +1,31 @@
+from abc import abstractmethod
+from typing import Generic
+
+from src.adapter.repository.abc import Repository
+from src.adapter.type import RawSessionType
+from src.domain.user.entity import User
+from src.domain.user.value import UserIdentifier
+
+
+class UserRepository(Repository, Generic[RawSessionType]):
+    @abstractmethod
+    async def save(
+        self,
+        user: User,
+    ) -> User:
+        raise NotImplementedError()
+
+    @abstractmethod
+    async def get_latest_by_id(
+        self,
+        user_id: UserIdentifier,
+    ) -> User:
+        raise NotImplementedError()
+
+    @abstractmethod
+    async def get_history_by_id(
+        self,
+        user_id: UserIdentifier,
+        limit: int,
+    ) -> list[User]:
+        raise NotImplementedError()

src/common/library/pydantic/validator/tzinfo.py

@@ -0,0 +1,10 @@
+import datetime
+
+
+def value_must_have_tzinfo(
+    v: datetime.datetime,
+) -> datetime.datetime:
+    if v.tzinfo is None:
+        raise ValueError("the value must have tzinfo.")
+
+    return v

src/common/library/sqlalchemy/field/sauuid.py

@@ -25,9 +25,7 @@ def process_bind_param(
         if isinstance(value, UUID):
             return str(value)
 
-        raise ValueError(
-            f"ValueError: value '{value}' is not a valid instance of 'uuid.UUID'."
-        )
+        raise ValueError(f"value '{value}' is not a valid instance of 'uuid.UUID'.")
 
     def process_result_value(
         self, value: Optional[str], dialect: Optional[Dialect] = None
@@ -39,7 +37,7 @@ def process_result_value(
             return UUID(value)
 
         raise ValueError(
-            f"ValueError: value '{value}' is not 'None' or a valid instance of 'uuid.UUID'."
+            f"value '{value}' is not 'None' or a valid instance of 'uuid.UUID'."
         )
 
     # noinspection PyMethodMayBeStatic

src/common/library/sqlalchemy/mixin/timestamp.py

@@ -10,7 +10,7 @@
 
 
 class CreatedAtMixin(object):
-    created_at: Mapped[datetime.datetime] = mapped_column(
+    record_created_at: Mapped[datetime.datetime] = mapped_column(
         name=DEFAULT_CREATED_AT_COLUMN_NAME,
         type_=DateTime(timezone=True),
         server_default=func.now(),
@@ -19,7 +19,7 @@ class CreatedAtMixin(object):
 
 
 class UpdatedAtMixin(object):
-    updated_at: Mapped[datetime.datetime] = mapped_column(
+    record_updated_at: Mapped[datetime.datetime] = mapped_column(
         name=DEFAULT_UPDATED_AT_COLUMN_NAME,
         type_=DateTime(timezone=True),
         onupdate=func.now(),
@@ -29,14 +29,14 @@ class UpdatedAtMixin(object):
 
 # We get an error when we do 'class TimestampMixin(CreatedAtMixin, UpdatedAtMixin)'
 class TimestampMixin(object):
-    created_at: Mapped[datetime.datetime] = mapped_column(
+    record_created_at: Mapped[datetime.datetime] = mapped_column(
         name=DEFAULT_CREATED_AT_COLUMN_NAME,
         type_=DateTime(timezone=True),
         server_default=func.now(),
         nullable=False,
     )
 
-    updated_at: Mapped[datetime.datetime] = mapped_column(
+    record_updated_at: Mapped[datetime.datetime] = mapped_column(
         name=DEFAULT_UPDATED_AT_COLUMN_NAME,
         type_=DateTime(timezone=True),
         onupdate=func.now(),

src/common/library/sqlalchemy/mixin/uid.py

@@ -8,10 +8,12 @@
 
 
 class UIDMixin(object):
-    uid: Mapped[uuid.UUID] = mapped_column(
+    record_uid: Mapped[uuid.UUID] = mapped_column(
         name=DEFAULT_UID_COLUMN_NAME,
         type_=SAUUID,
         primary_key=True,
         default=uuid.uuid4,
         nullable=False,
+        unique=True,
+        index=True,
     )

src/di/container.py

@@ -2,10 +2,12 @@
 
 from src.di.module.config import GenkaiEraConfigModule
 from src.di.module.database import GenkaiEraSADatabaseModule
+from src.di.module.message import GenkaiEraMessageModule
 
 container = Injector(
     [
         GenkaiEraConfigModule,
         GenkaiEraSADatabaseModule,
+        GenkaiEraMessageModule,
     ]
 )

src/di/module/message.py

@@ -0,0 +1,20 @@
+from injector import Module, Binder, ClassProvider
+
+from src.message.discord.client import DiscordClient
+from src.infrastructure.message.client import MessageClientInterface
+
+
+class GenkaiEraMessageModule(Module):
+    def __init__(
+        self,
+    ) -> None:
+        pass
+
+    def configure(
+        self,
+        binder: Binder,
+    ) -> None:
+        binder.bind(
+            MessageClientInterface,
+            ClassProvider(DiscordClient),
+        )

src/domain/base/entity.py

@@ -0,0 +1,7 @@
+from pydantic import BaseModel
+
+from src.common.library.pydantic.config import FrozenConfig
+
+
+class Entity(BaseModel):
+    model_config = FrozenConfig

src/domain/base/value.py

@@ -0,0 +1,11 @@
+from pydantic import BaseModel
+
+from src.common.library.pydantic.config import BaseConfig
+
+
+class ValueObject(BaseModel):
+    model_config = BaseConfig
+
+
+class FrozenValueObject(BaseModel):
+    model_config = BaseConfig