diff options
Diffstat (limited to 'vendor/code.superseriousbusiness.org/activity/streams/gen_json_resolver.go')
| -rw-r--r-- | vendor/code.superseriousbusiness.org/activity/streams/gen_json_resolver.go | 1187 |
1 files changed, 1187 insertions, 0 deletions
diff --git a/vendor/code.superseriousbusiness.org/activity/streams/gen_json_resolver.go b/vendor/code.superseriousbusiness.org/activity/streams/gen_json_resolver.go new file mode 100644 index 000000000..6ec189262 --- /dev/null +++ b/vendor/code.superseriousbusiness.org/activity/streams/gen_json_resolver.go @@ -0,0 +1,1187 @@ +// Code generated by astool. DO NOT EDIT. + +package streams + +import ( + vocab "code.superseriousbusiness.org/activity/streams/vocab" + "context" + "errors" + "fmt" + "strings" +) + +// JSONResolver resolves a JSON-deserialized map into its concrete ActivityStreams +// type +type JSONResolver struct { + callbacks []interface{} +} + +// NewJSONResolver creates a new Resolver that takes a JSON-deserialized generic +// map and determines the correct concrete Go type. The callback function is +// guaranteed to receive a value whose underlying ActivityStreams type matches +// the concrete interface name in its signature. The callback functions must +// be of the form: +// +// func(context.Context, <TypeInterface>) error +// +// where TypeInterface is the code-generated interface for an ActivityStream +// type. An error is returned if a callback function does not match this +// signature. +func NewJSONResolver(callbacks ...interface{}) (*JSONResolver, error) { + for _, cb := range callbacks { + // Each callback function must satisfy one known function signature, or else we will generate a runtime error instead of silently fail. + switch cb.(type) { + case func(context.Context, vocab.ActivityStreamsAccept) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsActivity) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsAdd) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.FunkwhaleAlbum) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsAnnounce) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.GoToSocialAnnounceApproval) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.GoToSocialAnnounceAuthorization) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.GoToSocialAnnounceRequest) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsApplication) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsArrive) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsArticle) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.FunkwhaleArtist) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsAudio) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsBlock) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.GoToSocialCanAnnounce) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.GoToSocialCanLike) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.GoToSocialCanQuote) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.GoToSocialCanReply) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsCollection) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsCollectionPage) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsCreate) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsDelete) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsDislike) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsDocument) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.TootEmoji) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsEndpoints) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsEvent) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsFlag) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsFollow) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsGroup) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.TootHashtag) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.TootIdentityProof) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsIgnore) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsImage) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.GoToSocialInteractionPolicy) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsIntransitiveActivity) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsInvite) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsJoin) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsLeave) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.FunkwhaleLibrary) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsLike) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.GoToSocialLikeApproval) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.GoToSocialLikeAuthorization) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.GoToSocialLikeRequest) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsLink) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsListen) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsMention) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsMove) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsNote) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsObject) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsOffer) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsOrderedCollection) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsOrderedCollectionPage) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsOrganization) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsPage) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsPerson) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsPlace) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsProfile) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.SchemaPropertyValue) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.W3IDSecurityV1PublicKey) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsQuestion) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsRead) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsReject) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsRelationship) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsRemove) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.GoToSocialReplyApproval) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.GoToSocialReplyAuthorization) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.GoToSocialReplyRequest) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsService) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsTentativeAccept) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsTentativeReject) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsTombstone) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.FunkwhaleTrack) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsTravel) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsUndo) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsUpdate) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsVideo) error: + // Do nothing, this callback has a correct signature. + case func(context.Context, vocab.ActivityStreamsView) error: + // Do nothing, this callback has a correct signature. + default: + return nil, errors.New("a callback function is of the wrong signature and would never be called") + } + } + return &JSONResolver{callbacks: callbacks}, nil +} + +// toAliasMap converts a JSONLD context into a map of vocabulary name to alias. +func toAliasMap(i interface{}) (m map[string]string) { + m = make(map[string]string) + toHttpHttpsFn := func(s string) (ok bool, http, https string) { + if strings.HasPrefix(s, "http://") { + ok = true + http = s + https = "https" + strings.TrimPrefix(s, "http") + } else if strings.HasPrefix(s, "https://") { + ok = true + https = s + http = "http" + strings.TrimPrefix(s, "https") + } + return + } + switch v := i.(type) { + case string: + // Single entry, no alias. + if ok, http, https := toHttpHttpsFn(v); ok { + m[http] = "" + m[https] = "" + } else { + m[v] = "" + } + case []interface{}: + // Recursively apply. + for _, elem := range v { + r := toAliasMap(elem) + for k, val := range r { + m[k] = val + } + } + case map[string]interface{}: + // Map any aliases. + for k, val := range v { + // Only handle string aliases. + switch conc := val.(type) { + case string: + m[k] = conc + } + } + } + return +} + +// Resolve determines the ActivityStreams type of the payload, then applies the +// first callback function whose signature accepts the ActivityStreams value's +// type. This strictly assures that the callback function will only be passed +// ActivityStream objects whose type matches its interface. Returns an error +// if the ActivityStreams type does not match callbackers or is not a type +// handled by the generated code. If multiple types are present, it will check +// each one in order and apply only the first one. It returns an unhandled +// error for a multi-typed object if none of the types were able to be handled. +func (this JSONResolver) Resolve(ctx context.Context, m map[string]interface{}) error { + typeValue, ok := m["type"] + if !ok { + return fmt.Errorf("cannot determine ActivityStreams type: 'type' property is missing") + } + rawContext, ok := m["@context"] + if !ok { + return fmt.Errorf("cannot determine ActivityStreams type: '@context' is missing") + } + aliasMap := toAliasMap(rawContext) + // Begin: Private lambda to handle a single string "type" value. Makes code generation easier. + handleFn := func(typeString string) error { + ActivityStreamsAlias, ok := aliasMap["https://www.w3.org/ns/activitystreams"] + if !ok { + ActivityStreamsAlias = aliasMap["http://www.w3.org/ns/activitystreams"] + } + if len(ActivityStreamsAlias) > 0 { + ActivityStreamsAlias += ":" + } + FunkwhaleAlias, ok := aliasMap["https://funkwhale.audio/ns"] + if !ok { + FunkwhaleAlias = aliasMap["http://funkwhale.audio/ns"] + } + if len(FunkwhaleAlias) > 0 { + FunkwhaleAlias += ":" + } + GoToSocialAlias, ok := aliasMap["https://gotosocial.org/ns"] + if !ok { + GoToSocialAlias = aliasMap["http://gotosocial.org/ns"] + } + if len(GoToSocialAlias) > 0 { + GoToSocialAlias += ":" + } + TootAlias, ok := aliasMap["https://joinmastodon.org/ns"] + if !ok { + TootAlias = aliasMap["http://joinmastodon.org/ns"] + } + if len(TootAlias) > 0 { + TootAlias += ":" + } + SchemaAlias, ok := aliasMap["https://schema.org"] + if !ok { + SchemaAlias = aliasMap["http://schema.org"] + } + if len(SchemaAlias) > 0 { + SchemaAlias += ":" + } + W3IDSecurityV1Alias, ok := aliasMap["https://w3id.org/security/v1"] + if !ok { + W3IDSecurityV1Alias = aliasMap["http://w3id.org/security/v1"] + } + if len(W3IDSecurityV1Alias) > 0 { + W3IDSecurityV1Alias += ":" + } + + if typeString == ActivityStreamsAlias+"Accept" { + v, err := mgr.DeserializeAcceptActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsAccept) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Activity" { + v, err := mgr.DeserializeActivityActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsActivity) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Add" { + v, err := mgr.DeserializeAddActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsAdd) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == FunkwhaleAlias+"Album" { + v, err := mgr.DeserializeAlbumFunkwhale()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.FunkwhaleAlbum) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Announce" { + v, err := mgr.DeserializeAnnounceActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsAnnounce) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == GoToSocialAlias+"AnnounceApproval" { + v, err := mgr.DeserializeAnnounceApprovalGoToSocial()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.GoToSocialAnnounceApproval) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == GoToSocialAlias+"AnnounceAuthorization" { + v, err := mgr.DeserializeAnnounceAuthorizationGoToSocial()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.GoToSocialAnnounceAuthorization) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == GoToSocialAlias+"AnnounceRequest" { + v, err := mgr.DeserializeAnnounceRequestGoToSocial()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.GoToSocialAnnounceRequest) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Application" { + v, err := mgr.DeserializeApplicationActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsApplication) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Arrive" { + v, err := mgr.DeserializeArriveActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsArrive) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Article" { + v, err := mgr.DeserializeArticleActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsArticle) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == FunkwhaleAlias+"Artist" { + v, err := mgr.DeserializeArtistFunkwhale()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.FunkwhaleArtist) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Audio" { + v, err := mgr.DeserializeAudioActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsAudio) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Block" { + v, err := mgr.DeserializeBlockActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsBlock) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == GoToSocialAlias+"CanAnnounce" { + v, err := mgr.DeserializeCanAnnounceGoToSocial()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.GoToSocialCanAnnounce) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == GoToSocialAlias+"CanLike" { + v, err := mgr.DeserializeCanLikeGoToSocial()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.GoToSocialCanLike) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == GoToSocialAlias+"CanQuote" { + v, err := mgr.DeserializeCanQuoteGoToSocial()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.GoToSocialCanQuote) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == GoToSocialAlias+"CanReply" { + v, err := mgr.DeserializeCanReplyGoToSocial()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.GoToSocialCanReply) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Collection" { + v, err := mgr.DeserializeCollectionActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsCollection) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"CollectionPage" { + v, err := mgr.DeserializeCollectionPageActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsCollectionPage) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Create" { + v, err := mgr.DeserializeCreateActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsCreate) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Delete" { + v, err := mgr.DeserializeDeleteActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsDelete) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Dislike" { + v, err := mgr.DeserializeDislikeActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsDislike) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Document" { + v, err := mgr.DeserializeDocumentActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsDocument) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == TootAlias+"Emoji" { + v, err := mgr.DeserializeEmojiToot()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.TootEmoji) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Endpoints" { + v, err := mgr.DeserializeEndpointsActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsEndpoints) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Event" { + v, err := mgr.DeserializeEventActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsEvent) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Flag" { + v, err := mgr.DeserializeFlagActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsFlag) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Follow" { + v, err := mgr.DeserializeFollowActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsFollow) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Group" { + v, err := mgr.DeserializeGroupActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsGroup) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == TootAlias+"Hashtag" { + v, err := mgr.DeserializeHashtagToot()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.TootHashtag) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == TootAlias+"IdentityProof" { + v, err := mgr.DeserializeIdentityProofToot()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.TootIdentityProof) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Ignore" { + v, err := mgr.DeserializeIgnoreActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsIgnore) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Image" { + v, err := mgr.DeserializeImageActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsImage) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == GoToSocialAlias+"InteractionPolicy" { + v, err := mgr.DeserializeInteractionPolicyGoToSocial()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.GoToSocialInteractionPolicy) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"IntransitiveActivity" { + v, err := mgr.DeserializeIntransitiveActivityActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsIntransitiveActivity) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Invite" { + v, err := mgr.DeserializeInviteActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsInvite) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Join" { + v, err := mgr.DeserializeJoinActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsJoin) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Leave" { + v, err := mgr.DeserializeLeaveActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsLeave) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == FunkwhaleAlias+"Library" { + v, err := mgr.DeserializeLibraryFunkwhale()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.FunkwhaleLibrary) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Like" { + v, err := mgr.DeserializeLikeActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsLike) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == GoToSocialAlias+"LikeApproval" { + v, err := mgr.DeserializeLikeApprovalGoToSocial()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.GoToSocialLikeApproval) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == GoToSocialAlias+"LikeAuthorization" { + v, err := mgr.DeserializeLikeAuthorizationGoToSocial()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.GoToSocialLikeAuthorization) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == GoToSocialAlias+"LikeRequest" { + v, err := mgr.DeserializeLikeRequestGoToSocial()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.GoToSocialLikeRequest) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Link" { + v, err := mgr.DeserializeLinkActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsLink) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Listen" { + v, err := mgr.DeserializeListenActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsListen) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Mention" { + v, err := mgr.DeserializeMentionActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsMention) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Move" { + v, err := mgr.DeserializeMoveActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsMove) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Note" { + v, err := mgr.DeserializeNoteActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsNote) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Object" { + v, err := mgr.DeserializeObjectActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsObject) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Offer" { + v, err := mgr.DeserializeOfferActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsOffer) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"OrderedCollection" { + v, err := mgr.DeserializeOrderedCollectionActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsOrderedCollection) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"OrderedCollectionPage" { + v, err := mgr.DeserializeOrderedCollectionPageActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsOrderedCollectionPage) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Organization" { + v, err := mgr.DeserializeOrganizationActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsOrganization) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Page" { + v, err := mgr.DeserializePageActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsPage) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Person" { + v, err := mgr.DeserializePersonActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsPerson) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Place" { + v, err := mgr.DeserializePlaceActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsPlace) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Profile" { + v, err := mgr.DeserializeProfileActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsProfile) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == SchemaAlias+"PropertyValue" { + v, err := mgr.DeserializePropertyValueSchema()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.SchemaPropertyValue) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == W3IDSecurityV1Alias+"PublicKey" { + v, err := mgr.DeserializePublicKeyW3IDSecurityV1()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.W3IDSecurityV1PublicKey) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Question" { + v, err := mgr.DeserializeQuestionActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsQuestion) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Read" { + v, err := mgr.DeserializeReadActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsRead) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Reject" { + v, err := mgr.DeserializeRejectActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsReject) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Relationship" { + v, err := mgr.DeserializeRelationshipActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsRelationship) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Remove" { + v, err := mgr.DeserializeRemoveActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsRemove) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == GoToSocialAlias+"ReplyApproval" { + v, err := mgr.DeserializeReplyApprovalGoToSocial()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.GoToSocialReplyApproval) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == GoToSocialAlias+"ReplyAuthorization" { + v, err := mgr.DeserializeReplyAuthorizationGoToSocial()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.GoToSocialReplyAuthorization) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == GoToSocialAlias+"ReplyRequest" { + v, err := mgr.DeserializeReplyRequestGoToSocial()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.GoToSocialReplyRequest) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Service" { + v, err := mgr.DeserializeServiceActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsService) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"TentativeAccept" { + v, err := mgr.DeserializeTentativeAcceptActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsTentativeAccept) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"TentativeReject" { + v, err := mgr.DeserializeTentativeRejectActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsTentativeReject) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Tombstone" { + v, err := mgr.DeserializeTombstoneActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsTombstone) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == FunkwhaleAlias+"Track" { + v, err := mgr.DeserializeTrackFunkwhale()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.FunkwhaleTrack) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Travel" { + v, err := mgr.DeserializeTravelActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsTravel) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Undo" { + v, err := mgr.DeserializeUndoActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsUndo) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Update" { + v, err := mgr.DeserializeUpdateActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsUpdate) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"Video" { + v, err := mgr.DeserializeVideoActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsVideo) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else if typeString == ActivityStreamsAlias+"View" { + v, err := mgr.DeserializeViewActivityStreams()(m, aliasMap) + if err != nil { + return err + } + for _, i := range this.callbacks { + if fn, ok := i.(func(context.Context, vocab.ActivityStreamsView) error); ok { + return fn(ctx, v) + } + } + return ErrNoCallbackMatch + } else { + return ErrUnhandledType + } + } + // End: Private lambda + if typeStr, ok := typeValue.(string); ok { + return handleFn(typeStr) + } else if typeIArr, ok := typeValue.([]interface{}); ok { + for _, typeI := range typeIArr { + if typeStr, ok := typeI.(string); ok { + if err := handleFn(typeStr); err == nil { + return nil + } else if err == ErrUnhandledType { + // Keep trying other types: only if all fail do we return this error. + continue + } else { + return err + } + } + } + return ErrUnhandledType + } else { + return ErrUnhandledType + } +} |