// Copyright 2023 The forgejo Authors. All rights reserved. // SPDX-License-Identifier: MIT package forgefed import ( "fmt" "net/url" "strings" "code.gitea.io/gitea/modules/setting" "code.gitea.io/gitea/modules/validation" ) // ----------------------------- ActorID -------------------------------------------- type ActorID struct { ID string Source string Schema string Path string Host string Port string UnvalidatedInput string } // Factory function for ActorID. Created struct is asserted to be valid func NewActorID(uri string) (ActorID, error) { result, err := newActorID(uri) if err != nil { return ActorID{}, err } if valid, outcome := validation.IsValid(result); !valid { return ActorID{}, outcome } return result, nil } func (id ActorID) AsURI() string { var result string if id.Port == "" { result = fmt.Sprintf("%s://%s/%s/%s", id.Schema, id.Host, id.Path, id.ID) } else { result = fmt.Sprintf("%s://%s:%s/%s/%s", id.Schema, id.Host, id.Port, id.Path, id.ID) } return result } func (id ActorID) Validate() []string { var result []string result = append(result, validation.ValidateNotEmpty(id.ID, "userId")...) result = append(result, validation.ValidateNotEmpty(id.Schema, "schema")...) result = append(result, validation.ValidateNotEmpty(id.Path, "path")...) result = append(result, validation.ValidateNotEmpty(id.Host, "host")...) result = append(result, validation.ValidateNotEmpty(id.UnvalidatedInput, "unvalidatedInput")...) if id.UnvalidatedInput != id.AsURI() { result = append(result, fmt.Sprintf("not all input: %q was parsed: %q", id.UnvalidatedInput, id.AsURI())) } return result } // ----------------------------- PersonID -------------------------------------------- type PersonID struct { ActorID } // Factory function for PersonID. Created struct is asserted to be valid func NewPersonID(uri, source string) (PersonID, error) { // TODO: remove after test //if !validation.IsValidExternalURL(uri) { // return PersonId{}, fmt.Errorf("uri %s is not a valid external url", uri) //} result, err := newActorID(uri) if err != nil { return PersonID{}, err } result.Source = source // validate Person specific path personID := PersonID{result} if valid, outcome := validation.IsValid(personID); !valid { return PersonID{}, outcome } return personID, nil } func (id PersonID) AsWebfinger() string { result := fmt.Sprintf("@%s@%s", strings.ToLower(id.ID), strings.ToLower(id.Host)) return result } func (id PersonID) AsLoginName() string { result := fmt.Sprintf("%s%s", strings.ToLower(id.ID), id.HostSuffix()) return result } func (id PersonID) HostSuffix() string { result := fmt.Sprintf("-%s", strings.ToLower(id.Host)) return result } func (id PersonID) Validate() []string { result := id.ActorID.Validate() result = append(result, validation.ValidateNotEmpty(id.Source, "source")...) result = append(result, validation.ValidateOneOf(id.Source, []any{"forgejo", "gitea"})...) switch id.Source { case "forgejo", "gitea": if strings.ToLower(id.Path) != "api/v1/activitypub/user-id" && strings.ToLower(id.Path) != "api/activitypub/user-id" { result = append(result, fmt.Sprintf("path: %q has to be a person specific api path", id.Path)) } } return result } // ----------------------------- RepositoryID -------------------------------------------- type RepositoryID struct { ActorID } // Factory function for RepositoryID. Created struct is asserted to be valid. func NewRepositoryID(uri, source string) (RepositoryID, error) { if !validation.IsAPIURL(uri) { return RepositoryID{}, fmt.Errorf("uri %s is not a valid repo url on this host %s", uri, setting.AppURL+"api") } result, err := newActorID(uri) if err != nil { return RepositoryID{}, err } result.Source = source // validate Person specific path repoID := RepositoryID{result} if valid, outcome := validation.IsValid(repoID); !valid { return RepositoryID{}, outcome } return repoID, nil } func (id RepositoryID) Validate() []string { result := id.ActorID.Validate() result = append(result, validation.ValidateNotEmpty(id.Source, "source")...) result = append(result, validation.ValidateOneOf(id.Source, []any{"forgejo", "gitea"})...) switch id.Source { case "forgejo", "gitea": if strings.ToLower(id.Path) != "api/v1/activitypub/repository-id" && strings.ToLower(id.Path) != "api/activitypub/repository-id" { result = append(result, fmt.Sprintf("path: %q has to be a repo specific api path", id.Path)) } } return result } func containsEmptyString(ar []string) bool { for _, elem := range ar { if elem == "" { return true } } return false } func removeEmptyStrings(ls []string) []string { var rs []string for _, str := range ls { if str != "" { rs = append(rs, str) } } return rs } func newActorID(uri string) (ActorID, error) { validatedURI, err := url.ParseRequestURI(uri) if err != nil { return ActorID{}, err } pathWithActorID := strings.Split(validatedURI.Path, "/") if containsEmptyString(pathWithActorID) { pathWithActorID = removeEmptyStrings(pathWithActorID) } length := len(pathWithActorID) pathWithoutActorID := strings.Join(pathWithActorID[0:length-1], "/") id := pathWithActorID[length-1] result := ActorID{} result.ID = id result.Schema = validatedURI.Scheme result.Host = validatedURI.Hostname() result.Path = pathWithoutActorID result.Port = validatedURI.Port() result.UnvalidatedInput = validatedURI.String() return result, nil }