diff options
Diffstat (limited to 'server/controllers/api/users/me.ts')
-rw-r--r-- | server/controllers/api/users/me.ts | 41 |
1 files changed, 39 insertions, 2 deletions
diff --git a/server/controllers/api/users/me.ts b/server/controllers/api/users/me.ts index 2300f5dbe..000c706b5 100644 --- a/server/controllers/api/users/me.ts +++ b/server/controllers/api/users/me.ts | |||
@@ -20,7 +20,8 @@ import { | |||
20 | deleteMeValidator, | 20 | deleteMeValidator, |
21 | userSubscriptionsSortValidator, | 21 | userSubscriptionsSortValidator, |
22 | videoImportsSortValidator, | 22 | videoImportsSortValidator, |
23 | videosSortValidator | 23 | videosSortValidator, |
24 | areSubscriptionsExistValidator | ||
24 | } from '../../../middlewares/validators' | 25 | } from '../../../middlewares/validators' |
25 | import { AccountVideoRateModel } from '../../../models/account/account-video-rate' | 26 | import { AccountVideoRateModel } from '../../../models/account/account-video-rate' |
26 | import { UserModel } from '../../../models/account/user' | 27 | import { UserModel } from '../../../models/account/user' |
@@ -99,7 +100,6 @@ meRouter.post('/me/avatar/pick', | |||
99 | 100 | ||
100 | meRouter.get('/me/subscriptions/videos', | 101 | meRouter.get('/me/subscriptions/videos', |
101 | authenticate, | 102 | authenticate, |
102 | authenticate, | ||
103 | paginationValidator, | 103 | paginationValidator, |
104 | videosSortValidator, | 104 | videosSortValidator, |
105 | setDefaultSort, | 105 | setDefaultSort, |
@@ -108,6 +108,12 @@ meRouter.get('/me/subscriptions/videos', | |||
108 | asyncMiddleware(getUserSubscriptionVideos) | 108 | asyncMiddleware(getUserSubscriptionVideos) |
109 | ) | 109 | ) |
110 | 110 | ||
111 | meRouter.get('/me/subscriptions/exist', | ||
112 | authenticate, | ||
113 | areSubscriptionsExistValidator, | ||
114 | asyncMiddleware(areSubscriptionsExist) | ||
115 | ) | ||
116 | |||
111 | meRouter.get('/me/subscriptions', | 117 | meRouter.get('/me/subscriptions', |
112 | authenticate, | 118 | authenticate, |
113 | paginationValidator, | 119 | paginationValidator, |
@@ -143,6 +149,37 @@ export { | |||
143 | 149 | ||
144 | // --------------------------------------------------------------------------- | 150 | // --------------------------------------------------------------------------- |
145 | 151 | ||
152 | async function areSubscriptionsExist (req: express.Request, res: express.Response) { | ||
153 | const uris = req.query.uris as string[] | ||
154 | const user = res.locals.oauth.token.User as UserModel | ||
155 | |||
156 | const handles = uris.map(u => { | ||
157 | let [ name, host ] = u.split('@') | ||
158 | if (host === CONFIG.WEBSERVER.HOST) host = null | ||
159 | |||
160 | return { name, host, uri: u } | ||
161 | }) | ||
162 | |||
163 | const results = await ActorFollowModel.listSubscribedIn(user.Account.Actor.id, handles) | ||
164 | |||
165 | const existObject: { [id: string ]: boolean } = {} | ||
166 | for (const handle of handles) { | ||
167 | const obj = results.find(r => { | ||
168 | const server = r.ActorFollowing.Server | ||
169 | |||
170 | return r.ActorFollowing.preferredUsername === handle.name && | ||
171 | ( | ||
172 | (!server && !handle.host) || | ||
173 | (server.host === handle.host) | ||
174 | ) | ||
175 | }) | ||
176 | |||
177 | existObject[handle.uri] = obj !== undefined | ||
178 | } | ||
179 | |||
180 | return res.json(existObject) | ||
181 | } | ||
182 | |||
146 | async function addUserSubscription (req: express.Request, res: express.Response) { | 183 | async function addUserSubscription (req: express.Request, res: express.Response) { |
147 | const user = res.locals.oauth.token.User as UserModel | 184 | const user = res.locals.oauth.token.User as UserModel |
148 | const [ name, host ] = req.body.uri.split('@') | 185 | const [ name, host ] = req.body.uri.split('@') |