const path = require('path');
const ros = require('realm-object-server');
const rose = require('realm-object-server-enterprise');
const os = require('os');

process.env.FEATURE_TOKEN = "eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJSZWFsbSIsIkFkYXB0ZXIiOnRydWUsIkJhY2t1cCI6dHJ1ZSwiTm90aWZpZXIiOnRydWUsIlN5bmMiOnRydWUsImlhdCI6MTUwMzQwMDU3OX0.OQETYgZQyqFWlC5_kn5oR573gu9k6hkpl-2VoQ4O9Frkdwr8Lj8b_wzybHMlgMT6iDGTwlFJ7_gUNsUVpI5RQ4iIlCNBU7Teev2WFvMmiztKCc4y519szBEf8vVvKqSh9_Z_S3UR9pugXb8jm8G7tAdQ4_obCuh6XVf1S9MWmCDvTU8y-EYh55Ui4Du9A0abPQKaDAZL-a2iqz6BDw8ZSjJ03wjywKe9KqODOlCtQsQ4OkmAzUGn0UikphzqP1NfU_g5aCBfduqDYApb9FNYH2kBqchKqssOPTpGo-sRzKZB-1TzPhzAPxBeEakmy31zwdrnDVMncFfvosSuTi2XtA";

function getIPv4Address(interfaceName) {
    return os.networkInterfaces()[interfaceName].filter(iface => iface.family === 'IPv4')[0].address;
}

const server = new ros.BasicServer();

const label = process.env.SYNC_LABEL || "default";
const syncId = process.env.SYNC_ID || os.hostname();
const syncPort = process.env.SYNC_PORT || 7800;
const publicKeyPath = path.join(__dirname, 'public.pem');

const discovery = new rose.ConsulDiscovery({
    consulHost: process.env.CONSUL_HOST || "127.0.0.1",
    consulPort: process.env.CONSUL_PORT || "8500"
});

const startConfig = {
    services: [
        new ros.LogService(),
        new rose.ReplicatedSyncService({
            consul: discovery.consul,
            dataPath: path.join(__dirname, 'data'),
            featureToken: process.env.FEATURE_TOKEN,
            id: syncId,
            label: label,
            listenAddress: getIPv4Address('eth0'),
            listenPort: Number(syncPort),
            logLevel: "debug",
            publicKeyPath
        })
    ],
    discovery,
    dataPath: path.join(__dirname, 'data'),
    logLevel: "debug"
};

server.start(startConfig).then(() => {
    console.log(`Your server is started at ${server.address}`);
})
.catch(err => {
    console.error('There was an error starting your server');
    console.error(err);
});