diff options
author | Chocobozzz <florian.bigard@gmail.com> | 2017-11-30 11:31:15 +0100 |
---|---|---|
committer | Chocobozzz <florian.bigard@gmail.com> | 2017-11-30 11:31:15 +0100 |
commit | 25ed141c7c7631ef21d8764c1163fbf8a6591391 (patch) | |
tree | 8f556181a3369e7e4938d612d91be0af813e5067 /server/models/video/video-share.ts | |
parent | 5cd80545422bba855cc9a730a2e13cc9d982c34b (diff) | |
download | PeerTube-25ed141c7c7631ef21d8764c1163fbf8a6591391.tar.gz PeerTube-25ed141c7c7631ef21d8764c1163fbf8a6591391.tar.zst PeerTube-25ed141c7c7631ef21d8764c1163fbf8a6591391.zip |
Put activity pub sends inside transactions
Diffstat (limited to 'server/models/video/video-share.ts')
-rw-r--r-- | server/models/video/video-share.ts | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/server/models/video/video-share.ts b/server/models/video/video-share.ts index fe5d56d42..37e405fa9 100644 --- a/server/models/video/video-share.ts +++ b/server/models/video/video-share.ts | |||
@@ -52,7 +52,7 @@ function associate (models) { | |||
52 | }) | 52 | }) |
53 | } | 53 | } |
54 | 54 | ||
55 | load = function (accountId: number, videoId: number) { | 55 | load = function (accountId: number, videoId: number, t: Sequelize.Transaction) { |
56 | return VideoShare.findOne({ | 56 | return VideoShare.findOne({ |
57 | where: { | 57 | where: { |
58 | accountId, | 58 | accountId, |
@@ -60,11 +60,12 @@ load = function (accountId: number, videoId: number) { | |||
60 | }, | 60 | }, |
61 | include: [ | 61 | include: [ |
62 | VideoShare['sequelize'].models.Account | 62 | VideoShare['sequelize'].models.Account |
63 | ] | 63 | ], |
64 | transaction: t | ||
64 | }) | 65 | }) |
65 | } | 66 | } |
66 | 67 | ||
67 | loadAccountsByShare = function (videoId: number) { | 68 | loadAccountsByShare = function (videoId: number, t: Sequelize.Transaction) { |
68 | const query = { | 69 | const query = { |
69 | where: { | 70 | where: { |
70 | videoId | 71 | videoId |
@@ -74,7 +75,8 @@ loadAccountsByShare = function (videoId: number) { | |||
74 | model: VideoShare['sequelize'].models.Account, | 75 | model: VideoShare['sequelize'].models.Account, |
75 | required: true | 76 | required: true |
76 | } | 77 | } |
77 | ] | 78 | ], |
79 | transaction: t | ||
78 | } | 80 | } |
79 | 81 | ||
80 | return VideoShare.findAll(query) | 82 | return VideoShare.findAll(query) |