Eventos de Lender

Referencia de cada CloudEvent que Lender emite, 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 la biblioteca de streaming de Lerian. 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

Lender emite 60 eventos: 59 hechos y 1 comando. 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.
assignment_set.cancelled	studio.lerian.lender.assignment_set.cancelled	Hecho	1.0.0	assignment_set_id	Se cancela una cesión cuya aprobación se había anunciado.
assignment_receivable.accepted	studio.lerian.lender.assignment_receivable.accepted	Hecho	1.0.0	receivable_ref	Un administrador de fondos acepta una cuenta por cobrar de una cesión, en una aceptación parcial o total.
assignment_receivable.cut	studio.lerian.lender.assignment_receivable.cut	Hecho	1.0.0	receivable_ref	Una cuenta por cobrar sale de una cesión aprobada y no se cede en ella.
assignment_fund.registered	studio.lerian.lender.assignment_fund.registered	Hecho	1.1.0	assignment_fund_id	Un registro de fondo crea un fondo.
assignment_fund.updated	studio.lerian.lender.assignment_fund.updated	Hecho	1.1.0	assignment_fund_id	Un fondo se edita por ID, o cambia de estado, y conserva su identificador.
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 o aprobada 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 o ya desembolsada.
loan_application.b3_registered	studio.lerian.lender.loan_application.b3_registered	Hecho	1.0.0	loan_application_id	Un cliente informa a Lender el código de instrumento B3 de un contrato que registró en B3.
loan_application.registration_recorded	studio.lerian.lender.loan_application.registration_recorded	Hecho	1.0.0	loan_application_id	Un cliente informa a Lender el registro de un contrato en una registradora que no es B3.
guarantee.execution_received	studio.lerian.lender.guarantee.execution_received	Hecho	1.0.0	guarantee_id	Una ejecución externa de una garantía trajo dinero, dividido entre los contratos que cubre.
loan_charge.applied	studio.lerian.lender.loan_charge.applied	Hecho	1.1.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.archived	studio.lerian.lender.loan_product.archived	Hecho	1.0.0	loan_product_id	Se archiva un producto de préstamo.
loan_product.unarchived	studio.lerian.lender.loan_product.unarchived	Hecho	1.0.0	loan_product_id	Se desarchiva un producto de préstamo.
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.1.0	schedule_version_id	Una reprogramación crea una versión sucesora del cronograma.
loan_schedule.index_fixed	studio.lerian.lender.loan_schedule.index_fixed	Hecho	1.0.0	schedule_version_id	Una fila posfijada de una cuenta de préstamo se fija en el índice publicado y una versión sucesora del cronograma lleva la diferencia.
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	Una reversión abre una deuda del prestatario por el efectivo retenido que la mesa de reembolsos ya devolvió.
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.
returned_payment_receivable.written_off	studio.lerian.lender.returned_payment_receivable.written_off	Hecho	1.0.0	receivable_id	Una deuda que envejeció hasta la etapa final de la escalera de su producto se castiga.
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.payoff_refund_recorded	studio.lerian.lender.loan_account.payoff_refund_recorded	Hecho	1.0.0	refund_id	Un cliente registra un reembolso que pagó al prestatario fuera de Lender, de intereses o de efectivo retenido que una liquidación debía devolver.
loan_account.written_off	studio.lerian.lender.loan_account.written_off	Hecho	1.0.0	write_off_id	Una cuenta de préstamo de crédito directo se da de baja como pérdida de crédito.
loan_account.credit_loss_recovered	studio.lerian.lender.loan_account.credit_loss_recovered	Hecho	1.0.0	recovery_id	El dinero que un prestatario dado de baja paga después salda la deuda antigua.
loan_account.credit_loss_recovery_reversed	studio.lerian.lender.loan_account.credit_loss_recovery_reversed	Hecho	1.0.0	recovery_id	Un operador devuelve una recuperación de una cuenta de préstamo dada de baja.
loan_account.write_off_collection_ended	studio.lerian.lender.loan_account.write_off_collection_ended	Hecho	1.0.0	write_off_id	El operador del cliente declara que terminó la cobranza de una cuenta de préstamo dada de baja.
loan_account.write_off_control_released	studio.lerian.lender.loan_account.write_off_control_released	Hecho	1.0.0	write_off_id	El resto del control de una baja sale de la contabilidad.
retained_installment.written_off	studio.lerian.lender.retained_installment.written_off	Hecho	1.0.0	retained_installment_id	El operador cierra una cuota retenida corta en la mesa y el resto se da de baja como pérdida de crédito del cliente.
retained_installment.write_off_collection_ended	studio.lerian.lender.retained_installment.write_off_collection_ended	Hecho	1.0.0	retained_installment_id	El operador del cliente declara que terminó la cobranza de un resto cerrado en la mesa.
retained_installment.write_off_control_released	studio.lerian.lender.retained_installment.write_off_control_released	Hecho	1.0.0	retained_installment_id	El resto del control de un resto cerrado en la mesa sale de la contabilidad.
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.
loan_account.problem_asset_assessed	studio.lerian.lender.loan_account.problem_asset_assessed	Hecho	1.0.0	loan_account_id	Un operador de crédito declara, con evidencia, si una cuenta de préstamo brasileña es un activo problemático por un motivo cualitativo.
loan_account.problem_asset_reassessment_overdue	studio.lerian.lender.loan_account.problem_asset_reassessment_overdue	Hecho	1.0.0	loan_account_id	Una caracterización cualitativa vigente de activo problemático supera el plazo de reevaluación de su versión de producto.
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.
payroll_deduction.refund_required	studio.lerian.lender.payroll_deduction.refund_required	Hecho	1.1.0	receipt_id	El efectivo de nómina que llega tras una liquidación total, o tras un refinanciamiento que sacó el contrato de la cartera, genera una obligación de reembolso para el prestatario.
payroll_overdeduction.refund_required	studio.lerian.lender.payroll_overdeduction.refund_required	Hecho	1.1.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.
collection.instruction.withdrawn	studio.lerian.lender.collection_instruction.withdrawn	Hecho	1.0.0	instrument_id	Lender retira una instrucción de cobranza porque la cuota se acreditó de otra forma, o porque se retiró la instrucción de liquidación anticipada del fondo de un contrato cedido y refinanciado.
collection.payment.applied	studio.lerian.lender.collection_payment.applied	Hecho	1.0.0	application_id	Un pago de cobranza verificado se conserva y se aplica a una ruta financiera de préstamo.
collection.payment.unapplied	studio.lerian.lender.collection_payment.unapplied	Hecho	1.0.0	application_id	Un pago de cobranza verificado se conserva como caja no aplicada, con un motivo de reparación.
collection.payment.reapplied	studio.lerian.lender.collection_payment.reapplied	Hecho	1.0.0	application_id	La caja de cobranza no aplicada se libera hacia los cobrables, sin un segundo recibo de caja.
collection.payment.refunded	studio.lerian.lender.collection_payment.refunded	Hecho	1.0.0	application_id	La caja de cobranza no aplicada se devuelve al prestatario, por el proveedor o por la tesorería del cliente.
collection.payment.routed_to_fund	studio.lerian.lender.collection_payment.routed_to_fund	Hecho	1.0.0	application_id	La caja de pago no aplicada de un contrato vendido bajo el art. 28 sale hacia la mesa de traspaso del fondo. refunded_amount la lleva.
collection.payment.routed_to_retained	studio.lerian.lender.collection_payment.routed_to_retained	Hecho	1.0.0	application_id	La caja de mora no aplicada de un contrato vendido bajo el art. 28 sale como la cuota precorte del propio cliente en la mesa de traspaso. refunded_amount la lleva.
consignado.booking.quarantined	studio.lerian.lender.consignado_booking.quarantined	Hecho	1.0.0	contract_id	Lender pone en cuarentena el registro de un contrato averbado hasta que un operador lo libere.
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. 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 en el nivel del conjunto después de la baja contable de las cuentas por cobrar del portafolio del tenant. El campo risk_retention indica el régimen de retención bajo el que se registró la cesión. El campo retained_fraction es la parte de la pérdida esperada que la institución conserva después de la venta.

