forked from DebaucheryLibrarian/traxxx
139 lines
3.3 KiB
JavaScript
139 lines
3.3 KiB
JavaScript
const config = require('config');
|
|
const manticore = require('manticoresearch');
|
|
|
|
const mantiClient = new manticore.ApiClient();
|
|
|
|
mantiClient.basePath = `http://${config.database.manticore.host}:${config.database.manticore.httpPort}`;
|
|
|
|
const utilsApi = new manticore.UtilsApi(mantiClient);
|
|
|
|
const scenesFields = `
|
|
id int,
|
|
title text,
|
|
title_filtered text,
|
|
shoot_id text,
|
|
channel_id int,
|
|
channel_name text,
|
|
channel_slug text,
|
|
network_id int,
|
|
network_name text,
|
|
network_slug text,
|
|
studio_id int,
|
|
studio_name text,
|
|
studio_slug text,
|
|
entity_ids multi,
|
|
actor_ids multi,
|
|
actors text,
|
|
tag_ids multi,
|
|
tags text,
|
|
movie_ids multi,
|
|
movies text,
|
|
serie_ids multi,
|
|
series text,
|
|
meta text,
|
|
date timestamp,
|
|
is_showcased bool,
|
|
created_at timestamp,
|
|
effective_date timestamp,
|
|
stashed int,
|
|
dupe_index int
|
|
`;
|
|
|
|
const moviesFields = `
|
|
id int,
|
|
title text,
|
|
title_filtered text,
|
|
channel_id int,
|
|
channel_name text,
|
|
channel_slug text,
|
|
network_id int,
|
|
network_name text,
|
|
network_slug text,
|
|
entity_ids multi,
|
|
actor_ids multi,
|
|
actors text,
|
|
tag_ids multi,
|
|
tags text,
|
|
meta text,
|
|
date timestamp,
|
|
has_cover bool,
|
|
created_at timestamp,
|
|
effective_date timestamp,
|
|
stashed int,
|
|
stashed_scenes int,
|
|
stashed_total int,
|
|
dupe_index int
|
|
`;
|
|
|
|
const actorsFields = `
|
|
id int,
|
|
name text,
|
|
slug string,
|
|
gender string,
|
|
date_of_birth timestamp,
|
|
country string,
|
|
has_avatar bool,
|
|
mass int,
|
|
height int,
|
|
cup string,
|
|
natural_boobs int,
|
|
penis_length int,
|
|
penis_girth int,
|
|
stashed int,
|
|
scenes int
|
|
`;
|
|
|
|
exports.up = async () => {
|
|
try {
|
|
await utilsApi.sql(`create table if not exists scenes (${scenesFields})`);
|
|
|
|
await utilsApi.sql(`create table if not exists scenes_stashed (
|
|
scene_id int,
|
|
stash_id int,
|
|
user_id int,
|
|
created_at timestamp
|
|
)`);
|
|
|
|
await utilsApi.sql(`create table if not exists movies (${moviesFields})`);
|
|
|
|
await utilsApi.sql(`create table if not exists movies_stashed (
|
|
movie_id int,
|
|
stash_id int,
|
|
user_id int,
|
|
created_at timestamp
|
|
)`);
|
|
|
|
await utilsApi.sql(`create table if not exists actors (${actorsFields}) min_prefix_len='3'`);
|
|
|
|
await utilsApi.sql(`create table if not exists actors_stashed (
|
|
actor_id int,
|
|
stash_id int,
|
|
user_id int,
|
|
created_at timestamp
|
|
)`);
|
|
|
|
/*
|
|
await knex.schema.alterTable('stashes_scenes', (table) => table.increments('id'));
|
|
await knex.schema.alterTable('stashes_movies', (table) => table.increments('id'));
|
|
await knex.schema.alterTable('stashes_actors', (table) => table.increments('id'));
|
|
await knex.schema.alterTable('stashes_series', (table) => table.increments('id'));
|
|
*/
|
|
} catch (error) {
|
|
console.log(error);
|
|
}
|
|
};
|
|
|
|
exports.down = async (knex) => {
|
|
await utilsApi.sql('drop table if exists scenes');
|
|
await utilsApi.sql('drop table if exists scenes_stashed');
|
|
await utilsApi.sql('drop table if exists movies');
|
|
await utilsApi.sql('drop table if exists movies_stashed');
|
|
await utilsApi.sql('drop table if exists actors');
|
|
await utilsApi.sql('drop table if exists actors_stashed');
|
|
|
|
await knex.schema.alterTable('stashes_scenes', (table) => table.dropColumn('id'));
|
|
await knex.schema.alterTable('stashes_movies', (table) => table.dropColumn('id'));
|
|
await knex.schema.alterTable('stashes_actors', (table) => table.dropColumn('id'));
|
|
await knex.schema.alterTable('stashes_series', (table) => table.dropColumn('id'));
|
|
};
|