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