"""Local duplicate-delivery example; no model, email or external service calls."""

import json
import sqlite3
from contextlib import closing
from pathlib import Path
from tempfile import TemporaryDirectory


if __name__ == '__main__':
    with TemporaryDirectory(prefix='task-dedup-demo-') as directory:
        with closing(sqlite3.connect(Path(directory) / 'demo.db')) as conn:
            conn.execute('CREATE TABLE jobs (request_id TEXT PRIMARY KEY, result TEXT NOT NULL)')
            outcomes = []
            for request_id in ('request-001', 'request-001'):
                with conn:
                    cursor = conn.execute('INSERT OR IGNORE INTO jobs VALUES (?, ?)', (request_id, 'local result'))
                outcomes.append('stored' if cursor.rowcount else 'duplicate_skipped')
            count = conn.execute('SELECT COUNT(*) FROM jobs').fetchone()[0]
            assert outcomes == ['stored', 'duplicate_skipped'] and count == 1
            print(json.dumps({'deliveries': 2, 'stored_jobs': count, 'outcomes': outcomes,
                              'external_side_effects_tested': False}, indent=2))