-import { Sequelize } from 'sequelize-typescript'
-import * as validator from 'validator'
+import { Model, Sequelize } from 'sequelize-typescript'
+import validator from 'validator'
+import { Col } from 'sequelize/types/lib/utils'
+import { literal, OrderItem, Op } from 'sequelize'
-type SortType = { sortModel: any, sortValue: string }
+type Primitive = string | Function | number | boolean | Symbol | undefined | null
+type DeepOmitHelper<T, K extends keyof T> = {
+ [P in K]: // extra level of indirection needed to trigger homomorhic behavior
+ T[P] extends infer TP // distribute over unions
+ ? TP extends Primitive
+ ? TP // leave primitives and functions alone
+ : TP extends any[]
+ ? DeepOmitArray<TP, K> // Array special handling
+ : DeepOmit<TP, K>
+ : never
+}
+type DeepOmit<T, K> = T extends Primitive ? T : DeepOmitHelper<T, Exclude<keyof T, K>>
+
+type DeepOmitArray<T extends any[], K> = {
+ [P in keyof T]: DeepOmit<T[P], K>
+}
+
+type SortType = { sortModel: string, sortValue: string }
// Translate for example "-name" to [ [ 'name', 'DESC' ], [ 'id', 'ASC' ] ]
-function getSort (value: string, lastSort: string[] = [ 'id', 'ASC' ]) {
- let { direction, field } = buildDirectionAndField(value)
+function getSort (value: string, lastSort: OrderItem = [ 'id', 'ASC' ]): OrderItem[] {
+ const { direction, field } = buildDirectionAndField(value)
+
+ let finalField: string | Col
if (field.toLowerCase() === 'match') { // Search
- field = Sequelize.col('similarity')
+ finalField = Sequelize.col('similarity')
+ } else if (field === 'videoQuotaUsed') { // Users list
+ finalField = Sequelize.col('videoQuotaUsed')
+ } else {
+ finalField = field
}
- return [ [ field, direction ], lastSort ]
+ return [ [ finalField, direction ], lastSort ]
}
-function getVideoSort (value: string, lastSort: string[] = [ 'id', 'ASC' ]) {
- let { direction, field } = buildDirectionAndField(value)
+function getCommentSort (value: string, lastSort: OrderItem = [ 'id', 'ASC' ]): OrderItem[] {
+ const { direction, field } = buildDirectionAndField(value)
- // Alias
- if (field.toLowerCase() === 'match') { // Search
- field = Sequelize.col('similarity')
- } else if (field.toLowerCase() === 'trending') { // Sort by aggregation
+ if (field === 'totalReplies') {
+ return [
+ [ Sequelize.literal('"totalReplies"'), direction ],
+ lastSort
+ ]
+ }
+
+ return getSort(value, lastSort)
+}
+
+function getVideoSort (value: string, lastSort: OrderItem = [ 'id', 'ASC' ]): OrderItem[] {
+ const { direction, field } = buildDirectionAndField(value)
+
+ if (field.toLowerCase() === 'trending') { // Sort by aggregation
return [
[ Sequelize.fn('COALESCE', Sequelize.fn('SUM', Sequelize.col('VideoViews.views')), '0'), direction ],
]
}
- const firstSort = typeof field === 'string' ?
- field.split('.').concat([ direction ]) :
- [ field, direction ]
+ let finalField: string | Col
+
+ // Alias
+ if (field.toLowerCase() === 'match') { // Search
+ finalField = Sequelize.col('similarity')
+ } else {
+ finalField = field
+ }
+
+ const firstSort = typeof finalField === 'string'
+ ? finalField.split('.').concat([ direction ]) as any // FIXME: sequelize typings
+ : [ finalField, direction ]
return [ firstSort, lastSort ]
}
-function getSortOnModel (model: any, value: string, lastSort: string[] = [ 'id', 'ASC' ]) {
- let [ firstSort ] = getSort(value)
+function getBlacklistSort (model: any, value: string, lastSort: OrderItem = [ 'id', 'ASC' ]): OrderItem[] {
+ const [ firstSort ] = getSort(value)
- if (model) return [ [ model, firstSort[0], firstSort[1] ], lastSort ]
+ if (model) return [ [ literal(`"${model}.${firstSort[0]}" ${firstSort[1]}`) ], lastSort ] as any[] // FIXME: typings
return [ firstSort, lastSort ]
}
-function throwIfNotValid (value: any, validator: (value: any) => boolean, fieldName = 'value') {
+function getFollowsSort (value: string, lastSort: OrderItem = [ 'id', 'ASC' ]): OrderItem[] {
+ const { direction, field } = buildDirectionAndField(value)
+
+ if (field === 'redundancyAllowed') {
+ return [
+ [ 'ActorFollowing', 'Server', 'redundancyAllowed', direction ],
+ lastSort
+ ]
+ }
+
+ return getSort(value, lastSort)
+}
+
+function isOutdated (model: { createdAt: Date, updatedAt: Date }, refreshInterval: number) {
+ const now = Date.now()
+ const createdAtTime = model.createdAt.getTime()
+ const updatedAtTime = model.updatedAt.getTime()
+
+ return (now - createdAtTime) > refreshInterval && (now - updatedAtTime) > refreshInterval
+}
+
+function throwIfNotValid (value: any, validator: (value: any) => boolean, fieldName = 'value', nullable = false) {
+ if (nullable && (value === null || value === undefined)) return
+
if (validator(value) === false) {
throw new Error(`"${value}" is not a valid ${fieldName}.`)
}
'SELECT "actor"."serverId" FROM "actorFollow" ' +
'INNER JOIN "actor" ON actor.id = "actorFollow"."targetActorId" ' +
'WHERE "actorFollow"."actorId" = ' + actorIdNumber +
- ')'
+ ')'
}
function buildWhereIdOrUUID (id: number | string) {
return validator.isInt('' + id) ? { id } : { uuid: id }
}
+function parseAggregateResult (result: any) {
+ if (!result) return 0
+
+ const total = parseInt(result + '', 10)
+ if (isNaN(total)) return 0
+
+ return total
+}
+
+const createSafeIn = (model: typeof Model, stringArr: (string | number)[]) => {
+ return stringArr.map(t => {
+ return t === null
+ ? null
+ : model.sequelize.escape('' + t)
+ }).join(', ')
+}
+
+function buildLocalAccountIdsIn () {
+ return literal(
+ '(SELECT "account"."id" FROM "account" INNER JOIN "actor" ON "actor"."id" = "account"."actorId" AND "actor"."serverId" IS NULL)'
+ )
+}
+
+function buildLocalActorIdsIn () {
+ return literal(
+ '(SELECT "actor"."id" FROM "actor" WHERE "actor"."serverId" IS NULL)'
+ )
+}
+
+function buildDirectionAndField (value: string) {
+ let field: string
+ let direction: 'ASC' | 'DESC'
+
+ if (value.substring(0, 1) === '-') {
+ direction = 'DESC'
+ field = value.substring(1)
+ } else {
+ direction = 'ASC'
+ field = value
+ }
+
+ return { direction, field }
+}
+
+function searchAttribute (sourceField, targetField) {
+ if (sourceField) {
+ return {
+ [targetField]: {
+ [Op.iLike]: `%${sourceField}%`
+ }
+ }
+ } else {
+ return {}
+ }
+}
+
+interface QueryStringFilterPrefixes {
+ [key: string]: string | { prefix: string, handler: Function, multiple?: boolean }
+}
+
+function parseQueryStringFilter (q: string, prefixes: QueryStringFilterPrefixes): {
+ search: string
+ [key: string]: string | number | string[] | number[]
+} {
+ const tokens = q // tokenize only if we have a querystring
+ ? [].concat.apply([], q.split('"').map((v, i) => i % 2 ? v : v.split(' '))).filter(Boolean) // split by space unless using double quotes
+ : []
+
+ const objectMap = (obj, fn) => Object.fromEntries(
+ Object.entries(obj).map(
+ ([ k, v ], i) => [ k, fn(v, k, i) ]
+ )
+ )
+
+ return {
+ // search is the querystring minus defined filters
+ search: tokens.filter(e => !Object.values(prefixes).some(p => {
+ if (typeof p === 'string') {
+ return e.startsWith(p)
+ } else {
+ return e.startsWith(p.prefix)
+ }
+ })).join(' '),
+ // filters defined in prefixes are added under their own name
+ ...objectMap(prefixes, p => {
+ if (typeof p === 'string') {
+ return tokens.filter(e => e.startsWith(p)).map(e => e.slice(p.length)) // we keep the matched item, and remove its prefix
+ } else {
+ const _tokens = tokens.filter(e => e.startsWith(p.prefix)).map(e => e.slice(p.prefix.length)).map(p.handler)
+ // multiple is false by default, meaning we usually just keep the first occurence of a given prefix
+ if (!p.multiple && _tokens.length > 0) {
+ return _tokens[0]
+ } else if (!p.multiple) {
+ return ''
+ }
+ return _tokens
+ }
+ })
+ }
+}
+
// ---------------------------------------------------------------------------
export {
+ DeepOmit,
buildBlockedAccountSQL,
+ buildLocalActorIdsIn,
SortType,
+ buildLocalAccountIdsIn,
getSort,
+ getCommentSort,
getVideoSort,
- getSortOnModel,
+ getBlacklistSort,
createSimilarityAttribute,
throwIfNotValid,
buildServerIdsFollowedBy,
buildTrigramSearchIndex,
- buildWhereIdOrUUID
+ buildWhereIdOrUUID,
+ isOutdated,
+ parseAggregateResult,
+ getFollowsSort,
+ buildDirectionAndField,
+ createSafeIn,
+ searchAttribute,
+ parseQueryStringFilter
}
// ---------------------------------------------------------------------------
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 }
-}
projects / github / Chocobozzz / PeerTube.git / blobdiff