]>
Commit | Line | Data |
---|---|---|
4d4e5cd4 | 1 | import * as express from 'express' |
3fd3ab2d | 2 | import { UserRight } from '../../../../shared/models/users' |
da854ddd C |
3 | import { logger } from '../../../helpers/logger' |
4 | import { getFormattedObjects, getServerActor } from '../../../helpers/utils' | |
74dc3bca | 5 | import { SERVER_ACTOR_NAME } from '../../../initializers/constants' |
14893eb7 | 6 | import { sendAccept, sendReject, sendUndoFollow } from '../../../lib/activitypub/send' |
3fd3ab2d | 7 | import { |
5350fd8e C |
8 | asyncMiddleware, |
9 | authenticate, | |
10 | ensureUserHasRight, | |
11 | paginationValidator, | |
5350fd8e C |
12 | setBodyHostsPort, |
13 | setDefaultPagination, | |
14 | setDefaultSort | |
3fd3ab2d | 15 | } from '../../../middlewares' |
0e9c48c2 | 16 | import { |
14893eb7 | 17 | acceptOrRejectFollowerValidator, |
0e9c48c2 C |
18 | followersSortValidator, |
19 | followingSortValidator, | |
20 | followValidator, | |
14893eb7 | 21 | getFollowerValidator, |
b8f4167f C |
22 | removeFollowingValidator, |
23 | listFollowsValidator | |
0e9c48c2 | 24 | } from '../../../middlewares/validators' |
50d6de9c | 25 | import { ActorFollowModel } from '../../../models/activitypub/actor-follow' |
5350fd8e | 26 | import { JobQueue } from '../../../lib/job-queue' |
161b061d | 27 | import { removeRedundancyOf } from '../../../lib/redundancy' |
74dc3bca | 28 | import { sequelizeTypescript } from '../../../initializers/database' |
8424c402 | 29 | import { autoFollowBackIfNeeded } from '../../../lib/activitypub/follow' |
51548b31 | 30 | |
4610bc5b | 31 | const serverFollowsRouter = express.Router() |
4610bc5b | 32 | serverFollowsRouter.get('/following', |
b8f4167f | 33 | listFollowsValidator, |
8a02bd04 | 34 | paginationValidator, |
7a7724e6 | 35 | followingSortValidator, |
1174a847 | 36 | setDefaultSort, |
f05a1c30 | 37 | setDefaultPagination, |
7a7724e6 C |
38 | asyncMiddleware(listFollowing) |
39 | ) | |
40 | ||
9a27cdc2 | 41 | serverFollowsRouter.post('/following', |
8e696487 | 42 | authenticate, |
4610bc5b | 43 | ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW), |
ce548a10 C |
44 | followValidator, |
45 | setBodyHostsPort, | |
5350fd8e | 46 | asyncMiddleware(followInstance) |
ce548a10 C |
47 | ) |
48 | ||
50d6de9c | 49 | serverFollowsRouter.delete('/following/:host', |
54141398 C |
50 | authenticate, |
51 | ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW), | |
a2431b7d | 52 | asyncMiddleware(removeFollowingValidator), |
0e9c48c2 | 53 | asyncMiddleware(removeFollowing) |
54141398 C |
54 | ) |
55 | ||
4610bc5b | 56 | serverFollowsRouter.get('/followers', |
b8f4167f | 57 | listFollowsValidator, |
7a7724e6 C |
58 | paginationValidator, |
59 | followersSortValidator, | |
1174a847 | 60 | setDefaultSort, |
f05a1c30 | 61 | setDefaultPagination, |
7a7724e6 | 62 | asyncMiddleware(listFollowers) |
65fcc311 | 63 | ) |
65fcc311 | 64 | |
0e9c48c2 C |
65 | serverFollowsRouter.delete('/followers/:nameWithHost', |
66 | authenticate, | |
67 | ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW), | |
14893eb7 C |
68 | asyncMiddleware(getFollowerValidator), |
69 | asyncMiddleware(removeOrRejectFollower) | |
70 | ) | |
71 | ||
72 | serverFollowsRouter.post('/followers/:nameWithHost/reject', | |
73 | authenticate, | |
74 | ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW), | |
75 | asyncMiddleware(getFollowerValidator), | |
76 | acceptOrRejectFollowerValidator, | |
77 | asyncMiddleware(removeOrRejectFollower) | |
78 | ) | |
79 | ||
80 | serverFollowsRouter.post('/followers/:nameWithHost/accept', | |
81 | authenticate, | |
82 | ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW), | |
83 | asyncMiddleware(getFollowerValidator), | |
84 | acceptOrRejectFollowerValidator, | |
85 | asyncMiddleware(acceptFollower) | |
0e9c48c2 C |
86 | ) |
87 | ||
65fcc311 C |
88 | // --------------------------------------------------------------------------- |
89 | ||
90 | export { | |
4610bc5b | 91 | serverFollowsRouter |
65fcc311 C |
92 | } |
93 | ||
94 | // --------------------------------------------------------------------------- | |
95 | ||
dae86118 | 96 | async function listFollowing (req: express.Request, res: express.Response) { |
50d6de9c | 97 | const serverActor = await getServerActor() |
b8f4167f C |
98 | const resultList = await ActorFollowModel.listFollowingForApi({ |
99 | id: serverActor.id, | |
100 | start: req.query.start, | |
101 | count: req.query.count, | |
102 | sort: req.query.sort, | |
103 | search: req.query.search, | |
104 | state: req.query.state | |
105 | }) | |
7a7724e6 C |
106 | |
107 | return res.json(getFormattedObjects(resultList.data, resultList.total)) | |
108 | } | |
109 | ||
dae86118 | 110 | async function listFollowers (req: express.Request, res: express.Response) { |
50d6de9c | 111 | const serverActor = await getServerActor() |
b8f4167f C |
112 | const resultList = await ActorFollowModel.listFollowersForApi({ |
113 | actorId: serverActor.id, | |
114 | start: req.query.start, | |
115 | count: req.query.count, | |
116 | sort: req.query.sort, | |
117 | search: req.query.search, | |
118 | state: req.query.state | |
119 | }) | |
eb080476 C |
120 | |
121 | return res.json(getFormattedObjects(resultList.data, resultList.total)) | |
65fcc311 | 122 | } |
ce548a10 | 123 | |
dae86118 | 124 | async function followInstance (req: express.Request, res: express.Response) { |
ce548a10 | 125 | const hosts = req.body.hosts as string[] |
06a05d5f | 126 | const follower = await getServerActor() |
350e31d6 | 127 | |
ce548a10 | 128 | for (const host of hosts) { |
06a05d5f C |
129 | const payload = { |
130 | host, | |
131 | name: SERVER_ACTOR_NAME, | |
132 | followerActorId: follower.id | |
133 | } | |
134 | ||
135 | JobQueue.Instance.createJob({ type: 'activitypub-follow', payload }) | |
5350fd8e | 136 | .catch(err => logger.error('Cannot create follow job for %s.', host, err)) |
ce548a10 C |
137 | } |
138 | ||
ce548a10 C |
139 | return res.status(204).end() |
140 | } | |
350e31d6 | 141 | |
0e9c48c2 | 142 | async function removeFollowing (req: express.Request, res: express.Response) { |
dae86118 | 143 | const follow = res.locals.follow |
54141398 | 144 | |
3fd3ab2d | 145 | await sequelizeTypescript.transaction(async t => { |
40ff5707 C |
146 | if (follow.state === 'accepted') await sendUndoFollow(follow, t) |
147 | ||
c48e82b5 C |
148 | // Disable redundancy on unfollowed instances |
149 | const server = follow.ActorFollowing.Server | |
150 | server.redundancyAllowed = false | |
151 | await server.save({ transaction: t }) | |
152 | ||
161b061d C |
153 | // Async, could be long |
154 | removeRedundancyOf(server.id) | |
155 | .catch(err => logger.error('Cannot remove redundancy of %s.', server.host, err)) | |
156 | ||
0f91ae62 | 157 | await follow.destroy({ transaction: t }) |
54141398 C |
158 | }) |
159 | ||
160 | return res.status(204).end() | |
161 | } | |
0e9c48c2 | 162 | |
14893eb7 | 163 | async function removeOrRejectFollower (req: express.Request, res: express.Response) { |
0e9c48c2 C |
164 | const follow = res.locals.follow |
165 | ||
5b9c965d | 166 | await sendReject(follow.ActorFollower, follow.ActorFollowing) |
0e9c48c2 C |
167 | |
168 | await follow.destroy() | |
169 | ||
170 | return res.status(204).end() | |
171 | } | |
14893eb7 C |
172 | |
173 | async function acceptFollower (req: express.Request, res: express.Response) { | |
174 | const follow = res.locals.follow | |
175 | ||
176 | await sendAccept(follow) | |
177 | ||
178 | follow.state = 'accepted' | |
179 | await follow.save() | |
180 | ||
8424c402 C |
181 | await autoFollowBackIfNeeded(follow) |
182 | ||
14893eb7 C |
183 | return res.status(204).end() |
184 | } |