Eventos de Lender

Referencia de cada CloudEvent que Lender emite en develop, con streams de aplicación, versiones de esquema, asuntos, contratos de payload, definiciones solo de catálogo y consumidores conectados.

Lender publica CloudEvents 1.0 en modo de contenido binario a través de lib-streaming v3. La emisión de negocio es solo mediante outbox y al menos una vez: la escritura de dominio y el envelope del outbox comparten una única transacción de base de datos, y el relay publica después del commit.

​

Contrato de stream de aplicación

• ce-source: lender
• Hechos: lerian.streaming.lender
• Comandos: lerian.streaming.lender.commands
• Ruta de dead letters: lerian.streaming.lender.dlq
• ce-type: studio.lerian.lender.<resource>.<event>
• Clave de despacho: <resource>.<event> a partir de ce-resourcetype y ce-eventtype

El tema identifica la aplicación productora y la clase de stream, no un evento individual. Enruta por los headers de CloudEvents, no por un nombre de tema por evento. Lender expone el catálogo exacto y los temas de aplicación en GET /api/v1/streaming/manifest.

​

Eventos emitidos

El catálogo declara 37 definiciones. Lender tiene llamadores de producción para 34 de ellas: 32 hechos y 2 comandos. La tabla separa las claves de catálogo del tipo de enrutamiento de CloudEvent.

