]> git.immae.eu Git - github/Chocobozzz/PeerTube.git/blame_incremental - server/models/account/account-video-rate.ts
Put activity pub sends inside transactions
[github/Chocobozzz/PeerTube.git] / server / models / account / account-video-rate.ts
... / ...
CommitLineData
1/*
2 Account rates per video.
3*/
4import { values } from 'lodash'
5import * as Sequelize from 'sequelize'
6
7import { VIDEO_RATE_TYPES } from '../../initializers'
8
9import { addMethodsToModel } from '../utils'
10import {
11 AccountVideoRateInstance,
12 AccountVideoRateAttributes,
13
14 AccountVideoRateMethods
15} from './account-video-rate-interface'
16
17let AccountVideoRate: Sequelize.Model<AccountVideoRateInstance, AccountVideoRateAttributes>
18let load: AccountVideoRateMethods.Load
19
20export default function (sequelize: Sequelize.Sequelize, DataTypes: Sequelize.DataTypes) {
21 AccountVideoRate = sequelize.define<AccountVideoRateInstance, AccountVideoRateAttributes>('AccountVideoRate',
22 {
23 type: {
24 type: DataTypes.ENUM(values(VIDEO_RATE_TYPES)),
25 allowNull: false
26 }
27 },
28 {
29 indexes: [
30 {
31 fields: [ 'videoId', 'accountId' ],
32 unique: true
33 }
34 ]
35 }
36 )
37
38 const classMethods = [
39 associate,
40
41 load
42 ]
43 addMethodsToModel(AccountVideoRate, classMethods)
44
45 return AccountVideoRate
46}
47
48// ------------------------------ STATICS ------------------------------
49
50function associate (models) {
51 AccountVideoRate.belongsTo(models.Video, {
52 foreignKey: {
53 name: 'videoId',
54 allowNull: false
55 },
56 onDelete: 'CASCADE'
57 })
58
59 AccountVideoRate.belongsTo(models.Account, {
60 foreignKey: {
61 name: 'accountId',
62 allowNull: false
63 },
64 onDelete: 'CASCADE'
65 })
66}
67
68load = function (accountId: number, videoId: number, transaction: Sequelize.Transaction) {
69 const options: Sequelize.FindOptions<AccountVideoRateAttributes> = {
70 where: {
71 accountId,
72 videoId
73 }
74 }
75 if (transaction) options.transaction = transaction
76
77 return AccountVideoRate.findOne(options)
78}