Blame

Date:
Message:
public-ish release I made a bit of an announcement to fediverse@lemmy.world: https://old.lemmy.world/post/12791602 Replies were delivered ok to my ActivityPub inbox and my mail inbox. And I replied to those from my email client, too!
Actions:
History | Blob | Raw File
  1 1d5ddf5d 2024-02-20 o // apub is an implementation of the ActivityPub protocol.

  2 1d5ddf5d 2024-02-20 o //

  3 1d5ddf5d 2024-02-20 o // https://www.w3.org/TR/activitypub/

  4 1d5ddf5d 2024-02-20 o // https://www.w3.org/TR/activitystreams-core/

  5 1d5ddf5d 2024-02-20 o // https://www.w3.org/TR/activitystreams-vocabulary/

  6 1d5ddf5d 2024-02-20 o package apub

  7 1d5ddf5d 2024-02-20 o 

  8 1d5ddf5d 2024-02-20 o import (

  9 1d5ddf5d 2024-02-20 o 	"bytes"

 10 1d5ddf5d 2024-02-20 o 	"encoding/json"

 11 1d5ddf5d 2024-02-20 o 	"errors"

 12 1d5ddf5d 2024-02-20 o 	"fmt"

 13 1d5ddf5d 2024-02-20 o 	"io"

 14 1d5ddf5d 2024-02-20 o 	"net/mail"

 15 1d5ddf5d 2024-02-20 o 	"strings"

 16 1d5ddf5d 2024-02-20 o 	"time"

 17 1d5ddf5d 2024-02-20 o )

 18 1d5ddf5d 2024-02-20 o 

 19 1d5ddf5d 2024-02-20 o // @context

 20 1d5ddf5d 2024-02-20 o const AtContext string = "https://www.w3.org/ns/activitystreams"

 21 1d5ddf5d 2024-02-20 o 

 22 1d5ddf5d 2024-02-20 o const ContentType string = "application/activity+json"

 23 1d5ddf5d 2024-02-20 o 

 24 1d5ddf5d 2024-02-20 o const AcceptMediaType string = `application/activity+json; profile="https://www.w3.org/ns/activitystreams"`

 25 1d5ddf5d 2024-02-20 o 

 26 77918b00 2024-03-07 o // Activities addressed to this collection indicates the activity

 27 77918b00 2024-03-07 o // is available to all users, authenticated or not.

 28 77918b00 2024-03-07 o // See W3C Recommendation ActivityPub Section 5.6.

 29 77918b00 2024-03-07 o const PublicCollection string = "https://www.w3.org/ns/activitystreams#Public"

 30 1d5ddf5d 2024-02-20 o 

 31 71191436 2024-02-28 o var ErrNotExist = errors.New("no such activity")

 32 71191436 2024-02-28 o 

 33 1d5ddf5d 2024-02-20 o type Activity struct {

 34 1d5ddf5d 2024-02-20 o 	AtContext    string     `json:"@context"`

 35 1d5ddf5d 2024-02-20 o 	ID           string     `json:"id"`

 36 1d5ddf5d 2024-02-20 o 	Type         string     `json:"type"`

 37 1d5ddf5d 2024-02-20 o 	Name         string     `json:"name,omitempty"`

 38 1d5ddf5d 2024-02-20 o 	Actor        string     `json:"actor,omitempty"`

 39 1d5ddf5d 2024-02-20 o 	Username     string     `json:"preferredUsername,omitempty"`

 40 77918b00 2024-03-07 o 	Summary      string     `json:"summary,omitempty"`

 41 1d5ddf5d 2024-02-20 o 	Inbox        string     `json:"inbox,omitempty"`

 42 1d5ddf5d 2024-02-20 o 	Outbox       string     `json:"outbox,omitempty"`

 43 1d5ddf5d 2024-02-20 o 	To           []string   `json:"to,omitempty"`

 44 1d5ddf5d 2024-02-20 o 	CC           []string   `json:"cc,omitempty"`

 45 77918b00 2024-03-07 o 	Followers    string     `json:"followers,omitempty"`

 46 1d5ddf5d 2024-02-20 o 	InReplyTo    string     `json:"inReplyTo,omitempty"`

 47 1d5ddf5d 2024-02-20 o 	Published    *time.Time `json:"published,omitempty"`

 48 1d5ddf5d 2024-02-20 o 	AttributedTo string     `json:"attributedTo,omitempty"`

 49 1d5ddf5d 2024-02-20 o 	Content      string     `json:"content,omitempty"`

 50 1d5ddf5d 2024-02-20 o 	MediaType    string     `json:"mediaType,omitempty"`

 51 1d5ddf5d 2024-02-20 o 	Source       struct {

 52 1d5ddf5d 2024-02-20 o 		Content   string `json:"content,omitempty"`

 53 1d5ddf5d 2024-02-20 o 		MediaType string `json:"mediaType,omitempty"`

 54 1d5ddf5d 2024-02-20 o 	} `json:"source,omitempty"`

 55 77918b00 2024-03-07 o 	PublicKey *PublicKey      `json:"publicKey,omitempty"`

 56 77918b00 2024-03-07 o 	Audience  string          `json:"audience,omitempty"`

 57 77918b00 2024-03-07 o 	Object    json.RawMessage `json:"object,omitempty"`

 58 1d5ddf5d 2024-02-20 o }

 59 1d5ddf5d 2024-02-20 o 

 60 1d5ddf5d 2024-02-20 o func (act *Activity) UnmarshalJSON(b []byte) error {

 61 1d5ddf5d 2024-02-20 o 	type Alias Activity

 62 1d5ddf5d 2024-02-20 o 	aux := &struct {

 63 1d5ddf5d 2024-02-20 o 		AtContext interface{} `json:"@context"`

 64 1d5ddf5d 2024-02-20 o 		Object    interface{}

 65 1d5ddf5d 2024-02-20 o 		*Alias

 66 1d5ddf5d 2024-02-20 o 	}{

 67 1d5ddf5d 2024-02-20 o 		Alias: (*Alias)(act),

 68 1d5ddf5d 2024-02-20 o 	}

 69 1d5ddf5d 2024-02-20 o 	if err := json.Unmarshal(b, &aux); err != nil {

 70 1d5ddf5d 2024-02-20 o 		return err

 71 1d5ddf5d 2024-02-20 o 	}

 72 1d5ddf5d 2024-02-20 o 	switch v := aux.AtContext.(type) {

 73 1d5ddf5d 2024-02-20 o 	case string:

 74 1d5ddf5d 2024-02-20 o 		act.AtContext = v

 75 1d5ddf5d 2024-02-20 o 	case []interface{}:

 76 1d5ddf5d 2024-02-20 o 		if vv, ok := v[0].(string); ok {

 77 1d5ddf5d 2024-02-20 o 			act.AtContext = vv

 78 1d5ddf5d 2024-02-20 o 		}

 79 1d5ddf5d 2024-02-20 o 	}

 80 1d5ddf5d 2024-02-20 o 	return nil

 81 1d5ddf5d 2024-02-20 o }

 82 1d5ddf5d 2024-02-20 o 

 83 1d5ddf5d 2024-02-20 o func (act *Activity) Unwrap(client *Client) (*Activity, error) {

 84 1d5ddf5d 2024-02-20 o 	if act.Object == nil {

 85 1d5ddf5d 2024-02-20 o 		return nil, errors.New("no wrapped activity")

 86 1d5ddf5d 2024-02-20 o 	}

 87 1d5ddf5d 2024-02-20 o 

 88 1d5ddf5d 2024-02-20 o 	var buf io.Reader

 89 1d5ddf5d 2024-02-20 o 	buf = bytes.NewReader(act.Object)

 90 1d5ddf5d 2024-02-20 o 	if strings.HasPrefix(string(act.Object), "https") {

 91 1d5ddf5d 2024-02-20 o 		if client == nil {

 92 1d5ddf5d 2024-02-20 o 			return Lookup(string(act.Object))

 93 1d5ddf5d 2024-02-20 o 		}

 94 1d5ddf5d 2024-02-20 o 		return client.Lookup(string(act.Object))

 95 1d5ddf5d 2024-02-20 o 	}

 96 1d5ddf5d 2024-02-20 o 	return Decode(buf)

 97 1d5ddf5d 2024-02-20 o }

 98 1d5ddf5d 2024-02-20 o 

 99 1d5ddf5d 2024-02-20 o func Decode(r io.Reader) (*Activity, error) {

100 1d5ddf5d 2024-02-20 o 	var a Activity

101 1d5ddf5d 2024-02-20 o 	if err := json.NewDecoder(r).Decode(&a); err != nil {

102 1d5ddf5d 2024-02-20 o 		return nil, fmt.Errorf("decode activity: %w", err)

103 1d5ddf5d 2024-02-20 o 	}

104 1d5ddf5d 2024-02-20 o 	return &a, nil

105 1d5ddf5d 2024-02-20 o }

