2 import * as express from 'express'
3 import { sendUndoFollow } from '@server/lib/activitypub/send'
4 import { VideoChannelModel } from '@server/models/video/video-channel'
5 import { VideosCommonQuery } from '@shared/models'
6 import { HttpStatusCode } from '../../../../shared/core-utils/miscs/http-error-codes'
7 import { buildNSFWFilter, getCountVideos } from '../../../helpers/express-utils'
8 import { getFormattedObjects } from '../../../helpers/utils'
9 import { WEBSERVER } from '../../../initializers/constants'
10 import { sequelizeTypescript } from '../../../initializers/database'
11 import { JobQueue } from '../../../lib/job-queue'
14 asyncRetryTransactionMiddleware,
16 commonVideosFiltersValidator,
21 userSubscriptionAddValidator,
22 userSubscriptionGetValidator
23 } from '../../../middlewares'
25 areSubscriptionsExistValidator,
26 userSubscriptionListValidator,
27 userSubscriptionsSortValidator,
29 } from '../../../middlewares/validators'
30 import { ActorFollowModel } from '../../../models/activitypub/actor-follow'
31 import { VideoModel } from '../../../models/video/video'
33 const mySubscriptionsRouter = express.Router()
35 mySubscriptionsRouter.get('/me/subscriptions/videos',
41 commonVideosFiltersValidator,
42 asyncMiddleware(getUserSubscriptionVideos)
45 mySubscriptionsRouter.get('/me/subscriptions/exist',
47 areSubscriptionsExistValidator,
48 asyncMiddleware(areSubscriptionsExist)
51 mySubscriptionsRouter.get('/me/subscriptions',
54 userSubscriptionsSortValidator,
57 userSubscriptionListValidator,
58 asyncMiddleware(getUserSubscriptions)
61 mySubscriptionsRouter.post('/me/subscriptions',
63 userSubscriptionAddValidator,
67 mySubscriptionsRouter.get('/me/subscriptions/:uri',
69 userSubscriptionGetValidator,
70 asyncMiddleware(getUserSubscription)
73 mySubscriptionsRouter.delete('/me/subscriptions/:uri',
75 userSubscriptionGetValidator,
76 asyncRetryTransactionMiddleware(deleteUserSubscription)
79 // ---------------------------------------------------------------------------
85 // ---------------------------------------------------------------------------
87 async function areSubscriptionsExist (req: express.Request, res: express.Response) {
88 const uris = req.query.uris as string[]
89 const user = res.locals.oauth.token.User
91 const handles = uris.map(u => {
92 let [ name, host ] = u.split('@')
93 if (host === WEBSERVER.HOST) host = null
95 return { name, host, uri: u }
98 const results = await ActorFollowModel.listSubscribedIn(user.Account.Actor.id, handles)
100 const existObject: { [id: string ]: boolean } = {}
101 for (const handle of handles) {
102 const obj = results.find(r => {
103 const server = r.ActorFollowing.Server
105 return r.ActorFollowing.preferredUsername === handle.name &&
107 (!server && !handle.host) ||
108 (server.host === handle.host)
112 existObject[handle.uri] = obj !== undefined
115 return res.json(existObject)
118 function addUserSubscription (req: express.Request, res: express.Response) {
119 const user = res.locals.oauth.token.User
120 const [ name, host ] = req.body.uri.split('@')
125 assertIsChannel: true,
126 followerActorId: user.Account.Actor.id
129 JobQueue.Instance.createJob({ type: 'activitypub-follow', payload })
131 return res.status(HttpStatusCode.NO_CONTENT_204).end()
134 async function getUserSubscription (req: express.Request, res: express.Response) {
135 const subscription = res.locals.subscription
136 const videoChannel = await VideoChannelModel.loadAndPopulateAccount(subscription.ActorFollowing.VideoChannel.id)
138 return res.json(videoChannel.toFormattedJSON())
141 async function deleteUserSubscription (req: express.Request, res: express.Response) {
142 const subscription = res.locals.subscription
144 await sequelizeTypescript.transaction(async t => {
145 if (subscription.state === 'accepted') await sendUndoFollow(subscription, t)
147 return subscription.destroy({ transaction: t })
150 return res.type('json')
151 .status(HttpStatusCode.NO_CONTENT_204)
155 async function getUserSubscriptions (req: express.Request, res: express.Response) {
156 const user = res.locals.oauth.token.User
157 const actorId = user.Account.Actor.id
159 const resultList = await ActorFollowModel.listSubscriptionsForApi({
161 start: req.query.start,
162 count: req.query.count,
163 sort: req.query.sort,
164 search: req.query.search
167 return res.json(getFormattedObjects(resultList.data, resultList.total))
170 async function getUserSubscriptionVideos (req: express.Request, res: express.Response) {
171 const user = res.locals.oauth.token.User
172 const countVideos = getCountVideos(req)
173 const query = req.query as VideosCommonQuery
175 const resultList = await VideoModel.listForApi({
179 includeLocalVideos: false,
180 categoryOneOf: query.categoryOneOf,
181 licenceOneOf: query.licenceOneOf,
182 languageOneOf: query.languageOneOf,
183 tagsOneOf: query.tagsOneOf,
184 tagsAllOf: query.tagsAllOf,
185 nsfw: buildNSFWFilter(res, query.nsfw),
186 filter: query.filter,
188 followerActorId: user.Account.Actor.id,
193 return res.json(getFormattedObjects(resultList.data, resultList.total))