message_handler

Documentation

Index

• Variables
• func HandleErrMsg(pbsData sendmodel.SendPayload, op *kafka.KafkaOpreations)
• func OFI_Camt026(sendPayload camt026pbstruct.SendPayload, op *kafka.KafkaOpreations)
• func OFI_Camt029(data camt029pbstruct.SendPayload, op *kafka.KafkaOpreations)
• func OFI_Ibwf001(data ibwf001pbstruct.SendPayload, op *kafka.KafkaOpreations)
• func OFI_Pacs002(data pacs002Pbstruct.SendPayload, op *kafka.KafkaOpreations)
• func RFI_Camt056(data camt056pbstruct.SendPayload, op *kafka.KafkaOpreations)
• func RFI_Camt087(data camt087pbstruct.SendPayload, op *kafka.KafkaOpreations)
• func RFI_Ibwf002(data ibwfPbStruct.SendPayload, op *kafka.KafkaOpreations)
• func RFI_Pacs008(sendPayload pbstruct.SendPayload, op *kafka.KafkaOpreations)
• func RFI_Pacs009(data pacs009Pbstruct.SendPayload, op *kafka.KafkaOpreations)
• type FbTrxLog
• type PaymentOperations
  • func InitiatePaymentOperations() (PaymentOperations, error)
  • func (op *PaymentOperations) Camt026(camt026 message_converter.Camt026) ([]byte, error)
  • func (op *PaymentOperations) Camt029(camt029 message_converter.Camt029) ([]byte, error)
  • func (op *PaymentOperations) Camt056(camt056 message_converter.Camt056) ([]byte, error)
  • func (op *PaymentOperations) Camt087(camt087 message_converter.Camt087) ([]byte, error)
  • func (op *PaymentOperations) Ibwf001(ibwf001 message_converter.Ibwf001) ([]byte, error)
  • func (op *PaymentOperations) Ibwf002(ibwf002 message_converter.Ibwf002) ([]byte, error)
  • func (op *PaymentOperations) Iso20022Validator(data []byte, bic, messageType, target string) ([]byte, error)
  • func (op *PaymentOperations) Pacs002(pacs002 message_converter.Pacs002, target, BIC string) ([]byte, error)
  • func (op *PaymentOperations) Pacs004_Cancellation(pacs004 message_converter.Pacs004) ([]byte, error)
  • func (op *PaymentOperations) Pacs004_Rdo(pacs004 message_converter.Pacs004) ([]byte, error)
  • func (op *PaymentOperations) Pacs008(pacs008 message_converter.Pacs008) ([]byte, error)
  • func (op *PaymentOperations) Pacs009(pacs009 message_converter.Pacs009) ([]byte, error)
  • func (op *PaymentOperations) ValidateRequest(raw *http.Request, bic, target string) ([]byte, []byte, string, error)

Variables

var LOGGER = logging.MustGetLogger("message-handler")

Functions

func HandleErrMsg

func HandleErrMsg(pbsData sendmodel.SendPayload, op *kafka.KafkaOpreations)

Sending the error message back to Kafka when there's a error on the other side

func OFI_Camt026

func OFI_Camt026(sendPayload camt026pbstruct.SendPayload, op *kafka.KafkaOpreations)

camt.26 message handler at OFI side

func OFI_Camt029

func OFI_Camt029(data camt029pbstruct.SendPayload, op *kafka.KafkaOpreations)

if message type is camt.029

func OFI_Ibwf001

func OFI_Ibwf001(data ibwf001pbstruct.SendPayload, op *kafka.KafkaOpreations)

ibwf.001 message handler at OFI side

func OFI_Pacs002

func OFI_Pacs002(data pacs002Pbstruct.SendPayload, op *kafka.KafkaOpreations)

pacs.002 message handler at OFI side

func RFI_Camt056

func RFI_Camt056(data camt056pbstruct.SendPayload, op *kafka.KafkaOpreations)

if message type is camt.056

func RFI_Camt087

func RFI_Camt087(data camt087pbstruct.SendPayload, op *kafka.KafkaOpreations)

if message type is camt.087

func RFI_Ibwf002

func RFI_Ibwf002(data ibwfPbStruct.SendPayload, op *kafka.KafkaOpreations)

if message type is ibwf.002

func RFI_Pacs008