Clave de definición	ce-type	Stream	Esquema	Asunto	Se dispara cuando
accounting_profile.configured	studio.lerian.lender.accounting_profile.configured	Hecho	1.1.0	profile_id	Un perfil contable se convierte en la configuración activa.
assignment_set.approved	studio.lerian.lender.assignment_set.approved	Hecho	1.0.0	assignment_set_id	Una composición de cesión queda aprobada de forma duradera y su archivo de oferta se vuelve derivable a partir de esa aprobación.
assignment_set.accepted	studio.lerian.lender.assignment_set.accepted	Hecho	1.0.0	assignment_set_id	Un administrador de fondos acepta la cesión completa y sus cuentas por cobrar salen del portafolio del tenant.
collection.payment.applied	studio.lerian.lender.collection_payment.applied	Hecho	1.0.0	application_id	Un pago de cobranza verificado se aplica a una ruta de préstamo.
collection.payment.unapplied	studio.lerian.lender.collection_payment.unapplied	Hecho	1.0.0	application_id	Un pago de cobranza verificado se retiene como efectivo no aplicado.
collection.payment.reapplied	studio.lerian.lender.collection_payment.reapplied	Hecho	1.0.0	application_id	El efectivo previamente no aplicado se libera hacia las cuentas por cobrar.
collection.payment.refunded	studio.lerian.lender.collection_payment.refunded	Hecho	1.0.0	application_id	El efectivo previamente no aplicado se reembolsa a través del proveedor.
loan_application.submitted	studio.lerian.lender.loan_application.submitted	Hecho	2.0.0	loan_application_id	Una solicitud validada se persiste para evaluación crediticia.
loan_application.approved	studio.lerian.lender.loan_application.approved	Hecho	2.0.0	loan_application_id	Una solicitud pendiente se aprueba.
loan_application.rejected	studio.lerian.lender.loan_application.rejected	Hecho	2.0.0	loan_application_id	Una solicitud pendiente se rechaza.
loan_application.withdrawn	studio.lerian.lender.loan_application.withdrawn	Hecho	2.0.0	loan_application_id	Una solicitud pendiente se retira.
loan_application.disbursed	studio.lerian.lender.loan_application.disbursed	Hecho	2.0.0	loan_application_id	Se desembolsan fondos para una solicitud aprobada.
loan_charge.applied	studio.lerian.lender.loan_charge.applied	Hecho	1.0.0	loan_account_id	Un cargo de la versión del producto se persiste en una cuenta de préstamo.
loan_product.created	studio.lerian.lender.loan_product.created	Hecho	1.0.0	loan_product_id	Se crea un producto de préstamo en borrador.
loan_product.activated	studio.lerian.lender.loan_product.activated	Hecho	1.0.0	loan_product_id	Un producto de préstamo se activa.
loan_product.current_version_promoted	studio.lerian.lender.loan_product.current_version_promoted	Hecho	1.0.0	loan_product_id	Un producto activo pasa a apuntar a otra de sus versiones.
loan_product_version.created	studio.lerian.lender.loan_product_version.created	Hecho	1.0.0	loan_product_version_id	Se agrega una versión inmutable del producto de préstamo.
loan_schedule.prepayment_applied	studio.lerian.lender.loan_schedule.prepayment_applied	Hecho	1.0.0	schedule_version_id	Un prepago crea una versión sucesora del cronograma.
loan_schedule.rescheduled	studio.lerian.lender.loan_schedule.rescheduled	Hecho	1.0.0	schedule_version_id	Una reprogramación crea una versión sucesora del cronograma.
repayment.recorded	studio.lerian.lender.repayment.recorded	Hecho	1.0.0	transaction_id	Se registra un pago y su asignación de efectivo.
returned_payment_receivable.opened	studio.lerian.lender.returned_payment_receivable.opened	Hecho	1.0.0	receivable_id	Un pago final revertido abre una deuda separada del prestatario, fuera de la operación de crédito ya cerrada.
returned_payment_receivable.collected	studio.lerian.lender.returned_payment_receivable.collected	Hecho	1.0.0	receivable_id	El prestatario paga esa deuda por otros medios y se cierra.
repayment_reversal.recorded	studio.lerian.lender.repayment_reversal.recorded	Hecho	1.0.0	transaction_id	Se registra una reversión de pago con su linaje.
loan_account.pdd_stage_transitioned	studio.lerian.lender.loan_account.pdd_stage_transitioned	Hecho	1.0.0	loan_account_id	Una cuenta de préstamo de BR cambia o resuelve su etapa PDD.
prepayment_quote.created	studio.lerian.lender.prepayment_quote.created	Hecho	1.0.0	quote_id	Se persiste una cotización de prepago de BR inmutable.
prepayment_settlement.recorded	studio.lerian.lender.prepayment_settlement.recorded	Hecho	1.0.0	settlement_id	Se registra una liquidación de prepago de BR aceptada.
loan_account.debt_balance_changed	studio.lerian.lender.loan_account.debt_balance_changed	Hecho	2.0.0	loan_account_id	Se revisa el saldo de deuda canónico de liquidación total.
loan_account.payment_overdue	studio.lerian.lender.loan_account.payment_overdue	Hecho	1.0.0	loan_account_id	Una cuota de consignado entra o sale del estado de mora.
consignado.exclusao.requested	studio.lerian.lender.consignado_exclusao.requested	Comando	1.0.0	request_ref	Lender solicita la cancelación de un contrato de Consignado después de la liquidación.
consignado.redirecionamento.requested	studio.lerian.lender.consignado_redirecionamento.requested	Comando	1.0.0	request_ref	Lender solicita la redirección de nómina hacia un vínculo laboral elegible.
payroll_deduction.refund_required	studio.lerian.lender.payroll_deduction.refund_required	Hecho	1.0.0	receipt_id	El efectivo de nómina posterior a la liquidación total genera una obligación de reembolso para el prestatario.
payroll_overdeduction.refund_required	studio.lerian.lender.payroll_overdeduction.refund_required	Hecho	1.0.0	refund_case_id	La nómina dedujo más de la competência adeudada.
collection.instruction.issued	studio.lerian.lender.collection_instruction.issued	Hecho	1.0.0	instrument_id	Lender emite una instrucción de cobranza extraordinaria.
guarantee_recovery.cash_allocated	studio.lerian.lender.guarantee_recovery_cash.allocated	Hecho	1.0.0	receipt_id	El efectivo confirmado de recuperación de garantía se asigna sin violar la conservación.

​

Contratos de payload emitidos

Los contratos siguientes reflejan las etiquetas JSON data de CloudEvent en el contrato publicado de Lender. ? significa que el campo puede estar ausente. Los structs de wire en Go no declaran campos de puntero anulables. unknown es JSON sin procesar y puede llevar cualquier valor JSON, incluido null. Los valores decimales son strings JSON, las marcas de tiempo son strings RFC 3339 en UTC, y YYYYMM es una competência de seis dígitos.

type DecimalString = string
type RFC3339 = string
type YYYYMM = string

accounting_profile.configured

Clave de definición: accounting_profile.configured

Tema: lerian.streaming.lender

Esquema: 1.1.0

Asunto: profile_id

type AccountingProfilePostingLeg = {
  account: string
  role?: string
  side: string
  component?: string
  optional: boolean
}

type AccountingProfilePostingRule = {
  event_type: string
  legs: AccountingProfilePostingLeg[]
}

