Eventos do Matcher

type RFC3339Nano = string
type DecimalString = string
type UUID = string
type MatchRunStats = Record<string, number>

// reconciliation_context.created
type ReconciliationContextCreatedDataV1 = {
  context_id: UUID
  name: string
  context_type: string
  interval: string
  status: string
  auto_match_on_upload: boolean
  created_at: RFC3339Nano
  tenant_id: string
}

// reconciliation_context.updated
type ReconciliationContextUpdatedDataV1 = {
  context_id: UUID
  name: string
  context_type: string
  interval: string
  status: string
  auto_match_on_upload: boolean
  updated_at: RFC3339Nano
  tenant_id: string
}

// reconciliation_source.created
type ReconciliationSourceCreatedDataV1 = {
  context_id: UUID
  source_id: UUID
  name: string
  source_type: string
  side: string
  created_at: RFC3339Nano
  tenant_id: string
}

// match_rule.created
type MatchRuleCreatedDataV1 = {
  context_id: UUID
  rule_id: UUID
  rule_type: string
  priority: number
  config_hash: string
  created_at: RFC3339Nano
  tenant_id: string
}

// match_rule.reordered
type MatchRuleReorderedDataV1 = {
  context_id: UUID
  ordered_rule_ids: UUID[]
  priority_version: string
  reordered_at: RFC3339Nano
  tenant_id: string
}

// fetcher_connection.synced
type FetcherConnectionSyncedDataV1 = {
  connection_id: UUID
  fetcher_connection_id: string
  config_name: string
  database_type: string
  status: string
  schema_discovered: boolean
  last_seen_at: RFC3339Nano
  updated_at: RFC3339Nano
}

// fetcher_connection.unreachable
type FetcherConnectionUnreachableDataV1 = {
  connection_id: UUID
  fetcher_connection_id: string
  previous_status: string
  status: string
  schema_discovered: boolean
  updated_at: RFC3339Nano
}

// extraction_request.created
type ExtractionRequestCreatedDataV1 = {
  extraction_request_id: UUID
  connection_id: UUID
  status: string
  table_count: number
  has_filters: boolean
  start_date: string
  end_date: string
  created_at: RFC3339Nano
}

// ingestion.completed
type IngestionCompletedDataV1 = {
  job_id: UUID
  context_id: UUID
  source_id: UUID
  status: string
  total_rows: number
  failed_rows: number
  transaction_count: number
  date_range_start?: RFC3339Nano
  date_range_end?: RFC3339Nano
  completed_at?: RFC3339Nano
  error_code?: string
}

// ingestion.failed
type IngestionFailedDataV1 = {
  job_id: UUID
  context_id: UUID
  source_id: UUID
  status: string
  total_rows: number
  failed_rows: number
  failed_at?: RFC3339Nano
  error_code?: string
}

// transaction.ignored
type TransactionIgnoredDataV1 = {
  transaction_id: UUID
  ingestion_job_id: UUID
  context_id: UUID
  source_id: UUID
  previous_status: string
  status: string
  extraction_status: string
  updated_at: RFC3339Nano
}

// transaction.matched
type TransactionMatchedDataV1 = {
  transaction_id: UUID
  context_id: UUID
  match_run_id: UUID
  previous_status: string
  status: string
  match_group_id?: UUID
  candidate_match_group_id?: UUID
  source_id?: UUID
  matched_at: RFC3339Nano
}

// transaction.pending_review
type TransactionPendingReviewDataV1 = {
  transaction_id: UUID
  context_id: UUID
  match_run_id: UUID
  previous_status: string
  status: string
  match_group_id?: UUID
  candidate_match_group_id?: UUID
  source_id?: UUID
  pending_review_at: RFC3339Nano
}

// match_run.completed
type MatchRunCompletedDataV1 = {
  match_run_id: UUID
  context_id: UUID
  mode: string
  status: string
  stats: MatchRunStats
  started_at: RFC3339Nano
  completed_at?: RFC3339Nano
}

// match_run.failed
type MatchRunFailedDataV1 = {
  match_run_id: UUID
  context_id: UUID
  mode: string
  status: string
  failure_reason: string
  started_at: RFC3339Nano
  completed_at?: RFC3339Nano
}

// match_group.confirmed
type MatchGroupConfirmedDataV1 = {
  match_group_id: UUID
  match_run_id: UUID
  context_id: UUID
  rule_id: UUID
  transaction_ids: UUID[]
  confidence: number
  status: string
  confirmed_at?: RFC3339Nano
}

// match_group.unmatched
type MatchGroupUnmatchedDataV1 = {
  match_group_id: UUID
  match_run_id: UUID
  context_id: UUID
  rule_id: UUID
  transaction_ids: UUID[]
  previous_status: string
  status: string
  reason: string
  unmatched_at: RFC3339Nano
}

