]>
Commit | Line | Data |
---|---|---|
74d63469 GR |
1 | import * as express from 'express' |
2 | import { logger } from '../../../helpers/logger' | |
80fdaf06 | 3 | import { sequelizeTypescript } from '../../../initializers/database' |
74d63469 GR |
4 | import { |
5 | asyncMiddleware, | |
6 | asyncRetryTransactionMiddleware, | |
7 | authenticate, | |
8 | paginationValidator, | |
9 | setDefaultPagination, | |
10 | videosAcceptChangeOwnershipValidator, | |
11 | videosChangeOwnershipValidator, | |
12 | videosTerminateChangeOwnershipValidator | |
13 | } from '../../../middlewares' | |
74d63469 | 14 | import { VideoChangeOwnershipModel } from '../../../models/video/video-change-ownership' |
22a73cb8 | 15 | import { VideoChangeOwnershipStatus, VideoState } from '../../../../shared/models/videos' |
74d63469 GR |
16 | import { VideoChannelModel } from '../../../models/video/video-channel' |
17 | import { getFormattedObjects } from '../../../helpers/utils' | |
8dc8a34e | 18 | import { changeVideoChannelShare } from '../../../lib/activitypub/share' |
5cf84858 | 19 | import { sendUpdateVideo } from '../../../lib/activitypub/send' |
b876eaf1 | 20 | import { VideoModel } from '../../../models/video/video' |
26d6bf65 | 21 | import { MVideoFullLight } from '@server/types/models' |
2d53be02 | 22 | import { HttpStatusCode } from '../../../../shared/core-utils/miscs/http-error-codes' |
74d63469 GR |
23 | |
24 | const ownershipVideoRouter = express.Router() | |
25 | ||
26 | ownershipVideoRouter.post('/:videoId/give-ownership', | |
27 | authenticate, | |
28 | asyncMiddleware(videosChangeOwnershipValidator), | |
29 | asyncRetryTransactionMiddleware(giveVideoOwnership) | |
30 | ) | |
31 | ||
32 | ownershipVideoRouter.get('/ownership', | |
33 | authenticate, | |
34 | paginationValidator, | |
35 | setDefaultPagination, | |
36 | asyncRetryTransactionMiddleware(listVideoOwnership) | |
37 | ) | |
38 | ||
39 | ownershipVideoRouter.post('/ownership/:id/accept', | |
40 | authenticate, | |
41 | asyncMiddleware(videosTerminateChangeOwnershipValidator), | |
42 | asyncMiddleware(videosAcceptChangeOwnershipValidator), | |
43 | asyncRetryTransactionMiddleware(acceptOwnership) | |
44 | ) | |
45 | ||
46 | ownershipVideoRouter.post('/ownership/:id/refuse', | |
47 | authenticate, | |
48 | asyncMiddleware(videosTerminateChangeOwnershipValidator), | |
49 | asyncRetryTransactionMiddleware(refuseOwnership) | |
50 | ) | |
51 | ||
52 | // --------------------------------------------------------------------------- | |
53 | ||
54 | export { | |
55 | ownershipVideoRouter | |
56 | } | |
57 | ||
58 | // --------------------------------------------------------------------------- | |
59 | ||
60 | async function giveVideoOwnership (req: express.Request, res: express.Response) { | |
453e83ea | 61 | const videoInstance = res.locals.videoAll |
dae86118 C |
62 | const initiatorAccountId = res.locals.oauth.token.User.Account.id |
63 | const nextOwner = res.locals.nextOwner | |
74d63469 | 64 | |
5cf84858 C |
65 | await sequelizeTypescript.transaction(t => { |
66 | return VideoChangeOwnershipModel.findOrCreate({ | |
74d63469 | 67 | where: { |
91411dba | 68 | initiatorAccountId, |
74d63469 GR |
69 | nextOwnerAccountId: nextOwner.id, |
70 | videoId: videoInstance.id, | |
71 | status: VideoChangeOwnershipStatus.WAITING | |
72 | }, | |
73 | defaults: { | |
91411dba | 74 | initiatorAccountId, |
74d63469 GR |
75 | nextOwnerAccountId: nextOwner.id, |
76 | videoId: videoInstance.id, | |
77 | status: VideoChangeOwnershipStatus.WAITING | |
5cf84858 C |
78 | }, |
79 | transaction: t | |
74d63469 | 80 | }) |
74d63469 | 81 | }) |
5cf84858 C |
82 | |
83 | logger.info('Ownership change for video %s created.', videoInstance.name) | |
2d53be02 RK |
84 | return res.type('json') |
85 | .status(HttpStatusCode.NO_CONTENT_204) | |
86 | .end() | |
74d63469 GR |
87 | } |
88 | ||
89 | async function listVideoOwnership (req: express.Request, res: express.Response) { | |
dae86118 | 90 | const currentAccountId = res.locals.oauth.token.User.Account.id |
91411dba | 91 | |
74d63469 | 92 | const resultList = await VideoChangeOwnershipModel.listForApi( |
91411dba | 93 | currentAccountId, |
74d63469 GR |
94 | req.query.start || 0, |
95 | req.query.count || 10, | |
96 | req.query.sort || 'createdAt' | |
97 | ) | |
98 | ||
99 | return res.json(getFormattedObjects(resultList.data, resultList.total)) | |
100 | } | |
101 | ||
102 | async function acceptOwnership (req: express.Request, res: express.Response) { | |
103 | return sequelizeTypescript.transaction(async t => { | |
dae86118 | 104 | const videoChangeOwnership = res.locals.videoChangeOwnership |
dae86118 | 105 | const channel = res.locals.videoChannel |
74d63469 | 106 | |
b876eaf1 C |
107 | // We need more attributes for federation |
108 | const targetVideo = await VideoModel.loadAndPopulateAccountAndServerAndTags(videoChangeOwnership.Video.id) | |
109 | ||
2cb03dc1 | 110 | const oldVideoChannel = await VideoChannelModel.loadAndPopulateAccount(targetVideo.channelId) |
5cf84858 | 111 | |
b876eaf1 C |
112 | targetVideo.channelId = channel.id |
113 | ||
453e83ea | 114 | const targetVideoUpdated = await targetVideo.save({ transaction: t }) as MVideoFullLight |
5cf84858 C |
115 | targetVideoUpdated.VideoChannel = channel |
116 | ||
22a73cb8 | 117 | if (targetVideoUpdated.hasPrivacyForFederation() && targetVideoUpdated.state === VideoState.PUBLISHED) { |
5cf84858 C |
118 | await changeVideoChannelShare(targetVideoUpdated, oldVideoChannel, t) |
119 | await sendUpdateVideo(targetVideoUpdated, t, oldVideoChannel.Account.Actor) | |
120 | } | |
74d63469 | 121 | |
b876eaf1 | 122 | videoChangeOwnership.status = VideoChangeOwnershipStatus.ACCEPTED |
5cf84858 | 123 | await videoChangeOwnership.save({ transaction: t }) |
74d63469 | 124 | |
2d53be02 | 125 | return res.sendStatus(HttpStatusCode.NO_CONTENT_204) |
74d63469 GR |
126 | }) |
127 | } | |
128 | ||
129 | async function refuseOwnership (req: express.Request, res: express.Response) { | |
130 | return sequelizeTypescript.transaction(async t => { | |
dae86118 | 131 | const videoChangeOwnership = res.locals.videoChangeOwnership |
5cf84858 | 132 | |
b876eaf1 | 133 | videoChangeOwnership.status = VideoChangeOwnershipStatus.REFUSED |
5cf84858 C |
134 | await videoChangeOwnership.save({ transaction: t }) |
135 | ||
2d53be02 | 136 | return res.sendStatus(HttpStatusCode.NO_CONTENT_204) |
74d63469 GR |
137 | }) |
138 | } |