nngo/LT_Janitorial_Quality_Control
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Jun 24 - Implement devices tracker - Fix phase30 migration file

Browse Source
This commit is contained in:
Nguyen Ngo
2026-06-24 17:25:02 -04:00
parent e77489d3d8
commit b8b89f39f1
1 changed files with 23 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
migrations/versions/phase30_device_registry.py
+23 -29
View File
@@ -1,41 +1,35 @@
"""phase30 — device_registrations table for iOS device tracking """phase30 — device_registrations table for iOS device tracking
Revision ID: phase30_device_registry Each row records a device that has opened the JanitorialQC app.
Down revision: phase29_broadcasts Upserted on every app foreground so last_seen_at stays current.
""" """
from alembic import op
revision = 'phase30_device_registry' revision = 'phase30_device_registry'
down_revision = 'phase29_broadcasts' down_revision = 'phase29_broadcasts'
branch_labels = None
from alembic import op depends_on = None
import sqlalchemy as sa
def upgrade(): def upgrade():
# Guard: skip if table already exists (safe to re-run) op.execute("""
conn = op.get_bind() CREATE TABLE IF NOT EXISTS device_registrations (
exists = conn.execute(sa.text( id INT NOT NULL AUTO_INCREMENT PRIMARY KEY,
"SELECT COUNT(*) FROM INFORMATION_SCHEMA.TABLES " device_id VARCHAR(64) NOT NULL,
"WHERE TABLE_SCHEMA = DATABASE() AND TABLE_NAME = 'device_registrations'" user_id INT NOT NULL,
)).scalar() device_name VARCHAR(255) NOT NULL DEFAULT '',
if exists: app_version VARCHAR(32) NOT NULL DEFAULT '',
return ios_version VARCHAR(32) NOT NULL DEFAULT '',
registered_at DATETIME NOT NULL,
op.create_table( last_seen_at DATETIME NOT NULL,
'device_registrations', CONSTRAINT uq_device_id UNIQUE (device_id),
sa.Column('id', sa.Integer(), primary_key=True), CONSTRAINT fk_device_reg_user
sa.Column('device_id', sa.String(64), nullable=False), FOREIGN KEY (user_id) REFERENCES users(id)
sa.Column('user_id', sa.Integer(), sa.ForeignKey('users.id'), nullable=False), ON DELETE CASCADE
sa.Column('device_name', sa.String(255), nullable=False, server_default=''), ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4
sa.Column('app_version', sa.String(32), nullable=False, server_default=''), """)
sa.Column('ios_version', sa.String(32), nullable=False, server_default=''),
sa.Column('registered_at', sa.DateTime(), nullable=False),
sa.Column('last_seen_at', sa.DateTime(), nullable=False),
)
op.create_index('uq_device_id', 'device_registrations', ['device_id'], unique=True)
op.create_index('ix_device_registrations_user_id', 'device_registrations', ['user_id'])
def downgrade(): def downgrade():
op.drop_table('device_registrations') op.execute("DROP TABLE IF EXISTS device_registrations")