ixddlZddlmZdedejfdZdejdededefd Zdeddfd Zy) N)Optionaldb_pathreturnc^tj|d}tj|_|S)N)timeout)sqlite3connectRow row_factory)rconns %/var/www/html/luxverbi-app/db/bulk.pybulk_dbrs# ??7B /D{{D Kr tablecolc|j}|jd|d|jDcgc]}|d }}||vScc}w)NzPRAGMA table_info())cursorexecutefetchall)r rrcurrcolss r_table_has_columnr sO ++-CKK$UG1-.,,. )QAaD )D ) $; *s A ct|}|j}|jdt|dds|jd|j |j y)u Crea la tabla bulk_jobs si no existe. Nota: mantenemos access_token NOT NULL por compatibilidad con tu versión anterior. Añadimos account_alias opcional (para refrescar tokens en el cron). a CREATE TABLE IF NOT EXISTS bulk_jobs ( id TEXT PRIMARY KEY, created_at_ts INTEGER NOT NULL, publish_at_ts INTEGER NOT NULL, next_attempt_ts INTEGER NOT NULL, status TEXT NOT NULL, -- scheduled | submitting | submitted | complete | failed | cancelled attempts INTEGER NOT NULL DEFAULT 0, last_error TEXT, -- token actual (puede caducar). Se mantiene por compatibilidad. access_token TEXT NOT NULL, -- alias opcional para refrescar token en cron (recomendado) account_alias TEXT, title TEXT, privacy_level TEXT NOT NULL, allow_comment INTEGER NOT NULL, allow_duet INTEGER NOT NULL, allow_stitch INTEGER NOT NULL, commercial_toggle INTEGER NOT NULL, brand_organic_toggle INTEGER NOT NULL, brand_content_toggle INTEGER NOT NULL, is_aigc INTEGER NOT NULL, stored_filename TEXT NOT NULL, original_filename TEXT, video_url TEXT, publish_id TEXT, last_status TEXT, last_fail_reason TEXT, updated_at_ts INTEGER NOT NULL ) bulk_jobs account_aliasz3ALTER TABLE bulk_jobs ADD COLUMN account_alias TEXTN)rrrrcommitclose)rr rs r init_bulk_dbr"sX 7 D ++-CKK# %P T; @ IJKKMJJLr) r typingrstr Connectionrboolrr"rrr(s^SW// G..s5#5$5r