type AccountingProfileConfiguredDataV1 = {
  profile_id: string
  loan_product_version_id: string
  accounting_mode: string
  posting_rules: AccountingProfilePostingRule[]
  effective_from: string
  created_at: RFC3339
}

effective_from es el día civil en que el plan de cuentas que describe empieza a regir. Sin ese campo, dos eventos sobre la misma versión de producto describen dos planes distintos y nada en el cable dice cuál rige en cada mes.

assignment_set.approved / assignment_set.accepted

Claves de definición: assignment_set.approved, assignment_set.accepted

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: assignment_set_id

Una composición de cesión queda aprobada de forma duradera. El evento identifica la aprobación inmutable que determina el archivo de oferta.

type AssignmentSetApprovedDataV1 = {
  assignment_set_id: string
  assignment_fund_id: string
  approval_id: string
  approval_digest: string
  approval_schema_version: string
  valuation_version: string
  currency: string
  item_count: number
  total_assignment_price: DecimalString
  approved_by: string
  approved_at: RFC3339
  trail_observed_at: RFC3339
}

Un administrador de fondos acepta la cesión completa. El evento reporta los totales monetarios a nivel de conjunto después de la baja contable de las cuentas por cobrar del portafolio del tenant.

type AssignmentSetAcceptedDataV1 = {
  assignment_set_id: string
  assignment_fund_id: string
  registry_provider: string
  provenance: string
  recorded_by: string
  accepted_at: RFC3339
  currency: string
  item_count: number
  total_face_value: DecimalString
  total_assignment_price: DecimalString
  total_discount_amount: DecimalString
}

collection.payment.*

Claves de definición: collection.payment.applied, collection.payment.unapplied, collection.payment.reapplied, collection.payment.refunded

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: application_id

type CollectionPaymentDataV1 = {
  application_id: string
  notification_id: string
  instrument_id: string
  provider: string
  provider_account_id: string
  provider_payment_id: string
  received_amount: DecimalString
  applied_amount: DecimalString
  unapplied_amount: DecimalString
  refunded_amount?: DecimalString
  currency: string
  applied_transaction_id?: string
  repair_reason?: string
  refund_request_id?: string
  refund_transaction_id?: string
}

loan_application.submitted

Clave de definición: loan_application.submitted

Tema: lerian.streaming.lender

Esquema: 2.0.0

Asunto: loan_application_id

type LoanApplicationSubmittedDataV2 = {
  loan_application_id: string
  loan_product_version_id: string
  borrower_id: string
  assigned_officer_id: string
  status: string
  requested_principal_amount: DecimalString
  requested_interest_rate: DecimalString
  requested_installments: number
  expected_disbursement_date: RFC3339
  preview_profile_version: string
  preview_jurisdiction_code: string
  preview_schedule_snapshot_id: string
  created_at: RFC3339
  updated_at: RFC3339
}

loan_application.approved

Clave de definición: loan_application.approved

Tema: lerian.streaming.lender

Esquema: 2.0.0

Asunto: loan_application_id

type LoanApplicationApprovedDataV2 = {
  loan_application_id: string
  loan_product_version_id: string
  borrower_id: string
  assigned_officer_id: string
  status: string
  approved_amount: DecimalString
  approval_decision_id: string
  approval_decision_at: RFC3339
  approved_by: string
  requested_principal_amount: DecimalString
  preview_profile_version: string
  preview_jurisdiction_code: string
  updated_at: RFC3339
}

loan_application.rejected

Clave de definición: loan_application.rejected

Tema: lerian.streaming.lender

Esquema: 2.0.0

Asunto: loan_application_id

type LoanApplicationRejectedDataV2 = {
  loan_application_id: string
  loan_product_version_id: string
  borrower_id: string
  assigned_officer_id: string
  status: string
  rejection_decision_id: string
  rejection_decision_at: RFC3339
  rejected_by: string
  requested_principal_amount: DecimalString
  preview_profile_version: string
  preview_jurisdiction_code: string
  updated_at: RFC3339
}

loan_application.withdrawn

Clave de definición: loan_application.withdrawn

Tema: lerian.streaming.lender

Esquema: 2.0.0

Asunto: loan_application_id

