Prismatic OSINT EU Institutions

Overview

Prismatic OSINT EU Institutions provides adapter pattern implementations for European Union institutional data sources, integrating with EU sanctions lists, ECB financial data, Europol threat assessments, and EU regulatory databases for comprehensive European intelligence collection. Each adapter normalizes source-specific data formats into the platform's unified entity resolution schema, enabling cross-source correlation and knowledge graph integration through consistent data structures.

The application implements real-time monitoring of EU sanctions list updates, automatically detecting additions, removals, and modifications to consolidated restrictive measures lists. Entity matching against sanctions lists uses fuzzy name resolution with transliteration support for names across European languages, combined with confidence scoring derived from the platform's NABLA epistemic framework to distinguish true matches from coincidental name similarities. All screening results pass through Trinity Gate validation before being reported as findings.

Financial intelligence adapters integrate with ECB reference rates, EU trade statistics, and state aid databases, providing the economic context necessary for comprehensive due diligence assessments. Regulatory data adapters cover ECHA chemical substance registrations, EMA medicinal product authorizations, and TED public procurement data, enabling cross-domain intelligence synthesis that connects business entities to their regulatory footprint across the European Union.

Architecture

Source Adapters --> Response Parser --> Entity Normalizer --> Evidence Store
       |                  |                    |                    |
  EU Sanctions       XML/JSON/CSV          Unified Schema      Knowledge Graph
  ECB Data           Normalization         Confidence Score     PostgreSQL
  TED Tenders        Validation            Source Provenance    Meilisearch
  ECHA/EMA           Rate Limiting         Deduplication        ETS Cache
       |                  |                    |                    |
       +------------------+--------------------+--------------------+
                                 |
                          Update Monitor --> Change Notifications
                                 |
                          Screening Engine --> Fuzzy Entity Matching

All parsing and entity normalization follows pure function principles. Network requests use rate limiting and backpressure to comply with EU API usage policies. Each adapter runs in its own supervised process under the OTP supervision tree.

Key Modules

Key Features

EU Sanctions Screening

The sanctions screening engine implements multi-criteria matching against the EU consolidated sanctions list, handling the complexity of names across European languages:

defmodule PrismaticOsintEuInstitutions.ScreeningEngine do
  @spec screen(String.t(), keyword()) :: {:ok, ScreeningResult.t()} | {:error, term()}
  def screen(entity_name, opts \\ []) do
    lists = Keyword.get(opts, :lists, [:eu_consolidated])
    threshold = Keyword.get(opts, :threshold, 0.85)

    candidates = Enum.flat_map(lists, fn list ->
      SanctionsAdapter.search(list, entity_name)
    end)

    matches = candidates
    |> Enum.map(fn candidate ->
      scores = %{
        exact: exact_match_score(entity_name, candidate.name),
        fuzzy: fuzzy_match_score(entity_name, candidate.name),
        transliterated: transliteration_score(entity_name, candidate.name),
        alias: alias_match_score(entity_name, candidate.aliases)
      }
      {candidate, aggregate_score(scores)}
    end)
    |> Enum.filter(fn {_candidate, score} -> score >= threshold end)
    |> Enum.sort_by(fn {_candidate, score} -> score end, :desc)

    {:ok, %ScreeningResult{
      entity: entity_name,
      matches: format_matches(matches),
      clear: Enum.empty?(matches),
      screening_id: generate_screening_id(),
      confidence: compute_result_confidence(matches),
      timestamp: DateTime.utc_now()
    }}
  end
end

• Consolidated EU sanctions list screening with real-time update monitoring and automatic list refresh
• Entity matching with fuzzy name resolution, transliteration support, and alias cross-referencing
• Sanctions program categorization (terrorism, proliferation, human rights, regional) with regime mapping
• Screening result confidence scoring with configurable thresholds for automated vs. manual review routing

Financial Intelligence

• ECB reference rates and monetary statistics with historical time-series access for currency analysis
• EU trade statistics and cross-border transaction pattern analysis for trade-based intelligence
• Financial regulation entity lists (banking, insurance, investment supervision) for authorized entity verification
• State aid database access for subsidy and government support tracking across member states

