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