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