import json
import os
import time
import psycopg2
from psycopg2.extras import RealDictCursor

since = time.time() - 600
with psycopg2.connect(os.environ['DATABASE_URL'], connect_timeout=3,
                      options='-c statement_timeout=2000 -c default_transaction_read_only=on') as conn:
    with conn.cursor(cursor_factory=RealDictCursor) as cursor:
        cursor.execute("""SELECT event_id,payload,artifact_state,delivery_state,http_status,created_at
            FROM contextra_event_artifacts WHERE created_at >= %s
            AND payload->>'cameraId'='24' ORDER BY created_at DESC LIMIT 5""", (since,))
        events = [dict(x) for x in cursor.fetchall()]
    conn.rollback()
print(json.dumps({'since': since, 'recent_events': events}))