2023-11-16 14:49:05 +01:00
|
|
|
package activitypub
|
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
|
|
|
"net/url"
|
2023-11-23 17:03:24 +01:00
|
|
|
"strconv"
|
2023-11-16 14:49:05 +01:00
|
|
|
"strings"
|
|
|
|
)
|
|
|
|
|
2023-11-23 14:50:32 +01:00
|
|
|
type Validatable interface { // ToDo: What is the right package for this interface?
|
2023-11-22 16:08:14 +01:00
|
|
|
validate_is_not_nil() error
|
|
|
|
validate_is_not_empty() error
|
2023-11-22 15:25:43 +01:00
|
|
|
Validate() error
|
|
|
|
}
|
|
|
|
|
2023-11-22 13:28:13 +01:00
|
|
|
type ActorID struct {
|
2023-11-16 14:49:05 +01:00
|
|
|
schema string
|
|
|
|
userId string
|
|
|
|
path string
|
|
|
|
host string
|
|
|
|
port string // optional
|
|
|
|
}
|
|
|
|
|
2023-11-22 16:08:14 +01:00
|
|
|
func (a ActorID) validate_is_not_empty(str string, field string) error {
|
|
|
|
|
2023-11-22 16:40:03 +01:00
|
|
|
if str == "" {
|
2023-11-22 16:08:14 +01:00
|
|
|
return fmt.Errorf("field %v was empty", field)
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2023-11-23 17:03:24 +01:00
|
|
|
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
|
|
|
|
}
|
|
|
|
|
2023-11-17 10:10:04 +01:00
|
|
|
// TODO: Align validation-api to example from dda-devops-build
|
2023-11-22 15:25:43 +01:00
|
|
|
func (a ActorID) Validate() error {
|
2023-11-16 14:49:05 +01:00
|
|
|
|
2023-11-22 16:08:14 +01:00
|
|
|
if err := a.validate_is_not_empty(a.schema, "schema"); err != nil {
|
|
|
|
return err
|
2023-11-22 15:27:44 +01:00
|
|
|
}
|
|
|
|
|
2023-11-22 16:08:14 +01:00
|
|
|
if err := a.validate_is_not_empty(a.host, "host"); err != nil {
|
|
|
|
return err
|
2023-11-16 14:49:05 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
if !strings.Contains(a.path, "api/v1/activitypub/user-id") {
|
|
|
|
return fmt.Errorf("the Path to the API was invalid: %v", a.path)
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
|
|
|
|
}
|
|
|
|
|
2023-11-22 13:28:13 +01:00
|
|
|
func ParseActorID(actor string) (ActorID, error) {
|
2023-11-16 14:49:05 +01:00
|
|
|
u, err := url.Parse(actor)
|
|
|
|
|
|
|
|
// check if userID IRI is well formed url
|
|
|
|
if err != nil {
|
2023-11-22 13:28:13 +01:00
|
|
|
return ActorID{}, fmt.Errorf("the actor ID was not a valid IRI: %v", err)
|
2023-11-16 14:49:05 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
pathWithUserID := strings.Split(u.Path, "/")
|
|
|
|
userId := pathWithUserID[len(pathWithUserID)-1]
|
|
|
|
|
2023-11-22 13:28:13 +01:00
|
|
|
return ActorID{
|
2023-11-16 14:49:05 +01:00
|
|
|
schema: u.Scheme,
|
|
|
|
userId: userId,
|
|
|
|
host: u.Host,
|
|
|
|
path: u.Path,
|
|
|
|
port: u.Port(),
|
|
|
|
}, nil
|
|
|
|
}
|