Compare commits
4 Commits
fcd1ae78c3
...
cebc9077c3
Author | SHA1 | Date | |
---|---|---|---|
cebc9077c3
|
|||
f862e124a6
|
|||
1bb75b28eb
|
|||
0a7337a313
|
@@ -30,5 +30,7 @@ env VIRTUAL_ENV=/app/.venv \
|
|||||||
COPY --from=builder ${VIRTUAL_ENV} ${VIRTUAL_ENV}
|
COPY --from=builder ${VIRTUAL_ENV} ${VIRTUAL_ENV}
|
||||||
|
|
||||||
COPY api /app/api
|
COPY api /app/api
|
||||||
|
COPY config.sample.yaml .
|
||||||
|
COPY api_server.py .
|
||||||
|
|
||||||
CMD ["python", "./api/main.py"]
|
CMD ["./api_server.py"]
|
@@ -35,6 +35,7 @@ env VIRTUAL_ENV=/app/.venv \
|
|||||||
COPY --from=builder ${VIRTUAL_ENV} ${VIRTUAL_ENV}
|
COPY --from=builder ${VIRTUAL_ENV} ${VIRTUAL_ENV}
|
||||||
|
|
||||||
COPY api /app/api
|
COPY api /app/api
|
||||||
COPY db_updater /app/db_updater
|
COPY config.sample.yaml .
|
||||||
|
COPY db_updater.py .
|
||||||
|
|
||||||
CMD ["python", "-m", "db_updater.fill_db"]
|
CMD ["./db_updater.py"]
|
||||||
|
@@ -14,7 +14,7 @@ from sqlalchemy.ext.asyncio import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
from .base_class import Base
|
from .base_class import Base
|
||||||
from settings import DatabaseSettings
|
from ..settings import DatabaseSettings
|
||||||
|
|
||||||
logger = getLogger(__name__)
|
logger = getLogger(__name__)
|
||||||
|
|
||||||
|
@@ -4,9 +4,9 @@ from fastapi_cache.backends.redis import RedisBackend
|
|||||||
from redis import asyncio as aioredis
|
from redis import asyncio as aioredis
|
||||||
from yaml import safe_load
|
from yaml import safe_load
|
||||||
|
|
||||||
from db import db
|
from .db import db
|
||||||
from idfm_interface.idfm_interface import IdfmInterface
|
from .idfm_interface.idfm_interface import IdfmInterface
|
||||||
from settings import CacheSettings, Settings
|
from .settings import CacheSettings, Settings
|
||||||
|
|
||||||
|
|
||||||
CONFIG_PATH = environ.get("CONFIG_PATH", "./config.sample.yaml")
|
CONFIG_PATH = environ.get("CONFIG_PATH", "./config.sample.yaml")
|
||||||
|
@@ -8,8 +8,8 @@ from msgspec import ValidationError
|
|||||||
from msgspec.json import Decoder
|
from msgspec.json import Decoder
|
||||||
|
|
||||||
from .idfm_types import Destinations as IdfmDestinations, IdfmResponse, IdfmState
|
from .idfm_types import Destinations as IdfmDestinations, IdfmResponse, IdfmState
|
||||||
from db import Database
|
from ..db import Database
|
||||||
from models import Line, Stop, StopArea
|
from ..models import Line, Stop, StopArea
|
||||||
|
|
||||||
|
|
||||||
class IdfmInterface:
|
class IdfmInterface:
|
||||||
|
@@ -141,6 +141,8 @@ class StopAreaStopAssociationFields(Struct, kw_only=True):
|
|||||||
artid: str | None = None
|
artid: str | None = None
|
||||||
arrversion: str
|
arrversion: str
|
||||||
zdcid: str
|
zdcid: str
|
||||||
|
pdeid: str | None = None
|
||||||
|
pdeversion: int | None = None
|
||||||
version: int
|
version: int
|
||||||
zdaid: str
|
zdaid: str
|
||||||
zdaversion: str
|
zdaversion: str
|
||||||
|
@@ -14,8 +14,8 @@ from sqlalchemy import (
|
|||||||
from sqlalchemy.orm import Mapped, mapped_column, relationship, selectinload
|
from sqlalchemy.orm import Mapped, mapped_column, relationship, selectinload
|
||||||
from sqlalchemy.sql.expression import tuple_
|
from sqlalchemy.sql.expression import tuple_
|
||||||
|
|
||||||
from db import Base, db
|
from ..db import Base, db
|
||||||
from idfm_interface.idfm_types import (
|
from ..idfm_interface.idfm_types import (
|
||||||
IdfmState,
|
IdfmState,
|
||||||
IdfmLineState,
|
IdfmLineState,
|
||||||
TransportMode,
|
TransportMode,
|
||||||
|
@@ -26,8 +26,8 @@ from sqlalchemy.orm import (
|
|||||||
from sqlalchemy.schema import Index
|
from sqlalchemy.schema import Index
|
||||||
from sqlalchemy_utils.types.ts_vector import TSVectorType
|
from sqlalchemy_utils.types.ts_vector import TSVectorType
|
||||||
|
|
||||||
from db import Base, db
|
from ..db import Base, db
|
||||||
from idfm_interface.idfm_types import TransportMode, IdfmState, StopAreaType
|
from ..idfm_interface.idfm_types import TransportMode, IdfmState, StopAreaType
|
||||||
|
|
||||||
if TYPE_CHECKING:
|
if TYPE_CHECKING:
|
||||||
from .line import Line
|
from .line import Line
|
||||||
|
@@ -1,7 +1,7 @@
|
|||||||
from sqlalchemy import BigInteger, ForeignKey, String
|
from sqlalchemy import BigInteger, ForeignKey, String
|
||||||
from sqlalchemy.orm import Mapped, mapped_column, relationship
|
from sqlalchemy.orm import Mapped, mapped_column, relationship
|
||||||
|
|
||||||
from db import Base, db
|
from ..db import Base, db
|
||||||
from .stop import _Stop
|
from .stop import _Stop
|
||||||
|
|
||||||
|
|
||||||
|
@@ -1,8 +1,8 @@
|
|||||||
from fastapi import APIRouter, HTTPException
|
from fastapi import APIRouter, HTTPException
|
||||||
from fastapi_cache.decorator import cache
|
from fastapi_cache.decorator import cache
|
||||||
|
|
||||||
from models import Line
|
from ..models import Line
|
||||||
from schemas import Line as LineSchema, TransportMode
|
from ..schemas import Line as LineSchema, TransportMode
|
||||||
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/line", tags=["line"])
|
router = APIRouter(prefix="/line", tags=["line"])
|
||||||
|
@@ -5,16 +5,16 @@ from typing import Sequence
|
|||||||
from fastapi import APIRouter, HTTPException
|
from fastapi import APIRouter, HTTPException
|
||||||
from fastapi_cache.decorator import cache
|
from fastapi_cache.decorator import cache
|
||||||
|
|
||||||
from idfm_interface import Destinations as IdfmDestinations, TrainStatus
|
from ..idfm_interface import Destinations as IdfmDestinations, TrainStatus
|
||||||
from models import Stop, StopArea, StopShape
|
from ..models import Stop, StopArea, StopShape
|
||||||
from schemas import (
|
from ..schemas import (
|
||||||
NextPassage as NextPassageSchema,
|
NextPassage as NextPassageSchema,
|
||||||
NextPassages as NextPassagesSchema,
|
NextPassages as NextPassagesSchema,
|
||||||
Stop as StopSchema,
|
Stop as StopSchema,
|
||||||
StopArea as StopAreaSchema,
|
StopArea as StopAreaSchema,
|
||||||
StopShape as StopShapeSchema,
|
StopShape as StopShapeSchema,
|
||||||
)
|
)
|
||||||
from dependencies import idfm_interface
|
from ..dependencies import idfm_interface
|
||||||
|
|
||||||
|
|
||||||
router = APIRouter(prefix="/stop", tags=["stop"])
|
router = APIRouter(prefix="/stop", tags=["stop"])
|
||||||
|
@@ -2,7 +2,7 @@ from enum import StrEnum
|
|||||||
|
|
||||||
from pydantic import BaseModel
|
from pydantic import BaseModel
|
||||||
|
|
||||||
from idfm_interface import (
|
from ..idfm_interface import (
|
||||||
IdfmLineState,
|
IdfmLineState,
|
||||||
IdfmState,
|
IdfmState,
|
||||||
TransportMode as IdfmTransportMode,
|
TransportMode as IdfmTransportMode,
|
||||||
|
@@ -1,6 +1,6 @@
|
|||||||
from pydantic import BaseModel
|
from pydantic import BaseModel
|
||||||
|
|
||||||
from idfm_interface.idfm_types import TrainStatus
|
from ..idfm_interface.idfm_types import TrainStatus
|
||||||
|
|
||||||
|
|
||||||
class NextPassage(BaseModel):
|
class NextPassage(BaseModel):
|
||||||
|
@@ -1,6 +1,6 @@
|
|||||||
from pydantic import BaseModel
|
from pydantic import BaseModel
|
||||||
|
|
||||||
from idfm_interface import StopAreaType
|
from ..idfm_interface import StopAreaType
|
||||||
|
|
||||||
|
|
||||||
class Stop(BaseModel):
|
class Stop(BaseModel):
|
||||||
|
@@ -12,9 +12,9 @@ from opentelemetry.sdk.resources import Resource, SERVICE_NAME
|
|||||||
from opentelemetry.sdk.trace import TracerProvider
|
from opentelemetry.sdk.trace import TracerProvider
|
||||||
from opentelemetry.sdk.trace.export import BatchSpanProcessor
|
from opentelemetry.sdk.trace.export import BatchSpanProcessor
|
||||||
|
|
||||||
from db import db
|
from api.db import db
|
||||||
from dependencies import idfm_interface, redis_backend, settings
|
from api.dependencies import idfm_interface, redis_backend, settings
|
||||||
from routers import line, stop
|
from api.routers import line, stop
|
||||||
|
|
||||||
|
|
||||||
@asynccontextmanager
|
@asynccontextmanager
|
Reference in New Issue
Block a user