type AssignmentSetAcceptedDataV1 = {
  assignment_set_id: string
  assignment_fund_id: string
  registry_provider: string
  risk_retention: string
  retained_fraction: DecimalString
  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
}

assignment_set.cancelled

Clave de definición: assignment_set.cancelled

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: assignment_set_id

Se cancela una cesión cuya aprobación se había anunciado, y el conjunto deja de retener toda cuenta por cobrar que aún estaba en él. Un conjunto cancelado antes de su aprobación no publica nada. reason es abandoned, member_ineligible, counterparty_declined, superseded o operator_removed_all_lines. El evento se emite una vez. No hay orden garantizado respecto de assignment_receivable.cut.

type AssignmentSetCancelledDataV1 = {
  assignment_set_id: string
  assignment_fund_id: string
  from_state: string
  reason: string
  cancelled_by: string
  cancelled_at: RFC3339
}

assignment_receivable.accepted

Clave de definición: assignment_receivable.accepted

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: receivable_ref

Un administrador de fondos acepta una cuenta por cobrar de una cesión, en una aceptación parcial o total. receivable_ref nombra el contrato como lo conoce el registro del fondo. offered_receivable_ref es el número que llevan el archivo de oferta y el archivo de retorno. Los dos son iguales, salvo que el registro haya renombrado la cuenta por cobrar después. El evento se emite una vez por cuenta por cobrar.