Regulatory Data Integration

• European Chemicals Agency (ECHA) substance registration and REACH compliance data
• European Medicines Agency (EMA) medicinal product authorization and pharmacovigilance
• EU procurement data from TED (Tenders Electronic Daily) with contract award monitoring
• EU regulatory body decision databases for enforcement action tracking

Real-Time Update Monitoring

The UpdateMonitor process continuously tracks changes to EU data sources, detecting additions, removals, and modifications:

defmodule PrismaticOsintEuInstitutions.UpdateMonitor do
  use GenServer

  @check_interval :timer.minutes(15)

  def handle_info(:check_updates, state) do
    updates = Enum.flat_map(state.monitored_sources, fn source ->
      case check_source_updates(source, state.last_check[source]) do
        {:ok, changes} -> [{source, changes}]
        {:error, _} -> []
      end
    end)

    Enum.each(updates, fn {source, changes} ->
      PrismaticPubSub.broadcast("eu_institutions:updates", {:source_updated, source, changes})
    end)

    Process.send_after(self(), :check_updates, @check_interval)
    {:noreply, update_last_check(state, updates)}
  end
end

Source Health Monitoring

• Availability tracking per EU data source with automatic failover and retry logic
• Circuit breaker patterns preventing cascading failures when EU portals are unavailable
• Telemetry emission for source response times, error rates, and data freshness metrics

Integrated Sources

Usage

# EU sanctions screening with confidence scoring
{:ok, result} = PrismaticOsintEuInstitutions.sanctions_screen("Entity Name",
  lists: [:eu_consolidated, :eu_terrorism],
  threshold: 0.85
)
# => %{matches: [...], confidence: 0.92, screening_id: "scr_..."}

# EU procurement search via TED
{:ok, tenders} = PrismaticOsintEuInstitutions.ted_search(
  keywords: "cybersecurity", country: "CZ", min_value: 100_000)
# => %{tenders: [...], total: 47, page: 1}

# ECB reference rate data
{:ok, rates} = PrismaticOsintEuInstitutions.ecb_rates(:CZK, period: :last_90_days)
# => %{current: 25.12, history: [...], trend: :stable}

# ECHA substance lookup
{:ok, substance} = PrismaticOsintEuInstitutions.echa_lookup(cas: "64-17-5")
# => %{name: "Ethanol", reach_status: :registered, tonnage_band: "1000+"}

# Monitor EU source updates
{:ok, _} = PrismaticOsintEuInstitutions.subscribe_updates(:eu_sanctions)

NABLA Compliance

Testing

Sanctions screening tests verify fuzzy matching accuracy, transliteration correctness, and false positive rates against labeled datasets of known sanctioned and non-sanctioned entities. ECB adapter tests verify rate data parsing, historical series accuracy, and update detection. TED adapter tests verify procurement search relevance and contract data completeness.

Integration tests exercise the full pipeline from EU source fetching through parsing, normalization, and evidence store persistence. Update monitoring tests verify change detection accuracy across simulated list updates.

Integration Points

Performance

Telemetry events: [:prismatic, :osint_eu, :sanctions_screened], [:prismatic, :osint_eu, :source_updated], [:prismatic, :osint_eu, :rate_fetched].

Related Resources

• Prismatic OSINT Core -- Core OSINT infrastructure shared across all source adapters
• Business Financial Intelligence Specialist -- Coordinates EU financial intelligence analysis
• Competitor Researcher -- Leverages EU procurement data for competitive intelligence
• Cross Pollination Specialist -- Cross-domain intelligence synthesis from EU sources
• Intelligence Synthesis -- Multi-source EU evidence fusion for entity assessment
• NABLA Axioms -- Epistemic confidence scoring for sanctions screening results
• Real-Time Monitoring -- EU source availability and data freshness monitoring

Connect & Contribute

Created by Tomáš Korcak (korczis) | Open Source under GHL

• GitHub | GitLab | LinkedIn | Contact
• Developer Portal | Architecture | Meet the Creator