func RFI_Pacs008(sendPayload pbstruct.SendPayload, op *kafka.KafkaOpreations)

pacs.008 message handler at RFI side

func RFI_Pacs009

func RFI_Pacs009(data pacs009Pbstruct.SendPayload, op *kafka.KafkaOpreations)

pacs.009 message handler at RFI side

Types

type FbTrxLog

type FbTrxLog struct {
	ParticipantID   string                 `json:"participant_id"`
	TransactionMemo map[string]interface{} `json:"transaction_memo"`
}

type PaymentOperations

type PaymentOperations struct {
	XsdSchemas []*xsd.Schema

	KafkaActor *kafka.KafkaOpreations

	DbClient        *DB.PostgreDatabaseClient
	ResponseHandler *parse.ResponseHandler
	// contains filtered or unexported fields
}

func InitiatePaymentOperations

func InitiatePaymentOperations() (PaymentOperations, error)

func (*PaymentOperations) Camt026

func (op *PaymentOperations) Camt026(camt026 message_converter.Camt026) ([]byte, error)

camt.26 message handler at RFI side

func (*PaymentOperations) Camt029

func (op *PaymentOperations) Camt029(camt029 message_converter.Camt029) ([]byte, error)

func (*PaymentOperations) Camt056

func (op *PaymentOperations) Camt056(camt056 message_converter.Camt056) ([]byte, error)

 	camt.056.001.08 FIToFIPaymentCancellationRequest
 	The FIToFIPaymentCancellationRequest message supports both the request for cancellation (the
	instructed agent - or assignee - has not yet processed and forwarded the payment instruction) as well
	as the request for refund (payment has been fully processed already by the instructed agent - or
	assignee).

	A FIToFIPaymentCancellationRequest message concerns one and only one original payment
	instruction at a time.

	[Mandatory fields]

	Assignment
	- Identifies the assignment of an investigation case from an assigner to an assignee.
	Usage: The assigner must be the sender of this confirmation and the assignee must be the
	receiver.

	Underlying
	- Identifies the payment instruction to be cancelled.

func (*PaymentOperations) Camt087

func (op *PaymentOperations) Camt087(camt087 message_converter.Camt087) ([]byte, error)

func (*PaymentOperations) Ibwf001

func (op *PaymentOperations) Ibwf001(ibwf001 message_converter.Ibwf001) ([]byte, error)

ibwf.001 message handler at RFI side

func (*PaymentOperations) Ibwf002

func (op *PaymentOperations) Ibwf002(ibwf002 message_converter.Ibwf002) ([]byte, error)

func (*PaymentOperations) Iso20022Validator

func (op *PaymentOperations) Iso20022Validator(data []byte, bic, messageType, target string) ([]byte, error)

validate signature & xml payload

func (*PaymentOperations) Pacs002

func (op *PaymentOperations) Pacs002(pacs002 message_converter.Pacs002, target, BIC string) ([]byte, error)

pacs.002 message handler at RFI side

func (*PaymentOperations) Pacs004_Cancellation

func (op *PaymentOperations) Pacs004_Cancellation(pacs004 message_converter.Pacs004) ([]byte, error)

pacs.004.001.08 PaymentReturn The PaymentReturn message is sent by an agent to the previous agent in the payment chain to undo a payment previously settled.

The PaymentReturn message is exchanged between agents to return funds after settlement of credit transfer instructions (i.e. FIToFICustomerCreditTransfer message and FinancialInstitutionCreditTransfer message) or direct debit instructions (FIToFICustomerDirectDebit message).

func (*PaymentOperations) Pacs004_Rdo

func (op *PaymentOperations) Pacs004_Rdo(pacs004 message_converter.Pacs004) ([]byte, error)

pacs.004.001.08 PaymentReturn

func (*PaymentOperations) Pacs008

func (op *PaymentOperations) Pacs008(pacs008 message_converter.Pacs008) ([]byte, error)

pacs.008 message handler at OFI side

func (*PaymentOperations) Pacs009

func (op *PaymentOperations) Pacs009(pacs009 message_converter.Pacs009) ([]byte, error)

pacs.009 message handler at OFI side

func (*PaymentOperations) ValidateRequest

func (op *PaymentOperations) ValidateRequest(raw *http.Request, bic, target string) ([]byte, []byte, string, error)

validate incoming request