type AssignmentReceivableAcceptedDataV1 = {
  assignment_set_id: string
  receivable_ref: string
  offered_receivable_ref: string
  fund_tax_id: string
  assignment_fund_id: string
  accepted_at: RFC3339
}

assignment_receivable.cut

Clave de definición: assignment_receivable.cut

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: receivable_ref

Una cuenta por cobrar sale de una cesión aprobada y no se cede en ella. exit_source es remessa cuando el fondo rechaza la cuenta por cobrar en su archivo de retorno, y operator cuando el operador del cliente saca la línea mediante un caso de excepción. repeated_cut_brake es true cuando este corte alcanza el límite de cortes repetidos del fondo y abre un caso. El freno vale para el par de fondo y cuenta por cobrar: la cuenta por cobrar queda fuera de las ofertas a ese fondo hasta que un operador resuelva el caso, y sigue ofrecible a cualquier otro fondo. El evento se emite una vez por cuenta por cobrar. No hay orden garantizado respecto de assignment_set.cancelled.

type AssignmentReceivableCutDataV1 = {
  assignment_set_id: string
  receivable_ref: string
  offered_receivable_ref: string
  assignment_fund_id: string
  fund_tax_id: string
  exit_source: string
  exit_reason: string
  repeated_cut_brake: boolean
  cut_at: RFC3339
}

assignment_fund.registered / assignment_fund.updated

Claves de definición: assignment_fund.registered, assignment_fund.updated

Tópico: lerian.streaming.lender

Esquema: 1.1.0

Asunto: assignment_fund_id

assignment_fund.registered se dispara cuando un registro crea el fondo, activo. assignment_fund.updated se dispara cuando un fondo se edita por ID, aunque ningún valor haya cambiado, y cuando su estado cambia. Conserva el assignment_fund_id. Los dos llevan el mismo payload, así que un suscriptor que nunca vio el primero puede proyectar el fondo a partir del segundo.

type AssignmentFundRegistryDataV1 = {
  assignment_fund_id: string
  fund_tax_id: string
  fund_name: string
  status: string
  active: boolean
  updated_at: RFC3339
}

status es active, suspended o closed, y active es true solo para el primero. updated_at lleva nanosegundos.

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
  disbursed_by?: string
}