type LoanApplicationWithdrawnDataV2 = {
  loan_application_id: string
  loan_product_version_id: string
  borrower_id: string
  assigned_officer_id: string
  status: string
  withdrawal_decision_id: string
  withdrawal_decision_at: RFC3339
  withdrawn_by: string
  requested_principal_amount: DecimalString
  preview_profile_version: string
  preview_jurisdiction_code: string
  updated_at: RFC3339
}

loan_application.disbursed

Clave de definición: loan_application.disbursed

Tema: lerian.streaming.lender

Esquema: 2.0.0

Asunto: loan_application_id

type LoanApplicationDisbursedDataV2 = {
  loan_application_id: string
  loan_product_version_id: string
  borrower_id: string
  assigned_officer_id: string
  status: string
  loan_account_id: string
  disbursement_event_id: string
  disbursement_transaction_id: string
  gross_requested_amount: DecimalString
  net_delivered_amount: DecimalString
  disbursed_at: RFC3339
  profile_version: string
  jurisdiction_extensions?: unknown
  preview_jurisdiction_code: string
  updated_at: RFC3339
}

loan_charge.applied

Clave de definición: loan_charge.applied

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: loan_account_id

type LoanChargeAppliedDataV1 = {
  request_id: string
  loan_account_id: string
  source_product_version_id: string
  charge_template_id: string
  charge_code: string
  charge_type: string
  amount: DecimalString
  rate: DecimalString
  currency: string
  account_created_at: RFC3339
  assessed_at: RFC3339
}

loan_product.created

Clave de definición: loan_product.created

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: loan_product_id

type LoanProductCreatedDataV1 = {
  loan_product_id: string
  name: string
  loan_type: string
  status: string
  jurisdiction_code: string
  current_version_id?: string
  created_at: RFC3339
}

loan_product.activated

Clave de definición: loan_product.activated

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: loan_product_id

type LoanProductActivatedDataV1 = {
  loan_product_id: string
  current_version_id: string
  status: string
  name: string
  loan_type: string
  jurisdiction_code: string
  created_at: RFC3339
}

loan_product.current_version_promoted

Clave de definición: loan_product.current_version_promoted

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: loan_product_id

El producto es el agregado después del reapuntado, así que current_version_id es el nuevo anclaje. Los contratos ya escritos se quedan en la versión en que nacieron; solo las nuevas solicitudes se originan en la versión promovida. promoted_by es el sujeto autenticado tal cual llegó, y queda vacío cuando ninguna persona pidió la promoción.

type LoanProductCurrentVersionPromotedDataV1 = {
  loan_product_id: string
  current_version_id: string
  status: string
  name: string
  loan_type: string
  jurisdiction_code: string
  promoted_by: string
  promoted_at: RFC3339
}

loan_product_version.created

Clave de definición: loan_product_version.created

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: loan_product_version_id

type LoanProductVersionCreatedDataV1 = {
  loan_product_version_id: string
  loan_product_id: string
  jurisdiction_code: string
  jurisdictionExtensions?: unknown
  rate_mode: string
  floating_rate_table_id?: string
  floating_spread_bps: number
  fixed_annual_rate_bps: number
  requires_floating_rate: boolean
  min_annual_rate_bps?: number
  max_annual_rate_bps?: number
  created_at: RFC3339
}

Las bandas mínima y máxima de tasa quedan ausentes cuando la versión no guarda ninguna. Una versión sin banda no emite ninguna de las dos claves, en lugar de emitir una banda de cero a cero, que se leería como “solo se permite 0%”.

loan_schedule.prepayment_applied

Clave de definición: loan_schedule.prepayment_applied

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: schedule_version_id

type LoanSchedulePrepaymentAppliedDataV1 = {
  loan_account_id: string
  schedule_version_id: string
  previous_schedule_version_id: string
  version_number: number
  reason: string
  trigger_transaction_id: string
  request_id: string
  payload_hash: string
  prepayment_amount: DecimalString
  effective_date: RFC3339
  business_date: RFC3339
  profile_version: string
  jurisdiction_code: string
  created_at: RFC3339
  installment_count: number
}

loan_schedule.rescheduled

Clave de definición: loan_schedule.rescheduled

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: schedule_version_id

type LoanScheduleRescheduledDataV1 = {
  loan_account_id: string
  schedule_version_id: string
  previous_schedule_version_id: string
  version_number: number
  reason: string
  trigger_transaction_id: string
  request_id: string
  payload_hash: string
  effective_date: RFC3339
  business_date: RFC3339
  first_rescheduled_due_date: RFC3339
  profile_version: string
  jurisdiction_code: string
  created_at: RFC3339
  installment_count: number
}

