Sultan
/
Flowise
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Resolved linting error

This commit is contained in:
Atish Amte 2023-07-19 00:03:48 +05:30
parent 318bd516d7
commit 4c4fd6ff67
2 changed files with 19 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
packages/server/src/ChildProcess.ts
View File

@ -142,19 +142,19 @@ export class ChildProcess {
* @returns {DataSource} * @returns {DataSource}
*/ */
async function initDB() { async function initDB() {
let childAppDataSource; let childAppDataSource
let homePath; let homePath
switch (process.env.DATABASE_TYPE) { switch (process.env.DATABASE_TYPE) {
case 'sqlite': case 'sqlite':
homePath = process.env.DATABASE_PATH ?? path.join(getUserHome(), '.flowise') homePath = process.env.DATABASE_PATH ?? path.join(getUserHome(), '.flowise')
childAppDataSource = new DataSource({ childAppDataSource = new DataSource({
type: 'sqlite', type: 'sqlite',
database: path.resolve(homePath, 'database.sqlite'), database: path.resolve(homePath, 'database.sqlite'),
synchronize: (process.env.OVERRIDE_DATABASE == 'true'), synchronize: process.env.OVERRIDE_DATABASE == 'true',
entities: [ChatFlow, ChatMessage, Tool], entities: [ChatFlow, ChatMessage, Tool],
migrations: [] migrations: []
}) })
break; break
case 'mysql': case 'mysql':
childAppDataSource = new DataSource({ childAppDataSource = new DataSource({
type: 'mysql', type: 'mysql',
@ -164,11 +164,11 @@ async function initDB() {
password: process.env.DATABASE_PASSWORD, password: process.env.DATABASE_PASSWORD,
database: process.env.DATABASE_NAME, database: process.env.DATABASE_NAME,
charset: 'utf8mb4', charset: 'utf8mb4',
synchronize: (process.env.OVERRIDE_DATABASE == 'true'), synchronize: process.env.OVERRIDE_DATABASE == 'true',
entities: [ChatFlow, ChatMessage, Tool], entities: [ChatFlow, ChatMessage, Tool],
migrations: [] migrations: []
}) })
break; break
case 'postgres': case 'postgres':
childAppDataSource = new DataSource({ childAppDataSource = new DataSource({
type: 'postgres', type: 'postgres',
@ -177,21 +177,21 @@ async function initDB() {
username: process.env.DATABASE_USER, username: process.env.DATABASE_USER,
password: process.env.DATABASE_PASSWORD, password: process.env.DATABASE_PASSWORD,
database: process.env.DATABASE_NAME, database: process.env.DATABASE_NAME,
synchronize: (process.env.OVERRIDE_DATABASE == 'true'), synchronize: process.env.OVERRIDE_DATABASE == 'true',
entities: [ChatFlow, ChatMessage, Tool], entities: [ChatFlow, ChatMessage, Tool],
migrations: [] migrations: []
}) })
break; break
default: default:
homePath = process.env.DATABASE_PATH ?? path.join(getUserHome(), '.flowise') homePath = process.env.DATABASE_PATH ?? path.join(getUserHome(), '.flowise')
childAppDataSource = new DataSource({ childAppDataSource = new DataSource({
type: 'sqlite', type: 'sqlite',
database: path.resolve(homePath, 'database.sqlite'), database: path.resolve(homePath, 'database.sqlite'),
synchronize: (process.env.OVERRIDE_DATABASE == 'true'), synchronize: process.env.OVERRIDE_DATABASE == 'true',
entities: [ChatFlow, ChatMessage, Tool], entities: [ChatFlow, ChatMessage, Tool],
migrations: [] migrations: []
}) })
break; break
} }
return await childAppDataSource.initialize() return await childAppDataSource.initialize()

18
packages/server/src/DataSource.ts
View File

@ -9,18 +9,18 @@ import { getUserHome } from './utils'
let appDataSource: DataSource let appDataSource: DataSource
export const init = async (): Promise<void> => { export const init = async (): Promise<void> => {
let homePath; let homePath
switch (process.env.DATABASE_TYPE) { switch (process.env.DATABASE_TYPE) {
case 'sqlite': case 'sqlite':
homePath = process.env.DATABASE_PATH ?? path.join(getUserHome(), '.flowise') homePath = process.env.DATABASE_PATH ?? path.join(getUserHome(), '.flowise')
appDataSource = new DataSource({ appDataSource = new DataSource({
type: 'sqlite', type: 'sqlite',
database: path.resolve(homePath, 'database.sqlite'), database: path.resolve(homePath, 'database.sqlite'),
synchronize: (process.env.OVERRIDE_DATABASE == 'true'), synchronize: process.env.OVERRIDE_DATABASE == 'true',
entities: [ChatFlow, ChatMessage, Tool], entities: [ChatFlow, ChatMessage, Tool],
migrations: [] migrations: []
}) })
break; break
case 'mysql': case 'mysql':
appDataSource = new DataSource({ appDataSource = new DataSource({
type: 'mysql', type: 'mysql',
@ -30,11 +30,11 @@ export const init = async (): Promise<void> => {
password: process.env.DATABASE_PASSWORD, password: process.env.DATABASE_PASSWORD,
database: process.env.DATABASE_NAME, database: process.env.DATABASE_NAME,
charset: 'utf8mb4', charset: 'utf8mb4',
synchronize: (process.env.OVERRIDE_DATABASE == 'true'), synchronize: process.env.OVERRIDE_DATABASE == 'true',
entities: [ChatFlow, ChatMessage, Tool], entities: [ChatFlow, ChatMessage, Tool],
migrations: [] migrations: []
}) })
break; break
case 'postgres': case 'postgres':
appDataSource = new DataSource({ appDataSource = new DataSource({
type: 'postgres', type: 'postgres',
@ -43,21 +43,21 @@ export const init = async (): Promise<void> => {
username: process.env.DATABASE_USER, username: process.env.DATABASE_USER,
password: process.env.DATABASE_PASSWORD, password: process.env.DATABASE_PASSWORD,
database: process.env.DATABASE_NAME, database: process.env.DATABASE_NAME,
synchronize: (process.env.OVERRIDE_DATABASE == 'true'), synchronize: process.env.OVERRIDE_DATABASE == 'true',
entities: [ChatFlow, ChatMessage, Tool], entities: [ChatFlow, ChatMessage, Tool],
migrations: [] migrations: []
}) })
break; break
default: default:
homePath = process.env.DATABASE_PATH ?? path.join(getUserHome(), '.flowise') homePath = process.env.DATABASE_PATH ?? path.join(getUserHome(), '.flowise')
appDataSource = new DataSource({ appDataSource = new DataSource({
type: 'sqlite', type: 'sqlite',
database: path.resolve(homePath, 'database.sqlite'), database: path.resolve(homePath, 'database.sqlite'),
synchronize: (process.env.OVERRIDE_DATABASE == 'true'), synchronize: process.env.OVERRIDE_DATABASE == 'true',
entities: [ChatFlow, ChatMessage, Tool], entities: [ChatFlow, ChatMessage, Tool],
migrations: [] migrations: []
}) })
break; break
} }
} }