from typing import Sequence

from sqlalchemy import select
from sqlalchemy.ext.asyncio import AsyncSession

from models import IspConnection
from schemas.isp_connections import IspConnectionCreate


async def get_all_isp_connection(session: AsyncSession) -> Sequence[IspConnection]:
    stmt = select(IspConnection).order_by(IspConnection.id)
    result = await session.scalars(stmt)
    return result.all()


async def create_isp_connection(
    session: AsyncSession, isp_connection_scheme: IspConnectionCreate
) -> IspConnection:
    isp_connection = IspConnection(**isp_connection_scheme.model_dump())

    session.add(isp_connection)
    await session.commit()
    return isp_connection