#!/usr/bin/env node

// Main executable for running the CodeStream API Server

//

// We'll load a bunch of configurations and then use a "generic" API server to do most of the work

'use strict';

// load configurations

const ApiConfig = require(process.env.CSSVC_BACKEND_ROOT + '/api_server/config/config');

const ModuleDirectory = process.env.CSSVC_BACKEND_ROOT + '/api_server/modules';

const SimpleFileLogger = require(process.env.CSSVC_BACKEND_ROOT + '/shared/server_utils/simple_file_logger');

const ClusterWrapper = require(process.env.CSSVC_BACKEND_ROOT + '/shared/server_utils/cluster_wrapper');

const StringifySortReplacer = require(process.env.CSSVC_BACKEND_ROOT + '/shared/server_utils/stringify_sort_replacer');

const ServerClass = require(process.env.CSSVC_BACKEND_ROOT + '/api_server/lib/api_server/api_server');

const getOnPremSupportData = require(process.env.CSSVC_BACKEND_ROOT + '/shared/server_utils/get_onprem_support_data');

const customSchemaMigrationMatrix = require(process.env.CSSVC_BACKEND_ROOT + '/shared/server_utils/custom_schema_migration');

const firstConfigInstallationHook= require(process.env.CSSVC_BACKEND_ROOT + '/shared/server_utils/custom_cfg_initialization');

// establish our data collections

const DataCollections = {

users: require(ModuleDirectory + '/users/user'),

companies: require(ModuleDirectory + '/companies/company'),

teams: require(ModuleDirectory + '/teams/team'),

repos: require(ModuleDirectory + '/repos/repo'),

streams: require(ModuleDirectory + '/streams/stream'),

posts: require(ModuleDirectory + '/posts/post'),

markers: require(ModuleDirectory + '/markers/marker'),

codemarks: require(ModuleDirectory + '/codemarks/codemark'),

reviews: require(ModuleDirectory + '/reviews/review'),

codeErrors: require(ModuleDirectory + '/code_errors/code_error'),

markerLocations: require(ModuleDirectory + '/marker_locations/marker_locations'),

providerPosts: require(ModuleDirectory + '/provider_posts/provider_post'),

codemarkLinks: require(ModuleDirectory + '/codemarks/codemark_link'),

msteams_conversations: require(ModuleDirectory + '/msteams_conversations/msteams_conversation'),

msteams_states: require(ModuleDirectory + '/msteams_states/msteams_state'),

msteams_teams: require(ModuleDirectory + '/msteams_teams/msteams_team'),

reposByCommitHash: require(ModuleDirectory + '/repos/repo_by_commit_hash'),

entities: require(ModuleDirectory + '/entities/entity')

};

// establish our mongo collections, these include our DataCollections, but

// may also include other collections that we speak to directly

// through mongo, we don't abstract them out into DataCollections

const MongoCollections = Object.keys(DataCollections).concat([

'signupTokens',

'versionMatrix',

'migrationVersion',

'test',

'phoneHomeJobs',

'phoneHomeStats',

'gitLensUsers',

'reinviteUsersLastRunAt',

'activeServerAlerts',

'globals',

'newRelicOrgs'

]);

(async function() {

if (ApiConfig.configIsMongo()) {

// set option so structured config will perform a schema version migration if needed upon initial load

ApiConfig.performMigrationUsing(customSchemaMigrationMatrix);

// set option to create a new config using the supplied default in the event no configs exist (empty database)

const initialConfigFile = process.env.CS_API_DEFAULT_CFG_FILE || process.env.CSSVC_BACKEND_ROOT + '/api_server/etc/configs/open-development.json';

console.log(`config initialization will use ${initialConfigFile} if no config is present`);

ApiConfig.loadDefaultConfigIfNoneFrom(initialConfigFile, firstConfigInstallationHook);

}

// changes to Config will be available globally via the /config/writeable.js module

const Config = await ApiConfig.loadPreferredConfig({ wait: true });

// establish our logger

const Logger = new SimpleFileLogger(Config.apiServer.logger);

ApiConfig.logger = Logger;

// onprem support data (service versions, docker registry info, on-prem version)

let onPremSupportData;

if (Config.sharedGeneral.isOnPrem) {

onPremSupportData = await getOnPremSupportData(Logger);

console.info('OnPrem Config:', JSON.stringify(onPremSupportData, StringifySortReplacer, 8));

}

// invoke a node cluster master with our configurations provided

const MyAPICluster = new ClusterWrapper(

ServerClass,

{

config: Config,

logger: Logger, // the logger passed to the constructed API Server

moduleDirectory: ModuleDirectory,

dataCollections: DataCollections,

rawCollections: MongoCollections,

onprem: onPremSupportData,

serviceName: 'codestream-server'

},

{

logger: Logger, // the logger used by ClusterWrapper itself

oneWorker: Config.apiServer.mockMode

}

);

try {

await MyAPICluster.start();

}

catch (error) {

console.error('Failed to start: ', error); // eslint-disable-line no-console

process.exit(1);

}

})();