const syncer = server({ atoms });

syncer.connect((player, payload) => {
    const newPayload = filterPayload(player, payload);

    warn(datastore.players());
    warn(newPayload);

    routes.sync.send(newPayload).to(player);
});

// syncer.connect((player, payload) => {
//     remotes.sync(player, filterPayload(player, payload));
// });

// remotes.init.connect((player) => {
//     syncer.hydrate(player);
// });

function replication() {
    for (const [_, player] of routes.init.query().server()) {
        syncer.hydrate(player);
    }
}

export = {
    system: replication,
};

const syncer = client({ atoms });

function replication() {
    for (const [_, payload] of routes.sync.query().client()) {
        print(payload);
        syncer.sync(payload);
    }
}

routes.init.send();

// remotes.sync.connect((payload) => {
//     syncer.sync(payload);
// });

// remotes.init();

export = {
    system: replication,
};