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
|
package db
import (
"github.com/FChannel0/FChannel-Server/activitypub"
)
func GetCollectionFromPath(path string) (activitypub.Collection, error) {
var nColl activitypub.Collection
var result []activitypub.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)
if err != nil {
return nColl, err
}
defer rows.Close()
for rows.Next() {
var actor activitypub.Actor
var post activitypub.ObjectBase
var attachID string
var previewID string
if err := rows.Scan(&post.Id, &post.Name, &post.Content, &post.Type, &post.Published, &post.AttributedTo, &attachID, &previewID, &actor.Id); err != nil {
return nColl, err
}
post.Actor = actor.Id
post.InReplyTo, err = GetInReplyToDB(post)
if err != nil {
return nColl, err
}
var postCnt int
var imgCnt int
post.Replies, postCnt, imgCnt, err = GetObjectRepliesDB(post)
if err != nil {
return nColl, err
}
post.Replies.TotalItems, post.Replies.TotalImgs, err = GetObjectRepliesCount(post)
if err != nil {
return nColl, err
}
post.Replies.TotalItems = post.Replies.TotalItems + postCnt
post.Replies.TotalImgs = post.Replies.TotalImgs + imgCnt
post.Attachment, err = GetObjectAttachment(attachID)
if err != nil {
return nColl, err
}
post.Preview, err = GetObjectPreview(previewID)
if err != nil {
return nColl, err
}
result = append(result, post)
}
nColl.AtContext.Context = "https://www.w3.org/ns/activitystreams"
nColl.OrderedItems = result
return nColl, nil
}
func GetObjectFromPath(path string) (activitypub.ObjectBase, error) {
var nObj activitypub.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)
if err != nil {
return nObj, err
}
defer rows.Close()
rows.Next()
var attachID string
var previewID string
var nActor activitypub.Actor
nObj.Actor = nActor.Id
if err := rows.Scan(&nObj.Id, &nObj.Name, &nObj.Content, &nObj.Type, &nObj.Published, &nObj.AttributedTo, &attachID, &previewID, &nObj.Actor); err != nil {
return nObj, err
}
var postCnt int
var imgCnt int
nObj.Replies, postCnt, imgCnt, err = GetObjectRepliesDB(nObj)
if err != nil {
return nObj, err
}
nObj.Replies.TotalItems, nObj.Replies.TotalImgs, err = GetObjectRepliesCount(nObj)
if err != nil {
return nObj, err
}
nObj.Replies.TotalItems = nObj.Replies.TotalItems + postCnt
nObj.Replies.TotalImgs = nObj.Replies.TotalImgs + imgCnt
nObj.Attachment, err = GetObjectAttachment(attachID)
if err != nil {
return nObj, err
}
nObj.Preview, err = GetObjectPreview(previewID)
return nObj, err
}
|
