X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=server%2Fmodels%2Futils.ts;h=60b0906e80964a4d5bf3e128dbd08b0b6289095e;hb=be0f59b4eec3c2c4dcd151e2b174be39dff1568e;hp=49d32c24f95c11c4c9e3bbdba1cef372c68e9e7c;hpb=57c36b277e68b764dd34cb2e449f6e2ca3d1e9b6;p=oweals%2Fpeertube.git diff --git a/server/models/utils.ts b/server/models/utils.ts index 49d32c24f..60b0906e8 100644 --- a/server/models/utils.ts +++ b/server/models/utils.ts @@ -1,20 +1,33 @@ -// Translate for example "-name" to [ [ 'name', 'DESC' ], [ 'id', 'ASC' ] ] import { Sequelize } from 'sequelize-typescript' +type SortType = { sortModel: any, sortValue: string } + +// Translate for example "-name" to [ [ 'name', 'DESC' ], [ 'id', 'ASC' ] ] function getSort (value: string, lastSort: string[] = [ 'id', 'ASC' ]) { - let field: any - let direction: 'ASC' | 'DESC' + let { direction, field } = buildDirectionAndField(value) - if (value.substring(0, 1) === '-') { - direction = 'DESC' - field = value.substring(1) - } else { - direction = 'ASC' - field = value + if (field.toLowerCase() === 'match') { // Search + field = Sequelize.col('similarity') } + return [ [ field, direction ], lastSort ] +} + +function getVideoSort (value: string, lastSort: string[] = [ 'id', 'ASC' ]) { + let { direction, field } = buildDirectionAndField(value) + // Alias - if (field.toLowerCase() === 'bestmatch') field = Sequelize.col('similarity') + if (field.toLowerCase() === 'match') { // Search + field = Sequelize.col('similarity') + } else if (field.toLowerCase() === 'trending') { // Sort by aggregation + return [ + [ Sequelize.fn('COALESCE', Sequelize.fn('SUM', Sequelize.col('VideoViews.views')), '0'), direction ], + + [ Sequelize.col('VideoModel.views'), direction ], + + lastSort + ] + } return [ [ field, direction ], lastSort ] } @@ -51,34 +64,55 @@ function createSimilarityAttribute (col: string, value: string) { ) } -function createSearchTrigramQuery (col: string, value: string) { - return { - [ Sequelize.Op.or ]: [ - // FIXME: use word_similarity instead of just similarity? - Sequelize.where(searchTrigramNormalizeCol(col), ' % ', searchTrigramNormalizeValue(value)), +function buildBlockedAccountSQL (serverAccountId: number, userAccountId?: number) { + const blockerIds = [ serverAccountId ] + if (userAccountId) blockerIds.push(userAccountId) - Sequelize.where(searchTrigramNormalizeCol(col), ' LIKE ', searchTrigramNormalizeValue(`%${value}%`)) - ] - } + const blockerIdsString = blockerIds.join(', ') + + const query = 'SELECT "targetAccountId" AS "id" FROM "accountBlocklist" WHERE "accountId" IN (' + blockerIdsString + ')' + + ' UNION ALL ' + + 'SELECT "account"."id" AS "id" FROM account INNER JOIN "actor" ON account."actorId" = actor.id ' + + 'INNER JOIN "serverBlocklist" ON "actor"."serverId" = "serverBlocklist"."targetServerId" ' + + 'WHERE "serverBlocklist"."accountId" IN (' + blockerIdsString + ')' + + return query } // --------------------------------------------------------------------------- export { + buildBlockedAccountSQL, + SortType, getSort, + getVideoSort, getSortOnModel, createSimilarityAttribute, throwIfNotValid, - buildTrigramSearchIndex, - createSearchTrigramQuery + buildTrigramSearchIndex } // --------------------------------------------------------------------------- function searchTrigramNormalizeValue (value: string) { - return Sequelize.fn('lower', Sequelize.fn('unaccent', value)) + return Sequelize.fn('lower', Sequelize.fn('immutable_unaccent', value)) } function searchTrigramNormalizeCol (col: string) { return Sequelize.fn('lower', Sequelize.fn('immutable_unaccent', Sequelize.col(col))) } + +function buildDirectionAndField (value: string) { + let field: any + let direction: 'ASC' | 'DESC' + + if (value.substring(0, 1) === '-') { + direction = 'DESC' + field = value.substring(1) + } else { + direction = 'ASC' + field = value + } + + return { direction, field } +}