disbursed_by es el operador que liberó el desembolso. Puede diferir de assigned_officer_id y está ausente cuando ningún operador lo liberó.

loan_application.b3_registered

Clave de definición: loan_application.b3_registered

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: loan_application_id

Un cliente, como bancarizadora, registró la CCB de un contrato en B3 e informó a Lender el código del instrumento (Código IF). Lender no ordena nada en ninguna registradora. El evento se publica una vez por contrato. registration_date y ccb_number están ausentes cuando el cliente no los informó.

type LoanApplicationB3RegisteredDataV1 = {
  loan_application_id: string
  instrument_code: string
  registration_date?: string
  ccb_number?: string
  recorded_by: string
  recorded_at: RFC3339
}

loan_application.registration_recorded

Clave de definición: loan_application.registration_recorded

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: loan_application_id

Un cliente registró la CCB de un contrato en una registradora que no es B3 (CERC, Grafeno, Nuclea, TAG u otra que nombra) e informó a Lender el código que asignó. Lender no ordena nada en ninguna registradora. El evento se publica una vez por contrato. registradora_name solo está presente para otra registradora, y registration_date y ccb_number están ausentes cuando el cliente no los informó. Un registro en B3 publica loan_application.b3_registered en su lugar.

type LoanApplicationRegistrationRecordedDataV1 = {
  loan_application_id: string
  registradora: string
  registradora_name?: string
  registration_code: string
  registration_date?: string
  ccb_number?: string
  recorded_by: string
  recorded_at: RFC3339
}

guarantee.execution_received

Clave de definición: guarantee.execution_received

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: guarantee_id

Una ejecución externa de una garantía trajo dinero, y el operador lo dividió entre los contratos que la garantía cubre. Cada recibo nombra el contrato, la asignación completa, cómo se asentó la parte vencida (applied_as: un pago o, en un contrato dado de baja, una recuperación de crédito), lo que pagó la deuda más allá de ella (prepaid_amount) y lo que quedó como dinero retenido del prestatario (held_amount). El evento se publica una vez por solicitud, y una repetición no publica nada.

type GuaranteeExecutionReceivedDataV1 = {
  guarantee_id: string
  received_at: RFC3339
  receipts: {
    receipt_id: string
    loan_application_id: string
    amount: DecimalString
    applied_as: string
    held_amount: DecimalString
    prepaid_amount: DecimalString
  }[]
  recorded_by: string
  recorded_at: RFC3339
}

loan_charge.applied

Clave de definición: loan_charge.applied

Tema: lerian.streaming.lender

Esquema: 1.1.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
  billed_installment_number?: number
  billed_due_date?: RFC3339
}

billed_installment_number y billed_due_date nombran la cuota en que se cobra el cargo. Los dos están ausentes en un cargo registrado antes de que se cobraran los cargos. Existen desde la 1.1.0.

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. El campo promoted_by contiene el sujeto autenticado tal cual llegó. 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.archived

Clave de definición: loan_product.archived

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: loan_product_id

El producto es el agregado después del cambio, así que status es el nuevo estado. El campo archived_by contiene el sujeto autenticado tal cual llegó. Queda vacío cuando ninguna persona pidió el cambio.

type LoanProductArchivedDataV1 = {
  loan_product_id: string
  current_version_id?: string
  status: string
  name: string
  loan_type: string
  jurisdiction_code: string
  archived_by: string
  archived_at: RFC3339
}

loan_product.unarchived

Clave de definición: loan_product.unarchived

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: loan_product_id

El producto es el agregado después del cambio, así que status es el nuevo estado. El campo unarchived_by contiene el sujeto autenticado tal cual llegó. Queda vacío cuando ninguna persona pidió el cambio.

