U ?ti@sPddlZddlmZeejdddZejeeedddZeddd d ZdS) N)Optional)db_pathreturncCstj|dd}tj|_|S)N)timeout)sqlite3connectRow row_factory)rconnr %/var/www/html/luxverbi-app/db/bulk.pybulk_dbsr)r tablecolrcCs4|}|d|ddd|D}||kS)NzPRAGMA table_info()cSsg|] }|dqS)r ).0rr r r sz%_table_has_column..)cursorexecutefetchall)r rrcurcolsr r r _table_has_column srcCsDt|}|}|dt|dds0|d||dS)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 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 ) Z bulk_jobsZ account_aliasz3ALTER TABLE bulk_jobs ADD COLUMN account_alias TEXTN)rrrrcommitclose)rr rr r r init_bulk_dbs(  r) rtypingrstr Connectionrboolrrr r r r s