"""add_objective_metrics_connections

Revision ID: d55cd0c624a5
Revises: 8c756c5af8c0
Create Date: 2021-03-25 10:56:38.657601

"""
from alembic import op
import sqlalchemy as sa


# revision identifiers, used by Alembic.
revision = 'd55cd0c624a5'
down_revision = '8c756c5af8c0'
branch_labels = None
depends_on = None

updated_video_watched_field = {
    "name": "Video 100% Watched",
    "title": "100% Watched",
    "total_name": "Average Video 100% Watched",
    "description": "Percentage of people who watched 100% of the video(s)",
  }


def upgrade():
    bind = op.get_bind()
    meta = sa.MetaData(bind=bind)
    meta.reflect()
    objective_metrics_table = meta.tables["ObjectiveMetricsField"]
    metrics_table = meta.tables["MetricsField"]

    op.execute(
        objective_metrics_table.update().values(index=objective_metrics_table.c.index * 10)
    )

    op.execute(
        metrics_table.update().values(**updated_video_watched_field).where(metrics_table.c.id == 41)
    )

    op.execute(
        objective_metrics_table.insert().values(metrics_field_id=63, objective_id=17, index=25)
    )
    op.execute(
        objective_metrics_table.insert().values(metrics_field_id=64, objective_id=17, index=35)
    )
    op.execute(
        objective_metrics_table.insert().values(metrics_field_id=60, objective_id=14, index=61)
    )
    op.execute(
        objective_metrics_table.insert().values(metrics_field_id=61, objective_id=14, index=62)
    )
    op.execute(
        objective_metrics_table.insert().values(metrics_field_id=59, objective_id=14, index=100)
    )
    op.execute(
        objective_metrics_table.insert().values(metrics_field_id=15, objective_id=14, index=110)
    )

    op.execute(
        metrics_table.update().values(format_id=4).where(metrics_table.c.id == 69)
    )


def downgrade():
    bind = op.get_bind()
    meta = sa.MetaData(bind=bind)
    meta.reflect()
    objective_metrics_table = meta.tables["ObjectiveMetricsField"]

    op.execute(
        objective_metrics_table.delete().where(objective_metrics_table.c.metrics_field_id.in_(63, 64, 60, 61, 59, 15))
    )

    op.execute(
        objective_metrics_table.update().values(index=int(objective_metrics_table.c.index / 10))
    )