X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Finitializers%2Fdatabase.ts;h=1f2b6d5211c18b335759536810ac2cf8729a089c;hb=d9a2a03196275065c28f4a0b7d4d7bc9992d77a1;hp=5cf5765f681b09ccb63724bf64e8294c46249157;hpb=4f24f16e27d942b063c945dde55b902572b7dee7;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/initializers/database.ts b/server/initializers/database.ts index 5cf5765f6..1f2b6d521 100644 --- a/server/initializers/database.ts +++ b/server/initializers/database.ts @@ -1,11 +1,13 @@ +import { TrackerModel } from '@server/models/server/tracker' +import { VideoTrackerModel } from '@server/models/server/video-tracker' import { QueryTypes, Transaction } from 'sequelize' import { Sequelize as SequelizeTypescript } from 'sequelize-typescript' -import { AbuseModel } from '@server/models/abuse/abuse' -import { AbuseMessageModel } from '@server/models/abuse/abuse-message' -import { VideoAbuseModel } from '@server/models/abuse/video-abuse' -import { VideoCommentAbuseModel } from '@server/models/abuse/video-comment-abuse' import { isTestInstance } from '../helpers/core-utils' import { logger } from '../helpers/logger' +import { AbuseModel } from '../models/abuse/abuse' +import { AbuseMessageModel } from '../models/abuse/abuse-message' +import { VideoAbuseModel } from '../models/abuse/video-abuse' +import { VideoCommentAbuseModel } from '../models/abuse/video-comment-abuse' import { AccountModel } from '../models/account/account' import { AccountBlocklistModel } from '../models/account/account-blocklist' import { AccountVideoRateModel } from '../models/account/account-video-rate' @@ -34,6 +36,7 @@ import { VideoChannelModel } from '../models/video/video-channel' import { VideoCommentModel } from '../models/video/video-comment' import { VideoFileModel } from '../models/video/video-file' import { VideoImportModel } from '../models/video/video-import' +import { VideoLiveModel } from '../models/video/video-live' import { VideoPlaylistModel } from '../models/video/video-playlist' import { VideoPlaylistElementModel } from '../models/video/video-playlist-element' import { VideoShareModel } from '../models/video/video-share' @@ -48,6 +51,7 @@ const dbname = CONFIG.DATABASE.DBNAME const username = CONFIG.DATABASE.USERNAME const password = CONFIG.DATABASE.PASSWORD const host = CONFIG.DATABASE.HOSTNAME +const ssl = CONFIG.DATABASE.SSL const port = CONFIG.DATABASE.PORT const poolMax = CONFIG.DATABASE.POOL.MAX @@ -58,6 +62,7 @@ const sequelizeTypescript = new SequelizeTypescript({ port, username, password, + ssl, pool: { max: poolMax }, @@ -66,22 +71,24 @@ const sequelizeTypescript = new SequelizeTypescript({ logging: (message: string, benchmark: number) => { if (process.env.NODE_DB_LOG === 'false') return - let newMessage = message + let newMessage = 'Executed SQL request' if (isTestInstance() === true && benchmark !== undefined) { - newMessage += ' | ' + benchmark + 'ms' + newMessage += ' in ' + benchmark + 'ms' } - logger.debug(newMessage) + logger.debug(newMessage, { sql: message }) } }) -sequelizeTypescript.authenticate() - .then(() => logger.debug('Connection to PostgreSQL has been established successfully.')) - .catch(err => { +function checkDatabaseConnectionOrDie () { + sequelizeTypescript.authenticate() + .then(() => logger.debug('Connection to PostgreSQL has been established successfully.')) + .catch(err => { - logger.error('Unable to connect to PostgreSQL database.', { err }) - process.exit(-1) - }) + logger.error('Unable to connect to PostgreSQL database.', { err }) + process.exit(-1) + }) +} async function initDatabaseModels (silent: boolean) { sequelizeTypescript.addModels([ @@ -114,6 +121,7 @@ async function initDatabaseModels (silent: boolean) { VideoViewModel, VideoRedundancyModel, UserVideoHistoryModel, + VideoLiveModel, AccountBlocklistModel, ServerBlocklistModel, UserNotificationModel, @@ -122,6 +130,8 @@ async function initDatabaseModels (silent: boolean) { VideoPlaylistModel, VideoPlaylistElementModel, ThumbnailModel, + TrackerModel, + VideoTrackerModel, PluginModel ]) @@ -138,6 +148,7 @@ async function initDatabaseModels (silent: boolean) { export { initDatabaseModels, + checkDatabaseConnectionOrDie, sequelizeTypescript }