451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
|
char* connstr = getenv("wgsync_conn");
if(connstr == null) _fatal("no connection string supplied");
PGconn* db = PQconnectdb(connstr);
if(PQstatus(db) != CONNECTION_OK)
_fatal(PQerrorMessage(db));
PGresult* q_get_hosts = PQprepare(db, "get_hosts",
"select h.ref, array_remove("
/* "select h.ref, array_remove(array_agg(wgv4::inet) ||" */
"array_agg(wgv6::inet), null)"
"from ns, hostref h "
"where ns.host = h.host and kind = 'pubkey' "
" group by h.host, h.ref;", 0, null);
/*"select ns.wgv4::inet, ns.wgv6::inet, h.ref from ns "
"right join hostref h "
"on h.host = ns.host "
"where h.kind = 'pubkey';"*/
if(!(q_get_hosts && PQresultStatus(q_get_hosts) == PGRES_COMMAND_OK))
_fatal(PQerrorMessage(db));
|
|
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
|
char* connstr = getenv("wgsync_conn");
if(connstr == null) _fatal("no connection string supplied");
PGconn* db = PQconnectdb(connstr);
if(PQstatus(db) != CONNECTION_OK)
_fatal(PQerrorMessage(db));
PGresult* q_get_hosts = PQprepare(db, "get_hosts",
"select h.ref, h.public_key, h.preshared_key, array_remove("
/* "select h.ref, array_remove(array_agg(wgv4::inet) ||" */
"array_agg(wgv6::inet), null)"
"from ns, hostref h "
"where ns.host = h.host and kind in ('pubkey', 'psk') "
" group by h.host, h.ref;", 0, null);
/*"select ns.wgv4::inet, ns.wgv6::inet, h.ref from ns "
"right join hostref h "
"on h.host = ns.host "
"where h.kind = 'pubkey';"*/
if(!(q_get_hosts && PQresultStatus(q_get_hosts) == PGRES_COMMAND_OK))
_fatal(PQerrorMessage(db));
|