2019-11-11 08:56:08 +00:00
|
|
|
from starlette.requests import Request
|
|
|
|
from starlette.responses import *
|
2020-02-08 00:49:07 +00:00
|
|
|
from royalnet.constellation.api import *
|
2019-11-11 08:56:08 +00:00
|
|
|
from royalnet.utils import *
|
2019-11-28 01:30:40 +00:00
|
|
|
from ..tables import *
|
2019-11-11 08:56:08 +00:00
|
|
|
|
|
|
|
|
2020-02-08 00:49:07 +00:00
|
|
|
class ApiDiarioListStar(ApiStar):
|
|
|
|
path = "/api/diario/list/v1"
|
2019-11-11 08:56:08 +00:00
|
|
|
|
2020-02-08 00:49:07 +00:00
|
|
|
async def api(self, data: ApiData) -> dict:
|
|
|
|
page_str = data["page"]
|
2019-11-11 08:56:08 +00:00
|
|
|
try:
|
|
|
|
page = int(page_str)
|
2020-02-08 00:49:07 +00:00
|
|
|
except ValueError:
|
|
|
|
raise InvalidParameterError("'page' is not a valid int.")
|
|
|
|
if page < 0:
|
|
|
|
page = -page-1
|
|
|
|
entries: typing.List[Diario] = await asyncify(
|
|
|
|
data.session
|
|
|
|
.query(self.alchemy.get(Diario))
|
|
|
|
.order_by(self.alchemy.get(Diario).diario_id.desc()).limit(500)
|
|
|
|
.offset(page * 500)
|
|
|
|
.all
|
|
|
|
)
|
|
|
|
else:
|
|
|
|
entries: typing.List[Diario] = await asyncify(
|
|
|
|
data.session
|
|
|
|
.query(self.alchemy.get(Diario))
|
|
|
|
.order_by(self.alchemy.get(Diario).diario_id)
|
|
|
|
.limit(500)
|
|
|
|
.offset(page * 500)
|
|
|
|
.all
|
|
|
|
)
|
|
|
|
response = [entry.json() for entry in entries]
|
|
|
|
return response
|