2 import * as express from 'express'
3 import { VideoFilter } from '../../../../shared/models/videos/video-query.type'
4 import { buildNSFWFilter, getCountVideos } from '../../../helpers/express-utils'
5 import { getFormattedObjects } from '../../../helpers/utils'
6 import { WEBSERVER } from '../../../initializers/constants'
7 import { sequelizeTypescript } from '../../../initializers/database'
8 import { JobQueue } from '../../../lib/job-queue'
11 asyncRetryTransactionMiddleware,
13 commonVideosFiltersValidator,
18 userSubscriptionAddValidator,
19 userSubscriptionGetValidator
20 } from '../../../middlewares'
22 areSubscriptionsExistValidator,
23 userSubscriptionListValidator,
24 userSubscriptionsSortValidator,
26 } from '../../../middlewares/validators'
27 import { ActorFollowModel } from '../../../models/activitypub/actor-follow'
28 import { VideoModel } from '../../../models/video/video'
29 import { sendUndoFollow } from '@server/lib/activitypub/send'
31 const mySubscriptionsRouter = express.Router()
33 mySubscriptionsRouter.get('/me/subscriptions/videos',
39 commonVideosFiltersValidator,
40 asyncMiddleware(getUserSubscriptionVideos)
43 mySubscriptionsRouter.get('/me/subscriptions/exist',
45 areSubscriptionsExistValidator,
46 asyncMiddleware(areSubscriptionsExist)
49 mySubscriptionsRouter.get('/me/subscriptions',
52 userSubscriptionsSortValidator,
55 userSubscriptionListValidator,
56 asyncMiddleware(getUserSubscriptions)
59 mySubscriptionsRouter.post('/me/subscriptions',
61 userSubscriptionAddValidator,
65 mySubscriptionsRouter.get('/me/subscriptions/:uri',
67 userSubscriptionGetValidator,
71 mySubscriptionsRouter.delete('/me/subscriptions/:uri',
73 userSubscriptionGetValidator,
74 asyncRetryTransactionMiddleware(deleteUserSubscription)
77 // ---------------------------------------------------------------------------
83 // ---------------------------------------------------------------------------
85 async function areSubscriptionsExist (req: express.Request, res: express.Response) {
86 const uris = req.query.uris as string[]
87 const user = res.locals.oauth.token.User
89 const handles = uris.map(u => {
90 let [ name, host ] = u.split('@')
91 if (host === WEBSERVER.HOST) host = null
93 return { name, host, uri: u }
96 const results = await ActorFollowModel.listSubscribedIn(user.Account.Actor.id, handles)
98 const existObject: { [id: string ]: boolean } = {}
99 for (const handle of handles) {
100 const obj = results.find(r => {
101 const server = r.ActorFollowing.Server
103 return r.ActorFollowing.preferredUsername === handle.name &&
105 (!server && !handle.host) ||
106 (server.host === handle.host)
110 existObject[handle.uri] = obj !== undefined
113 return res.json(existObject)
116 function addUserSubscription (req: express.Request, res: express.Response) {
117 const user = res.locals.oauth.token.User
118 const [ name, host ] = req.body.uri.split('@')
123 assertIsChannel: true,
124 followerActorId: user.Account.Actor.id
127 JobQueue.Instance.createJob({ type: 'activitypub-follow', payload })
129 return res.status(204).end()
132 function getUserSubscription (req: express.Request, res: express.Response) {
133 const subscription = res.locals.subscription
135 return res.json(subscription.ActorFollowing.VideoChannel.toFormattedJSON())
138 async function deleteUserSubscription (req: express.Request, res: express.Response) {
139 const subscription = res.locals.subscription
141 await sequelizeTypescript.transaction(async t => {
142 if (subscription.state === 'accepted') await sendUndoFollow(subscription, t)
144 return subscription.destroy({ transaction: t })
147 return res.type('json').status(204).end()
150 async function getUserSubscriptions (req: express.Request, res: express.Response) {
151 const user = res.locals.oauth.token.User
152 const actorId = user.Account.Actor.id
154 const resultList = await ActorFollowModel.listSubscriptionsForApi({
156 start: req.query.start,
157 count: req.query.count,
158 sort: req.query.sort,
159 search: req.query.search
162 return res.json(getFormattedObjects(resultList.data, resultList.total))
165 async function getUserSubscriptionVideos (req: express.Request, res: express.Response) {
166 const user = res.locals.oauth.token.User
167 const countVideos = getCountVideos(req)
169 const resultList = await VideoModel.listForApi({
170 start: req.query.start,
171 count: req.query.count,
172 sort: req.query.sort,
173 includeLocalVideos: false,
174 categoryOneOf: req.query.categoryOneOf,
175 licenceOneOf: req.query.licenceOneOf,
176 languageOneOf: req.query.languageOneOf,
177 tagsOneOf: req.query.tagsOneOf,
178 tagsAllOf: req.query.tagsAllOf,
179 nsfw: buildNSFWFilter(res, req.query.nsfw),
180 filter: req.query.filter as VideoFilter,
182 followerActorId: user.Account.Actor.id,
187 return res.json(getFormattedObjects(resultList.data, resultList.total))