X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Finitializers%2Fdatabase.ts;h=633d4f95645eac497265a5ccb32cbd06e8448caf;hb=caf2aaf4f9d38ad441a5562c3b8720f8779d6f78;hp=8f237eb23b48a02a6b290363a2d11c4ebdd52f4b;hpb=e8bafea35bc930cb8ac5b2d521a188642a1adffe;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/initializers/database.ts b/server/initializers/database.ts index 8f237eb23..633d4f956 100644 --- a/server/initializers/database.ts +++ b/server/initializers/database.ts @@ -25,7 +25,7 @@ import { CONFIG } from './config' import { ScheduleVideoUpdateModel } from '../models/video/schedule-video-update' import { VideoCaptionModel } from '../models/video/video-caption' import { VideoImportModel } from '../models/video/video-import' -import { VideoViewModel } from '../models/video/video-views' +import { VideoViewModel } from '../models/video/video-view' import { VideoChangeOwnershipModel } from '../models/video/video-change-ownership' import { VideoRedundancyModel } from '../models/redundancy/video-redundancy' import { UserVideoHistoryModel } from '../models/account/user-video-history' @@ -37,6 +37,8 @@ import { VideoStreamingPlaylistModel } from '../models/video/video-streaming-pla import { VideoPlaylistModel } from '../models/video/video-playlist' import { VideoPlaylistElementModel } from '../models/video/video-playlist-element' import { ThumbnailModel } from '../models/video/thumbnail' +import { PluginModel } from '../models/server/plugin' +import { QueryTypes, Transaction } from 'sequelize' require('pg').defaults.parseInt8 = true // Avoid BIGINT to be converted to string @@ -58,8 +60,7 @@ const sequelizeTypescript = new SequelizeTypescript({ max: poolMax }, benchmark: isTestInstance(), - isolationLevel: SequelizeTypescript.Transaction.ISOLATION_LEVELS.SERIALIZABLE, - operatorsAliases: false, + isolationLevel: Transaction.ISOLATION_LEVELS.SERIALIZABLE, logging: (message: string, benchmark: number) => { if (process.env.NODE_DB_LOG === 'false') return @@ -86,6 +87,7 @@ async function initDatabaseModels (silent: boolean) { AccountVideoRateModel, UserModel, VideoAbuseModel, + VideoModel, VideoChangeOwnershipModel, VideoChannelModel, VideoShareModel, @@ -93,7 +95,6 @@ async function initDatabaseModels (silent: boolean) { VideoCaptionModel, VideoBlacklistModel, VideoTagModel, - VideoModel, VideoCommentModel, ScheduleVideoUpdateModel, VideoImportModel, @@ -107,7 +108,8 @@ async function initDatabaseModels (silent: boolean) { VideoStreamingPlaylistModel, VideoPlaylistModel, VideoPlaylistElementModel, - ThumbnailModel + ThumbnailModel, + PluginModel ]) // Check extensions exist in the database @@ -117,8 +119,6 @@ async function initDatabaseModels (silent: boolean) { await createFunctions() if (!silent) logger.info('Database %s is ready.', dbname) - - return } // --------------------------------------------------------------------------- @@ -140,11 +140,16 @@ async function checkPostgresExtensions () { } async function checkPostgresExtension (extension: string) { - const query = `SELECT true AS enabled FROM pg_available_extensions WHERE name = '${extension}' AND installed_version IS NOT NULL;` - const [ res ] = await sequelizeTypescript.query(query, { raw: true }) + const query = `SELECT 1 FROM pg_available_extensions WHERE name = '${extension}' AND installed_version IS NOT NULL;` + const options = { + type: QueryTypes.SELECT as QueryTypes.SELECT, + raw: true + } + + const res = await sequelizeTypescript.query(query, options) - if (!res || res.length === 0 || res[ 0 ][ 'enabled' ] !== true) { - // Try to create the extension ourself + if (!res || res.length === 0) { + // Try to create the extension ourselves try { await sequelizeTypescript.query(`CREATE EXTENSION ${extension};`, { raw: true }) @@ -156,7 +161,7 @@ async function checkPostgresExtension (extension: string) { } } -async function createFunctions () { +function createFunctions () { const query = `CREATE OR REPLACE FUNCTION immutable_unaccent(text) RETURNS text AS $func$