Compare commits
7 Commits
4056b3a739
...
bdbc72ab39
Author | SHA1 | Date | |
---|---|---|---|
bdbc72ab39
|
|||
4cc8f60076
|
|||
cf5c4c6224
|
|||
f69aee1c9c
|
|||
8c493f8fab
|
|||
4fce832db5
|
|||
bfc669cd11
|
@@ -61,9 +61,6 @@ class Database:
|
|||||||
while not ret:
|
while not ret:
|
||||||
try:
|
try:
|
||||||
async with self._async_engine.begin() as session:
|
async with self._async_engine.begin() as session:
|
||||||
await session.execute(
|
|
||||||
text("CREATE EXTENSION IF NOT EXISTS pg_trgm;")
|
|
||||||
)
|
|
||||||
if clear_static_data:
|
if clear_static_data:
|
||||||
await session.run_sync(Base.metadata.drop_all)
|
await session.run_sync(Base.metadata.drop_all)
|
||||||
await session.run_sync(Base.metadata.create_all)
|
await session.run_sync(Base.metadata.create_all)
|
||||||
|
@@ -1,6 +1,14 @@
|
|||||||
from typing import Any
|
from __future__ import annotations
|
||||||
|
|
||||||
from pydantic import BaseModel, BaseSettings, Field, root_validator, SecretStr
|
from typing import Annotated
|
||||||
|
|
||||||
|
from pydantic import BaseModel, SecretStr
|
||||||
|
from pydantic.functional_validators import model_validator
|
||||||
|
from pydantic_settings import (
|
||||||
|
BaseSettings,
|
||||||
|
PydanticBaseSettingsSource,
|
||||||
|
SettingsConfigDict,
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
class HttpSettings(BaseModel):
|
class HttpSettings(BaseModel):
|
||||||
@@ -9,28 +17,13 @@ class HttpSettings(BaseModel):
|
|||||||
cert: str | None = None
|
cert: str | None = None
|
||||||
|
|
||||||
|
|
||||||
def check_user_password(cls, values: dict[str, Any]) -> dict[str, Any]:
|
|
||||||
user = values.get("user")
|
|
||||||
password = values.get("password")
|
|
||||||
|
|
||||||
if user is not None and password is None:
|
|
||||||
raise ValueError("user is set, password shall be set too.")
|
|
||||||
|
|
||||||
if password is not None and user is None:
|
|
||||||
raise ValueError("password is set, user shall be set too.")
|
|
||||||
|
|
||||||
return values
|
|
||||||
|
|
||||||
|
|
||||||
class DatabaseSettings(BaseModel):
|
class DatabaseSettings(BaseModel):
|
||||||
name: str = "carrramba-encore-rate"
|
name: str
|
||||||
host: str = "127.0.0.1"
|
host: str
|
||||||
port: int = 5432
|
port: int
|
||||||
driver: str = "postgresql+psycopg"
|
driver: str = "postgresql+psycopg"
|
||||||
user: str | None = None
|
user: str
|
||||||
password: SecretStr | None = None
|
password: Annotated[SecretStr, check_user_password]
|
||||||
|
|
||||||
_user_password_validation = root_validator(allow_reuse=True)(check_user_password)
|
|
||||||
|
|
||||||
|
|
||||||
class CacheSettings(BaseModel):
|
class CacheSettings(BaseModel):
|
||||||
@@ -38,9 +31,18 @@ class CacheSettings(BaseModel):
|
|||||||
host: str = "127.0.0.1"
|
host: str = "127.0.0.1"
|
||||||
port: int = 6379
|
port: int = 6379
|
||||||
user: str | None = None
|
user: str | None = None
|
||||||
password: SecretStr | None = None
|
password: Annotated[SecretStr | None, check_user_password] = None
|
||||||
|
|
||||||
_user_password_validation = root_validator(allow_reuse=True)(check_user_password)
|
|
||||||
|
@model_validator(mode="after")
|
||||||
|
def check_user_password(self) -> DatabaseSettings | CacheSettings:
|
||||||
|
if self.user is not None and self.password is None:
|
||||||
|
raise ValueError("user is set, password shall be set too.")
|
||||||
|
|
||||||
|
if self.password is not None and self.user is None:
|
||||||
|
raise ValueError("password is set, user shall be set too.")
|
||||||
|
|
||||||
|
return self
|
||||||
|
|
||||||
|
|
||||||
class TracingSettings(BaseModel):
|
class TracingSettings(BaseModel):
|
||||||
@@ -50,10 +52,23 @@ class TracingSettings(BaseModel):
|
|||||||
class Settings(BaseSettings):
|
class Settings(BaseSettings):
|
||||||
app_name: str
|
app_name: str
|
||||||
|
|
||||||
idfm_api_key: SecretStr = Field(..., env="IDFM_API_KEY")
|
idfm_api_key: SecretStr
|
||||||
clear_static_data: bool = Field(False, env="CLEAR_STATIC_DATA")
|
clear_static_data: bool
|
||||||
|
|
||||||
http: HttpSettings = HttpSettings()
|
http: HttpSettings
|
||||||
db: DatabaseSettings = DatabaseSettings()
|
db: DatabaseSettings
|
||||||
cache: CacheSettings = CacheSettings()
|
cache: CacheSettings
|
||||||
tracing: TracingSettings = TracingSettings()
|
tracing: TracingSettings
|
||||||
|
|
||||||
|
model_config = SettingsConfigDict(env_prefix="CER__", env_nested_delimiter="__")
|
||||||
|
|
||||||
|
@classmethod
|
||||||
|
def settings_customise_sources(
|
||||||
|
cls,
|
||||||
|
settings_cls: type[BaseSettings],
|
||||||
|
init_settings: PydanticBaseSettingsSource,
|
||||||
|
env_settings: PydanticBaseSettingsSource,
|
||||||
|
dotenv_settings: PydanticBaseSettingsSource,
|
||||||
|
file_secret_settings: PydanticBaseSettingsSource,
|
||||||
|
) -> tuple[PydanticBaseSettingsSource, ...]:
|
||||||
|
return env_settings, init_settings, file_secret_settings
|
||||||
|
@@ -10,9 +10,7 @@ db:
|
|||||||
name: carrramba-encore-rate
|
name: carrramba-encore-rate
|
||||||
host: postgres
|
host: postgres
|
||||||
port: 5432
|
port: 5432
|
||||||
driver: postgresql+psycopg
|
|
||||||
user: cer
|
user: cer
|
||||||
password: cer_password
|
|
||||||
|
|
||||||
cache:
|
cache:
|
||||||
enable: true
|
enable: true
|
||||||
|
@@ -34,13 +34,12 @@ app = FastAPI(lifespan=lifespan)
|
|||||||
|
|
||||||
app.add_middleware(
|
app.add_middleware(
|
||||||
CORSMiddleware,
|
CORSMiddleware,
|
||||||
allow_origins=["https://localhost:4443", "https://localhost:3000"],
|
allow_origins=["http://carrramba.adrien.run", "https://carrramba.adrien.run"],
|
||||||
allow_credentials=True,
|
allow_credentials=True,
|
||||||
allow_methods=["*"],
|
allow_methods=["OPTIONS", "GET"],
|
||||||
allow_headers=["*"],
|
allow_headers=["*"],
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
# The cache-control header entry is not managed properly by fastapi-cache:
|
# The cache-control header entry is not managed properly by fastapi-cache:
|
||||||
# For now, a request with a cache-control set to no-cache
|
# For now, a request with a cache-control set to no-cache
|
||||||
# is interpreted as disabling the use of the server cache.
|
# is interpreted as disabling the use of the server cache.
|
||||||
|
@@ -9,7 +9,7 @@ readme = "README.md"
|
|||||||
python = "^3.11"
|
python = "^3.11"
|
||||||
aiohttp = "^3.8.3"
|
aiohttp = "^3.8.3"
|
||||||
aiofiles = "^22.1.0"
|
aiofiles = "^22.1.0"
|
||||||
fastapi = "^0.95.0"
|
fastapi = "^0.103.0"
|
||||||
uvicorn = "^0.20.0"
|
uvicorn = "^0.20.0"
|
||||||
msgspec = "^0.12.0"
|
msgspec = "^0.12.0"
|
||||||
opentelemetry-instrumentation-fastapi = "^0.38b0"
|
opentelemetry-instrumentation-fastapi = "^0.38b0"
|
||||||
@@ -23,11 +23,12 @@ sqlalchemy = "^2.0.12"
|
|||||||
psycopg = "^3.1.9"
|
psycopg = "^3.1.9"
|
||||||
pyyaml = "^6.0"
|
pyyaml = "^6.0"
|
||||||
fastapi-cache2 = {extras = ["redis"], version = "^0.2.1"}
|
fastapi-cache2 = {extras = ["redis"], version = "^0.2.1"}
|
||||||
|
pydantic-settings = "^2.0.3"
|
||||||
|
|
||||||
[tool.poetry.group.db_updater.dependencies]
|
[tool.poetry.group.db_updater.dependencies]
|
||||||
aiofiles = "^22.1.0"
|
aiofiles = "^22.1.0"
|
||||||
aiohttp = "^3.8.3"
|
aiohttp = "^3.8.3"
|
||||||
fastapi = "^0.95.0"
|
fastapi = "^0.103.0"
|
||||||
msgspec = "^0.12.0"
|
msgspec = "^0.12.0"
|
||||||
opentelemetry-instrumentation-fastapi = "^0.38b0"
|
opentelemetry-instrumentation-fastapi = "^0.38b0"
|
||||||
opentelemetry-instrumentation-sqlalchemy = "^0.38b0"
|
opentelemetry-instrumentation-sqlalchemy = "^0.38b0"
|
||||||
@@ -41,11 +42,14 @@ pyyaml = "^6.0"
|
|||||||
sqlalchemy = "^2.0.12"
|
sqlalchemy = "^2.0.12"
|
||||||
sqlalchemy-utils = "^0.41.1"
|
sqlalchemy-utils = "^0.41.1"
|
||||||
tqdm = "^4.65.0"
|
tqdm = "^4.65.0"
|
||||||
|
pydantic-settings = "^2.0.3"
|
||||||
|
|
||||||
[build-system]
|
[build-system]
|
||||||
requires = ["poetry-core"]
|
requires = ["poetry-core"]
|
||||||
build-backend = "poetry.core.masonry.api"
|
build-backend = "poetry.core.masonry.api"
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
[tool.poetry.group.dev.dependencies]
|
[tool.poetry.group.dev.dependencies]
|
||||||
pylsp-mypy = "^0.6.2"
|
pylsp-mypy = "^0.6.2"
|
||||||
mccabe = "^0.7.0"
|
mccabe = "^0.7.0"
|
||||||
|
@@ -28,8 +28,7 @@ export interface BusinessDataStore {
|
|||||||
export const BusinessDataContext = createContext<BusinessDataStore>();
|
export const BusinessDataContext = createContext<BusinessDataStore>();
|
||||||
|
|
||||||
export function BusinessDataProvider(props: { children: JSX.Element }) {
|
export function BusinessDataProvider(props: { children: JSX.Element }) {
|
||||||
|
const [serverUrl] = createSignal<string>("https://carrramba.adrien.run/api");
|
||||||
const [serverUrl] = createSignal<string>("https://localhost:4443");
|
|
||||||
|
|
||||||
type Store = {
|
type Store = {
|
||||||
lines: Lines;
|
lines: Lines;
|
||||||
|
@@ -26,7 +26,7 @@ export const TransportModeWeights: Record<string, number> = {
|
|||||||
export function getTransportModeSrc(mode: string, color: boolean = true): string | undefined {
|
export function getTransportModeSrc(mode: string, color: boolean = true): string | undefined {
|
||||||
let ret = undefined;
|
let ret = undefined;
|
||||||
if (validTransportModes.includes(mode)) {
|
if (validTransportModes.includes(mode)) {
|
||||||
return `/carrramba-encore-rate/public/symbole_${mode}_${color ? "" : "support_fonce_"}RVB.svg`;
|
return `/symbole_${mode}_${color ? "" : "support_fonce_"}RVB.svg`;
|
||||||
}
|
}
|
||||||
return ret;
|
return ret;
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user