-
1
-
2
-
3
-
4
-
5
-
6
-
7
-
8
-
9
-
10
-
11
-
12
-
13
-
14
-
15
-
16
-
17
-
18
-
19
-
20
-
21
-
22
-
23
-
24
-
25
-
26
-
27
-
28
-
29
-
30
-
31
-
32
-
33
-
34
-
35
-
36
-
37
-
38
-
39
-
40
-
41
-
42
-
43
-
44
-
45
-
46
-
47
-
48
-
49
-
50
-
51
-
52
-
53
-
54
-
55
-
56
-
57
-
58
-
59
-
60
-
61
-
62
-
63
-
64
-
65
-
66
-
67
-
68
-
69
-
70
-
71
-
72
-
73
-
74
-
75
-
76
-
77
-
78
-
79
-
80
-
81
-
82
-
83
-
84
-
85
-
86
-
87
-
88
-
89
-
90
-
91
-
92
-
93
-
94
-
95
-
96
-
97
-
98
-
99
-
100
-
101
-
102
-
103
-
104
-
105
-
106
-
107
-
108
-
109
-
110
-
111
-
112
-
113
-
114
-
115
-
116
-
117
-
118
-
119
-
120
-
121
-
122
-
123
-
124
-
125
-
126
-
127
-
128
-
129
-
130
-
131
-
132
-
133
-
134
-
135
-
136
-
137
-
138
-
139
-
140
-
141
-
142
-
143
-
144
-
145
-
146
-
147
-
148
-
149
-
150
-
151
-
152
-
153
-
154
-
155
-
156
-
157
-
158
-
159
-
160
-
161
-
162
-
163
-
164
-
165
-
166
-
167
-
168
-
169
-
170
-
171
-
172
-
173
-
174
-
175
-
176
-
177
-
178
-
179
-
180
-
181
-
182
package activitypub
import (
"errors"
as "github.com/go-ap/activitystreams"
)
// Endpoints a json object which maps additional (typically server/domain-wide)
// endpoints which may be useful either for this actor or someone referencing this actor.
// This mapping may be nested inside the actor document as the value or may be a link to
// a JSON-LD document with these properties.
type Endpoints struct {
// UploadMedia Upload endpoint URI for this user for binary data.
UploadMedia as.Item `jsonld:"uploadMedia,omitempty"`
// OauthAuthorizationEndpoint Endpoint URI so this actor's clients may access remote ActivityStreams objects which require authentication
// to access. To use this endpoint, the client posts an x-www-form-urlencoded id parameter with the value being
// the id of the requested ActivityStreams object.
OauthAuthorizationEndpoint as.Item `jsonld:"oauthAuthorizationEndpoint,omitempty"`
// OauthTokenEndpoint If OAuth 2.0 bearer tokens [RFC6749] [RFC6750] are being used for authenticating client to server interactions,
// this endpoint specifies a URI at which a browser-authenticated user may obtain a new authorization grant.
OauthTokenEndpoint as.Item `jsonld:"oauthTokenEndpoint,omitempty"`
// ProvideClientKey If OAuth 2.0 bearer tokens [RFC6749] [RFC6750] are being used for authenticating client to server interactions,
// this endpoint specifies a URI at which a client may acquire an access token.
ProvideClientKey as.Item `jsonld:"provideClientKey,omitempty"`
// SignClientKey If Linked Data Signatures and HTTP Signatures are being used for authentication and authorization,
// this endpoint specifies a URI at which browser-authenticated users may authorize a client's public
// key for client to server interactions.
SignClientKey as.Item `jsonld:"signClientKey,omitempty"`
// SharedInbox If Linked Data Signatures and HTTP Signatures are being used for authentication and authorization,
// this endpoint specifies a URI at which a client key may be signed by the actor's key for a time window to
// act on behalf of the actor in interacting with foreign servers.
SharedInbox as.Item `jsonld:"sharedInbox,omitempty"`
}
// Actor is generally one of the ActivityStreams actor Types, but they don't have to be.
// For example, a Profile object might be used as an actor, or a type from an ActivityStreams extension.
// Actors are retrieved like any other Object in ActivityPub.
// Like other ActivityStreams objects, actors have an id, which is a URI.
type actor struct {
Parent
// A reference to an [ActivityStreams] OrderedCollection comprised of all the messages received by the actor;
// see 5.2 Inbox.
Inbox as.Item `jsonld:"inbox,omitempty"`
// An [ActivityStreams] OrderedCollection comprised of all the messages produced by the actor;
// see 5.1 Outbox.
Outbox as.Item `jsonld:"outbox,omitempty"`
// A link to an [ActivityStreams] collection of the actors that this actor is following;
// see 5.4 Following Collection
Following as.Item `jsonld:"following,omitempty"`
// A link to an [ActivityStreams] collection of the actors that follow this actor;
// see 5.3 Followers Collection.
Followers as.Item `jsonld:"followers,omitempty"`
// A link to an [ActivityStreams] collection of the actors that follow this actor;
// see 5.5 Liked Collection.
Liked as.Item `jsonld:"liked,omitempty"`
// A link to an [ActivityStreams] collection of the actors that follow this actor;
// see 5.7 Likes Collection.
Likes as.Item `jsonld:"likes,omitempty"`
// A link to an [ActivityStreams] collection of the actors that follow this actor;
// see 5.8 Shares Collection
Shares as.Item `jsonld:"shares,omitempty"`
// A short username which may be used to refer to the actor, with no uniqueness guarantees.
PreferredUsername as.NaturalLanguageValues `jsonld:"preferredUsername,omitempty,collapsible"`
// A json object which maps additional (typically server/domain-wide) endpoints which may be useful either
// for this actor or someone referencing this actor.
// This mapping may be nested inside the actor document as the value or may be a link
// to a JSON-LD document with these properties.
Endpoints *Endpoints `jsonld:"endpoints,omitempty"`
// A list of supplementary Collections which may be of interest.
Streams []as.ItemCollection `jsonld:"streams,omitempty"`
}
type (
// Application describes a software application.
Application = actor
// Group represents a formal or informal collective of Actors.
Group = actor
// Organization represents an organization.
Organization = actor
// Person represents an individual person.
Person = actor
// Service represents a service of any kind.
Service = actor
)
// actorNew initializes an actor type actor
func actorNew(id as.ObjectID, typ as.ActivityVocabularyType) *actor {
if !as.ActorTypes.Contains(typ) {
typ = as.ActorType
}
a := actor{Parent: Object{Parent: as.Parent{ID: id, Type: typ}}}
a.Name = as.NaturalLanguageValuesNew()
a.Content = as.NaturalLanguageValuesNew()
a.Summary = as.NaturalLanguageValuesNew()
in := as.OrderedCollectionNew(as.ObjectID("test-inbox"))
out := as.OrderedCollectionNew(as.ObjectID("test-outbox"))
liked := as.OrderedCollectionNew(as.ObjectID("test-liked"))
a.Inbox = in
a.Outbox = out
a.Liked = liked
a.PreferredUsername = as.NaturalLanguageValuesNew()
return &a
}
// ApplicationNew initializes an Application type actor
func ApplicationNew(id as.ObjectID) *Application {
return actorNew(id, as.ApplicationType)
}
// GroupNew initializes a Group type actor
func GroupNew(id as.ObjectID) *Group {
return actorNew(id, as.GroupType)
}
// OrganizationNew initializes an Organization type actor
func OrganizationNew(id as.ObjectID) *Organization {
return actorNew(id, as.OrganizationType)
}
// PersonNew initializes a Person type actor
func PersonNew(id as.ObjectID) *Person {
return actorNew(id, as.PersonType)
}
// ServiceNew initializes a Service type actor
func ServiceNew(id as.ObjectID) *Service {
return actorNew(id, as.ServiceType)
}
func (a *actor) UnmarshalJSON(data []byte) error {
if as.ItemTyperFunc == nil {
as.ItemTyperFunc = JSONGetItemByType
}
a.Parent.UnmarshalJSON(data)
a.PreferredUsername = as.JSONGetNaturalLanguageField(data, "preferredUsername")
a.Followers = as.JSONGetItem(data, "followers")
a.Following = as.JSONGetItem(data, "following")
a.Inbox = as.JSONGetItem(data, "inbox")
a.Outbox = as.JSONGetItem(data, "outbox")
a.Liked = as.JSONGetItem(data, "liked")
a.Endpoints = JSONGetActorEndpoints(data, "endpoints")
// TODO(marius): Streams needs custom unmarshalling
//a.Streams = as.JSONGetItems(data, "streams")
return nil
}
// ToPerson
func ToPerson(it as.Item) (*Person, error) {
switch i := it.(type) {
case *as.Object:
return &Person{Parent: Object{Parent: *i}}, nil
case as.Object:
return &Person{Parent: Object{Parent: i}}, nil
case *Object:
return &Person{Parent: *i}, nil
case Object:
return &Person{Parent: i}, nil
case *actor:
return i, nil
case actor:
return &i, nil
}
return nil, errors.New("unable to convert object")
}
// UnmarshalJSON
func (e *Endpoints) UnmarshalJSON(data []byte) error {
e.OauthAuthorizationEndpoint = as.JSONGetItem(data, "oauthAuthorizationEndpoint")
e.OauthTokenEndpoint = as.JSONGetItem(data, "oauthTokenEndpoint")
e.UploadMedia = as.JSONGetItem(data, "uploadMedia")
e.ProvideClientKey = as.JSONGetItem(data, "provideClientKey")
e.SignClientKey = as.JSONGetItem(data, "signClientKey")
e.SharedInbox = as.JSONGetItem(data, "sharedInbox")
return nil
}