type LoanProductUnarchivedDataV1 = {
  loan_product_id: string
  current_version_id?: string
  status: string
  name: string
  loan_type: string
  jurisdiction_code: string
  unarchived_by: string
  unarchived_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
  jurisdiction_extensions?: unknown
  rate_mode: string
  floating_rate_table_id?: string
  floating_spread_bps: number
  fixed_monthly_rate: DecimalString
  requires_floating_rate: boolean
  min_annual_rate_bps?: number
  max_annual_rate_bps?: number
  admitted_borrower_kinds: string[]
  terms: VersionTerms
  created_at: RFC3339
}

type VersionTerms = {
  amortization_systems: string[]
  payment_periodicities: string[]
  day_count: string
  amount_anchors: string[]
  payment_rule_kinds: string[]
  origination_fronts: string[]
  credit_instrument_mode: string
  admits_assignment: boolean
  release_requires_signed_instrument: boolean
  index_absorption?: string
  refinance?: { rate_policy: string }
  prepayment_mode: string
  late_payment?: {
    fine_pct: DecimalString
    default_interest_monthly: DecimalString
    grace_days: number
  }
  limits: {
    min_principal?: DecimalString
    max_principal?: DecimalString
    min_term_months?: number
    max_term_months?: number
    min_installments?: number
    max_installments?: number
  }
  payoff_quote_validity_hours?: number
}

min_annual_rate_bps y max_annual_rate_bps son la banda de la versión en puntos básicos anuales efectivos, y fixed_monthly_rate es la tasa mensual como cadena decimal. Las claves de la banda 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%”. El campo admitted_borrower_kinds siempre está presente. Un arreglo vacío significa que la versión no admite ningún prestatario.

terms guarda los términos de la versión con el formato de la API. refinance, late_payment y payoff_quote_validity_hours están ausentes cuando la versión no los define, igual que un límite no definido de limits.

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.1.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
  financed_tax_amount: DecimalString
  replacement_loan_account_id?: string
}

financed_tax_amount es el impuesto que la reprogramación cobró y financió en el principal. Es 0.00 cuando no hay. replacement_loan_account_id es el contrato que una renegociación sustancial abrió en lugar de este. Está ausente en los demás casos.

loan_schedule.index_fixed

Clave de definición: loan_schedule.index_fixed

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: schedule_version_id

Se dispara cuando una fila posfijada de una cuenta de préstamo se fija en el índice publicado y una versión sucesora del cronograma lleva la diferencia. La fijación en sí (la fila, el factor del índice y los intereses proyectado y efectivo) se lee del cronograma.

type LoanScheduleIndexFixedDataV1 = {
  loan_account_id: string
  schedule_version_id: string
  previous_schedule_version_id: string
  version_number: number
  reason: string
  trigger_transaction_id: string
  effective_date: RFC3339
  business_date: RFC3339
  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 / returned_payment_receivable.written_off

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

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: receivable_id

Los tres hechos proyectan el mismo agregado por una única proyección compartida, de modo que dos hechos sobre la misma deuda no pueden describirla de formas distintas. Todo campo está siempre presente. Un campo que todavía no aplica contiene una cadena vacía. Nunca está ausente y nunca es null. Lee status para distinguir los estados, no la vacuidad de un campo.

Los campos stage y provision_amount traen el envejecimiento de la deuda. Los campos provision_consumed y loss dividen el castigo. El 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
  stage: string
  provision_amount: DecimalString
  written_off_at: RFC3339 | ""
  written_off_on: string
  provision_consumed: DecimalString | ""
  loss: DecimalString | ""
}

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
}

instrument_id, instrument_type e instrument_requested_at están ausentes cuando el efectivo retenido cubre la liquidación.

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
  accrued_interest: DecimalString
  interest_concession: DecimalString
  late_charges: DecimalString
  fees: DecimalString
  interest_to_refund: DecimalString
  held_cash_applied: DecimalString
  held_cash_to_refund: DecimalString
  profile_version?: string
  jurisdiction_code?: string
  consumer_protection_regime?: string
  accepted_at: RFC3339
  created_at: RFC3339
}

