EU Parliament Monitor โ€” API Documentation - v1.0.11
    Preparing search index...

    Hack23 Logo

    ๐Ÿ”„ EU Parliament Monitor โ€” Future Flowcharts

    ๐Ÿ“Š From Static Intelligence Generation to AWS-Native Serverless OSINT Operations
    ๐ŸŽฏ Three Horizons: Enhanced Static (v2.0) โ†’ AWS Serverless Platform (v3.0+) โ†’ 10-Year AI Lookahead (2026-2037)

    Owner Version Timeline Status

    ๐Ÿ“‹ Document Owner: CEO | ๐Ÿ“„ Version: 4.1 | ๐Ÿ“… Last Updated: 2026-05-31 (UTC)
    ๐Ÿ”„ Review Cycle: Quarterly | โฐ Next Review: 2026-08-31 | ๐Ÿท๏ธ Release: v1.0.1
    ๐Ÿท๏ธ Classification: Public (Open Source European Parliament Monitoring Platform)


    Document Focus Description Documentation Link
    Architecture ๐Ÿ›๏ธ Architecture C4 model showing current system structure View Source
    Future Architecture ๐Ÿ›๏ธ Architecture C4 model showing future system structure View Source
    Mindmaps ๐Ÿง  Concept Current system component relationships View Source
    Future Mindmaps ๐Ÿง  Concept Future capability evolution View Source
    SWOT Analysis ๐Ÿ’ผ Business Current strategic assessment View Source
    Future SWOT Analysis ๐Ÿ’ผ Business Future strategic opportunities View Source
    Data Model ๐Ÿ“Š Data Current data structures and relationships View Source
    Future Data Model ๐Ÿ“Š Data Enhanced European Parliament data architecture View Source
    Flowcharts ๐Ÿ”„ Process Current data processing workflows View Source
    Future Flowcharts ๐Ÿ”„ Process Enhanced AI-driven workflows This Document
    State Diagrams ๐Ÿ”„ Behavior Current system state transitions View Source
    Future State Diagrams ๐Ÿ”„ Behavior Enhanced adaptive state transitions View Source
    Security Architecture ๐Ÿ›ก๏ธ Security Current security implementation View Source
    Future Security Architecture ๐Ÿ›ก๏ธ Security Security enhancement roadmap View Source
    Threat Model ๐ŸŽฏ Security STRIDE threat analysis View Source
    Classification ๐Ÿท๏ธ Governance CIA classification & BCP View Source
    CRA Assessment ๐Ÿ›ก๏ธ Compliance Cyber Resilience Act View Source
    Workflows โš™๏ธ DevOps CI/CD documentation View Source
    Future Workflows ๐Ÿš€ DevOps Planned CI/CD enhancements View Source
    Business Continuity Plan ๐Ÿ”„ Resilience Recovery planning View Source
    Financial Security Plan ๐Ÿ’ฐ Financial Cost & security analysis View Source
    End-of-Life Strategy ๐Ÿ“ฆ Lifecycle Technology EOL planning View Source
    Unit Test Plan ๐Ÿงช Testing Unit testing strategy View Source
    E2E Test Plan ๐Ÿ” Testing End-to-end testing View Source
    Performance Testing โšก Performance Performance benchmarks View Source
    Security Policy ๐Ÿ”’ Security Vulnerability reporting & security policy View Source

    This future flowchart is designed to implement all controls from Hack23 AB's ISMS framework as the EU Parliament Monitor platform evolves across its three horizons โ€” v2.0 enhanced static intelligence, v3.0+ AWS-native serverless OSINT operations, and the 10-year AI lookahead. The static front door remains the cheap, cacheable, auditable substrate; dynamic AWS-native features layer behind it without weakening provenance or neutrality guarantees.

    Policy Domain Policy Planned Implementation
    ๐Ÿ” Core Security Information Security Policy Overall security governance for enhanced monitoring & AWS workloads
    ๐Ÿค– AI Governance AI Policy AI = proposal generator; human accountability; no autonomous deploy
    ๐Ÿ› ๏ธ Development Secure Development Policy Security-integrated SSDLC for Lambda/Step Functions pipelines
    ๐ŸŒ Network Network Security Policy CloudFront + AWS WAF + Shield, VPC isolation, private endpoints
    ๐Ÿ”’ Cryptography Cryptography Policy AWS KMS, TLS 1.3, SLSA provenance, content integrity verification
    ๐Ÿ”‘ Access Control Access Control Policy Amazon Cognito, IAM least-privilege, API Gateway authorizers
    ๐Ÿท๏ธ Data Classification Data Classification Policy European Parliament PUBLIC open-data classification
    ๐Ÿ” Vulnerability Vulnerability Management CodeQL, OpenSSF Scorecard, GuardDuty, Security Hub automation
    ๐Ÿšจ Incident Response Incident Response Plan CloudWatch alarms, EventBridge-driven automated response
    ๐Ÿ’พ Backup & Recovery Backup Recovery Policy S3 versioning, DynamoDB PITR, Aurora snapshots, Git provenance
    ๐Ÿ”„ Business Continuity Business Continuity Plan Multi-AZ serverless, CloudFront edge, static fallback
    ๐Ÿค Third-Party Third Party Management EP MCP, World Bank MCP, IMF REST, Bedrock model provider review
    ๐Ÿท๏ธ Classification Classification Framework Business impact analysis for platform
    Framework Version Relevant Controls
    ISO 27001 2022 A.5.1, A.5.23, A.8.25, A.8.26, A.8.27, A.8.28
    NIST CSF 2.0 GV.OC, GV.RM, ID.AM, PR.AT, PR.DS, DE.CM
    CIS Controls v8.1 Control 1-5, 8, 13, 14, 16
    GDPR 2016/679 Public MEP roles only; data minimization; purpose limitation

    This document maps the evolution of EU Parliament Monitor's process and data flows across three strategic horizons. Today's platform (v1.0.x) is a pure static-site generator โ€” gh-aw agentic workflows author Stage-B analysis markdown, the deterministic src/aggregator/** pipeline renders 14-language HTML, and the result is served from Amazon S3 + Amazon CloudFront. No servers, no runtime database, no AI-authored HTML.

    • ๐ŸŸข v2.0 โ€” Enhanced Static Intelligence (2026 H2 โ†’ 2027): keep the static architecture. Deepen the political-landscape and party/political-group dashboards and the OSINT tradecraft (51-template catalog, ICD 203 confidence, Admiralty grading, Kent/WEP bands, 5-framework political threat methodology, 2-pass AI-first quality). All dashboard data is pre-computed at build time and delivered as static assets via CloudFront. The moat is analysis quality, not real-time infrastructure.
    • ๐Ÿ”ต v3.0+ โ€” AWS-Native Serverless OSINT Platform (2028+): layer dynamic, event-driven intelligence behind the static edge using AWS Lambda, Step Functions, EventBridge, Kinesis, API Gateway, AppSync, Cognito, DynamoDB, Aurora Serverless v2, OpenSearch Serverless, Neptune Serverless, and Amazon Bedrock (foundation models, Knowledge Bases RAG, Bedrock Agents, Guardrails). Real-time EP event ingestion, natural-language query over the political knowledge graph, and an API ecosystem for journalists and researchers.
    • โšช 10-Year AI Lookahead (2026 โ†’ 2037): annual major-model upgrades, competitor evaluation each release, model-agnostic routing via Bedrock, and resilience to paradigm shifts (quantum AI, neuromorphic computing) and AGI / post-AGI โ€” all governed by the Hack23 AI Policy (AI proposes, humans are accountable, no autonomous deploy).
    Aspect Current (v1.0.x) v2.0 (Static-Enhanced) v3.0+ (AWS Serverless)
    Trigger Scheduled gh-aw (cron) Scheduled + richer build matrix EventBridge / Kinesis (real-time)
    Compute GitHub Actions runners GitHub Actions runners AWS Lambda + Step Functions
    Authoring LLM (Claude) โ†’ markdown LLM + 51-template OSINT catalog Bedrock + Knowledge Bases RAG + Agents
    Rendering src/aggregator/** โ†’ HTML Aggregator + richer dashboards Aggregator (edge) + dynamic APIs
    Dashboards Chart.js 4 + D3 7 (in-article) Pre-computed party/landscape datasets Live datasets via AppSync/API Gateway
    Data stores Committed markdown + JSON Committed artifacts + build cache DynamoDB ยท Aurora ยท OpenSearch ยท Neptune
    Delivery S3 + CloudFront (static) S3 + CloudFront (static) CloudFront static edge + serverless APIs
    Query None (pre-rendered pages) Faceted client-side filtering NL query over knowledge graph (Bedrock)
    Neutrality control Style guide + 2-pass review Style guide + ICD 203 + Admiralty Bedrock Guardrails + human sign-off

    gantt
    title Workflow Evolution Roadmap (v2.0 to v3.0+)
    dateFormat YYYY-MM

    section v2.0 Enhanced Static Intelligence
    Party landscape dashboards :v2a, 2026-07, 3M
    Coalition mathematics visualizations :v2b, 2026-09, 2M
    OSINT 51-template catalog hardening :v2c, 2026-08, 3M
    ICD 203 + Admiralty quality gates :v2d, 2026-10, 2M
    Seat projection + election cycle views :v2e, 2026-11, 3M

    section v3.0 Serverless Foundation
    EventBridge + Kinesis ingestion :v3a, 2028-01, 3M
    Lambda + Step Functions orchestration :v3b, 2028-02, 3M
    Neptune knowledge graph build :v3c, 2028-04, 4M
    Cognito + API Gateway + AppSync :v3d, 2028-06, 3M

    section v3.x Bedrock Intelligence
    Bedrock Knowledge Bases RAG :v3e, 2028-09, 3M
    Bedrock Agents OSINT workflows :v3f, 2028-11, 4M
    NL query over knowledge graph :v3g, 2029-02, 3M
    Guardrails neutrality + GDPR controls :v3h, 2029-01, 3M

    section 10-Year AI Lookahead
    Model-agnostic Bedrock routing :ai1, 2029-06, 6M
    Autonomous agentic pipelines (assisted) :ai2, 2030-01, 12M
    Multi-parliament expansion :ai3, 2031-01, 18M

    ๐ŸŸข HORIZON v2.0 โ€” Enhanced Static Intelligence Flows

    Architecture unchanged: build-time generation, gh-aw + aggregator, pure static delivery on Amazon S3 + Amazon CloudFront. v2.0 adds depth โ€” better party/political-landscape dashboards and stronger OSINT tradecraft โ€” while every byte served remains a pre-computed static asset.

    Build-time flow producing pre-computed party / political-group dashboard datasets from European Parliament open data. All charts render client-side from JSON baked into the static bundle โ€” no server, no runtime query.

    flowchart TD
    Trigger([๐Ÿ•’ gh-aw Scheduled Workflow<br/>GitHub Actions]) --> MCPFetch[๐Ÿ”Œ EP MCP Server Fetch<br/>get_meps, get_voting_records<br/>analyze_coalition_dynamics<br/>compare_political_groups]

    MCPFetch --> Enrich[๐ŸŒ Optional Context Enrichment<br/>World Bank MCP WDI<br/>IMF REST WEO/FM]

    Enrich --> Analysis[๐Ÿง  Stage-A/B Analysis Artifacts<br/>significance-scoring, actor-mapping<br/>coalition-dynamics, voting-patterns<br/>51-template catalog]

    Analysis --> Precompute[โš™๏ธ Pre-compute Dashboard Datasets<br/>Party cohesion + defection rates<br/>Coalition mathematics<br/>Seat projections + election cycle<br/>Cross-party alliance edges]

    Precompute --> Shape[๐Ÿ“ Shape Static JSON<br/>Heatmap matrices<br/>Network graph nodes/edges<br/>Time-series voting trends]

    Shape --> AggRender[๐Ÿ—๏ธ Deterministic Aggregator<br/>src/aggregator/** renders HTML<br/>Embeds Chart.js 4 + D3 7]

    AggRender --> Lang[๐ŸŒ 14-Language Expansion<br/>Per-language static pages]

    Lang --> Commit[๐Ÿ’พ Commit Artifacts + Provenance<br/>SLSA 3, signed, version-controlled]

    Commit --> Deploy[๐Ÿ“ค Deploy Static Bundle<br/>Amazon S3 origin]

    Deploy --> CDN[โšก Amazon CloudFront<br/>Global edge cache<br/>Lambda@Edge headers/security]

    CDN --> Client[๐Ÿ–ฅ๏ธ Browser Renders Dashboards<br/>Client-side Chart.js/D3<br/>Faceted filtering, no backend]

    Client --> Done([โœ… Static Party/Landscape Dashboard Live<br/>Cacheable, cheap, auditable])

    style Trigger fill:#e8f5e9
    style MCPFetch fill:#e1f5ff
    style Precompute fill:#fff4e1
    style AggRender fill:#e1f5ff
    style CDN fill:#fff4e1
    style Done fill:#d4edda
    Dashboard Source MCP Tools Visualization Delivery
    Party / group landscape generate_political_landscape, get_meps Seat-share treemap, group cards Static JSON + Chart.js
    Coalition mathematics analyze_coalition_dynamics, compare_political_groups Stacked-bar majority calculator Static JSON + D3
    Cohesion & defection sentiment_tracker, detect_voting_anomalies Cohesion heatmap, z-score flags Static JSON + Chart.js
    Cross-party alliances network_analysis, analyze_voting_patterns Force-directed network graph Static JSON + D3
    Seat projection / election cycle electoral-domain artifacts Trend lines + projection bands Static JSON + Chart.js
    MEP / party scorecards assess_mep_influence, analyze_legislative_effectiveness Radar + ranked tables Static JSON + Chart.js

    The 2.0 moat. Every analysis artifact passes structured OSINT tradecraft โ€” ICD 203 confidence verbalization, Admiralty source grading, Kent/WEP probability bands, structured analytic techniques (ACH) โ€” and the mandatory 2-pass AI-first quality loop. STRIDE is explicitly rejected for political analysis in favour of the 5-framework political threat methodology (Political Threat Landscape 6D + Attack Trees + Kill Chain + Diamond Model + ICO Profiling).

    flowchart TD
    Raw([๐Ÿ“ฅ Raw EP Open Data<br/>MCP feeds, documents, votes]) --> Collect[๐Ÿ—‚๏ธ Collection & Provenance<br/>Source capture<br/>PUBLIC-only classification]

    Collect --> Grade[๐Ÿท๏ธ Admiralty Source Grading<br/>Reliability A-F<br/>Credibility 1-6]

    Grade --> Template[๐Ÿ“š 51-Template Catalog Routing<br/>artifact-catalog.md maps<br/>artifact to methodology]

    Template --> Pass1[โœ๏ธ Pass 1 - Initial Analysis<br/>SWOT, actor-mapping<br/>coalition-dynamics, risk-matrix<br/>significance-scoring]

    Pass1 --> Confidence[๐Ÿ“Š ICD 203 Confidence Verbalization<br/>High / Moderate / Low<br/>Kent/WEP probability bands]

    Confidence --> Threat[๐ŸŽฏ 5-Framework Threat Methodology<br/>Threat Landscape 6D, Attack Trees<br/>Kill Chain, Diamond, ICO<br/>STRIDE rejected]

    Threat --> ACH[๐Ÿ”€ Structured Analytic Techniques<br/>Competing hypotheses ACH<br/>Key assumptions check<br/>Devil's advocacy]

    ACH --> Pass2[๐Ÿ” Pass 2 - Full Read-Back<br/>Word-by-word improvement<br/>Expand shallow sections<br/>Add evidence citations]

    Pass2 --> Gate{โœ… Quality Gate<br/>Reference thresholds met?}

    Gate -->|โŒ Below floor| Refine[๐Ÿ”ง Refine & Re-deepen<br/>Add cross-references<br/>Add confidence levels]
    Refine --> Pass2

    Gate -->|โœ… Meets floor| Neutral{โš–๏ธ Neutrality & GDPR Check<br/>Politically neutral?<br/>Public roles only?}

    Neutral -->|Biased / PII risk| Adjust[๐ŸŽจ Neutralize & Minimize<br/>Remove opinion<br/>Public MEP roles only]
    Adjust --> Neutral

    Neutral -->|โœ… Neutral| Audit[๐Ÿงพ Self-Audit Artifacts<br/>workflow-audit<br/>methodology-reflection]

    Audit --> Publish([โœ… Committed Analysis Artifacts<br/>Feed aggregator + dashboards])

    style Raw fill:#e8f5e9
    style Gate fill:#fff4e1
    style Neutral fill:#fff4e1
    style Refine fill:#fff9c4
    style Adjust fill:#fff9c4
    style Publish fill:#d4edda
    Standard Purpose Where Enforced
    ICD 203 Analytic confidence verbalization Every assessment carries High/Moderate/Low
    Admiralty System Source reliability ร— credibility grading Collection stage, before analysis
    Kent / WEP bands Calibrated probability language Forecast & scenario artifacts
    ACH Competing-hypothesis discipline Significance & actor-mapping artifacts
    5-framework threat Political threat analysis (not STRIDE) political-threat-landscape artifact
    2-pass AI-first Depth & evidence quality floor All artifacts, Pass 1 + Pass 2

    ๐Ÿ”ต HORIZON v3.0+ โ€” AWS-Native Serverless OSINT Operations

    All-in on AWS, fully serverless. The static CloudFront edge stays the public, cacheable front door; dynamic intelligence is layered behind it. No Kubernetes, no self-managed message bus, no self-hosted databases โ€” every component is a managed AWS service with IAM least-privilege and zero-ops scaling.

    Event-driven pipeline replacing scheduled polling with near-real-time capture of plenary votes, committee activity, and document publication.

    flowchart TD
    EP([๐ŸŒ European Parliament Events<br/>Plenary votes, committees, docs]) --> Ingest[๐Ÿ”Œ Ingestion Lambda<br/>EP MCP + Open Data Portal<br/>Poll/subscribe adapters]

    Ingest --> Stream[๐ŸŒŠ Amazon Kinesis Data Streams<br/>Ordered event shards<br/>Durable buffer]

    Stream --> Bus[๐Ÿ“ก Amazon EventBridge<br/>Event bus + rules<br/>Schema registry]

    Bus --> Route{๐Ÿ”€ EventBridge Rule Routing<br/>detail-type}

    Route -->|Plenary Vote| VoteSF[๐Ÿ—ณ๏ธ Vote Step Functions<br/>Enrich + score significance]
    Route -->|Committee Activity| CommSF[๐Ÿ“‹ Committee Step Functions<br/>Activity + document linkage]
    Route -->|Document Published| DocSF[๐Ÿ“„ Document Step Functions<br/>Parse + classify + index]
    Route -->|Anomaly Signal| AnomSF[๐Ÿšจ Anomaly Step Functions<br/>detect_voting_anomalies]

    VoteSF --> Persist[๐Ÿ’พ Persist & Index Lambda]
    CommSF --> Persist
    DocSF --> Persist
    AnomSF --> Persist

    Persist --> DDB[(๐ŸŸฆ DynamoDB<br/>Hot single-table state)]
    Persist --> Aurora[(๐ŸŸฆ Aurora Serverless v2<br/>Voting history)]
    Persist --> OS[(๐ŸŸฆ OpenSearch Serverless<br/>Full-text + vector)]
    Persist --> Neptune[(๐ŸŸฆ Neptune Serverless<br/>Knowledge graph)]

    Persist --> Notify[๐Ÿ“ฃ Amazon SNS / SQS<br/>Downstream fan-out]

    Notify --> DLQ{Delivery OK?}
    DLQ -->|โŒ Fail| DeadLetter[(๐Ÿชฆ SQS Dead-Letter Queue<br/>Replay + alarm)]
    DLQ -->|โœ… OK| Trigger([โš™๏ธ Triggers Generation Pipeline<br/>See Bedrock flow])

    style EP fill:#e8f5e9
    style Stream fill:#e1f5ff
    style Bus fill:#e1f5ff
    style Route fill:#fff4e1
    style DLQ fill:#fff4e1
    style DeadLetter fill:#ffcdd2
    style Trigger fill:#d4edda

    ๐Ÿง  Bedrock-Backed Article & Intelligence Generation Flow

    Managed generative pipeline using Amazon Bedrock foundation models, Knowledge Bases (RAG over the EP corpus + committed analysis artifacts), Bedrock Agents for agentic OSINT tool use, and Guardrails for neutrality, GDPR, and hallucination control. Output still flows through the deterministic aggregator โ€” AI proposes content; humans remain accountable for what publishes.

    sequenceDiagram
    autonumber
    participant EB as EventBridge
    participant SF as Step Functions
    participant Agent as Bedrock Agent
    participant KB as Bedrock Knowledge Base (RAG)
    participant FM as Bedrock Foundation Model
    participant GR as Bedrock Guardrails
    participant Agg as Deterministic Aggregator
    participant Rev as Human Editor
    participant S3 as S3 + CloudFront

    EB->>SF: Significant EP event detected
    SF->>Agent: Invoke OSINT generation workflow
    Agent->>KB: Retrieve EP corpus + analysis artifacts
    KB-->>Agent: Grounded context + citations
    Agent->>FM: Generate analysis proposal (model-agnostic)
    FM-->>Agent: Draft intelligence artifact
    Agent->>GR: Apply neutrality / PII / hallucination checks
    GR-->>Agent: Pass or block with reasons
    Agent->>SF: Return graded artifact + confidence
    SF->>Rev: Route to human review queue
    Rev-->>SF: Approve / request changes (accountable sign-off)
    SF->>Agg: Approved markdown artifact
    Agg->>S3: Render 14-language static HTML
    S3-->>EB: Publish event (article.published)
    Component Role Governance
    Bedrock Foundation Models Draft analysis (Claude, Nova; model-agnostic) Routed by cost/quality/latency
    Bedrock Knowledge Bases Managed RAG grounding over EP corpus Citations required; no ungrounded claims
    Bedrock Agents Agentic OSINT tool use / orchestration Tool allow-list, least-privilege IAM
    Bedrock Guardrails Neutrality, PII/GDPR, hallucination control Blocks biased or private-life content
    Human Editor Accountable approval before publish Per AI Policy โ€” no autonomous deploy

    Authenticated, serverless API layered behind the static edge. Amazon Cognito federates identity; API Gateway (REST/WebSocket) and AppSync (GraphQL) front Lambda resolvers that read the polyglot data layer.

    flowchart TD
    User([๐Ÿ‘ค Journalist / Researcher / API Client]) --> Edge[โšก Amazon CloudFront<br/>Static edge + API routing]

    Edge --> WAF[๐Ÿ›ก๏ธ AWS WAF + Shield<br/>Rate limiting, OWASP rules]

    WAF --> Auth[๐Ÿ”‘ Amazon Cognito<br/>User pools, federated auth<br/>JWT / OAuth2 tokens]

    Auth --> AuthZ{โœ… Token Valid + Scoped?}
    AuthZ -->|โŒ Denied| Reject[๐Ÿšซ 401/403 Response]

    AuthZ -->|โœ… REST| APIGW[๐ŸŒ Amazon API Gateway<br/>REST + WebSocket APIs<br/>Authorizer + throttling]
    AuthZ -->|โœ… GraphQL| AppSync[๐Ÿ”— AWS AppSync<br/>GraphQL + subscriptions]

    APIGW --> Resolver[โš™๏ธ Lambda Resolvers<br/>Business logic, least-privilege IAM]
    AppSync --> Resolver

    Resolver --> DDB[(๐ŸŸฆ DynamoDB<br/>Hot key-value + DAX cache)]
    Resolver --> Aurora[(๐ŸŸฆ Aurora Serverless v2<br/>Relational voting history)]
    Resolver --> OS[(๐ŸŸฆ OpenSearch Serverless<br/>Full-text + vector search)]
    Resolver --> Neptune[(๐ŸŸฆ Neptune Serverless<br/>Political knowledge graph)]

    DDB --> Compose[๐Ÿงฉ Compose Response<br/>Shape JSON / GraphQL payload]
    Aurora --> Compose
    OS --> Compose
    Neptune --> Compose

    Compose --> Trace[๐Ÿ“Š CloudWatch + X-Ray<br/>Metrics, traces, CloudTrail audit]

    Trace --> Return([โœ… Response to Client<br/>Cached at edge where safe])

    style User fill:#e8f5e9
    style Auth fill:#e1f5ff
    style AuthZ fill:#fff4e1
    style Reject fill:#ffcdd2
    style Return fill:#d4edda

    Conversational OSINT access. A user asks a question in natural language; Bedrock translates intent into graph + search queries against Neptune and OpenSearch, grounds the answer via Knowledge Bases, and returns a cited, neutral response โ€” never an ungrounded opinion.

    flowchart TD
    Q([๐Ÿ’ฌ NL Question<br/>Which groups co-voted most<br/>on energy dossiers in 2028?]) --> Front[โšก CloudFront + Cognito Auth]

    Front --> NLU[๐Ÿง  Bedrock Agent<br/>Intent + entity extraction<br/>Amazon Comprehend NLP]

    NLU --> Plan[๐Ÿ—บ๏ธ Query Planning<br/>Decompose to graph + search ops]

    Plan --> GraphQ[๐Ÿ”ท Neptune Serverless<br/>Gremlin/openCypher traversal<br/>MEP-group-dossier-vote edges]
    Plan --> SearchQ[๐Ÿ”Ž OpenSearch Serverless<br/>Vector + full-text retrieval]
    Plan --> KBQ[๐Ÿ“š Bedrock Knowledge Base<br/>RAG over analysis artifacts]

    GraphQ --> Fuse[๐Ÿงฉ Evidence Fusion<br/>Join graph + search + RAG<br/>Attach source citations]
    SearchQ --> Fuse
    KBQ --> Fuse

    Fuse --> Generate[โœจ Bedrock Foundation Model<br/>Compose grounded answer]

    Generate --> Guard{โš–๏ธ Bedrock Guardrails<br/>Neutral? Grounded? PII-safe?}

    Guard -->|โŒ Block| Safe[๐Ÿšง Safe Fallback<br/>Decline + show raw evidence]
    Guard -->|โœ… Pass| Answer([๐Ÿ“‹ Cited Neutral Answer<br/>Links to dashboards + sources])

    style Q fill:#e8f5e9
    style NLU fill:#e1f5ff
    style Guard fill:#fff4e1
    style Safe fill:#ffcdd2
    style Answer fill:#d4edda

    Self-monitoring, human-governed. Quality and engagement signals feed model routing and prompt/template refinement. Per the AI Policy, model or prompt changes are proposals that require human approval and canary validation before promotion โ€” there is no autonomous production deploy.

    flowchart TD
    Observe[๐Ÿ“Š Observe<br/>CloudWatch metrics<br/>Quality scores, citations<br/>User engagement] --> Lake[๐Ÿชฃ S3 Data Lake<br/>Glue catalog + Athena<br/>QuickSight BI]

    Lake --> Detect[๐Ÿ” Pattern Detection<br/>SageMaker anomaly/quality models<br/>What drives quality?]

    Detect --> Propose[๐Ÿ’ก Improvement Proposals<br/>Model routing tweaks<br/>Prompt + template updates<br/>Guardrail adjustments]

    Propose --> Human{๐Ÿ‘ค Human Review<br/>AI Policy gate}

    Human -->|โŒ Reject| Archive[๐Ÿ—„๏ธ Archive + Document<br/>Rationale captured]
    Human -->|โœ… Approve| Canary[๐Ÿค Canary via Lambda Alias<br/>Weighted traffic shift<br/>Monitor X-Ray + alarms]

    Canary --> Result{Canary Healthy?}
    Result -->|โŒ Regress| Rollback[โ†ฉ๏ธ Rollback Alias<br/>Revert weights, post-mortem]
    Result -->|โœ… Improve| Promote[๐Ÿš€ Promote<br/>Update routing + templates]

    Promote --> Observe
    Rollback --> Observe
    Archive --> Observe

    style Observe fill:#e8f5e9
    style Human fill:#fff4e1
    style Result fill:#fff4e1
    style Rollback fill:#ffcdd2
    style Promote fill:#d4edda

    Metric Target Monitoring
    Build-to-publish (full site) <30 min per scheduled run GitHub Actions timing
    Dashboard dataset freshness โ‰ค daily (per EP feed cadence) Provenance timestamps
    Page load (LCP) <2.0 s on CloudFront edge RUM / Lighthouse CI
    Analysis quality floor All artifacts meet reference thresholds Stage-C quality gate
    Accessibility WCAG 2.1 AA axe-core CI
    Languages 14 complete Aggregator coverage check
    Metric Target Monitoring
    Event ingestion latency <30 s (event โ†’ indexed) CloudWatch + X-Ray
    Breaking analysis (assisted) <5 min event โ†’ reviewed draft Step Functions metrics
    API response (P95) <200 ms API Gateway / AppSync metrics
    NL query (P95) <3 s grounded answer Bedrock + X-Ray traces
    Static edge availability 99.99% (CloudFront + S3) CloudWatch Synthetics
    Guardrail block accuracy >95% neutrality/PII enforcement Bedrock Guardrails reports
    Cost per 1k API calls Within serverless budget envelope Cost Explorer / Budgets

    Process Step Current (v1.0.x) v2.0 (Static-Enhanced) v3.0+ (AWS Serverless)
    Event detection Scheduled gh-aw cron Scheduled cron (richer matrix) EventBridge + Kinesis (<30 s)
    Compute substrate GitHub Actions runners GitHub Actions runners Lambda + Step Functions
    Data fetching EP MCP batch EP MCP + WB/IMF enrichment Streaming ingestion adapters
    Analysis authoring LLM โ†’ markdown LLM + 51-template OSINT Bedrock + KB RAG + Agents
    Quality control 2-pass review ICD 203 + Admiralty + 2-pass Guardrails + human sign-off
    Dashboards In-article Chart.js/D3 Pre-computed party/landscape Live AppSync/API Gateway data
    Rendering Aggregator โ†’ HTML Aggregator โ†’ HTML Aggregator (edge) + dynamic APIs
    Data stores Committed markdown/JSON Committed artifacts + cache DynamoDB ยท Aurora ยท OpenSearch ยท Neptune
    Query None (pre-rendered) Client-side faceted filter NL query over knowledge graph
    Identity None (public static) None (public static) Amazon Cognito federated auth
    Delivery S3 + CloudFront S3 + CloudFront CloudFront edge + serverless APIs
    Observability Actions logs Actions logs + RUM CloudWatch ยท X-Ray ยท CloudTrail

    The flows above cover analysis and delivery. These flows add the missing intelligence-cycle stages โ€” direction (PIR), indications and warning, adversarial review, integrity analytics, and counter-FIMI โ€” that turn the platform from an analysis pipeline into a full OSINT observatory. They are the process view of the capability roadmap in FUTURE_MINDMAP.md. Every flow ends at a human-accountability gate; none publishes autonomously.

    flowchart TD
    REQ([๐Ÿ“‹ Intelligence Requirements<br/>standing + event-driven]) --> NAI[๐ŸŽฏ Define Named Areas of Interest<br/>contested dossier, fracturing group, election]
    NAI --> EEI[๐Ÿงฉ Derive Essential Elements of Information<br/>what must be known to answer]
    EEI --> TASK[๐Ÿ›ฐ๏ธ Task Agentic Collectors<br/>EP MCP, DOCEO, external, ASR]
    TASK --> COV{๐Ÿ“Š Coverage vs Gap?}
    COV -->|Gap found| RETASK[๐Ÿ” Re-task Collection<br/>add source, widen window]
    RETASK --> TASK
    COV -->|Sufficient| MANI[๐Ÿงพ Provenance Manifest<br/>collection-plan.json]
    MANI --> HAND([โžก๏ธ Hand to Processing + Analysis])

    style REQ fill:#e7f0ff
    style COV fill:#fff4e1
    style RETASK fill:#fff9c4
    style HAND fill:#d4edda
    flowchart TD
    WATCH([๐Ÿ‘๏ธ Watchlist Indicators<br/>cohesion, attendance, abstention, rhetoric]) --> BASE[๐Ÿ“ˆ Compare to Rolling Baseline]
    BASE --> TRIP{๐Ÿšจ Tripwire breached?}
    TRIP -->|No| LOG[๐Ÿ—’๏ธ Log Baseline Drift<br/>suppress false alarms]
    TRIP -->|Yes| DRAFT[โœ๏ธ Draft Warning<br/>WEP band + evidence chain]
    DRAFT --> HUMAN{๐Ÿง‘โ€โš–๏ธ Human confirms?}
    HUMAN -->|No| LOG
    HUMAN -->|Yes| EMIT([๐Ÿ“ฃ Graded Warning<br/>brief + alert + dashboard])
    EMIT --> CAL[๐ŸŽฏ Record for Calibration]
    LOG --> CAL
    CAL -.feedback.-> BASE

    style WATCH fill:#e7f0ff
    style TRIP fill:#fff4e1
    style HUMAN fill:#fff4e1
    style DRAFT fill:#fff9c4
    style EMIT fill:#d4edda
    style LOG fill:#eceff1
    flowchart TD
    Q([โ“ Estimative Question<br/>will dossier X pass? will coalition hold?]) --> HYP[๐Ÿง  Generate Competing Hypotheses<br/>minimum two, mutually exclusive]
    HYP --> EVID[๐Ÿ”— Map Evidence to Hypotheses<br/>cited PUBLIC sources only]
    EVID --> ACH[๐Ÿ”€ ACH Matrix<br/>diagnostic evidence weighting]
    ACH --> RED[๐Ÿ˜ˆ Devil's Advocate Agent<br/>attack the leading hypothesis]
    RED --> KAC[๐Ÿงพ Key Assumptions Check<br/>what would falsify this?]
    KAC --> SPLIT{๐Ÿค Analyst agreement?}
    SPLIT -->|Dissent| RECORD[๐Ÿ“ Record Dissent<br/>preserve minority view]
    RECORD --> ADJ[๐Ÿง‘โ€โš–๏ธ Human Adjudication]
    SPLIT -->|Converged| ADJ
    ADJ --> EST([๐Ÿ“Š WEP-Banded Estimate<br/>confidence + evidence chain])

    style Q fill:#e7f0ff
    style RED fill:#ffe0e0
    style SPLIT fill:#fff4e1
    style RECORD fill:#fff9c4
    style EST fill:#d4edda
    flowchart TD
    PUB([๐Ÿ—‚๏ธ PUBLIC Sources<br/>declarations, register, roll-calls, media]) --> NORM[๐Ÿงน Normalize + Entity Resolve]
    NORM --> INT[๐Ÿ” Integrity Analytics<br/>lobby-to-vote, revolving-door overlap]
    NORM --> FIMI[๐Ÿ›ฐ๏ธ Counter-FIMI Detection<br/>DISARM TTP tagging, coordination signals]
    INT --> QUEST[โ“ Sourced Question<br/>NOT an accusation]
    FIMI --> CTX[๐Ÿงญ Neutral Context<br/>sourced fact vs spin]
    QUEST --> GATE{๐Ÿง‘โ€โš–๏ธ Human Review<br/>neutral, sourced, public-role?}
    CTX --> GATE
    GATE -->|Needs work| REFINE[๐Ÿ”ง Re-source / Re-frame]
    REFINE --> GATE
    GATE -->|Approved| OUT([โœ… Published with Evidence Chain])

    style PUB fill:#e7f0ff
    style FIMI fill:#ffe0e0
    style INT fill:#ede7f6
    style GATE fill:#fff4e1
    style REFINE fill:#fff9c4
    style OUT fill:#d4edda

    Boundary reminder. Integrity findings are sourced questions for journalistic review, never adjudicated accusations. Counter-FIMI is detection and context only โ€” the platform never conducts influence operations and never targets individuals' private lives.


    The platform's workflows evolve from human-orchestrated gh-aw pipelines, through AWS-native serverless OSINT operations, toward increasingly autonomous โ€” but always human-accountable โ€” agentic intelligence. Three principles hold across the decade: model-agnostic routing (no single-vendor lock-in via Amazon Bedrock), neutrality and provenance by construction, and AI as a proposal generator with humans accountable for every publish (per the AI Policy).

    Year AI Model DevSecOps Capability Evolution
    2026 Opus 4.6โ€“4.9 ๐ŸŸข AI-assisted code review, automated test generation, agentic CI/CD workflows
    2027 Opus 5.x ๐Ÿ”ต Predictive vulnerability detection, intelligent dependency management
    2028 Opus 6.x ๐ŸŸฃ Multi-modal security analysis (code + architecture + runtime), automated threat modeling
    2029 Opus 7.x ๐ŸŸ  Autonomous security pipeline orchestration, self-healing build systems
    2030 Opus 8.x ๐Ÿ”ด Near-expert automated security review, AI-driven architecture validation
    2031โ€“2033 Opus 9โ€“10.x / Pre-AGI โšช Autonomous secure development lifecycle management
    2034โ€“2037 AGI / Post-AGI โญ Transformative software engineering with built-in security assurance

    Assumptions: major AI model upgrades occur annually; competitors (OpenAI, Google, Meta, EU sovereign AI) are evaluated at each release; the architecture accommodates potential paradigm shifts (quantum AI, neuromorphic computing). Full cross-perspective analysis lives in the Hack23 Information Security Strategy ยง AI Model Evolution Strategy; governance per AI Policy.

    • Self-Directing OSINT Workflows: Bedrock Agents propose which analyses to generate based on parliamentary-activity signals and significance scoring; humans approve scope. AI decides what to draft, not what to publish.
    • Model-Agnostic Bedrock Routing: every generation task routed to the optimal foundation model (Opus 5.x, Amazon Nova, open-source) by cost, quality, and latency โ€” swappable without rewriting pipelines.
    • Zero-Touch Drafting, Human Publish: routine summaries flow end-to-end to a reviewed draft automatically; a human editor remains the accountable gate before CloudFront publication.
    • Anticipatory Frameworks: Step Functions pre-stage analytical scaffolds for upcoming votes and committee sessions from the EP calendar in Neptune.
    • Dynamic Workflow Composition: Bedrock Agents assemble optimal Step Functions graphs on demand by content type, urgency, and quality requirement.
    • Cross-Parliament Synthesis: serverless fan-out detects related legislative activity across multiple parliaments for comparative, neutral analysis.
    • Causal Analysis Pipelines: trace legislative impacts through economic (IMF/World Bank), social, and environmental indicators with cited evidence chains.
    • Adaptive Guardrails: Bedrock Guardrails dynamically tune to content sensitivity and regulatory context while holding the neutrality floor.
    • Global Event Correlation: Kinesis + Neptune correlate parliamentary events worldwide to surface emerging legislative trends.
    • Continuous Democratic Monitoring: AGI-class systems monitor covered parliaments with real-time, evidence-cited analysis โ€” under standing human oversight and audit (CloudTrail, Security Hub).
    • Natural-Language Workflow Definition: stakeholders describe desired analyses in plain language; systems design and execute optimal serverless workflows, subject to AI-Policy approval gates.
    • Self-Evolving, Human-Accountable Pipelines: workflows propose their own efficiency and quality improvements; promotion always requires human sign-off and canary validation โ€” never autonomous production deploy.


    Document Status: โœ… APPROVED FOR PLANNING
    Last Updated: 2026-05-31 (UTC) | Release: v1.0.1
    Next Review: 2026-08-31 (Quarterly)
    Classification: Public