Added endpoint to return lei data from list of leis

src/entities/repos/institutions_repo.py

@@ -42,6 +42,20 @@ async def get_institution(session: AsyncSession, lei: str) -> FinancialInstituti
         return await session.scalar(stmt)
 
 
+async def get_institutions_from_lei_list(
+        session: AsyncSession,
+        lei_list: List[str]
+) -> List[FinancialInstitutionDao]:
+    async with session.begin():
+        stmt = (
+            select(FinancialInstitutionDao)
+            .options(joinedload(FinancialInstitutionDao.domains))
+            .filter(FinancialInstitutionDao.lei.in_(lei_list))
+        )
+        res = await session.scalars(stmt)
+        return res.unique().all()
+
+
 async def upsert_institution(
     session: AsyncSession, fi: FinancialInstitutionDto
 ) -> FinancialInstitutionDao:

src/routers/institutions.py

@@ -52,6 +52,19 @@ async def get_institution(
     return res
 
 
+@router.post("/leis", response_model=List[FinancialInstitutionWithDomainsDto])
+@requires("authenticated")
+async def get_institutions_from_lei_list(
+        request: Request,
+        lei_list: List[str],
+        session: AsyncSession = Depends(get_session),
+):
+    res = await repo.get_institutions_from_lei_list(session, lei_list)
+    if not res:
+        raise HTTPException(HTTPStatus.NOT_FOUND, f"Leis in {lei_list} not found.")
+    return res
+
+
 @router.post("/{lei}/domains/", response_model=List[FinancialInsitutionDomainDto])
 @requires(["query-groups", "manage-users"])
 async def add_domains(