// fee_variance.created
type FeeVarianceCreatedDataV1 = {
  fee_variance_id: UUID
  context_id: UUID
  match_run_id: UUID
  match_group_id: UUID
  transaction_id: UUID
  fee_schedule_id: UUID
  fee_schedule_name_snapshot: string
  currency: string
  expected_fee: DecimalString
  actual_fee: DecimalString
  delta: DecimalString
  variance_type: string
  created_at: RFC3339Nano
}

type ExceptionDataBaseV1 = {
  exception_id: UUID
  status: string
  version: number
  resolution_type?: string
  transaction_id?: UUID
}

// exception.assigned
type ExceptionAssignedDataV1 = ExceptionDataBaseV1 & {
  assigned_at: RFC3339Nano
}

// exception.resolved
type ExceptionResolvedDataV1 = ExceptionDataBaseV1 & {
  resolved_at: RFC3339Nano
}

// exception.callback_processed
type ExceptionCallbackProcessedDataV1 = ExceptionDataBaseV1 & {
  external_system: string
  external_issue_id: string
  callback_type: string
  processed_at: RFC3339Nano
}

// exception.force_match_resolved
type ExceptionForceMatchResolvedDataV1 = ExceptionDataBaseV1 & {
  resolution_type: "FORCE_MATCH"
  override_reason_code: string
  resolved_at: RFC3339Nano
}

// exception.adjust_entry_resolved
type ExceptionAdjustEntryResolvedDataV1 = ExceptionDataBaseV1 & {
  resolution_type: "ADJUST_ENTRY"
  reason_code: string
  amount: DecimalString
  currency: string
  resolved_at: RFC3339Nano
}

// exception.dispatched
type ExceptionDispatchedDataV1 = {
  exception_id: UUID
  target_system: string
  queue: string
  external_reference: string
  acknowledged: boolean
  dispatched_at: RFC3339Nano
}

// exception_comment.added
type ExceptionCommentAddedDataV1 = {
  comment_id: UUID
  exception_id: UUID
  created_at: RFC3339Nano
}

// exception_comment.deleted
type ExceptionCommentDeletedDataV1 = {
  comment_id: UUID
  exception_id: UUID
  actor: string
  deleted_at: RFC3339Nano
}

// dispute.opened
type DisputeOpenedDataV1 = {
  dispute_id: UUID
  exception_id: UUID
  state: string
  resolution?: string
  category: string
  opened_at: RFC3339Nano
}

// dispute.won and dispute.lost
type DisputeClosedDataV1 = {
  dispute_id: UUID
  exception_id: UUID
  state: string
  resolution?: string
  closed_at: RFC3339Nano
}

// evidence.submitted
type EvidenceSubmittedDataV1 = {
  evidence_id: UUID
  dispute_id: UUID
  exception_id: UUID
  has_file: boolean
  submitted_at: RFC3339Nano
}

// audit_log.created
type AuditLogCreatedDataV1 = {
  audit_log_id: UUID
  tenant_id: UUID
  entity_type: string
  entity_id: UUID
  action: string
  tenant_seq: number
  hash_version: number
  record_hash: string
  created_at: RFC3339Nano
}

// archive_metadata.created, archive.uploaded, and archive.completed
type ArchiveDataV1 = {
  archive_metadata_id: UUID
  tenant_id: UUID
  partition_name: string
  date_range_start: RFC3339Nano
  date_range_end: RFC3339Nano
  status: string
  created_at: RFC3339Nano
  updated_at: RFC3339Nano
  checksum?: string
  row_count?: number
  compressed_size_bytes?: number
  storage_class?: string
  archived_at?: RFC3339Nano
}

// actor.pseudonymized
type ActorPseudonymizedDataV1 = {
  actor_id: string
  pseudonymized: boolean
  display_name_status: "REDACTED"
  email_status: "REDACTED"
  updated_at: RFC3339Nano
  tenant_id: string
}

// export_job.created, export_job.succeeded, export_job.failed, and export_job.expired
type ExportJobDataV1 = {
  export_job_id: UUID
  tenant_id: UUID
  context_id: UUID
  report_type: string
  format: string
  status: string
  schema_version: "1.0.0"
  created_at: RFC3339Nano
  expires_at: RFC3339Nano
  updated_at: RFC3339Nano
  file_name?: string
  sha256?: string
  records_written?: number
  bytes_written?: number
  attempts?: number
  error_code?: "EXPORT_JOB_FAILED"
  finished_at?: RFC3339Nano
  expired_at?: RFC3339Nano
}