import * as Sequelize from 'sequelize'
import { ResultList } from '../../shared/models'
import { VideoCommentThreadTree } from '../../shared/models/videos/video-comment.model'
+import { AccountModel } from '../models/account/account'
import { VideoModel } from '../models/video/video'
import { VideoCommentModel } from '../models/video/video-comment'
import { getVideoCommentActivityPubUrl } from './activitypub'
+import { sendCreateVideoComment } from './activitypub/send'
async function createVideoComment (obj: {
text: string,
- inReplyToCommentId: number,
+ inReplyToComment: VideoCommentModel | null,
video: VideoModel
- accountId: number
+ account: AccountModel
}, t: Sequelize.Transaction) {
- let originCommentId: number = null
+ let originCommentId: number | null = null
+ let inReplyToCommentId: number | null = null
- if (obj.inReplyToCommentId) {
- const repliedComment = await VideoCommentModel.loadById(obj.inReplyToCommentId)
- if (!repliedComment) throw new Error('Unknown replied comment.')
-
- originCommentId = repliedComment.originCommentId || repliedComment.id
+ if (obj.inReplyToComment && obj.inReplyToComment !== null) {
+ originCommentId = obj.inReplyToComment.originCommentId || obj.inReplyToComment.id
+ inReplyToCommentId = obj.inReplyToComment.id
}
const comment = await VideoCommentModel.create({
text: obj.text,
originCommentId,
- inReplyToCommentId: obj.inReplyToCommentId,
+ inReplyToCommentId,
videoId: obj.video.id,
- accountId: obj.accountId,
+ accountId: obj.account.id,
url: 'fake url'
}, { transaction: t, validate: false })
comment.set('url', getVideoCommentActivityPubUrl(obj.video, comment))
- return comment.save({ transaction: t })
+ const savedComment = await comment.save({ transaction: t })
+ savedComment.InReplyToVideoComment = obj.inReplyToComment
+ savedComment.Video = obj.video
+ savedComment.Account = obj.account
+
+ await sendCreateVideoComment(savedComment, t)
+
+ return savedComment
}
function buildFormattedCommentTree (resultList: ResultList<VideoCommentModel>): VideoCommentThreadTree {
}
const parentCommentThread = idx[childComment.inReplyToCommentId]
- if (!parentCommentThread) {
- const msg = `Cannot format video thread tree, parent ${childComment.inReplyToCommentId} not found for child ${childComment.id}`
- throw new Error(msg)
- }
+ // Maybe the parent comment was blocked by the admin/user
+ if (!parentCommentThread) continue
parentCommentThread.children.push(childCommentThread)
idx[childComment.id] = childCommentThread