import asyncio
import json
import re
from . import get_sq_env
import aiosqlite
from time import time

from . import asquare
from . import db
from . import abricksetapi
from . import throttler 
Throttler = throttler.GlobalThrottler


LEGO_CAT_ID = get_sq_env.LEGO_CAT_ID

# big glue boy
async def do_review() -> bool:
    result = await asquare.acat2id(LEGO_CAT_ID) # type: ignore
    for item in result:
        if not re.match(r".*\d{5}.*", item["name"]):
            missing = []
            print(f"{item} is missing its set number!")
            #print(f"[@DEBUG] Upserting {item['id']} into REVIEW table")
            item_sanitized = {
                "sq_object": item["id"],
                "set_name": item["name"],
                "set_number": None,
                "time_added": time
            }
            missing.append(item_sanitized)
    
    for item in missing:
        print(item)
        # sq_item = await db.fetch(item["id"])  
        if item["id"] != sq_item["sq_object"]:
            print(f"[@DEBUG] {item['id']} is missing)")
            #await db.upsert("MISSING", item_sanitized, "sq_object")
        #    #print(f"[@DEBUG] Upserted {item['id']} into REVIEW table")
        #print(f"[@DEBUG] {item['id']} already in REVIEW table")
    return True