123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633 |
- /* vim: set expandtab ts=4 sw=4: */
- /*
- * You may redistribute this program and/or modify it under the terms of
- * the GNU General Public License as published by the Free Software Foundation,
- * either version 3 of the License, or (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program. If not, see <http://www.gnu.org/licenses/>.
- */
- #include "client/AdminClient.h"
- #include "client/Configurator.h"
- #include "benc/String.h"
- #include "benc/Dict.h"
- #include "benc/Int.h"
- #include "benc/List.h"
- #include "memory/Allocator.h"
- #include "util/events/Event.h"
- #include "util/events/UDPAddrIface.h"
- #include "util/Bits.h"
- #include "util/log/Log.h"
- #include "util/platform/Sockaddr.h"
- #include "util/Defined.h"
- #include "util/events/Timeout.h"
- #include <stdlib.h>
- #include <stdbool.h>
- struct Context
- {
- struct Log* logger;
- struct Allocator* alloc;
- struct AdminClient* client;
- struct Allocator* currentReqAlloc;
- struct AdminClient_Result* currentResult;
- struct EventBase* base;
- };
- static void rpcCallback(struct AdminClient_Promise* p, struct AdminClient_Result* res)
- {
- struct Context* ctx = p->userData;
- Allocator_adopt(ctx->alloc, p->alloc);
- ctx->currentResult = res;
- EventBase_endLoop(ctx->base);
- }
- static void die(struct AdminClient_Result* res, struct Context* ctx, struct Allocator* alloc)
- {
- Log_keys(ctx->logger, "message bytes = [%s]", res->messageBytes);
- #ifndef Log_KEYS
- Log_critical(ctx->logger, "enable Log_LEVEL=KEYS to see message content.");
- #endif
- Dict d = NULL;
- struct AdminClient_Promise* exitPromise =
- AdminClient_rpcCall(String_CONST("Core_exit"), &d, ctx->client, alloc);
- exitPromise->callback = rpcCallback;
- exitPromise->userData = ctx;
- EventBase_beginLoop(ctx->base);
- if (ctx->currentResult->err) {
- Log_critical(ctx->logger, "Failed to stop the core.");
- }
- Log_critical(ctx->logger, "Aborting.");
- exit(1);
- }
- static int rpcCall0(String* function,
- Dict* args,
- struct Context* ctx,
- struct Allocator* alloc,
- Dict** resultP,
- bool exitIfError)
- {
- ctx->currentReqAlloc = Allocator_child(alloc);
- ctx->currentResult = NULL;
- struct AdminClient_Promise* promise = AdminClient_rpcCall(function, args, ctx->client, alloc);
- promise->callback = rpcCallback;
- promise->userData = ctx;
- EventBase_beginLoop(ctx->base);
- struct AdminClient_Result* res = ctx->currentResult;
- Assert_true(res);
- if (res->err) {
- Log_critical(ctx->logger,
- "Failed to make function call [%s], error: [%s]",
- AdminClient_errorString(res->err),
- function->bytes);
- die(res, ctx, alloc);
- }
- String* error = Dict_getString(res->responseDict, String_CONST("error"));
- int ret = 0;
- if (error && !String_equals(error, String_CONST("none"))) {
- if (exitIfError) {
- Log_critical(ctx->logger,
- "Got error [%s] calling [%s]",
- error->bytes,
- function->bytes);
- die(res, ctx, alloc);
- }
- Log_warn(ctx->logger, "Got error [%s] calling [%s], ignoring.",
- error->bytes, function->bytes);
- ret = 1;
- }
- if (resultP) {
- *resultP = res->responseDict;
- } else {
- Allocator_free(ctx->currentReqAlloc);
- }
- ctx->currentReqAlloc = NULL;
- return ret;
- }
- static void rpcCall(String* function, Dict* args, struct Context* ctx, struct Allocator* alloc)
- {
- rpcCall0(function, args, ctx, alloc, NULL, true);
- }
- static void authorizedPasswords(List* list, struct Context* ctx)
- {
- uint32_t count = List_size(list);
- for (uint32_t i = 0; i < count; i++) {
- Dict* d = List_getDict(list, i);
- Log_info(ctx->logger, "Checking authorized password %d.", i);
- if (!d) {
- Log_critical(ctx->logger, "Not a dictionary type %d.", i);
- exit(-1);
- }
- String* passwd = Dict_getString(d, String_CONST("password"));
- if (!passwd) {
- Log_critical(ctx->logger, "Must specify a password %d.", i);
- exit(-1);
- }
- }
- for (uint32_t i = 0; i < count; i++) {
- struct Allocator* child = Allocator_child(ctx->alloc);
- Dict* d = List_getDict(list, i);
- String* passwd = Dict_getString(d, String_CONST("password"));
- String* user = Dict_getString(d, String_CONST("user"));
- if (!user) {
- user = String_printf(child, "password [%d]", i);
- }
- //String* publicKey = Dict_getString(d, String_CONST("publicKey"));
- String* ipv6 = Dict_getString(d, String_CONST("ipv6"));
- Log_info(ctx->logger, "Adding authorized password #[%d] for user [%s].", i, user->bytes);
- Dict *args = Dict_new(child);
- uint32_t i = 1;
- Dict_putInt(args, String_CONST("authType"), i, child);
- Dict_putString(args, String_CONST("password"), passwd, child);
- Dict_putString(args, String_CONST("user"), user, child);
- if (ipv6) {
- Log_info(ctx->logger,
- " This connection password restricted to [%s] only.", ipv6->bytes);
- Dict_putString(args, String_CONST("ipv6"), ipv6, child);
- }
- rpcCall(String_CONST("AuthorizedPasswords_add"), args, ctx, child);
- Allocator_free(child);
- }
- }
- static void udpInterface(Dict* config, struct Context* ctx)
- {
- List* ifaces = Dict_getList(config, String_CONST("UDPInterface"));
- if (!ifaces) {
- ifaces = List_new(ctx->alloc);
- List_addDict(ifaces, Dict_getDict(config, String_CONST("UDPInterface")), ctx->alloc);
- }
- uint32_t count = List_size(ifaces);
- for (uint32_t i = 0; i < count; i++) {
- Dict *udp = List_getDict(ifaces, i);
- if (!udp) {
- continue;
- }
- // Setup the interface.
- String* bindStr = Dict_getString(udp, String_CONST("bind"));
- Dict* d = Dict_new(ctx->alloc);
- if (bindStr) {
- Dict_putString(d, String_CONST("bindAddress"), bindStr, ctx->alloc);
- }
- Dict* resp = NULL;
- rpcCall0(String_CONST("UDPInterface_new"), d, ctx, ctx->alloc, &resp, true);
- int ifNum = *(Dict_getInt(resp, String_CONST("interfaceNumber")));
- // Make the connections.
- Dict* connectTo = Dict_getDict(udp, String_CONST("connectTo"));
- if (connectTo) {
- struct Dict_Entry* entry = *connectTo;
- struct Allocator* perCallAlloc = Allocator_child(ctx->alloc);
- while (entry != NULL) {
- String* key = (String*) entry->key;
- if (entry->val->type != Object_DICT) {
- Log_critical(ctx->logger, "interfaces.UDPInterface.connectTo: entry [%s] "
- "is not a dictionary type.", key->bytes);
- exit(-1);
- }
- Dict* value = entry->val->as.dictionary;
- Log_keys(ctx->logger, "Attempting to connect to node [%s].", key->bytes);
- key = String_clone(key, perCallAlloc);
- char* lastColon = CString_strrchr(key->bytes, ':');
- if (!Sockaddr_parse(key->bytes, NULL)) {
- // it's a sockaddr, fall through
- } else if (lastColon) {
- // try it as a hostname.
- int port = atoi(lastColon+1);
- if (!port) {
- Log_critical(ctx->logger, "Couldn't get port number from [%s]", key->bytes);
- exit(-1);
- }
- *lastColon = '\0';
- struct Sockaddr* adr = Sockaddr_fromName(key->bytes, perCallAlloc);
- if (adr != NULL) {
- Sockaddr_setPort(adr, port);
- key = String_new(Sockaddr_print(adr, perCallAlloc), perCallAlloc);
- } else {
- Log_warn(ctx->logger, "Failed to lookup hostname [%s]", key->bytes);
- entry = entry->next;
- continue;
- }
- }
- Dict_putInt(value, String_CONST("interfaceNumber"), ifNum, perCallAlloc);
- Dict_putString(value, String_CONST("address"), key, perCallAlloc);
- rpcCall(String_CONST("UDPInterface_beginConnection"), value, ctx, perCallAlloc);
- entry = entry->next;
- }
- Allocator_free(perCallAlloc);
- }
- }
- }
- static void tunInterface(Dict* ifaceConf, struct Allocator* tempAlloc, struct Context* ctx)
- {
- String* ifaceType = Dict_getString(ifaceConf, String_CONST("type"));
- if (!String_equals(ifaceType, String_CONST("TUNInterface"))) {
- return;
- }
- // Setup the interface.
- String* device = Dict_getString(ifaceConf, String_CONST("tunDevice"));
- Dict* args = Dict_new(tempAlloc);
- if (device) {
- Dict_putString(args, String_CONST("desiredTunName"), device, tempAlloc);
- }
- rpcCall0(String_CONST("Core_initTunnel"), args, ctx, tempAlloc, NULL, false);
- }
- static void ipTunnel(Dict* ifaceConf, struct Allocator* tempAlloc, struct Context* ctx)
- {
- List* incoming = Dict_getList(ifaceConf, String_CONST("allowedConnections"));
- if (incoming) {
- Dict* d;
- for (int i = 0; (d = List_getDict(incoming, i)) != NULL; i++) {
- String* key = Dict_getString(d, String_CONST("publicKey"));
- String* ip4 = Dict_getString(d, String_CONST("ip4Address"));
- // Note that the prefix length has to be a proper int in the config
- // (not quoted!)
- int64_t* ip4Prefix = Dict_getInt(d, String_CONST("ip4Prefix"));
- String* ip6 = Dict_getString(d, String_CONST("ip6Address"));
- int64_t* ip6Prefix = Dict_getInt(d, String_CONST("ip6Prefix"));
- if (!key) {
- Log_critical(ctx->logger, "In router.ipTunnel.allowedConnections[%d]"
- "'publicKey' required.", i);
- exit(1);
- }
- if (!ip4 && !ip6) {
- Log_critical(ctx->logger, "In router.ipTunnel.allowedConnections[%d]"
- "either 'ip4Address' or 'ip6Address' required.", i);
- exit(1);
- } else if (ip4Prefix && !ip4) {
- Log_critical(ctx->logger, "In router.ipTunnel.allowedConnections[%d]"
- "'ip4Address' required with 'ip4Prefix'.", i);
- exit(1);
- } else if (ip6Prefix && !ip6) {
- Log_critical(ctx->logger, "In router.ipTunnel.allowedConnections[%d]"
- "'ip6Address' required with 'ip6Prefix'.", i);
- exit(1);
- }
- Log_debug(ctx->logger, "Allowing IpTunnel connections from [%s]", key->bytes);
- if (ip4) {
- Log_debug(ctx->logger, "Issue IPv4 address %s", ip4->bytes);
- if (ip4Prefix) {
- Log_debug(ctx->logger, "Issue IPv4 netmask/prefix length /%d",
- (int) *ip4Prefix);
- } else {
- Log_debug(ctx->logger, "Use default netmask/prefix length /0");
- }
- }
- if (ip6) {
- Log_debug(ctx->logger, "Issue IPv6 address [%s]", ip6->bytes);
- if (ip6Prefix) {
- Log_debug(ctx->logger, "Issue IPv6 netmask/prefix length /%d",
- (int) *ip6Prefix);
- } else {
- Log_debug(ctx->logger, "Use default netmask/prefix length /0");
- }
- }
- Dict_putString(d, String_CONST("publicKeyOfAuthorizedNode"), key, tempAlloc);
- rpcCall0(String_CONST("IpTunnel_allowConnection"), d, ctx, tempAlloc, NULL, true);
- }
- }
- List* outgoing = Dict_getList(ifaceConf, String_CONST("outgoingConnections"));
- if (outgoing) {
- String* s;
- for (int i = 0; (s = List_getString(outgoing, i)) != NULL; i++) {
- Log_debug(ctx->logger, "Initiating IpTunnel connection to [%s]", s->bytes);
- Dict requestDict =
- Dict_CONST(String_CONST("publicKeyOfNodeToConnectTo"), String_OBJ(s), NULL);
- rpcCall0(String_CONST("IpTunnel_connectTo"), &requestDict, ctx, tempAlloc, NULL, true);
- }
- }
- }
- static void routerConfig(Dict* routerConf, struct Allocator* tempAlloc, struct Context* ctx)
- {
- tunInterface(Dict_getDict(routerConf, String_CONST("interface")), tempAlloc, ctx);
- ipTunnel(Dict_getDict(routerConf, String_CONST("ipTunnel")), tempAlloc, ctx);
- }
- static void ethInterfaceSetBeacon(int ifNum, Dict* eth, struct Context* ctx)
- {
- int64_t* beaconP = Dict_getInt(eth, String_CONST("beacon"));
- if (beaconP) {
- int64_t beacon = *beaconP;
- if (beacon > 3 || beacon < 0) {
- Log_error(ctx->logger, "interfaces.ETHInterface.beacon may only be 0, 1,or 2");
- } else {
- // We can cast beacon to an int here because we know it's small enough
- Log_info(ctx->logger, "Setting beacon mode on ETHInterface to [%d].", (int) beacon);
- Dict d = Dict_CONST(String_CONST("interfaceNumber"), Int_OBJ(ifNum),
- Dict_CONST(String_CONST("state"), Int_OBJ(beacon), NULL));
- rpcCall(String_CONST("ETHInterface_beacon"), &d, ctx, ctx->alloc);
- }
- }
- }
- static void ethInterface(Dict* config, struct Context* ctx)
- {
- List* ifaces = Dict_getList(config, String_CONST("ETHInterface"));
- if (!ifaces) {
- ifaces = List_new(ctx->alloc);
- List_addDict(ifaces, Dict_getDict(config, String_CONST("ETHInterface")), ctx->alloc);
- }
- uint32_t count = List_size(ifaces);
- for (uint32_t i = 0; i < count; i++) {
- Dict *eth = List_getDict(ifaces, i);
- if (!eth) { continue; }
- String* deviceStr = Dict_getString(eth, String_CONST("bind"));
- if (!deviceStr || !String_equals(String_CONST("all"), deviceStr)) { continue; }
- Log_info(ctx->logger, "Setting up all ETHInterfaces...");
- Dict* res = NULL;
- Dict* d = Dict_new(ctx->alloc);
- if (rpcCall0(String_CONST("ETHInterface_listDevices"), d, ctx, ctx->alloc, &res, false)) {
- Log_info(ctx->logger, "Getting device list failed");
- break;
- }
- List* devs = Dict_getList(res, String_CONST("devices"));
- uint32_t devCount = List_size(devs);
- for (uint32_t j = 0; j < devCount; j++) {
- Dict* d = Dict_new(ctx->alloc);
- String* deviceName = List_getString(devs, j);
- // skip loopback...
- if (String_equals(String_CONST("lo"), deviceName)) { continue; }
- Dict_putString(d, String_CONST("bindDevice"), deviceName, ctx->alloc);
- Dict* resp;
- Log_info(ctx->logger, "Creating new ETHInterface [%s]", deviceName->bytes);
- if (rpcCall0(String_CONST("ETHInterface_new"), d, ctx, ctx->alloc, &resp, false)) {
- Log_warn(ctx->logger, "Failed to create ETHInterface.");
- continue;
- }
- int ifNum = *(Dict_getInt(resp, String_CONST("interfaceNumber")));
- ethInterfaceSetBeacon(ifNum, eth, ctx);
- }
- return;
- }
- for (uint32_t i = 0; i < count; i++) {
- Dict *eth = List_getDict(ifaces, i);
- if (!eth) { continue; }
- // Setup the interface.
- String* deviceStr = Dict_getString(eth, String_CONST("bind"));
- Log_info(ctx->logger, "Setting up ETHInterface [%d].", i);
- Dict* d = Dict_new(ctx->alloc);
- if (deviceStr) {
- Log_info(ctx->logger, "Binding to device [%s].", deviceStr->bytes);
- Dict_putString(d, String_CONST("bindDevice"), deviceStr, ctx->alloc);
- }
- Dict* resp = NULL;
- if (rpcCall0(String_CONST("ETHInterface_new"), d, ctx, ctx->alloc, &resp, false)) {
- Log_warn(ctx->logger, "Failed to create ETHInterface.");
- continue;
- }
- int ifNum = *(Dict_getInt(resp, String_CONST("interfaceNumber")));
- ethInterfaceSetBeacon(ifNum, eth, ctx);
- // Make the connections.
- Dict* connectTo = Dict_getDict(eth, String_CONST("connectTo"));
- if (connectTo) {
- Log_info(ctx->logger, "ETHInterface should connect to a specific node.");
- struct Dict_Entry* entry = *connectTo;
- while (entry != NULL) {
- String* key = (String*) entry->key;
- if (entry->val->type != Object_DICT) {
- Log_critical(ctx->logger, "interfaces.ETHInterface.connectTo: entry [%s] "
- "is not a dictionary type.", key->bytes);
- exit(-1);
- }
- Dict* value = entry->val->as.dictionary;
- Log_keys(ctx->logger, "Attempting to connect to node [%s].", key->bytes);
- struct Allocator* perCallAlloc = Allocator_child(ctx->alloc);
- // Turn the dict from the config into our RPC args dict by filling in all
- // the arguments,
- Dict_putString(value, String_CONST("macAddress"), key, perCallAlloc);
- Dict_putInt(value, String_CONST("interfaceNumber"), ifNum, perCallAlloc);
- rpcCall(String_CONST("ETHInterface_beginConnection"), value, ctx, perCallAlloc);
- Allocator_free(perCallAlloc);
- entry = entry->next;
- }
- }
- }
- }
- static void security(struct Allocator* tempAlloc, List* conf, struct Log* log, struct Context* ctx)
- {
- int seccomp = 1;
- int nofiles = 0;
- int noforks = 1;
- int chroot = 1;
- int setupComplete = 1;
- int setuser = 1;
- int uid = -1;
- int keepNetAdmin = 1;
- do {
- Dict* d = Dict_new(tempAlloc);
- Dict_putString(d, String_CONST("user"), String_CONST("nobody"), tempAlloc);
- Dict* ret = NULL;
- rpcCall0(String_CONST("Security_getUser"), d, ctx, tempAlloc, &ret, true);
- uid = *Dict_getInt(ret, String_CONST("uid"));
- } while (0);
- for (int i = 0; conf && i < List_size(conf); i++) {
- Dict* elem = List_getDict(conf, i);
- String* s;
- if (elem && (s = Dict_getString(elem, String_CONST("setuser")))) {
- if (setuser == 0) { continue; }
- Dict* d = Dict_new(tempAlloc);
- Dict_putString(d, String_CONST("user"), s, tempAlloc);
- Dict* ret = NULL;
- rpcCall0(String_CONST("Security_getUser"), d, ctx, tempAlloc, &ret, true);
- uid = *Dict_getInt(ret, String_CONST("uid"));
- int64_t* nka = Dict_getInt(elem, String_CONST("keepNetAdmin"));
- int64_t* exemptAngel = Dict_getInt(elem, String_CONST("exemptAngel"));
- keepNetAdmin = ((nka) ? *nka : ((exemptAngel) ? *exemptAngel : 0));
- continue;
- }
- if (elem && (s = Dict_getString(elem, String_CONST("chroot")))) {
- Log_debug(log, "Security_chroot(%s)", s->bytes);
- Dict* d = Dict_new(tempAlloc);
- Dict_putString(d, String_CONST("root"), s, tempAlloc);
- rpcCall0(String_CONST("Security_chroot"), d, ctx, tempAlloc, NULL, false);
- chroot = 0;
- continue;
- }
- uint64_t* x;
- if (elem && (x = Dict_getInt(elem, String_CONST("nofiles")))) {
- if (!*x) { continue; }
- nofiles = 1;
- continue;
- }
- if (elem && (x = Dict_getInt(elem, String_CONST("setuser")))) {
- if (!*x) { setuser = 0; }
- continue;
- }
- if (elem && (x = Dict_getInt(elem, String_CONST("seccomp")))) {
- if (!*x) { seccomp = 0; }
- continue;
- }
- if (elem && (x = Dict_getInt(elem, String_CONST("noforks")))) {
- if (!*x) { noforks = 0; }
- continue;
- }
- if (elem && (x = Dict_getInt(elem, String_CONST("chroot")))) {
- if (!*x) { chroot = 0; }
- continue;
- }
- if (elem && (x = Dict_getInt(elem, String_CONST("setupComplete")))) {
- if (!*x) { setupComplete = 0; }
- continue;
- }
- Log_info(ctx->logger, "Unrecognized entry in security at index [%d]", i);
- }
- if (chroot) {
- Log_debug(log, "Security_chroot(/var/run)");
- Dict* d = Dict_new(tempAlloc);
- Dict_putString(d, String_CONST("root"), String_CONST("/var/run/"), tempAlloc);
- rpcCall0(String_CONST("Security_chroot"), d, ctx, tempAlloc, NULL, false);
- }
- if (noforks) {
- Log_debug(log, "Security_noforks()");
- Dict* d = Dict_new(tempAlloc);
- rpcCall(String_CONST("Security_noforks"), d, ctx, tempAlloc);
- }
- if (setuser) {
- Log_debug(log, "Security_setUser(uid:%d, keepNetAdmin:%d)", uid, keepNetAdmin);
- Dict* d = Dict_new(tempAlloc);
- Dict_putInt(d, String_CONST("uid"), uid, tempAlloc);
- Dict_putInt(d, String_CONST("keepNetAdmin"), keepNetAdmin, tempAlloc);
- rpcCall0(String_CONST("Security_setUser"), d, ctx, tempAlloc, NULL, false);
- }
- if (nofiles) {
- Log_debug(log, "Security_nofiles()");
- Dict* d = Dict_new(tempAlloc);
- rpcCall(String_CONST("Security_nofiles"), d, ctx, tempAlloc);
- }
- if (seccomp) {
- Log_debug(log, "Security_seccomp()");
- Dict* d = Dict_new(tempAlloc);
- rpcCall(String_CONST("Security_seccomp"), d, ctx, tempAlloc);
- }
- if (setupComplete) {
- Log_debug(log, "Security_setupComplete()");
- Dict* d = Dict_new(tempAlloc);
- rpcCall(String_CONST("Security_setupComplete"), d, ctx, tempAlloc);
- }
- }
- static int tryPing(struct Allocator* tempAlloc, struct Context* ctx)
- {
- Dict* resp = NULL;
- Dict* d = Dict_new(tempAlloc);
- rpcCall0(String_CONST("ping"), d, ctx, tempAlloc, &resp, false);
- if (!resp) { return -1; }
- String* q = Dict_getString(resp, String_CONST("q"));
- if (String_equals(q, String_CONST("pong"))) {
- return true;
- }
- return false;
- }
- static void awaken(void* vcontext)
- {
- struct Context* ctx = vcontext;
- EventBase_endLoop(ctx->base);
- }
- static void sleep(int milliseconds, struct Context* ctx, struct Allocator* temp)
- {
- Timeout_setTimeout(awaken, ctx, milliseconds, ctx->base, temp);
- EventBase_beginLoop(ctx->base);
- }
- static void waitUntilPong(struct Context* ctx)
- {
- for (int i = 0; i < 10; i++) {
- struct Allocator* temp = Allocator_child(ctx->alloc);
- if (tryPing(temp, ctx)) {
- Allocator_free(temp);
- return;
- }
- sleep(200, ctx, temp);
- Allocator_free(temp);
- }
- Assert_failure("Failed connecting to core (perhaps you have a firewall on loopback device?)");
- }
- void Configurator_config(Dict* config,
- struct Sockaddr* sockAddr,
- String* adminPassword,
- struct EventBase* eventBase,
- struct Log* logger,
- struct Allocator* alloc)
- {
- struct Allocator* tempAlloc = Allocator_child(alloc);
- struct UDPAddrIface* udp = UDPAddrIface_new(eventBase, NULL, alloc, NULL, logger);
- struct AdminClient* client =
- AdminClient_new(&udp->generic, sockAddr, adminPassword, eventBase, logger, tempAlloc);
- struct Context ctx = {
- .logger = logger,
- .alloc = tempAlloc,
- .client = client,
- .base = eventBase,
- };
- waitUntilPong(&ctx);
- List* authedPasswords = Dict_getList(config, String_CONST("authorizedPasswords"));
- if (authedPasswords) {
- authorizedPasswords(authedPasswords, &ctx);
- }
- Dict* ifaces = Dict_getDict(config, String_CONST("interfaces"));
- udpInterface(ifaces, &ctx);
- if (Defined(HAS_ETH_INTERFACE)) {
- ethInterface(ifaces, &ctx);
- }
- Dict* routerConf = Dict_getDict(config, String_CONST("router"));
- routerConfig(routerConf, tempAlloc, &ctx);
- List* secList = Dict_getList(config, String_CONST("security"));
- security(tempAlloc, secList, logger, &ctx);
- Log_debug(logger, "Cjdns started in the background");
- Allocator_free(tempAlloc);
- }
|