Simon/romm
1
0
Fork 0
mirror of https://github.com/rommapp/romm.git synced 2026-06-27 22:35:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

run sgdb in parallel

Browse Source
This commit is contained in:
Georges-Antoine Assi
2025-08-15 22:30:13 -04:00
parent 7c3764802f
commit e0d1d1cf23
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
backend/endpoints/search.py
View File

@@ -14,7 +14,7 @@ from handler.metadata import (
)
from handler.metadata.igdb_handler import IGDB_API_ENABLED, IGDBRom
from handler.metadata.moby_handler import MOBY_API_ENABLED, MobyGamesRom
from handler.metadata.sgdb_handler import STEAMGRIDDB_API_ENABLED
from handler.metadata.sgdb_handler import STEAMGRIDDB_API_ENABLED, SGDBRom
from handler.metadata.ss_handler import SS_API_ENABLED, SSRom
from handler.scan_handler import get_main_platform_igdb_id
from logger.formatter import BLUE, CYAN
@@ -147,11 +147,18 @@ async def search_rom(
**merged_dict.get(ss_name, {}),
}
for name, matched_rom in merged_dict.items():
sgdb_rom = await meta_sgdb_handler.get_details_by_names([name])
async def get_sgdb_rom(name: str) -> tuple[str, SGDBRom]:
return name, await meta_sgdb_handler.get_details_by_names([name])
# Only get SteamGridDB details for first 5 results
sgdb_roms = await asyncio.gather(
*[get_sgdb_rom(name) for name in list(merged_dict.keys())[:5]]
)
for name, sgdb_rom in sgdb_roms:
if sgdb_rom["sgdb_id"]:
merged_dict[name] = {
**matched_rom,
**merged_dict[name],
"sgdb_id": sgdb_rom.get("sgdb_id", ""),
"sgdb_url_cover": sgdb_rom.get("url_cover", ""),
}