repayment.recorded

Clave de definición: repayment.recorded

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: transaction_id

type RepaymentAllocation = {
  installment_number: number
  due_date: RFC3339
  principal_amount: DecimalString
  interest_amount: DecimalString
  fees_amount: DecimalString
  penalties_amount: DecimalString
  total_amount: DecimalString
  fully_paid: boolean
}

type RepaymentRecordedDataV1 = {
  transaction_id: string
  loan_account_id: string
  request_id: string
  funding_mode: string
  paid_amount: DecimalString
  overpayment_amount: DecimalString
  effective_date: RFC3339
  created_at: RFC3339
  allocation_count: number
  allocations: RepaymentAllocation[]
}

returned_payment_receivable.opened / returned_payment_receivable.collected

Claves de definición: returned_payment_receivable.opened, returned_payment_receivable.collected

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: receivable_id

Los dos hechos proyectan el mismo agregado por una única proyección compartida, de modo que los dos hechos sobre la misma deuda no pueden describirla de formas distintas. Todo campo está siempre presente: en .opened, los tres campos de cobro son cadenas vacías, nunca ausentes y nunca null. Lee status para distinguir los dos estados, no la vacuidad de un campo. reversal_transaction_id es único por cuenta por cobrar y es el ancla a la que resuelve una reentrega de la misma reversión.

type ReturnedPaymentReceivableDataV1 = {
  receivable_id: string
  loan_account_id: string
  borrower_id: string
  original_transaction_id: string
  reversal_transaction_id: string
  currency: string
  amount: DecimalString
  status: string
  opened_at: RFC3339
  opened_on: string
  collected_at: RFC3339 | ""
  collected_on: string
  collected_by: string
}

repayment_reversal.recorded

Clave de definición: repayment_reversal.recorded

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: transaction_id

type RepaymentAllocation = {
  installment_number: number
  due_date: RFC3339
  principal_amount: DecimalString
  interest_amount: DecimalString
  fees_amount: DecimalString
  penalties_amount: DecimalString
  total_amount: DecimalString
  fully_paid: boolean
}

type RepaymentReversalRecordedDataV1 = {
  transaction_id: string
  original_transaction_id: string
  loan_account_id: string
  request_id: string
  paid_amount: DecimalString
  overpayment_amount: DecimalString
  effective_date: RFC3339
  created_at: RFC3339
  profile_version: string
  jurisdiction_code: string
  allocation_count: number
  allocations: RepaymentAllocation[]
}

loan_account.pdd_stage_transitioned

Clave de definición: loan_account.pdd_stage_transitioned

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: loan_account_id

type LoanAccountPDDStageTransitionedDataV1 = {
  loan_account_id: string
  transition_id: string
  from_stage: string
  to_stage: string
  accrual_state: string
  reason?: string
  effective_at: RFC3339
  business_date: RFC3339
  triggered_by?: string
  profile_version?: string
  jurisdiction_code?: string
  created_at: RFC3339
}

prepayment_quote.created

Clave de definición: prepayment_quote.created

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: quote_id

type PrepaymentQuoteCreatedDataV1 = {
  quote_id: string
  loan_account_id: string
  quote_type: string
  principal_outstanding: DecimalString
  interest_rebate: DecimalString
  charge_rebate: DecimalString
  iof_reconciliation: DecimalString
  gross_amount: DecimalString
  net_settlement_amount: DecimalString
  rebate_mandatory: boolean
  expires_at: RFC3339
  currency: string
  sla_due_at: RFC3339
  statement_available_at: RFC3339
  instrument_id: string
  instrument_type: string
  instrument_requested_at: RFC3339
  profile_version?: string
  jurisdiction_code?: string
  consumer_protection_regime?: string
  created_at: RFC3339
}

prepayment_settlement.recorded

Clave de definición: prepayment_settlement.recorded

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: settlement_id

type PrepaymentSettlementRecordedDataV1 = {
  settlement_id: string
  quote_id: string
  loan_account_id: string
  transaction_id: string
  schedule_version_id?: string
  settlement_type: string
  principal_outstanding: DecimalString
  interest_rebate: DecimalString
  charge_rebate: DecimalString
  iof_reconciliation: DecimalString
  gross_amount: DecimalString
  net_settlement_amount: DecimalString
  final_principal_amount: DecimalString
  final_interest_amount: DecimalString
  final_charge_amount: DecimalString
  final_iof_amount: DecimalString
  profile_version?: string
  jurisdiction_code?: string
  consumer_protection_regime?: string
  accepted_at: RFC3339
  created_at: RFC3339
}

