parse

Documentation

Index

• Variables
• func CreatePacs008DbData(d *pacs008struct.FIToFICustomerCreditTransferV07) *sendmodel.DBData
• func CreatePacs009DbData(d *pacs009struct.FinancialInstitutionCreditTransferV08) *sendmodel.DBData
• func CreateSuccessPacs002(participantBIC, target string, statusCode int, xmlData *sendmodel.XMLData) []byte
• func DecodeBase64(str string) ([]byte, error)
• func EncodeBase64(content []byte) string
• func GetDBData(msgId string) (interface{}, []model.TransactionReceipt)
• func HeaderIdentifierCheck(bizMsgIdr string, msgDefIdr string, msgType string) error
• func Init()
• func InstructionIdCheck(instrId string) error
• func SchemaInitiate(path []string) ([]*xsd.Schema, error)
• func ValidateSchema(xml string) error
• type Document
• type EndPointInput
  • func (i *EndPointInput) SetSchema(path string) (*xsd.Schema, error)
• type ISOMessage
• type ResponseHandler
  • func Initialize() (*ResponseHandler, error)
  • func (handler *ResponseHandler) CreateCamt030(participantBIC, caseId, assignmentId, xmlType, target string, statusCode int) []byte
  • func (handler *ResponseHandler) CreatePacs002(participantBIC, originalInstrId, target string, statusCode int, ...) []byte
  • func (handler *ResponseHandler) KafkaErrorRouter(xmlMsgType, msgId, instructionId, ofiId, rfiId string, statusCode int, ...) (string, []byte, error)

Variables

var LOGGER = logging.MustGetLogger("parsing")

Functions

func CreatePacs008DbData

func CreatePacs008DbData(d *pacs008struct.FIToFICustomerCreditTransferV07) *sendmodel.DBData

func CreatePacs009DbData

func CreatePacs009DbData(d *pacs009struct.FinancialInstitutionCreditTransferV08) *sendmodel.DBData

func CreateSuccessPacs002

func CreateSuccessPacs002(participantBIC, target string, statusCode int, xmlData *sendmodel.XMLData) []byte

func DecodeBase64

func DecodeBase64(str string) ([]byte, error)

func EncodeBase64

func EncodeBase64(content []byte) string

func GetDBData

func GetDBData(msgId string) (interface{}, []model.TransactionReceipt)

func HeaderIdentifierCheck

func HeaderIdentifierCheck(bizMsgIdr string, msgDefIdr string, msgType string) error

BizMsgIdr Format : ByyyymmddbbbbbbbbbbbXAAnnnnnnn

func Init

func Init()

func InstructionIdCheck

func InstructionIdCheck(instrId string) error

func SchemaInitiate

func SchemaInitiate(path []string) ([]*xsd.Schema, error)

func ValidateSchema

func ValidateSchema(xml string) error

Types

type Document

type Document struct {
	Format string `xml:"xmlns,attr"`
}

Basic struct used to test XML format

type EndPointInput

type EndPointInput struct {
	SchemaFile []byte
	Vars       sendmodel.SendVariables
	// contains filtered or unexported fields
}

var V EndPointInput

func (*EndPointInput) SetSchema

func (i *EndPointInput) SetSchema(path string) (*xsd.Schema, error)

type ISOMessage

type ISOMessage interface {
	String() (result string, ok bool)
}

Defines an ISO Message Can either be ISO 8583 or 20022

type ResponseHandler

type ResponseHandler struct {
	// contains filtered or unexported fields
}

func Initialize

func Initialize() (*ResponseHandler, error)

func (*ResponseHandler) CreateCamt030

func (handler *ResponseHandler) CreateCamt030(participantBIC, caseId, assignmentId, xmlType, target string, statusCode int) []byte

func (*ResponseHandler) CreatePacs002

func (handler *ResponseHandler) CreatePacs002(participantBIC, originalInstrId, target string, statusCode int, originalGroupInf *reportstruct.OriginalGroupInformation29) []byte

func (*ResponseHandler) KafkaErrorRouter

func (handler *ResponseHandler) KafkaErrorRouter(xmlMsgType, msgId, instructionId, ofiId, rfiId string, statusCode int, generateReport bool) (string, []byte, error)