vbatts/quay
Archived
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Add bidirectional migration code of webhooks to/from repo-push webhook notifications.

Browse source
This commit is contained in:
Joseph Schorr 2014-07-31 16:02:14 -04:00
parent ee2abf590a
commit a44345338d
1 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
data/migrations/versions/47670cbeced_migrate_existing_webhooks_to_.py
View file

@ -3,6 +3,7 @@
Revision ID: 47670cbeced Revision ID: 47670cbeced
Revises: 325a4d7c79d9 Revises: 325a4d7c79d9
Create Date: 2014-07-31 13:49:38.332807 Create Date: 2014-07-31 13:49:38.332807
Hand Edited By Joseph Schorr
""" """
@ -12,11 +13,17 @@ down_revision = '325a4d7c79d9'
from alembic import op from alembic import op
import sqlalchemy as sa import sqlalchemy as sa
from data.database import *
from app import app
def upgrade(): def upgrade():
pass event_id = list(db.execute_sql('Select id From ExternalNotificationEvent Where name="repo_push" Limit 1', ()))[0][0]
method_id = list(db.execute_sql('Select id From ExternalNotificationMethod Where name="webhook" Limit 1', ()))[0][0]
db.execute_sql('Insert Into RepositoryNotification (uuid, repository_id, event_id, method_id, config_json) Select public_id, repository_id, %s, %s, parameters FROM Webhook' % (event_id, method_id))
def downgrade(): def downgrade():
pass event_id = list(db.execute_sql('Select id From ExternalNotificationEvent Where name="repo_push" Limit 1', ()))[0][0]
method_id = list(db.execute_sql('Select id From ExternalNotificationMethod Where name="webhook" Limit 1', ()))[0][0]
db.execute_sql('Insert Into Webhook (public_id, repository_id, parameters) Select uuid, repository_id, config_json FROM RepositoryNotification Where event_id=%s And method_id=%s' % (event_id, method_id))