loan_account.debt_balance_changed

Clave de definición: loan_account.debt_balance_changed

Tema: lerian.streaming.lender

Esquema: 2.0.0

Asunto: loan_account_id

type LoanAccountDebtBalanceChangedDataV2 = {
  loan_account_id: string
  numero_contrato: string
  reason: string
  revision: number
  balance_before: DecimalString
  balance_after: DecimalString
  currency: string
  valuation_version: string
  profile_version?: string
  jurisdiction_code?: string
  effective_at: RFC3339
  created_at: RFC3339
}

loan_account.payment_overdue

Clave de definición: loan_account.payment_overdue

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: loan_account_id

type LoanAccountPaymentOverdueDataV1 = {
  loan_account_id: string
  numero_contrato: string
  competencia: YYYYMM
  occurrence: number
  reason: string
  installment_number: number
  installment_due_date: RFC3339
  overdue_amount: DecimalString
  currency: string
  profile_version?: string
  jurisdiction_code?: string
  detected_at: RFC3339
  resolved_at?: RFC3339
  created_at: RFC3339
}

consignado.exclusao.requested

Clave de definición: consignado.exclusao.requested

Tema: lerian.streaming.lender.commands

Esquema: 1.0.0

Asunto: request_ref

type ConsignadoExclusaoRequestedDataV1 = {
  request_ref: string
  settlement_id: string
  loan_account_id: string
  contract_id: string
  numero_contrato: string
  motivo_exclusao: string
  settled_at: RFC3339
}

consignado.redirecionamento.requested

Clave de definición: consignado.redirecionamento.requested

Tema: lerian.streaming.lender.commands

Esquema: 1.0.0

Asunto: request_ref

type ConsignadoRedirecionamentoRequestedDataV1 = {
  request_ref: string
  numero_contrato: string
  source_vinculo_ref: string
  target_vinculo_ref: string
  target_matricula: string
  target_cnpj: string
  target_esocial_category: string
  disruption_status: string
  effective_at: RFC3339
}

payroll_deduction.refund_required

Clave de definición: payroll_deduction.refund_required

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: receipt_id

type PayrollDeductionRefundRequiredDataV1 = {
  receipt_id: string
  account_id: string
  product_version_id: string
  payoff_effective_at: RFC3339
  receipt_settled_at: RFC3339
  amount: DecimalString
  currency: string
  required_at: RFC3339
}

payroll_overdeduction.refund_required

Clave de definición: payroll_overdeduction.refund_required

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: refund_case_id

type PayrollOverdeductionRefundRequiredDataV1 = {
  refund_case_id: string
  loan_account_id: string
  product_version_id: string
  numero_contrato: string
  competencia: YYYYMM
  detecting_run_id: string
  amount: DecimalString
  currency: string
  reversal_source_reference: string
  required_at: RFC3339
}

collection.instruction.issued

Clave de definición: collection.instruction.issued

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: instrument_id

type CollectionInstructionIssuedDataV1 = {
  instrument_id: string
  loan_account_id: string
  instruction_ref: string
  agent_name: string
  agent_account_id: string
  kind: string
  numero_contrato: string
  competencia?: YYYYMM
  amount: DecimalString
  currency: string
  issued_at: RFC3339
  valid_until: RFC3339
}

guarantee_recovery.cash_allocated

Clave de definición: guarantee_recovery.cash_allocated

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: receipt_id

type GuaranteeRecoveryCashAllocatedDataV1 = {
  receipt_id: string
  loan_account_id: string
  disruption_ref: string
  source_sequence: number
  cash_source: string
  amount: DecimalString
  repayment_applied: DecimalString
  prepayment_applied: DecimalString
  unapplied: DecimalString
  currency: string
  settled_at: RFC3339
}

​

Catalogados pero no emitidos

Estas tres definiciones están presentes en el manifest, pero no tienen ningún llamador de emisión de Lender que no sea de prueba. No trates sus formas con origen en lender como integraciones operativas.

