jetstream_errors.go

package server

import (
"fmt"
)

typeerrOptsstruct {
errerror
}

// ErrorOption configures a NATS Error helper
typeErrorOptionfunc(*errOpts)

// Unless ensures that if err is a ApiErr that err will be returned rather than the one being created via the helper
funcUnless(errerror) ErrorOption {
returnfunc(opts*errOpts) {
opts.err=err
 }
}

funcparseOpts(opts []ErrorOption) *errOpts {
eopts:=&errOpts{}
for_, opt:=rangeopts {
opt(eopts)
 }
returneopts
}

typeErrorIdentifieruint16

// IsNatsErr determines if an error matches ID, if multiple IDs are given if the error matches any of these the function will be true
funcIsNatsErr(errerror, ids...ErrorIdentifier) bool {
iferr==nil {
returnfalse
 }

ce, ok:=err.(*ApiError)
if!ok||ce==nil {
returnfalse
 }

for_, id:=rangeids {
ae, ok:=ApiErrors[id]
if!ok||ae==nil {
continue
 }

ifce.ErrCode==ae.ErrCode {
returntrue
 }
 }

returnfalse
}

// ApiError is included in all responses if there was an error.
typeApiErrorstruct {
Codeint`json:"code"`
ErrCodeuint16`json:"err_code,omitempty"`
Descriptionstring`json:"description,omitempty"`
}

// ErrorsData is the source data for generated errors as found in errors.json
typeErrorsDatastruct {
Constantstring`json:"constant"`
Codeint`json:"code"`
ErrCodeuint16`json:"error_code"`
Descriptionstring`json:"description"`
Commentstring`json:"comment"`
Helpstring`json:"help"`
URLstring`json:"url"`
Deprecatesstring`json:"deprecates"`
}

func (e*ApiError) Error() string {
returnfmt.Sprintf("%s (%d)", e.Description, e.ErrCode)
}

func (e*ApiError) toReplacerArgs(replacements []any) []string {
var (
ra []string
keystring
 )

fori, replacement:=rangereplacements {
ifi%2==0 {
key=replacement.(string)
continue
 }

switchv:=replacement.(type) {
casestring:
ra=append(ra, key, v)
caseerror:
ra=append(ra, key, v.Error())
default:
ra=append(ra, key, fmt.Sprintf("%v", v))
 }
 }

returnra
}