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
|
package activitypub
import (
"errors"
"fmt"
"strings"
"github.com/FChannel0/FChannel-Server/config"
"github.com/FChannel0/FChannel-Server/util"
)
func AcceptActivity(header string) bool {
accept := false
if strings.Contains(header, ";") {
split := strings.Split(header, ";")
accept = accept || activityRegexp.MatchString(split[0])
accept = accept || strings.Contains(split[len(split)-1], "profile=\"https://www.w3.org/ns/activitystreams\"")
} else {
accept = accept || activityRegexp.MatchString(header)
}
return accept
}
func (activity Activity) IsLocal() (bool, error) {
for _, e := range activity.To {
if res, _ := GetActorFromDB(e); res.Id != "" {
return true, nil
}
}
for _, e := range activity.Cc {
if res, _ := GetActorFromDB(e); res.Id != "" {
return true, nil
}
}
if activity.Actor != nil {
if res, _ := GetActorFromDB(activity.Actor.Id); res.Id != "" {
return true, nil
}
}
return false, nil
}
func (activity Activity) Process() error {
activityType := activity.Type
if activityType == "Create" {
for _, e := range activity.To {
if res, err := GetActorFromDB(e); res.Id != "" {
fmt.Println("actor is in the database")
} else if err != nil {
return util.MakeError(err, "Process")
} else {
fmt.Println("actor is NOT in the database")
}
}
} else if activityType == "Follow" {
// TODO: okay?
return errors.New("not implemented")
} else if activityType == "Delete" {
return errors.New("not implemented")
}
return nil
}
func (activity Activity) Reject() Activity {
var accept Activity
accept.AtContext.Context = activity.AtContext.Context
accept.Type = "Reject"
var nObj ObjectBase
accept.Object = &nObj
var nActor Actor
accept.Actor = &nActor
accept.Actor.Id = activity.Object.Actor
accept.Object.Actor = activity.Actor.Id
var nNested NestedObjectBase
accept.Object.Object = &nNested
accept.Object.Object.Actor = activity.Object.Actor
accept.Object.Object.Type = "Follow"
accept.To = append(accept.To, activity.Actor.Id)
return accept
}
func (activity Activity) Report(reason string) (bool, error) {
if isLocal, err := activity.Object.IsLocal(); !isLocal || err != nil {
return false, util.MakeError(err, "Report")
}
activityCol, err := activity.Object.GetCollection()
if err != nil {
return false, util.MakeError(err, "Report")
}
query := `insert into reported (id, count, board, reason) values ($1, $2, $3, $4)`
if _, err = config.DB.Exec(query, activity.Object.Object.Id, 1, activityCol.Actor.Id, reason); err != nil {
return false, util.MakeError(err, "Report")
}
return true, nil
}
func (activity Activity) SetFollower() (Activity, error) {
var query string
alreadyFollow, err := activity.Actor.IsAlreadyFollower(activity.Object.Actor)
if err != nil {
return activity, util.MakeError(err, "SetFollower")
}
activity.Type = "Reject"
if activity.Actor.Id == activity.Object.Actor {
return activity, nil
}
if alreadyFollow {
query = `delete from follower where id=$1 and follower=$2`
activity.Summary = activity.Object.Actor + " Unfollow " + activity.Actor.Id
if _, err := config.DB.Exec(query, activity.Actor.Id, activity.Object.Actor); err != nil {
return activity, util.MakeError(err, "SetFollower")
}
activity.Type = "Accept"
return activity, util.MakeError(err, "SetFollower")
}
query = `insert into follower (id, follower) values ($1, $2)`
activity.Summary = activity.Object.Actor + " Follow " + activity.Actor.Id
if _, err := config.DB.Exec(query, activity.Actor.Id, activity.Object.Actor); err != nil {
return activity, util.MakeError(err, "SetFollower")
}
activity.Type = "Accept"
return activity, nil
}
|