106 1d5ddf5d 2024-02-20 o 

107 71191436 2024-02-28 o func DecodeActor(r io.Reader) (*Actor, error) {

108 71191436 2024-02-28 o 	a, err := Decode(r)

109 71191436 2024-02-28 o 	if err != nil {

110 71191436 2024-02-28 o 		return nil, err

111 71191436 2024-02-28 o 	}

112 71191436 2024-02-28 o 	return activityToActor(a), nil

113 71191436 2024-02-28 o }

114 71191436 2024-02-28 o 

115 1d5ddf5d 2024-02-20 o type Actor struct {

116 71191436 2024-02-28 o 	AtContext string     `json:"@context"`

117 71191436 2024-02-28 o 	ID        string     `json:"id"`

118 71191436 2024-02-28 o 	Type      string     `json:"type"`

119 71191436 2024-02-28 o 	Name      string     `json:"name"`

120 71191436 2024-02-28 o 	Username  string     `json:"preferredUsername"`

121 77918b00 2024-03-07 o 	Summary   string     `json:"summary,omitempty"`

122 71191436 2024-02-28 o 	Inbox     string     `json:"inbox"`

123 71191436 2024-02-28 o 	Outbox    string     `json:"outbox"`

124 77918b00 2024-03-07 o 	Followers string     `json:"followers"`

125 71191436 2024-02-28 o 	Published *time.Time `json:"published,omitempty"`

126 71191436 2024-02-28 o 	PublicKey PublicKey  `json:"publicKey"`

127 1d5ddf5d 2024-02-20 o }