Clave de definición	ce-type derivado (no emitido)	Stream	Estado
consignado.averbacao.confirmed	studio.lerian.lender.consignado_averbacao.confirmed	Hecho	Registrada, hoy no emitida, y ningún consumidor de Lender se suscribe a ella. Seguimiento en LerianStudio/lender#442. Consignado emite el hecho operativo con ce-source: consignado-gw.
consignado.averbacao.rejected	studio.lerian.lender.consignado_averbacao.rejected	Hecho	Espejo reservado con origen en Lender. Lender consume ese hecho del gateway; mira Eventos consumidos. Consignado emite el hecho operativo con ce-source: consignado-gw.
consignado.reconciliation.received	studio.lerian.lender.consignado_reconciliation.received	Hecho	Espejo reservado con origen en Lender. Lender consume ese hecho del gateway; mira Eventos consumidos. Consignado emite el hecho operativo con ce-source: consignado-gw.

​

Eventos consumidos

Lender conecta 15 claves de hechos del gateway desde lerian.streaming.consignado-gw y un hecho de Matcher desde lerian.streaming.matcher. Cada consumidor está controlado por configuración y registrado en el bootstrap.

Productor	Clave de definición	ce-type
consignado-gw	consignado.contract.registered	studio.lerian.consignado-gw.consignado_contract.registered
consignado-gw	consignado.disbursement.confirmed	studio.lerian.consignado-gw.consignado_disbursement.confirmed
consignado-gw	consignado.averbacao.rejected	studio.lerian.consignado-gw.consignado_averbacao.rejected
consignado-gw	consignado.employment_status.reported	studio.lerian.consignado-gw.consignado_employment_status.reported
consignado-gw	consignado.redirecionamento.confirmed	studio.lerian.consignado-gw.consignado_redirecionamento.confirmed
consignado-gw	consignado.redirecionamento.rejected	studio.lerian.consignado-gw.consignado_redirecionamento.rejected
consignado-gw	consignado.reconciliation.received	studio.lerian.consignado-gw.consignado_reconciliation.received
consignado-gw	consignado.exclusao.confirmed	studio.lerian.consignado-gw.consignado_exclusao.confirmed
consignado-gw	consignado.exclusao.rejected	studio.lerian.consignado-gw.consignado_exclusao.rejected
consignado-gw	consignado.contract_correction.available	studio.lerian.consignado-gw.consignado_contract_correction.available
consignado-gw	consignado.disbursement_correction.available	studio.lerian.consignado-gw.consignado_disbursement_correction.available
consignado-gw	consignado_portabilidade.efetivada	studio.lerian.consignado-gw.consignado_portabilidade.efetivada
consignado-gw	consignado_portabilidade.rejeitada	studio.lerian.consignado-gw.consignado_portabilidade.rejeitada
consignado-gw	consignado_refinanciamento.efetivado	studio.lerian.consignado-gw.consignado_refinanciamento.efetivado
consignado-gw	consignado_refinanciamento.revertido	studio.lerian.consignado-gw.consignado_refinanciamento.revertido
matcher	match_run.completed	studio.lerian.matcher.match_run.completed

El gateway tiene rutas de emisión para las primeras 13 claves de gateway listadas. El par de portabilidad llega a Lender solo cuando su consumidor de resultado está habilitado y el manifest del gateway desplegado declara el evento. El manifest no declara los dos resultados de refinanciamiento, por lo que esos dos listeners no reciben tráfico del runtime actual del gateway. Lender no registra consignado.proposal.accepted. Esa clave no es una entrada de contabilización para Lender.

​

Planos internos de eventos

Lender también escribe tipos de eventos de outbox internos para intenciones de ledger, trabajo de cobranza y traspasos firmados al hub. Son contratos de coordinación locales al proceso, no entradas del catálogo de CloudEvents de lib-streaming. Este inventario público los omite a propósito.

​

Reglas de entrega y compatibilidad

• Deduplica por (ce-source, ce-id) y haz que los handlers sean idempotentes.
• Lee ce-schemaversion antes de decodificar. La versión es un header de CloudEvents, nunca un sufijo de tema.
• El dinero y las tasas son strings decimales. Las marcas de tiempo son RFC 3339 en UTC.
• Los consumidores de hechos conectados filtran claves exactas. Omiten y confirman los hechos no coincidentes en los temas de aplicación compartidos. Los registros manejados con formato incorrecto siguen la política de DLQ del consumidor.
• La ausencia de un identificador de negocio requerido impide la emisión o la ejecución del comando. Lender nunca lo sintetiza.