net_settlement_amount más held_cash_applied es igual a final_principal_amount más accrued_interest más final_charge_amount más final_iof_amount más late_charges más fees. final_interest_amount es solo divulgación (Portaria MTE 435/2025 art. 17): son intereses futuros perdonados, nunca devengados y nunca parte del efectivo de la liquidación. interest_to_refund son cobros de intereses pagados después de la salida de la liquidación, que se deben devolver al prestatario. held_cash_to_refund es lo que la liquidación dejó del efectivo retenido.

loan_account.payoff_refund_recorded

Clave de definición: loan_account.payoff_refund_recorded

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: refund_id

Un cliente pagó a un prestatario, fuera de Lender, intereses o efectivo retenido que una liquidación debía devolver, y el reembolso dejó en cero esa parte del efectivo retenido.

type LoanAccountPayoffRefundRecordedDataV1 = {
  refund_id: string
  loan_account_id: string
  request_id: string
  amount: DecimalString
  amount_to_refund: DecimalString
  amount_refunded: DecimalString
  amount_outstanding: DecimalString
  refunded_at: RFC3339
}

loan_account.written_off

Clave de definición: loan_account.written_off

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: write_off_id

Una cuenta de préstamo de crédito directo se da de baja como pérdida de crédito (Res. CMN 4.966 art. 49). El efectivo retenido paga primero la deuda, el asiento limpia el libro contra el ingreso retenido y la provisión, y el contrato sale del libro.

type LoanAccountWrittenOffDataV1 = {
  write_off_id: string
  loan_account_id: string
  written_off_at: RFC3339
  reason: string
  recorded_by: string
  currency: string
  carrying_amount: DecimalString
  held_cash_applied: DecimalString
  withheld_derecognized: DecimalString
  provision_consumed: DecimalString
  additional_loss: DecimalString
  provision_released: DecimalString
}

loan_account.credit_loss_recovered

Clave de definición: loan_account.credit_loss_recovered

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: recovery_id

El dinero que un prestatario dado de baja paga después salda la deuda antigua. El evento divide el monto entre lo que salda la baja, el ingreso nuevo y su impuesto, el control liberado y la deuda que queda.

type LoanAccountCreditLossRecoveredDataV1 = {
  recovery_id: string
  write_off_id: string
  loan_account_id: string
  received_at: RFC3339
  recorded_by: string
  currency: string
  amount: DecimalString
  untaxed_amount: DecimalString
  taxed_amount: DecimalString
  tax_amount: DecimalString
  control_released: DecimalString
  remaining_after: DecimalString
}

loan_account.credit_loss_recovery_reversed

Clave de definición: loan_account.credit_loss_recovery_reversed

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: recovery_id

Un operador devuelve una recuperación. El ingreso, el impuesto y el control que la recuperación registró se revierten, y la deuda sigue en pie.

type LoanAccountCreditLossRecoveryReversedDataV1 = {
  recovery_id: string
  write_off_id: string
  loan_account_id: string
  reversed_at: RFC3339
  reversed_by: string
  currency: string
  amount: DecimalString
  tax_amount: DecimalString
  control_reopened: DecimalString
  remaining_debt: DecimalString
}

loan_account.write_off_collection_ended / loan_account.write_off_control_released

Claves de definición: loan_account.write_off_collection_ended, loan_account.write_off_control_released

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: write_off_id

loan_account.write_off_collection_ended se dispara cuando el operador del cliente declara que terminó la cobranza de una cuenta de préstamo dada de baja (Res. CMN 4.966 art. 49 par. 1). loan_account.write_off_control_released se dispara cuando el resto del control de la baja sale de la contabilidad, en la más tardía entre 5 años después de la baja y el fin declarado de la cobranza. control_released es el monto liberado.

type LoanAccountWriteOffCollectionEndedDataV1 = {
  write_off_id: string
  loan_account_id: string
  collection_ended_at: RFC3339
  recorded_by: string
}

type LoanAccountWriteOffControlReleasedDataV1 = {
  write_off_id: string
  loan_account_id: string
  released_on: string
  currency: string
  control_released: DecimalString
}

