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
|
package main
import "net/http"
import "database/sql"
import _ "github.com/lib/pq"
import "encoding/json"
func GetActorOutbox(w http.ResponseWriter, r *http.Request, db *sql.DB) {
actor := GetActorFromPath(db, r.URL.Path, "/")
var collection Collection
collection.OrderedItems = GetObjectFromDB(db, actor.Id).OrderedItems
collection.AtContext.Context = "https://www.w3.org/ns/activitystreams"
collection.Actor = &actor
collection.TotalItems = GetObjectPostsTotalDB(db, actor)
collection.TotalImgs = GetObjectImgsTotalDB(db, actor)
enc, _ := json.MarshalIndent(collection, "", "\t")
w.Header().Set("Content-Type", activitystreams)
w.Write(enc)
}
func GetObjectsFromFollow(db *sql.DB, actor Actor) []ObjectBase {
var followingCol Collection
var followObj []ObjectBase
followingCol = GetActorCollection(actor.Following)
for _, e := range followingCol.Items {
var followOutbox Collection
if !IsActorLocal(db, e.Id) {
followOutbox = GetObjectFromCache(db, e.Id)
} else {
followOutbox = GetObjectFromDB(db, e.Id)
}
for _, e := range followOutbox.OrderedItems {
followObj = append(followObj, e)
}
}
return followObj
}
func GetCollectionFromPath(db *sql.DB, path string) Collection {
var nColl Collection
var result []ObjectBase
query := `select id, name, content, type, published, attributedto, attachment, preview, actor from activitystream where id=$1 order by published desc`
rows, err := db.Query(query, path)
CheckError(err, "error query collection path from db")
defer rows.Close()
for rows.Next(){
var actor Actor
var post ObjectBase
var attachID string
var previewID string
err = rows.Scan(&post.Id, &post.Name, &post.Content, &post.Type, &post.Published, &post.AttributedTo, &attachID, &previewID, &actor.Id)
CheckError(err, "error scan object into post struct from path")
post.Actor = &actor
post.InReplyTo = GetInReplyToDB(db, post)
var postCnt int
var imgCnt int
post.Replies, postCnt, imgCnt = GetObjectRepliesDB(db, post)
post.Replies.TotalItems, post.Replies.TotalImgs = GetObjectRepliesDBCount(db, post)
post.Replies.TotalItems = post.Replies.TotalItems + postCnt
post.Replies.TotalImgs = post.Replies.TotalImgs + imgCnt
post.Attachment = GetObjectAttachment(db, attachID)
post.Preview = GetObjectPreview(db, previewID)
result = append(result, post)
}
nColl.AtContext.Context = "https://www.w3.org/ns/activitystreams"
nColl.OrderedItems = result
return nColl
}
func GetObjectFromPath(db *sql.DB, path string) ObjectBase{
var nObj ObjectBase
var result []ObjectBase
query := `select id, name, content, type, published, attributedto, attachment, preview, actor from activitystream where id=$1 order by published desc`
rows, err := db.Query(query, path)
CheckError(err, "error query collection path from db")
defer rows.Close()
for rows.Next(){
var post ObjectBase
var attachID string
var previewID string
var nActor Actor
post.Actor = &nActor
err = rows.Scan(&post.Id, &post.Name, &post.Content, &post.Type, &post.Published, &post.AttributedTo, &attachID, &previewID, &post.Actor.Id)
CheckError(err, "error scan object into post struct from path")
var postCnt int
var imgCnt int
post.Replies, postCnt, imgCnt = GetObjectRepliesDB(db, post)
post.Replies.TotalItems, post.Replies.TotalImgs = GetObjectRepliesDBCount(db, post)
post.Replies.TotalItems = post.Replies.TotalItems + postCnt
post.Replies.TotalImgs = post.Replies.TotalImgs + imgCnt
post.Attachment = GetObjectAttachment(db, attachID)
post.Preview = GetObjectPreview(db, previewID)
result = append(result, post)
}
nObj = result[0]
return nObj
}
|