128 1d5ddf5d 2024-02-20 o 

129 1d5ddf5d 2024-02-20 o type PublicKey struct {

130 1d5ddf5d 2024-02-20 o 	ID           string `json:"id"`

131 1d5ddf5d 2024-02-20 o 	Owner        string `json:"owner"`

132 1d5ddf5d 2024-02-20 o 	PublicKeyPEM string `json:"publicKeyPem"`

133 1d5ddf5d 2024-02-20 o }

134 1d5ddf5d 2024-02-20 o 

135 1d5ddf5d 2024-02-20 o func (a *Actor) Address() *mail.Address {

136 71191436 2024-02-28 o 	if a.Username == "" && a.Name == "" {

137 71191436 2024-02-28 o 		return &mail.Address{"", a.ID}

138 71191436 2024-02-28 o 	}

139 1d5ddf5d 2024-02-20 o 	trimmed := strings.TrimPrefix(a.ID, "https://")

140 1d5ddf5d 2024-02-20 o 	host, _, _ := strings.Cut(trimmed, "/")

141 1d5ddf5d 2024-02-20 o 	addr := fmt.Sprintf("%s@%s", a.Username, host)

142 1d5ddf5d 2024-02-20 o 	return &mail.Address{a.Name, addr}

143 1d5ddf5d 2024-02-20 o }

144 77918b00 2024-03-07 o 

145 77918b00 2024-03-07 o func (a *Actor) FollowersAddress() *mail.Address {

146 77918b00 2024-03-07 o 	if a.Followers == "" {

147 77918b00 2024-03-07 o 		return &mail.Address{"", ""}

148 77918b00 2024-03-07 o 	}

149 77918b00 2024-03-07 o 	addr := a.Address()

150 77918b00 2024-03-07 o 	user, domain, found := strings.Cut(addr.Address, "@")

151 77918b00 2024-03-07 o 	if !found {

152 77918b00 2024-03-07 o 		return &mail.Address{"", ""}

153 77918b00 2024-03-07 o 	}

154 77918b00 2024-03-07 o 	addr.Address = fmt.Sprintf("%s+followers@%s", user, domain)

155 77918b00 2024-03-07 o 	if addr.Name != "" {

156 77918b00 2024-03-07 o 		addr.Name += " (followers)"

157 77918b00 2024-03-07 o 	}

158 77918b00 2024-03-07 o 	return addr

159 77918b00 2024-03-07 o }