retained_installment.written_off / retained_installment.write_off_collection_ended / retained_installment.write_off_control_released

Claves de definición: retained_installment.written_off, retained_installment.write_off_collection_ended, retained_installment.write_off_control_released

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: retained_installment_id

retained_installment.written_off se dispara cuando el operador cierra una cuota retenida corta en la mesa y el resto se da de baja como pérdida de crédito del cliente. retained_installment.write_off_collection_ended se dispara cuando el operador del cliente declara que terminó la cobranza de ese resto (Res. CMN 4.966 art. 49 par. 1). retained_installment.write_off_control_released se dispara cuando lo que quedaba del control del art. 49 del resto sale de la contabilidad. control_released es el monto liberado.

type RetainedInstallmentWrittenOffDataV1 = {
  retained_installment_id: string
  loan_account_id: string
  numero_contrato: string
  competencia: string
  written_off: DecimalString
  currency: string
  closed_at: RFC3339
  closed_by: string
  reason: string
}

type RetainedInstallmentWriteOffCollectionEndedDataV1 = {
  retained_installment_id: string
  loan_account_id: string
  numero_contrato: string
  competencia: string
  collection_ended_at: RFC3339
  recorded_by: string
}

type RetainedInstallmentWriteOffControlReleasedDataV1 = {
  retained_installment_id: string
  loan_account_id: string
  currency: string
  control_released: DecimalString
  released_on: string
}

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
}

loan_account.problem_asset_assessed

Clave de definición: loan_account.problem_asset_assessed

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: loan_account_id

Lender lo emite en los dos veredictos. Una declaración con characterizes_problem_asset en false es la única forma de retirar una caracterización anterior.

type LoanAccountProblemAssetAssessedDataV1 = {
  assessment_id: string
  loan_account_id: string
  trigger: string
  source: string
  evidence_reference: string
  characterizes_problem_asset: boolean
  declared_by: string
  evaluated_on: string
  created_at: RFC3339
}

loan_account.problem_asset_reassessment_overdue

Clave de definición: loan_account.problem_asset_reassessment_overdue

Tema: lerian.streaming.lender

Esquema: 1.0.0

Asunto: loan_account_id

Este hecho es un llamado a revisión. No cambia nada en el contrato: la etapa, la provisión y la decisión de reconocimiento de ingresos quedan como estaban. Lender lo emite una vez por contrato por fecha de negocio, y una declaración de cualquiera de los dos veredictos lo cierra.

type LoanAccountProblemAssetReassessmentOverdueDataV1 = {
  loan_account_id: string
  business_date: string
  trigger: string
  last_assessed_on: string
  horizon_days: number
  days_overdue: number
}

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
}

payroll_deduction.refund_required

Clave de definición: payroll_deduction.refund_required

Tema: lerian.streaming.lender

Esquema: 1.1.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
  refunded_total?: DecimalString
  currency: string
  required_at: RFC3339
}

amount es el reembolso de este evento: el primer reembolso, o un crecimiento. Un crecimiento emite un evento más con el mismo receipt_id. refunded_total guarda los reembolsos del recibo después de este evento; en el primer evento es igual a amount. Está ausente en los eventos 1.0.0. Un suscriptor que deduplica por receipt_id usa el par (receipt_id, refunded_total) como clave: un reenvío repite el par, y un crecimiento trae un total mayor.

payroll_overdeduction.refund_required

Clave de definición: payroll_overdeduction.refund_required

Tema: lerian.streaming.lender

Esquema: 1.1.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
  refunded_total?: DecimalString
  currency: string
  reversal_source_reference: string
  required_at: RFC3339
}

amount es el reembolso de este evento: el monto de apertura del caso, o un crecimiento. Un crecimiento emite un evento más con el mismo refund_case_id. refunded_total guarda el monto del caso después de este evento; en el evento de apertura es igual a amount. Está ausente en los eventos 1.0.0. Un suscriptor que deduplica por refund_case_id usa el par (refund_case_id, refunded_total) como clave: un reenvío repite el par, y un crecimiento trae un total mayor.

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
}

