forgejo/models/activitypub/actor.go

114 lines
2.4 KiB
Go
Raw Normal View History

package activitypub
import (
"fmt"
"net/url"
"strconv"
"strings"
)
2023-11-23 16:50:32 +03:00
type Validatable interface { // ToDo: What is the right package for this interface?
validate_is_not_nil() error
validate_is_not_empty() error
Validate() error
IsValid() (bool, error)
PanicIfInvalid()
}
2023-11-22 15:28:13 +03:00
type ActorID struct {
schema string
userId string
path string
host string
port string // optional
}
func (a ActorID) GetUserId() int {
result, err := strconv.Atoi(a.userId)
if err != nil {
panic(err)
}
return result
}
// Returns the combination of host:port if port exists, host otherwise
func (a ActorID) GetHostAndPort() string {
if a.port != "" {
return strings.Join([]string{a.host, a.port}, ":")
}
return a.host
}
// ToDo: validate_is_not_empty maybe not as an extra method
func (a ActorID) validate_is_not_empty(str string, field string) error {
if str == "" {
return fmt.Errorf("field %v was empty", field)
}
return nil
}
/*
Validate collects error strings, concatenates and returns them
TODO: Align validation-api to example from dda-devops-build
*/
func (a ActorID) Validate() []string {
err := make([]string, 0, 3)
if res := a.validate_is_not_empty(a.schema, "schema"); res != nil {
err = append(err, res.Error())
2023-11-22 17:27:44 +03:00
}
if res := a.validate_is_not_empty(a.host, "host"); res != nil {
err = append(err, res.Error())
}
2023-11-24 11:55:47 +03:00
if !strings.Contains(a.path, "api/v1/activitypub/user-id") { // This needs to happen in dependence to the star source type.
err = append(err, fmt.Errorf("the Path to the API was invalid: %v", a.path).Error())
}
return err
}
func (a ActorID) IsValid() (bool, error) {
if err := a.Validate(); len(err) > 0 {
errString := strings.Join(err, "\n")
return false, fmt.Errorf(errString)
}
return true, nil
}
func (a ActorID) PanicIfInvalid() {
if valid, err := a.IsValid(); !valid {
panic(err)
}
}
2023-11-22 15:28:13 +03:00
func ParseActorID(actor string) (ActorID, error) {
u, err := url.Parse(actor)
// check if userID IRI is well formed url
if err != nil {
2023-11-22 15:28:13 +03:00
return ActorID{}, fmt.Errorf("the actor ID was not a valid IRI: %v", err)
}
pathWithUserID := strings.Split(u.Path, "/")
userId := pathWithUserID[len(pathWithUserID)-1]
2023-11-24 11:55:47 +03:00
return ActorID{ // ToDo: maybe keep original input to validate against (maybe extra method)
schema: u.Scheme, // ToDo: Add source type field
userId: userId,
host: u.Host,
path: u.Path,
port: u.Port(),
}, nil
}