config.js

// CONFIGURATION
export const SYNC_FILES_PATH = process.env.DCR_SYNC_FILES_PATH || '/sync/files';
export const DOWNLOAD_FILE_PATH = process.env.DCR_DOWNLOAD_FILE_PATH || '/files/:id/download';
export const SYNC_DATASET_PATH = process.env.DCR_SYNC_DATASET_PATH || '/datasets';
export const START_FROM_DELTA_TIMESTAMP = process.env.DCR_START_FROM_DELTA_TIMESTAMP;
export const DELTA_FILE_FOLDER = process.env.DCR_DELTA_FILE_FOLDER || '/tmp/';
export const KEEP_DELTA_FILES = process.env.DCR_KEEP_DELTA_FILES == 'true';
export const DISABLE_DELTA_INGEST = process.env.DCR_DISABLE_DELTA_INGEST == 'true' ? true : false;
export const DISABLE_INITIAL_SYNC = process.env.DCR_DISABLE_INITIAL_SYNC == 'true' ? true : false;
export const WAIT_FOR_INITIAL_SYNC = process.env.DCR_WAIT_FOR_INITIAL_SYNC == 'false' ? false : true;
export const DUMPFILE_FOLDER = process.env.DCR_DUMPFILE_FOLDER || 'consumer/deltas';
export const CRON_PATTERN_DELTA_SYNC = process.env.DCR_CRON_PATTERN_DELTA_SYNC || '0 * * * * *'; // every minute
export const DELTA_JOBS_RETENTION_PERIOD = parseInt(process.env.DCR_DELTA_JOBS_RETENTION_PERIOD || -1);
export const CRON_PATTERN_DELTA_CLEANUP = process.env.DCR_CRON_PATTERN_DELTA_CLEANUP || '0 0 * * * *'; // every hour
export const BATCH_SIZE = parseInt(process.env.DCR_BATCH_SIZE) || 100;
// GRAPHS
export const JOBS_GRAPH = process.env.JOBS_GRAPH || 'http://mu.semte.ch/graphs/system/jobs';

// DELTA CONTEXT
export const ENABLE_DELTA_CONTEXT = process.env.DCR_ENABLE_DELTA_CONTEXT == 'true' ? true : false;

// LANDING ZONE (used for context and sparql mapping configuration)
export const LANDING_ZONE_GRAPH = process.env.DCR_LANDING_ZONE_GRAPH || `http://mu.semte.ch/graphs/system/landingzone`;
export const LANDING_ZONE_DATABASE = process.env.DCR_LANDING_ZONE_DATABASE || 'database';
export const LANDING_ZONE_DATABASE_ENDPOINT = process.env.DCR_LANDING_ZONE_DATABASE_ENDPOINT || `http://${LANDING_ZONE_DATABASE}:8890/sparql`;

export const MAPPING_QUERY_FOLDER = process.env.DCR_MAPPING_QUERY_FOLDER || '/config/mapping';
export const ENABLE_TRIPLE_REMAPPING = process.env.DCR_ENABLE_TRIPLE_REMAPPING == 'true' ? true : false;
export const ENABLE_CUSTOM_DISPATCH = !ENABLE_TRIPLE_REMAPPING; // disable custom dispatching if triple remapping is enabled
export const REMAPPING_DATABASE = process.env.DCR_REMAPPING_DATABASE || 'database';
export const REMAPPING_DATABASE_ENDPOINT = process.env.DCR_REMAPPING_DATABASE_ENDPOINT || `http://${REMAPPING_DATABASE}:8890/sparql`;
export const REMAPPING_GRAPH = process.env.DCR_REMAPPING_GRAPH || 'http://mu.semte.ch/graphs/consumer-transformed';

export const DIRECT_EXECUTE_EXPENSIVE_QUERIES = process.env.DCR_DIRECT_EXECUTE_EXPENSIVE_QUERIES == 'false' ? false : true; // default true
export const DIRECT_REMAPPING_DATABASE = process.env.DCR_DIRECT_REMAPPING_DATABASE || 'virtuoso';
export const DIRECT_REMAPPING_DATABASE_ENDPOINT = process.env.DCR_DIRECT_REMAPPING_DATABASE_ENDPOINT || `http://${DIRECT_REMAPPING_DATABASE}:8890/sparql`;


// MANDATORY SIMPLE
if (!process.env.DCR_SYNC_BASE_URL)
  throw `Expected 'DCR_SYNC_BASE_URL' to be provided.`;
export const SYNC_BASE_URL = process.env.DCR_SYNC_BASE_URL;

if (!process.env.DCR_SERVICE_NAME)
  throw `Expected 'DCR_SERVICE_NAME' to be provided.`;
export const SERVICE_NAME = process.env.DCR_SERVICE_NAME;

if (!process.env.DCR_JOB_CREATOR_URI)
  throw `Expected 'DCR_JOB_CREATOR_URI' to be provided.`;
export const JOB_CREATOR_URI = process.env.DCR_JOB_CREATOR_URI;

if (!process.env.DCR_DELTA_SYNC_JOB_OPERATION)
  throw `Expected 'DCR_DELTA_SYNC_JOB_OPERATION' to be provided.`;
export const DELTA_SYNC_JOB_OPERATION = process.env.DCR_DELTA_SYNC_JOB_OPERATION;

// MANDATARY CONDITIONAL
if (!process.env.DCR_SYNC_DATASET_SUBJECT && (WAIT_FOR_INITIAL_SYNC || !DISABLE_INITIAL_SYNC))
  throw `Expected 'DCR_SYNC_DATASET_SUBJECT' to be provided by default.`;
export const SYNC_DATASET_SUBJECT = process.env.DCR_SYNC_DATASET_SUBJECT;

if (!process.env.DCR_INITIAL_SYNC_JOB_OPERATION && (WAIT_FOR_INITIAL_SYNC || !DISABLE_INITIAL_SYNC))
  throw `Expected 'DCR_INITIAL_SYNC_JOB_OPERATION' to be provided by default.`;
export const INITIAL_SYNC_JOB_OPERATION = process.env.DCR_INITIAL_SYNC_JOB_OPERATION;

// COMPOSED VARIABLES
export const SYNC_FILES_ENDPOINT = `${SYNC_BASE_URL}${SYNC_FILES_PATH}`;
export const DOWNLOAD_FILE_ENDPOINT = `${SYNC_BASE_URL}${DOWNLOAD_FILE_PATH}`;
export const SYNC_DATASET_ENDPOINT = `${SYNC_BASE_URL}${SYNC_DATASET_PATH}`;

// LOGIN
export const SECRET_KEY = process.env.DCR_SECRET_KEY;
export const SYNC_LOGIN_ENDPOINT = process.env.DCR_SYNC_LOGIN_ENDPOINT;