collection.instruction.withdrawn

Clave de definición: collection.instruction.withdrawn

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: instrument_id

Lender retiró una instrucción de cobranza que tiene el agente de cobranza del cliente, porque la cuota se acreditó de otra forma, o porque se retiró la instrucción de liquidación anticipada del fondo de un contrato cedido y refinanciado. En el segundo caso, reason es fund_settlement_withdrawn y competencia queda vacía. El agente da de baja ese boleto. Solo un canal designado para tratar el retiro recibe el evento. No nombra monto ni reemplazo: lo que el prestatario aún debe llega como un evento collection.instruction.issued propio.

type CollectionInstructionWithdrawnDataV1 = {
  instrument_id: string
  loan_account_id: string
  instruction_ref: string
  agent_name: string
  agent_account_id: string
  numero_contrato: string
  competencia: YYYYMM | ""
  reason: string
  withdrawn_at: RFC3339
}

collection.payment.applied

Clave de definición: collection.payment.applied

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: application_id

Todo evento collection.payment.* mantiene la regla de conservación: applied_amount + unapplied_amount + refunded_amount es igual a received_amount. Un refunded_amount ausente vale cero.

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
}

applied_amount es positivo, refunded_amount está ausente y applied_transaction_id está informado.

collection.payment.unapplied

Clave de definición: collection.payment.unapplied

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: application_id

Lleva el mismo payload que collection.payment.applied. unapplied_amount es positivo, refunded_amount está ausente y repair_reason está informado.

collection.payment.reapplied

Clave de definición: collection.payment.reapplied

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: application_id

Lleva el mismo payload que collection.payment.applied. applied_amount es positivo, refunded_amount está ausente y applied_transaction_id está informado.

collection.payment.refunded

Clave de definición: collection.payment.refunded

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: application_id

Lleva el mismo payload que collection.payment.applied. refunded_amount es positivo, unapplied_amount es 0, y refund_request_id y refund_transaction_id están informados.

collection.payment.routed_to_fund

Clave de definición: collection.payment.routed_to_fund

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: application_id

Lleva el mismo payload que collection.payment.applied.

collection.payment.routed_to_retained

Clave de definición: collection.payment.routed_to_retained

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: application_id

Lleva el mismo payload que collection.payment.applied.

consignado.booking.quarantined

Clave de definición: consignado.booking.quarantined

Tópico: lerian.streaming.lender

Esquema: 1.0.0

Asunto: contract_id

Lender puso en cuarentena el registro de un contrato averbado hasta que un operador lo libere. reason es terminal_refusal o attempt_budget_exhausted.

type ConsignadoBookingQuarantinedDataV1 = {
  contract_id: string
  numero_contrato: string
  reason: string
  quarantined_at: 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
  refund: DecimalString
  currency: string
  settled_at: RFC3339
}

refund es el efectivo de indemnización por encima de la deuda, devuelto al trabajador. amount es igual a la suma de repayment_applied, prepayment_applied, unapplied y refund.

Catalogados pero no emitidos

Estas dos 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.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 claves de hecho del gateway de lerian.streaming.consignado-gw y un hecho de Matcher de lerian.streaming.matcher. Cada consumidor se controla por configuración y se registra 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.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
consignado-gw	consignado_migracao.efetivada	studio.lerian.consignado-gw.consignado_migracao.efetivada
consignado-gw	consignado_renegociacao.efetivada	studio.lerian.consignado-gw.consignado_renegociacao.efetivada
consignado-gw	consignado_garantia.block_failed	studio.lerian.consignado-gw.consignado_garantia.block_failed
matcher	match_run.completed	studio.lerian.matcher.match_run.completed

En un refinanciamiento, Lender contabiliza el nuevo contrato solo cuando consignado.refinanciamento.efetivado lleva novo_contrato. Sin ese bloque, Lender deja el hecho en cuarentena para una intervención operativa. 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 eventos. 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.