41 lines
1.2 KiB
Python
41 lines
1.2 KiB
Python
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 |