handler

package

v0.0.0-...-befd928 Latest Latest Go to latest Published: Sep 1, 2026 License: AGPL-3.0 Imports: 24 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/indexdata/crosslink

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func Iso18626PostHandler(repo ill_db.IllRepo, eventBus events.EventBus, ...) http.HandlerFunc
type ErrorValue
type Iso18626Handler
- func CreateIso18626Handler(eventBus events.EventBus, eventRepo events.EventRepo, illRepo ill_db.IllRepo, ...) Iso18626Handler
type Iso18626HandlerInterface
type RequestWait

Constants ¶

View Source

const HANDLER_COMP = "iso18626_handler"

View Source

const InternalFailedToConfirmRequesterMessage = "failed to confirm requester message"

View Source

const InternalFailedToConfirmSupplierMessage = "failed to confirm supplier message"

View Source

const InternalFailedToCreateNotice = "failed to create notice event"

View Source

const InternalFailedToLookupSupplier = "failed to lookup supplier"

View Source

const InternalFailedToLookupTx = "failed to lookup ILL transaction"

View Source

const InternalFailedToSaveTx = "failed to save ILL transaction"

View Source

const ORIGINAL_INCOMING_MESSAGE = "originalIncomingMessage"

View Source

const PublicFailedToProcessReqMsg = "failed to process request"

Variables ¶

View Source

var ErrDuplicateRequest = errors.New(string(ReqIsDuplicate))

View Source

var ErrInvalidAction = errors.New(string(InvalidAction))

View Source

var ErrInvalidReason = errors.New(string(InvalidReason))

View Source

var ErrInvalidStatus = errors.New(string(InvalidStatus))

View Source

var ErrReqAgencyNotFound = errors.New(string(ReqAgencyNotFound))

View Source

var ErrReqIdNotFound = errors.New(string(ReqIdNotFound))

View Source

var ErrRetryNotPossible = errors.New(string(RetryNotPossible))

View Source

var ErrSupplierNotFoundOrInvalid = errors.New(string(SupplierNotFoundOrInvalid))

Functions ¶

func Iso18626PostHandler ¶

func Iso18626PostHandler(repo ill_db.IllRepo, eventBus events.EventBus, dirAdapter adapter.DirectoryLookupAdapter, maxMsgSize int) http.HandlerFunc

Types ¶

type ErrorValue ¶

type ErrorValue string

const (
	ReqIdAlreadyExists        ErrorValue = "requestingAgencyRequestId: request with a given ID already exists"
	ReqIdIsEmpty              ErrorValue = "requestingAgencyRequestId: cannot be empty"
	ReqIdNotFound             ErrorValue = "requestingAgencyRequestId: request with a given ID not found"
	RetryNotPossible          ErrorValue = "requestType: Retry not possible"
	SupplierNotFoundOrInvalid ErrorValue = "supplyingAgencyId: supplying agency not found or invalid"
	UnsupportedRequestType    ErrorValue = "requestType: unsupported value"
	ReqAgencyNotFound         ErrorValue = "requestingAgencyId: requesting agency not found"
	CouldNotSendReqToPeer     ErrorValue = "Could not send request to peer"
	InvalidAction             ErrorValue = "invalid action"
	InvalidStatus             ErrorValue = "invalid status"
	InvalidReason             ErrorValue = "invalid reason"
	ReqIsDuplicate            ErrorValue = "" /* 134-byte string literal not displayed */
)

type Iso18626Handler ¶

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

func CreateIso18626Handler ¶

func CreateIso18626Handler(eventBus events.EventBus, eventRepo events.EventRepo, illRepo ill_db.IllRepo, dirAdapter adapter.DirectoryLookupAdapter) Iso18626Handler

func (*Iso18626Handler) ConfirmRequesterMsg ¶

func (h *Iso18626Handler) ConfirmRequesterMsg(ctx common.ExtendedContext, event events.Event)

func (*Iso18626Handler) ConfirmSupplierMsg ¶

func (h *Iso18626Handler) ConfirmSupplierMsg(ctx common.ExtendedContext, event events.Event)

func (*Iso18626Handler) HandleRequest ¶

func (h *Iso18626Handler) HandleRequest(ctx common.ExtendedContext, illMessage *iso18626.ISO18626Message, w http.ResponseWriter) map[string]any

func (*Iso18626Handler) HandleRequestingAgencyMessage ¶

func (h *Iso18626Handler) HandleRequestingAgencyMessage(ctx common.ExtendedContext, illMessage *iso18626.ISO18626Message, w http.ResponseWriter)

func (*Iso18626Handler) HandleSupplyingAgencyMessage ¶

func (h *Iso18626Handler) HandleSupplyingAgencyMessage(ctx common.ExtendedContext, illMessage *iso18626.ISO18626Message, w http.ResponseWriter)

type Iso18626HandlerInterface ¶

type Iso18626HandlerInterface interface {
	HandleRequest(ctx common.ExtendedContext, illMessage *iso18626.ISO18626Message, w http.ResponseWriter) map[string]any
	HandleRequestingAgencyMessage(ctx common.ExtendedContext, illMessage *iso18626.ISO18626Message, w http.ResponseWriter)
	HandleSupplyingAgencyMessage(ctx common.ExtendedContext, illMessage *iso18626.ISO18626Message, w http.ResponseWriter)
}

type RequestWait ¶

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

Source Files ¶

View all Source files

iso18626-handler.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL