#!/usr/bin/env python3
"""Read only success wake text from a reproduction database, never a live database."""
import json, sqlite3, sys
connection = sqlite3.connect('file:' + sys.argv[1] + '?mode=ro', uri=True)
for occurred_at, payload_json in connection.execute(
    "SELECT occurred_at, payload_json FROM orchestration_events "
    "WHERE event_type = 'message.updated' AND payload_json LIKE '%All %required %passed%'"
):
    payload = json.loads(payload_json)
    print(json.dumps({'occurredAt': occurred_at, 'summary': payload.get('notification', {}).get('summary'), 'text': payload.get('text')}))