diff options
Diffstat (limited to 'views/outbox.go')
-rw-r--r-- | views/outbox.go | 85 |
1 files changed, 0 insertions, 85 deletions
diff --git a/views/outbox.go b/views/outbox.go index 5c1ade3..4dd5ab5 100644 --- a/views/outbox.go +++ b/views/outbox.go @@ -6,93 +6,8 @@ import ( "git.capotej.com/capotej/communique/models" "git.capotej.com/capotej/communique/urls" "github.com/go-fed/activity/streams" - "github.com/go-fed/activity/streams/vocab" ) -func activityObjectNote(name, domain string, v models.OutboxItem) (vocab.ActivityStreamsNote, error) { - var err error - note := streams.NewActivityStreamsNote() - - noteUrl, err := urls.UrlNote(name, domain, string(v.Id)) - if err != nil { - return nil, err - } - noteIdProp := streams.NewJSONLDIdProperty() - noteIdProp.Set(noteUrl) - note.SetJSONLDId(noteIdProp) - contentProp := streams.NewActivityStreamsContentProperty() - contentProp.AppendXMLSchemaString(string(v.Content)) - note.SetActivityStreamsContent(contentProp) - - actorUrl, err := urls.UrlProfile(name, domain) - if err != nil { - return nil, err - } - attrProp := streams.NewActivityStreamsAttributedToProperty() - attrProp.AppendIRI(actorUrl) - note.SetActivityStreamsAttributedTo(attrProp) - - summaryProp := streams.NewActivityStreamsSummaryProperty() - summaryProp.AppendXMLSchemaString("") - note.SetActivityStreamsSummary(summaryProp) - - noteUrlProp := streams.NewActivityStreamsUrlProperty() - noteUrlProp.AppendIRI(noteUrl) - note.SetActivityStreamsUrl(noteUrlProp) - - publicUrl, err := url.Parse("https://www.w3.org/ns/activitystreams#Public") - if err != nil { - return nil, err - } - toProp := streams.NewActivityStreamsToProperty() - toProp.AppendIRI(publicUrl) - note.SetActivityStreamsTo(toProp) - - publishedProp := streams.NewActivityStreamsPublishedProperty() - publishedProp.Set(v.CreatedAt) - note.SetActivityStreamsPublished(publishedProp) - return note, err -} - -func activityObjectCreate(name, domain string, v models.OutboxItem, note vocab.ActivityStreamsNote) (vocab.ActivityStreamsCreate, error) { - var err error - crea := streams.NewActivityStreamsCreate() - obj := streams.NewActivityStreamsObjectProperty() - - creaIdProp := streams.NewJSONLDIdProperty() - activityUrl, err := urls.UrlActivity(name, domain, string(v.Id)) - if err != nil { - return nil, err - } - creaIdProp.Set(activityUrl) - crea.SetJSONLDId(creaIdProp) - - crea.SetActivityStreamsObject(obj) - - publicUrl, err := url.Parse("https://www.w3.org/ns/activitystreams#Public") - if err != nil { - return nil, err - } - toProp := streams.NewActivityStreamsToProperty() - toProp.AppendIRI(publicUrl) - crea.SetActivityStreamsTo(toProp) - - publishedProp := streams.NewActivityStreamsPublishedProperty() - publishedProp.Set(v.CreatedAt) - crea.SetActivityStreamsPublished(publishedProp) - - actorUrl, err := urls.UrlProfile(name, domain) - if err != nil { - return nil, err - } - actorProp := streams.NewActivityStreamsActorProperty() - actorProp.AppendIRI(actorUrl) - crea.SetActivityStreamsActor(actorProp) - obj.AppendActivityStreamsNote(note) - - return crea, err -} - // RenderOutboxCollection takes a page of ActivityStream objects as JSON strings and concatenates them together to return an // ActivtyStreamsOrderedCollection func RenderOutboxCollection(name, domain string, page []models.OutboxItem) (map[string]interface{}, error) { |