async def product_search(keyword: str):
    query = urllib.parse.urlencode({"term": keyword})
    request = Request.from_url(f"{BASE_URL}/search?{query}", label="product search")
    dataset = await Dataset.open(name=request.id)

    crawler = ParselCrawler(
        configure_logging=False,
        request_handler=router,
        http_client=HttpxHttpClient(),
    )

    await crawler.run([request])
    result = [item for item in (await dataset.get_data()).items]
    await dataset.drop()  # Manual cleanup
    crawler.stop()
    return result

async def product_search(keyword: str):
    query = urllib.parse.urlencode({"term": keyword})
    request = Request.from_url(f"{BASE_URL}/search?{query}", label="product search")
    dataset = await Dataset.open()

    crawler = ParselCrawler(
        configure_logging=False,
        request_handler=router,
        dataset=dataset,  # Inject custom dataset
        http_client=HttpxHttpClient(),
    )

    await crawler.run([request])
    result = [item for item in (await crawler.get_data()).items]
    crawler.stop()
    return result