aboutsummaryrefslogtreecommitdiff
path: root/tools
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2021-01-01 11:30:03 -0800
committerGarrett D'Amore <garrett@damore.org>2021-01-01 12:46:17 -0800
commited542ac45e00c9b2faa0b41f3c00de6e291e5678 (patch)
tree673924ff077d468e6756529c2c204698d3faa47c /tools
parent1413b2421a82cd9b9cde178d44fb60c7893176b0 (diff)
downloadnng-ed542ac45e00c9b2faa0b41f3c00de6e291e5678.tar.gz
nng-ed542ac45e00c9b2faa0b41f3c00de6e291e5678.tar.bz2
nng-ed542ac45e00c9b2faa0b41f3c00de6e291e5678.zip
fixes #1345 Restructure the source tree
This is not quite complete, but it sets the stage for other protocols (such as zmq or mqtt) to be added to the project.
Diffstat (limited to 'tools')
-rw-r--r--tools/nngcat/CMakeLists.txt39
-rw-r--r--tools/nngcat/nngcat.c1217
-rwxr-xr-xtools/nngcat/nngcat_ambiguous_test.sh31
-rwxr-xr-xtools/nngcat/nngcat_async_test.sh32
-rwxr-xr-xtools/nngcat/nngcat_dup_proto_test.sh23
-rwxr-xr-xtools/nngcat/nngcat_help_test.sh32
-rwxr-xr-xtools/nngcat/nngcat_incompat_test.sh73
-rwxr-xr-xtools/nngcat/nngcat_need_proto_test.sh23
-rwxr-xr-xtools/nngcat/nngcat_pubsub_test.sh45
-rwxr-xr-xtools/nngcat/nngcat_recvmaxsz_test.sh46
-rwxr-xr-xtools/nngcat/nngcat_stdin_pipe_test.sh44
-rwxr-xr-xtools/nngcat/nngcat_unlimited_test.sh46
-rw-r--r--tools/pubrefman/README.adoc10
-rw-r--r--tools/pubrefman/go.mod11
-rw-r--r--tools/pubrefman/go.sum277
-rw-r--r--tools/pubrefman/pubrefman.go493
16 files changed, 0 insertions, 2442 deletions
diff --git a/tools/nngcat/CMakeLists.txt b/tools/nngcat/CMakeLists.txt
deleted file mode 100644
index bd7327ac..00000000
--- a/tools/nngcat/CMakeLists.txt
+++ /dev/null
@@ -1,39 +0,0 @@
-#
-# Copyright 2020 Staysail Systems, Inc. <info@staysail.tech>
-# Copyright 2018 Capitar IT Group BV <info@capitar.com>
-#
-# This software is supplied under the terms of the MIT License, a
-# copy of which should be located in the distribution where this
-# file was obtained (LICENSE.txt). A copy of the license may also be
-# found online at https://opensource.org/licenses/MIT.
-#
-
-if (NNG_ENABLE_NNGCAT)
- add_executable(nngcat nngcat.c)
- target_include_directories(nngcat PUBLIC ${PROJECT_SOURCE_DIR}/src)
- target_link_libraries(nngcat nng nng_private)
- install(TARGETS nngcat RUNTIME DESTINATION ${CMAKE_INSTALL_BINDIR}
- COMPONENT Tools)
-
- if (NNG_TESTS AND CMAKE_SYSTEM_NAME MATCHES "Linux")
- include(FindUnixCommands)
- endif ()
- # TODO: This should be refactored to use a test driver.
- # We only run the tests on Linux for now, because the Darwin CI/CD is too brittle.
- if (NNG_TESTS AND BASH AND CMAKE_SYSTEM_NAME MATCHES "Linux")
- macro(add_nngcat_test NAME TIMEOUT)
- add_test(NAME nng.${NAME} COMMAND ${BASH} ${CMAKE_CURRENT_SOURCE_DIR}/${NAME}_test.sh $<TARGET_FILE:nngcat>)
- set_tests_properties(nng.${NAME} PROPERTIES TIMEOUT ${TIMEOUT})
- endmacro()
- add_nngcat_test(nngcat_async 10)
- add_nngcat_test(nngcat_ambiguous 10)
- add_nngcat_test(nngcat_need_proto 10)
- add_nngcat_test(nngcat_dup_proto 10)
- add_nngcat_test(nngcat_help 10)
- add_nngcat_test(nngcat_incompat 10)
- add_nngcat_test(nngcat_pubsub 20)
- add_nngcat_test(nngcat_recvmaxsz 20)
- add_nngcat_test(nngcat_unlimited 20)
- add_nngcat_test(nngcat_stdin_pipe 20)
- endif ()
-endif ()
diff --git a/tools/nngcat/nngcat.c b/tools/nngcat/nngcat.c
deleted file mode 100644
index 9e106069..00000000
--- a/tools/nngcat/nngcat.c
+++ /dev/null
@@ -1,1217 +0,0 @@
-//
-// Copyright 2020 Staysail Systems, Inc. <info@staysail.tech>
-// Copyright 2018 Capitar IT Group BV <info@capitar.com>
-// Copyright 2020 Lager Data, Inc. <support@lagerdata.com>
-//
-// This software is supplied under the terms of the MIT License, a
-// copy of which should be located in the distribution where this
-// file was obtained (LICENSE.txt). A copy of the license may also be
-// found online at https://opensource.org/licenses/MIT.
-//
-
-#include <ctype.h>
-#include <errno.h>
-#include <stdarg.h>
-#include <stdbool.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-
-#include <nng/nng.h>
-#include <nng/protocol/bus0/bus.h>
-#include <nng/protocol/pair0/pair.h>
-#include <nng/protocol/pair1/pair.h>
-#include <nng/protocol/pipeline0/pull.h>
-#include <nng/protocol/pipeline0/push.h>
-#include <nng/protocol/pubsub0/pub.h>
-#include <nng/protocol/pubsub0/sub.h>
-#include <nng/protocol/reqrep0/rep.h>
-#include <nng/protocol/reqrep0/req.h>
-#include <nng/protocol/survey0/respond.h>
-#include <nng/protocol/survey0/survey.h>
-#include <nng/supplemental/tls/tls.h>
-#include <nng/supplemental/util/options.h>
-#include <nng/supplemental/util/platform.h>
-#include <nng/transport/zerotier/zerotier.h>
-
-// Globals. We need this to avoid passing around everything.
-int format = 0;
-int proto = 0;
-int verbose = 0;
-int delay = 0;
-nng_duration interval = NNG_DURATION_INFINITE;
-nng_duration sendtimeo = NNG_DURATION_INFINITE;
-nng_duration recvtimeo = NNG_DURATION_INFINITE;
-void * data = NULL;
-size_t datalen = 0;
-int compat = 0;
-int async = 0;
-int insecure = 0;
-void * cacert = NULL;
-size_t cacertlen = 0;
-void * keyfile = NULL;
-size_t keylen = 0;
-void * certfile = NULL;
-size_t certlen = 0;
-const char * zthome = NULL;
-int count = 0;
-int recvmaxsz = -1;
-
-// Options, must start at 1 because zero is sentinel.
-enum options {
- OPT_HELP = 1,
- OPT_VERBOSE,
- OPT_SILENT,
- OPT_REP0,
- OPT_REQ0,
- OPT_PUSH0,
- OPT_PULL0,
- OPT_PUB0,
- OPT_SUB0,
- OPT_SURVEY0,
- OPT_RESPOND0,
- OPT_PAIR0,
- OPT_PAIR1,
- OPT_PAIR,
- OPT_BUS0,
- OPT_DIAL,
- OPT_LISTEN,
- OPT_DATA,
- OPT_FILE,
- OPT_SUBSCRIBE,
- OPT_INTERVAL,
- OPT_DELAY,
- OPT_COUNT,
- OPT_FORMAT,
- OPT_RAW,
- OPT_ASCII,
- OPT_QUOTED,
- OPT_MSGPACK,
- OPT_HEX,
- OPT_BLANK, // no printing, not an actual option.
- OPT_COMPAT,
- OPT_ASYNC,
- OPT_RCV_TIMEO,
- OPT_SND_TIMEO,
- OPT_SOCK_NAME,
- OPT_LISTEN_IPC,
- OPT_DIAL_IPC,
- OPT_LISTEN_LOCAL,
- OPT_DIAL_LOCAL,
- OPT_INSECURE,
- OPT_CACERT,
- OPT_KEYFILE,
- OPT_CERTFILE,
- OPT_VERSION,
- OPT_RECVMAXSZ,
- OPT_ZTHOME,
-};
-
-static nng_optspec opts[] = {
- { .o_name = "help", .o_short = 'h', .o_val = OPT_HELP },
- { .o_name = "verbose", .o_short = 'v', .o_val = OPT_VERBOSE },
- { .o_name = "silent", .o_short = 'q', .o_val = OPT_SILENT },
- { .o_name = "req0", .o_val = OPT_REQ0 },
- { .o_name = "rep0", .o_val = OPT_REP0 },
- { .o_name = "push0", .o_val = OPT_PUSH0 },
- { .o_name = "pull0", .o_val = OPT_PULL0 },
- { .o_name = "pub0", .o_val = OPT_PUB0 },
- { .o_name = "sub", .o_val = OPT_SUB0 }, // explicit for alias
- { .o_name = "sub0", .o_val = OPT_SUB0 },
- { .o_name = "surveyor0", .o_val = OPT_SURVEY0 },
- { .o_name = "respondent0", .o_val = OPT_RESPOND0 },
- { .o_name = "pair", .o_val = OPT_PAIR },
- { .o_name = "pair0", .o_val = OPT_PAIR0 },
- { .o_name = "pair1", .o_val = OPT_PAIR1 },
- { .o_name = "bus0", .o_val = OPT_BUS0 },
- { .o_name = "dial", .o_val = OPT_DIAL, .o_arg = true },
- { .o_name = "listen", .o_val = OPT_LISTEN, .o_arg = true },
- { .o_name = "data", .o_short = 'D', .o_val = OPT_DATA, .o_arg = true },
- { .o_name = "file", .o_short = 'F', .o_val = OPT_FILE, .o_arg = true },
- { .o_name = "subscribe", .o_val = OPT_SUBSCRIBE, .o_arg = true },
- { .o_name = "format", .o_val = OPT_FORMAT, .o_arg = true },
- { .o_name = "ascii", .o_short = 'A', .o_val = OPT_ASCII },
- { .o_name = "quoted", .o_short = 'Q', .o_val = OPT_QUOTED },
- { .o_name = "raw", .o_val = OPT_RAW },
- { .o_name = "hex", .o_val = OPT_HEX },
- { .o_name = "compat", .o_val = OPT_COMPAT },
- { .o_name = "async", .o_val = OPT_ASYNC },
- { .o_name = "msgpack", .o_val = OPT_MSGPACK },
-
- {
- .o_name = "recv-maxsz",
- .o_short = 'Z',
- .o_val = OPT_RECVMAXSZ,
- .o_arg = true,
- },
- {
- .o_name = "count",
- .o_short = 'C',
- .o_val = OPT_COUNT,
- .o_arg = true,
- },
- {
- .o_name = "delay",
- .o_short = 'd',
- .o_val = OPT_DELAY,
- .o_arg = true,
- },
- {
- .o_name = "interval",
- .o_short = 'i',
- .o_val = OPT_INTERVAL,
- .o_arg = true,
- },
- { .o_name = "recv-timeout", .o_val = OPT_RCV_TIMEO, .o_arg = true },
- { .o_name = "send-timeout", .o_val = OPT_SND_TIMEO, .o_arg = true },
- { .o_name = "socket-name", .o_val = OPT_SOCK_NAME, .o_arg = true },
-
- // Legacy compatibility with nanocat.
- { .o_name = "bind", .o_val = OPT_LISTEN, .o_arg = true },
- { .o_name = "connect", .o_val = OPT_DIAL, .o_arg = true },
- {
- .o_name = "bind-ipc",
- .o_short = 'X',
- .o_val = OPT_LISTEN_IPC,
- .o_arg = true,
- },
- {
- .o_name = "connect-ipc",
- .o_short = 'x',
- .o_val = OPT_DIAL_IPC,
- .o_arg = true,
- },
- {
- .o_name = "bind-local",
- .o_short = 'L',
- .o_val = OPT_LISTEN_LOCAL,
- .o_arg = true,
- },
- {
- .o_name = "connect-local",
- .o_short = 'l',
- .o_val = OPT_DIAL_LOCAL,
- .o_arg = true,
- },
- { .o_name = "insecure", .o_short = 'k', .o_val = OPT_INSECURE },
- { .o_name = "cacert", .o_val = OPT_CACERT, .o_arg = true },
- { .o_name = "key", .o_val = OPT_KEYFILE, .o_arg = true },
- {
- .o_name = "cert",
- .o_short = 'E',
- .o_val = OPT_CERTFILE,
- .o_arg = true,
- },
- {
- .o_name = "zt-home",
- .o_val = OPT_ZTHOME,
- .o_arg = true,
- },
- { .o_name = "version", .o_short = 'V', .o_val = OPT_VERSION },
-
- // Sentinel.
- { .o_name = NULL, .o_val = 0 },
-};
-
-static void
-fatal(const char *msg, ...)
-{
- va_list ap;
- va_start(ap, msg);
- vfprintf(stderr, msg, ap);
- va_end(ap);
- fprintf(stderr, "\n");
- exit(1);
-}
-
-static void
-help(void)
-{
- printf(
- "Usage: nngcat <proto> <addr>... [<fmt>] [<opts>...] [<src>]\n\n");
- printf("<proto> must be one of:\n");
- printf(" --req0 (or alias --req)\n");
- printf(" --rep0 (or alias --rep)\n");
- printf(" --pub0 (or alias --pub)\n");
- printf(" --sub0 (or alias --sub)\n");
- printf(" --push0 (or alias --push)\n");
- printf(" --pull0 (or alias --pull)\n");
- printf(" --surveyor0 (or alias --surveyor)\n");
- printf(" --respondent0 (or alias --respondent)\n");
- printf(" --pair0\n");
- printf(" --pair1\n");
- printf(" --pair (alias for either pair0 or pair1)\n");
- printf("\n<addr> must be one or more of:\n");
- printf(" --dial <url> (or alias --connect <url>)\n");
- printf(" --listen <url> (or alias --bind <url>)\n");
- printf(" --bind-local <port> (or alias -L <port>)\n");
- printf(" --connect-local <port> (or alias -l <port>)\n");
- printf(" --bind-ipc <path> (or alias -X <path>)\n");
- printf(" --connect-ipc <path> (or alias -x <path>)\n");
- printf("\n<fmt> may be one or none of:\n");
- printf(" --format <no|ascii|hex|msgpack|quoted|raw>\n");
- printf(" --ascii (or alias -A)\n");
- printf(" --quoted (or alias -Q)\n");
- printf(" --hex\n");
- printf(" --msgpack\n");
- printf(" --raw\n");
- printf("\n<opts> may be any of:\n");
- printf(" --subscribe <topic> (only with --sub protocol)\n");
- printf(" --silent (or alias -q)\n");
- printf(" --verbose (or alias -v)\n");
- printf(" --count <num> (or alias -C <num>)\n");
- printf(" --delay <secs> (or alias -d <secs>)\n");
- printf(" --interval <secs> (or alias -i <secs>)\n");
- printf(" --recv-timeout <secs>\n");
- printf(" --send-timeout <secs>\n");
- printf(" --recv-maxsz <size> (or alias -Z <size>)\n");
- printf(" --compat\n");
- printf(" --async\n");
- printf(" --insecure (or alias -k)\n");
- printf(" --cacert <file>\n");
- printf(" --cert <file> (or alias -E <file>)\n");
- printf(" --key <file>\n");
- printf(" --zt-home <path>\n");
- printf("\n<src> may be one of:\n");
- printf(" --file <file> (or alias -F <file>). "
- "Use - for standard input.\n");
- printf(" --data <data> (or alias -D <data>)\n");
- exit(1);
-}
-
-static int
-intarg(const char *val, int maxv)
-{
- int v = 0;
-
- if (val[0] == '\0') {
- fatal("Empty integer argument.");
- }
- while (*val != '\0') {
- if (!isdigit(*val)) {
- fatal("Integer argument expected.");
- }
- v *= 10;
- v += ((*val) - '0');
- val++;
- if (v > maxv) {
- fatal("Integer argument too large.");
- }
- }
- if (v < 0) {
- fatal("Integer argument overflow.");
- }
- return (v);
-}
-
-// This reads a file into memory. Care is taken to ensure that
-// the buffer is one byte larger and contains a terminating
-// NUL. (Useful for key files and such.)
-static void
-loadfile(const char *path, void **datap, size_t *lenp)
-{
- FILE * f;
- size_t total_read = 0;
- size_t allocation_size = BUFSIZ;
- char * fdata;
- char * realloc_result;
-
- if (strcmp(path, "-") == 0) {
- f = stdin;
- } else {
- if ((f = fopen(path, "rb")) == NULL) {
- fatal(
- "Cannot open file %s: %s", path, strerror(errno));
- }
- }
-
- if ((fdata = malloc(allocation_size + 1)) == NULL) {
- fatal("Out of memory.");
- }
-
- while (1) {
- total_read += fread(
- fdata + total_read, 1, allocation_size - total_read, f);
- if (ferror(f)) {
- if (errno == EINTR) {
- continue;
- }
- fatal(
- "Read from %s failed: %s", path, strerror(errno));
- }
- if (feof(f)) {
- break;
- }
- if (total_read == allocation_size) {
- if (allocation_size > SIZE_MAX / 2) {
- fatal("Out of memory.");
- }
- allocation_size *= 2;
- if ((realloc_result = realloc(
- fdata, allocation_size + 1)) == NULL) {
- free(fdata);
- fatal("Out of memory.");
- }
- fdata = realloc_result;
- }
- }
- if (f != stdin) {
- fclose(f);
- }
- fdata[total_read] = '\0';
- *datap = fdata;
- *lenp = total_read;
-}
-
-static void
-configtls(nng_tls_config *tls)
-{
- int rv = 0;
- if (insecure) {
- rv = nng_tls_config_auth_mode(tls, NNG_TLS_AUTH_MODE_NONE);
- }
- if ((rv == 0) && (certfile != NULL)) {
- keyfile = keyfile ? keyfile : certfile;
- rv = nng_tls_config_own_cert(tls, certfile, keyfile, NULL);
- }
- if ((rv == 0) && (cacert != NULL)) {
- rv = nng_tls_config_ca_chain(tls, cacert, NULL);
- }
- if (rv != 0) {
- fatal("Unable to configure TLS: %s", nng_strerror(rv));
- }
-}
-
-struct addr {
- struct addr *next;
- int mode;
- char * val;
-};
-
-struct addr **
-addaddr(struct addr **endp, int mode, const char *a)
-{
- struct addr *na;
-
- if (((na = malloc(sizeof(*na))) == NULL) ||
- ((na->val = malloc(strlen(a) + 1)) == NULL)) {
- fatal("Out of memory.");
- }
- na->mode = mode;
- memcpy(na->val, a, strlen(a) + 1);
- na->next = NULL;
- *endp = na;
- return (&na->next);
-}
-
-struct topic {
- struct topic *next;
- char * val;
-};
-
-struct topic **
-addtopic(struct topic **endp, const char *s)
-{
- struct topic *t;
-
- if (((t = malloc(sizeof(*t))) == NULL) ||
- ((t->val = malloc(strlen(s) + 1)) == NULL)) {
- fatal("Out of memory.");
- }
- memcpy(t->val, s, strlen(s) + 1);
- t->next = NULL;
- *endp = t;
- return (&t->next);
-}
-
-void
-printmsg(char *buf, size_t len)
-{
- switch (format) {
- case OPT_BLANK: // Suppress contents.
- return;
- case OPT_RAW: // Just emit raw contents.
- fwrite(buf, 1, len, stdout);
- break;
- case OPT_ASCII: // ASCII, but non-ASCII substituted with '.'
- for (size_t i = 0; i < len; i++) {
- if (isprint(buf[i])) {
- putchar(buf[i]);
- } else {
- putchar('.');
- }
- }
- break;
- case OPT_QUOTED: // C style quoted strings.
- putchar('"');
- for (size_t i = 0; i < len; i++) {
- switch (buf[i]) {
- case '\n':
- putchar('\\');
- putchar('n');
- break;
- case '\r':
- putchar('\\');
- putchar('r');
- break;
- case '\t':
- putchar('\\');
- putchar('t');
- break;
- case '"':
- case '\\':
- putchar('\\');
- putchar(buf[i]);
- break;
- default:
- if (isprint(buf[i])) {
- fputc(buf[i], stdout);
- } else {
- printf("\\x%02x", (uint8_t) buf[i]);
- }
- }
- }
- putchar('"');
- putchar('\n');
- break;
- case OPT_MSGPACK: // MsgPack, we just encode prefix + len, then
- // raw.
- if (len < 256) {
- putchar('\xc4');
- putchar(len & 0xff);
- } else if (len < 65536) {
- putchar('\xc5');
- putchar((len >> 8) & 0xff);
- putchar(len & 0xff);
- } else {
- putchar('\xc6');
- putchar((len >> 24) & 0xff);
- putchar((len >> 16) & 0xff);
- putchar((len >> 8) & 0xff);
- putchar(len & 0xff);
- }
- fwrite(buf, 1, len, stdout);
- break;
- case OPT_HEX: // Hex, quoted C string encoded with hex
- // literals.
- putchar('"');
- for (size_t i = 0; i < len; i++) {
- printf("\\x%02x", (uint8_t) buf[i]);
- }
- putchar('"');
- putchar('\n');
- break;
- }
- fflush(stdout);
-}
-
-void
-recvloop(nng_socket sock)
-{
- int iters = 0;
- for (;;) {
- int rv;
- nng_msg *msg;
-
- if ((count > 0) && (iters >= count)) {
- break;
- }
- rv = nng_recvmsg(sock, &msg, 0);
- iters++;
- switch (rv) {
- case NNG_ETIMEDOUT:
- case NNG_ESTATE:
- // Either a regular timeout, or we reached the
- // end of an event like a survey completing.
- return;
- case 0:
- printmsg(nng_msg_body(msg), nng_msg_len(msg));
- nng_msg_free(msg);
- continue;
- default:
- fatal("Receive error: %s", nng_strerror(rv));
- }
- }
-}
-
-void
-resploop(nng_socket sock)
-{
- int iters = 0;
- for (;;) {
- int rv;
- nng_msg *msg;
-
- rv = nng_recvmsg(sock, &msg, 0);
- if (rv != 0) {
- fatal("Receive error: %s", nng_strerror(rv));
- }
- printmsg(nng_msg_body(msg), nng_msg_len(msg));
- nng_msg_clear(msg);
- if ((rv = nng_msg_append(msg, data, datalen)) != 0) {
- fatal(nng_strerror(rv));
- }
- if ((rv = nng_sendmsg(sock, msg, 0)) != 0) {
- fatal("Send error: %s", nng_strerror(rv));
- }
-
- iters++;
- if ((count > 0) && (iters >= count)) {
- break;
- }
- }
-
- nng_msleep(200);
-}
-
-void
-sendloop(nng_socket sock)
-{
- int iters = 0;
-
- if (data == NULL) {
- fatal("No data to send (specify with --data or --file)");
- }
- if (delay > 0) {
- nng_msleep(delay);
- }
-
- for (;;) {
- int rv;
- nng_msg * msg;
- nng_time start;
- nng_time end;
- nng_duration delta;
-
- start = nng_clock();
- if (((rv = nng_msg_alloc(&msg, 0)) != 0) ||
- ((rv = nng_msg_append(msg, data, datalen)) != 0)) {
- fatal(nng_strerror(rv));
- }
- if ((rv = nng_sendmsg(sock, msg, 0)) != 0) {
- fatal("Send error: %s", nng_strerror(rv));
- }
- end = nng_clock();
- delta = (nng_duration)(end - start);
-
- iters++;
- // By default, we don't loop.
- if (((interval < 0) && (count == 0)) ||
- ((count > 0) && (iters >= count))) {
- break;
- }
-
- // We sleep, but we account for time spent, so that our
- // interval appears more or less constant. Of course
- // if we took more than the interval here, then we skip
- // the sleep altogether.
- if ((delta >= 0) && (delta < interval)) {
- nng_msleep(interval - delta);
- }
- }
- // Wait a bit to give queues a chance to drain.
- nng_msleep(200);
-}
-
-void
-sendrecv(nng_socket sock)
-{
- int iters = 0;
-
- if (data == NULL) {
- fatal("No data to send (specify with --data or --file)");
- }
- if (delay > 0) {
- nng_msleep(delay);
- }
-
- // We start by sending a message, then we receive iteratively
- // but we set a concrete timeout if interval is set, to ensure
- // that we exit the receive loop, and can continue.
- for (;;) {
- int rv;
- nng_msg * msg;
- nng_time start;
- nng_time end;
- nng_duration delta;
-
- start = nng_clock();
- if (((rv = nng_msg_alloc(&msg, 0)) != 0) ||
- ((rv = nng_msg_append(msg, data, datalen)) != 0)) {
- fatal(nng_strerror(rv));
- }
- if ((rv = nng_sendmsg(sock, msg, 0)) != 0) {
- fatal("Send error: %s", nng_strerror(rv));
- }
- if ((interval < 0) && (count == 0)) {
- // Only one iteration through.
- recvloop(sock);
- break;
- }
-
- // We would like to use recvloop, but we need to reset
- // our timeout each time, as the timer counts down
- // towards zero. Furthermore, with survey, we don't
- // want to increment the iteration count.
-
- for (;;) {
- delta = (nng_duration)(nng_clock() - start);
-
- nng_duration expire = interval - delta;
- if ((recvtimeo >= 0) && (expire > recvtimeo)) {
- expire = recvtimeo;
- }
- rv =
- nng_socket_set_ms(sock, NNG_OPT_RECVTIMEO, expire);
- if (rv != 0) {
- fatal("Cannot set recv timeout: %s",
- nng_strerror(rv));
- }
-
- rv = nng_recvmsg(sock, &msg, 0);
- switch (rv) {
- case 0:
- printmsg(nng_msg_body(msg), nng_msg_len(msg));
- nng_msg_free(msg);
- continue;
- case NNG_ETIMEDOUT:
- case NNG_ESTATE:
- // We're done receiving
- break;
- default:
- fatal("Cannot receive: %s", nng_strerror(rv));
- break;
- }
-
- // We're done receiving, break out.
- break;
- }
-
- end = nng_clock();
- delta = (nng_duration)(end - start);
-
- iters++;
- if ((count > 0) && (iters >= count)) {
- break;
- }
-
- // We sleep, but we account for time spent, so that our
- // interval appears more or less constant. Of course
- // if we took more than the interval here, then we skip
- // the sleep altogether.
- if ((delta >= 0) && (delta < interval)) {
- nng_msleep(interval - delta);
- }
- }
-}
-
-int
-main(int ac, char **av)
-{
- int idx;
- char * arg;
- int val;
- int rv;
- char scratch[512];
- struct addr * addrs = NULL;
- struct addr ** addrend;
- struct topic * topics = NULL;
- struct topic **topicend;
- nng_socket sock;
- int port;
-
- idx = 1;
- addrend = &addrs;
- topicend = &topics;
-
- while ((rv = nng_opts_parse(ac, av, opts, &val, &arg, &idx)) == 0) {
- switch (val) {
- case OPT_HELP:
- help();
- break;
- case OPT_REQ0:
- case OPT_REP0:
- case OPT_SUB0:
- case OPT_PUB0:
- case OPT_BUS0:
- case OPT_SURVEY0:
- case OPT_RESPOND0:
- case OPT_PAIR0:
- case OPT_PAIR1:
- case OPT_PUSH0:
- case OPT_PULL0:
- if (proto != 0) {
- fatal("Only one protocol may be "
- "specified.");
- }
- proto = val;
- break;
- case OPT_DIAL:
- case OPT_LISTEN:
- addrend = addaddr(addrend, val, arg);
- break;
- case OPT_DIAL_LOCAL:
- case OPT_LISTEN_LOCAL:
- port = intarg(arg, 65536);
- snprintf(scratch, sizeof(scratch),
- "tcp://127.0.0.1:%d", port);
- addrend = addaddr(addrend, val, scratch);
- break;
- case OPT_DIAL_IPC:
- case OPT_LISTEN_IPC:
- snprintf(scratch, sizeof(scratch), "ipc:///%s", arg);
- addrend = addaddr(addrend, val, scratch);
- break;
- case OPT_COUNT:
- count = intarg(arg, 0x7fffffff);
- break;
- case OPT_SUBSCRIBE:
- topicend = addtopic(topicend, arg);
- break;
- case OPT_VERBOSE:
- case OPT_SILENT:
- verbose = val;
- break;
- case OPT_DELAY:
- delay = intarg(arg, 86400) * 1000; // max 1 day
- break;
- case OPT_INTERVAL:
- interval = intarg(arg, 86400) * 1000; // max 1 day
- break;
- case OPT_SND_TIMEO:
- sendtimeo = intarg(arg, 86400) * 1000; // max 1 day
- break;
- case OPT_RCV_TIMEO:
- recvtimeo = intarg(arg, 86400) * 1000; // max 1 day
- break;
- case OPT_RECVMAXSZ:
- recvmaxsz = intarg(arg, 0x7fffffff);
- if (recvmaxsz == 0) {
- recvmaxsz = 0x7fffffff;
- }
- break;
- case OPT_COMPAT:
- compat = 1;
- break;
- case OPT_ASYNC:
- async = NNG_FLAG_NONBLOCK;
- break;
- case OPT_ASCII:
- case OPT_RAW:
- case OPT_QUOTED:
- case OPT_MSGPACK:
- case OPT_HEX:
- if (format != 0) {
- fatal("Format may be specified only "
- "once.");
- }
- format = val;
- break;
- case OPT_FORMAT:
- if (format != 0) {
- fatal("Format may be specified only "
- "once.");
- }
- if (strcmp(arg, "no") == 0) {
- format = OPT_BLANK;
- } else if (strcmp(arg, "ascii") == 0) {
- format = OPT_ASCII;
- } else if (strcmp(arg, "hex") == 0) {
- format = OPT_HEX;
- } else if (strcmp(arg, "quoted") == 0) {
- format = OPT_QUOTED;
- } else if (strcmp(arg, "raw") == 0) {
- format = OPT_RAW;
- } else if (strcmp(arg, "msgpack") == 0) {
- format = OPT_MSGPACK;
- } else {
- fatal("Invalid format specified.");
- }
- break;
- case OPT_FILE:
- if (data != NULL) {
- fatal("Data (--file, --data) may be "
- "specified "
- "only once.");
- }
- loadfile(arg, &data, &datalen);
- break;
- case OPT_DATA:
- if (data != NULL) {
- fatal("Data (--file, --data) may be "
- "specified "
- "only once.");
- }
- if ((data = malloc(strlen(arg) + 1)) == NULL) {
- fatal("Out of memory.");
- }
- memcpy(data, arg, strlen(arg) + 1);
- datalen = strlen(arg);
- break;
- case OPT_CACERT:
- if (cacert != NULL) {
- fatal("CA Certificate (--cacert) may be "
- "specified only once.");
- }
- loadfile(arg, &cacert, &cacertlen);
- break;
- case OPT_KEYFILE:
- if (keyfile != NULL) {
- fatal(
- "Key (--key) may be specified only once.");
- }
- loadfile(arg, &keyfile, &keylen);
- break;
- case OPT_CERTFILE:
- if (certfile != NULL) {
- fatal("Cert (--cert) may be specified "
- "only "
- "once.");
- }
- loadfile(arg, &certfile, &certlen);
- break;
- case OPT_ZTHOME:
- zthome = arg;
- break;
- case OPT_INSECURE:
- insecure = 1;
- break;
- case OPT_VERSION:
- printf("%s\n", nng_version());
- exit(0);
- }
- }
- switch (rv) {
- case NNG_EINVAL:
- fatal("Option %s is invalid.", av[idx]);
- break;
- case NNG_EAMBIGUOUS:
- fatal("Option %s is ambiguous (specify in full).", av[idx]);
- break;
- case NNG_ENOARG:
- fatal("Option %s requires argument.", av[idx]);
- break;
- default:
- break;
- }
-
- if (addrs == NULL) {
- fatal("No address specified.");
- }
-
- if (compat) {
- if (async != 0) {
- fatal("Options --async and --compat are "
- "incompatible.");
- }
- if (count != 0) {
- fatal("Options --count and --compat are "
- "incompatible.");
- }
- if (proto == OPT_PAIR) {
- proto = OPT_PAIR0;
- }
- if (proto == OPT_PAIR1) {
- fatal("Protocol does not support --compat.");
- }
- async = NNG_FLAG_NONBLOCK;
- } else {
- if (proto == OPT_PAIR) {
- proto = OPT_PAIR1;
- }
- }
- if (proto == OPT_SUB0) {
- if (topics == NULL) {
- (void) addtopic(topicend, ""); // subscribe to all
- }
- } else {
- if (topics != NULL) {
- fatal("Protocol does not support --subscribe.");
- }
- }
-
- switch (proto) {
- case OPT_PULL0:
- case OPT_SUB0:
- if (data != NULL) {
- fatal("Protocol does not support --file or "
- "--data.");
- }
- if (interval >= 0) {
- fatal("Protocol does not support --interval.");
- }
- break;
- case OPT_PUSH0:
- case OPT_PUB0:
- if (format != 0) {
- fatal("Protocol does not support --format "
- "options.");
- }
- if (data == NULL) {
- fatal("Protocol requires either --file or "
- "--data.");
- }
- break;
- case OPT_SURVEY0:
- case OPT_REQ0:
- if (data == NULL) {
- fatal("Protocol requires either --file or "
- "--data.");
- }
- break;
- case OPT_REP0:
- case OPT_RESPOND0:
- if (interval >= 0) {
- fatal("Protocol does not support --interval.");
- }
- break;
- case OPT_PAIR0:
- case OPT_PAIR1:
- case OPT_BUS0:
- if ((interval >= 0) && (data == NULL)) {
- fatal("Option --interval requires either "
- "--file or --data.");
- }
- break;
- default:
- // Will be caught in next switch statement.
- break;
- }
-
- switch (proto) {
- case OPT_REQ0:
-#ifdef NNG_HAVE_REQ0
- rv = nng_req0_open(&sock);
-#else
- fatal("Protocol not supported.");
-#endif
- break;
- case OPT_REP0:
-#ifdef NNG_HAVE_REP0
- rv = nng_rep0_open(&sock);
-#else
- fatal("Protocol not supported.");
-#endif
- break;
- case OPT_SUB0:
-#ifdef NNG_HAVE_SUB0
- rv = nng_sub0_open(&sock);
-#else
- fatal("Protocol not supported.");
-#endif
- break;
- case OPT_PUB0:
-#ifdef NNG_HAVE_PUB0
- rv = nng_pub0_open(&sock);
-#else
- fatal("Protocol not supported.");
-#endif
- break;
- case OPT_PAIR0:
-#ifdef NNG_HAVE_PAIR0
- rv = nng_pair0_open(&sock);
-#else
- fatal("Protocol not supported.");
-#endif
- break;
- case OPT_PAIR1:
-#ifdef NNG_HAVE_PAIR1
- rv = nng_pair1_open(&sock);
-#else
- fatal("Protocol not supported");
-#endif
- break;
- case OPT_BUS0:
-#ifdef NNG_HAVE_BUS0
- rv = nng_bus0_open(&sock);
-#else
- fatal("Protocol not supported.");
-#endif
- break;
- case OPT_PUSH0:
-#ifdef NNG_HAVE_PUSH0
- rv = nng_push0_open(&sock);
-#else
- fatal("Protocol not supported.");
-#endif
- break;
- case OPT_PULL0:
-#ifdef NNG_HAVE_PULL0
- rv = nng_pull0_open(&sock);
-#else
- fatal("Protocol not supported.");
-#endif
- break;
- case OPT_SURVEY0:
-#ifdef NNG_HAVE_SURVEYOR0
- rv = nng_surveyor0_open(&sock);
-#else
- fatal("Protocol not supported.");
-#endif
- break;
- case OPT_RESPOND0:
-#ifdef NNG_HAVE_RESPONDENT0
- rv = nng_respondent0_open(&sock);
-#else
- fatal("Protocol not supported");
-#endif
- break;
- case 0:
- default:
- fatal("No protocol specified.");
- break;
- }
- if (rv != 0) {
- fatal("Unable to open socket: %s", nng_strerror(rv));
- }
-
- for (struct topic *t = topics; t != NULL; t = t->next) {
- rv = nng_socket_set(
- sock, NNG_OPT_SUB_SUBSCRIBE, t->val, strlen(t->val));
- if (rv != 0) {
- fatal("Unable to subscribe to topic %s: %s", t->val,
- nng_strerror(rv));
- }
- }
-
- if ((sendtimeo > 0) &&
- ((rv = nng_socket_set_ms(sock, NNG_OPT_SENDTIMEO, sendtimeo)) !=
- 0)) {
- fatal("Unable to set send timeout: %s", nng_strerror(rv));
- }
- if ((recvtimeo > 0) &&
- ((rv = nng_socket_set_ms(sock, NNG_OPT_RECVTIMEO, recvtimeo)) !=
- 0)) {
- fatal("Unable to set send timeout: %s", nng_strerror(rv));
- }
-
- if ((recvmaxsz >= 0) &&
- ((rv = nng_socket_set_size(sock, NNG_OPT_RECVMAXSZ, recvmaxsz)) !=
- 0)) {
- fatal("Unable to set max receive size: %s", nng_strerror(rv));
- }
-
- for (struct addr *a = addrs; a != NULL; a = a->next) {
- char * act;
- nng_listener l;
- nng_dialer d;
- nng_tls_config *tls;
- switch (a->mode) {
- case OPT_DIAL:
- case OPT_DIAL_IPC:
- case OPT_DIAL_LOCAL:
- rv = nng_dialer_create(&d, sock, a->val);
- if (rv != 0) {
- fatal("Unable to create dialer for %s: %s",
- a->val, nng_strerror(rv));
- }
- rv = nng_dialer_getopt_ptr(
- d, NNG_OPT_TLS_CONFIG, (void **) &tls);
- if (rv == 0) {
- configtls(tls);
- } else if (rv != NNG_ENOTSUP) {
- fatal("Unable to get TLS config: %s",
- nng_strerror(rv));
- }
- if (zthome != NULL) {
- rv = nng_dialer_set(d, NNG_OPT_ZT_HOME,
- zthome, strlen(zthome) + 1);
- if ((rv != 0) && (rv != NNG_ENOTSUP)) {
- fatal("Unable to set ZT home: %s",
- nng_strerror(rv));
- }
- }
- rv = nng_dialer_start(d, async);
- act = "dial";
- if ((rv == 0) && (verbose == OPT_VERBOSE)) {
- char ustr[256];
- size_t sz;
- sz = sizeof(ustr);
- if (nng_dialer_getopt(
- d, NNG_OPT_URL, ustr, &sz) == 0) {
- printf("Connected to: %s\n", ustr);
- }
- }
- break;
- case OPT_LISTEN:
- case OPT_LISTEN_IPC:
- case OPT_LISTEN_LOCAL:
- rv = nng_listener_create(&l, sock, a->val);
- if (rv != 0) {
- fatal("Unable to create listener for %s: %s",
- a->val, nng_strerror(rv));
- }
- rv = nng_listener_getopt_ptr(
- l, NNG_OPT_TLS_CONFIG, (void **) &tls);
- if (rv == 0) {
- configtls(tls);
- } else if (rv != NNG_ENOTSUP) {
- fatal("Unable to get TLS config: %s",
- nng_strerror(rv));
- }
- if (zthome != NULL) {
- rv = nng_listener_set(l, NNG_OPT_ZT_HOME,
- zthome, strlen(zthome) + 1);
- if ((rv != 0) && (rv != NNG_ENOTSUP)) {
- fatal("Unable to set ZT home: %s",
- nng_strerror(rv));
- }
- }
- rv = nng_listener_start(l, async);
- act = "listen";
- if ((rv == 0) && (verbose == OPT_VERBOSE)) {
- char ustr[256];
- size_t sz;
- sz = sizeof(ustr);
- if (nng_listener_getopt(
- l, NNG_OPT_URL, ustr, &sz) == 0) {
- printf("Listening at: %s\n", ustr);
- }
- }
- break;
- default:
- fatal("Invalid address mode! (Bug!)");
- }
-
- if (rv != 0) {
- fatal("Unable to %s on %s: %s", act, a->val,
- nng_strerror(rv));
- }
- }
-
- switch (proto) {
- case OPT_SUB0:
- case OPT_PULL0:
- recvloop(sock);
- break;
- case OPT_REP0:
- case OPT_RESPOND0:
- if (data == NULL) {
- recvloop(sock);
- } else {
- resploop(sock);
- }
- break;
- case OPT_PUSH0:
- case OPT_PUB0:
- sendloop(sock);
- break;
- case OPT_BUS0:
- case OPT_PAIR0:
- case OPT_PAIR1:
- if (data != NULL) {
- sendrecv(sock);
- } else {
- recvloop(sock);
- }
- break;
- case OPT_REQ0:
- case OPT_SURVEY0:
- sendrecv(sock);
- break;
- default:
- fatal("Protocol handling unimplemented.");
- }
-
- exit(0);
-}
diff --git a/tools/nngcat/nngcat_ambiguous_test.sh b/tools/nngcat/nngcat_ambiguous_test.sh
deleted file mode 100755
index 414b6d19..00000000
--- a/tools/nngcat/nngcat_ambiguous_test.sh
+++ /dev/null
@@ -1,31 +0,0 @@
-#!/bin/bash
-
-#
-# Copyright 2018 Staysail Systems, Inc. <info@staysail.tech>
-# Copyright 2018 Capitar IT Group BV <info@capitar.com>
-#
-# This software is supplied under the terms of the MIT License, a
-# copy of which should be located in the distribution where this
-# file was obtained (LICENSE.txt). A copy of the license may also be
-# found online at https://opensource.org/licenses/MIT.
-#
-
-NNGCAT=${NNGCAT:=$1}
-NNGCAT=${NNGCAT:-./nngcat}
-CMD="${NNGCAT} --re --dial=tcp://127.0.0.1:27272"
-
-echo -n "Verify ambiguous options fail: "
-if ${CMD} >/dev/null 2>&1
-then
- echo "Failed: ambigous accepted"
- exit 1
-fi
-x=$(${CMD} 2>&1)
-if [[ ${x} =~ "ambiguous" ]]
-then
- echo "pass"
- exit 0
-fi
-
-echo "Failed: error did not match"
-exit 1
diff --git a/tools/nngcat/nngcat_async_test.sh b/tools/nngcat/nngcat_async_test.sh
deleted file mode 100755
index 2b03e522..00000000
--- a/tools/nngcat/nngcat_async_test.sh
+++ /dev/null
@@ -1,32 +0,0 @@
-#!/bin/bash
-
-#
-# Copyright 2018 Staysail Systems, Inc. <info@staysail.tech>
-# Copyright 2018 Capitar IT Group BV <info@capitar.com>
-#
-# This software is supplied under the terms of the MIT License, a
-# copy of which should be located in the distribution where this
-# file was obtained (LICENSE.txt). A copy of the license may also be
-# found online at https://opensource.org/licenses/MIT.
-#
-
-NNGCAT=${NNGCAT:=$1}
-NNGCAT=${NNGCAT:-./nngcat}
-ADDR="ipc:///tmp/nngcat_async_test"
-
-echo -n "Verify async connect: "
-
-${NNGCAT} --async -d 1 --connect ${ADDR} --req0 -D "ping" &
-
-
-answer=$( ${NNGCAT} --rep0 --recv-timeout=3 --listen ${ADDR} -D "pong" --ascii 2>/dev/null )
-
-if [[ ${answer} == "ping" ]]
-then
- echo "pass"
- exit 0
-fi
-
-echo "Failed: req did not match"
-echo "RES: $answer"
-exit 1
diff --git a/tools/nngcat/nngcat_dup_proto_test.sh b/tools/nngcat/nngcat_dup_proto_test.sh
deleted file mode 100755
index 1513d01c..00000000
--- a/tools/nngcat/nngcat_dup_proto_test.sh
+++ /dev/null
@@ -1,23 +0,0 @@
-#!/bin/bash
-
-#
-# Copyright 2018 Staysail Systems, Inc. <info@staysail.tech>
-# Copyright 2018 Capitar IT Group BV <info@capitar.com>
-#
-# This software is supplied under the terms of the MIT License, a
-# copy of which should be located in the distribution where this
-# file was obtained (LICENSE.txt). A copy of the license may also be
-# found online at https://opensource.org/licenses/MIT.
-#
-
-NNGCAT=${NNGCAT:=$1}
-NNGCAT=${NNGCAT:-./nngcat}
-
-echo -n "Verify only a single protocol is allowed: "
-if ${NNGCAT} --pub0 --sub0 --dial=tcp://127.0.0.1:8989 >/dev/null 2>&1
-then
- echo "Failed: duplicate protocols accepted"
- exit 1
-fi
-echo "pass"
-exit 0
diff --git a/tools/nngcat/nngcat_help_test.sh b/tools/nngcat/nngcat_help_test.sh
deleted file mode 100755
index 95ed9e3e..00000000
--- a/tools/nngcat/nngcat_help_test.sh
+++ /dev/null
@@ -1,32 +0,0 @@
-#!/bin/bash
-
-#
-# Copyright 2018 Staysail Systems, Inc. <info@staysail.tech>
-# Copyright 2018 Capitar IT Group BV <info@capitar.com>
-#
-# This software is supplied under the terms of the MIT License, a
-# copy of which should be located in the distribution where this
-# file was obtained (LICENSE.txt). A copy of the license may also be
-# found online at https://opensource.org/licenses/MIT.
-#
-
-NNGCAT=${NNGCAT:=$1}
-NNGCAT=${NNGCAT:-./nngcat}
-
-echo -n "Verify nngcat help: "
-if ${NNGCAT} --help >/dev/null 2>&1
-then
- echo "Failed: help didn't return 1"
- exit 1
-fi
-x=$(${NNGCAT} --help 2>&1)
-if [[ ${x} =~ "Usage:" ]]
-then
- echo "pass"
- exit 0
-fi
-
-echo "Failed: usage did not match"
-echo "Output:"
-echo "$x"
-exit 1
diff --git a/tools/nngcat/nngcat_incompat_test.sh b/tools/nngcat/nngcat_incompat_test.sh
deleted file mode 100755
index 128b57ba..00000000
--- a/tools/nngcat/nngcat_incompat_test.sh
+++ /dev/null
@@ -1,73 +0,0 @@
-#!/bin/sh
-
-#
-# Copyright 2018 Staysail Systems, Inc. <info@staysail.tech>
-# Copyright 2018 Capitar IT Group BV <info@capitar.com>
-#
-# This software is supplied under the terms of the MIT License, a
-# copy of which should be located in the distribution where this
-# file was obtained (LICENSE.txt). A copy of the license may also be
-# found online at https://opensource.org/licenses/MIT.
-#
-
-NNGCAT=${NNGCAT:=$1}
-NNGCAT=${NNGCAT:-./nngcat}
-
-echo "Verify incompatible options: "
-
-# Just bind something to this so other ones connect
-${NNGCAT} --pull0 --ascii -X /tmp/bogusipc &
-pid=$!
-
-trap "kill $pid && wait $pid 2>/dev/null" 0
-
-echo -n " --subscribe doesn't work with non-sub"
-if ${NNGCAT} --req0 -x /tmp/bogusipc --subscribe=oops >/dev/null 2>&1
-then
- echo "fail"
- exit 1
-fi
-echo "pass"
-
-echo -n " --interval doesn't work with recv only: "
-if ${NNGCAT} --interval 1 --pull -x /tmp/bogusipc >/dev/null 2>&1
-then
- echo "fail"
- exit 1
-fi
-echo "pass"
-
-echo -n " --pair1 doesn't work with --compat: "
-if ${NNGCAT} --compat --pair1 -x /tmp/bogusipc >/dev/null 2>&1
-then
- echo "fail"
- exit 1
-fi
-echo "pass"
-
-echo -n " --count doesn't work with --compat: "
-if ${NNGCAT} --compat --count=1 --pair0 -x /tmp/bogusipc >/dev/null 2>&1
-then
- echo "fail"
- exit 1
-fi
-echo "pass"
-
-echo -n " --count fails with non-integer: "
-if ${NNGCAT} --count=xyz --pair0 -x /tmp/bogusipc >/dev/null 2>&1
-then
- echo "fail"
- exit 1
-fi
-echo "pass"
-
-echo -n " --file fails with non-existing file: "
-if ${NNGCAT} --async --file=/nosuchfilehere --push0 -x /tmp/bogusipc >/dev/null 2>&1
-then
- echo "fail"
- exit 1
-fi
-echo "pass"
-
-echo "PASS."
-exit 0
diff --git a/tools/nngcat/nngcat_need_proto_test.sh b/tools/nngcat/nngcat_need_proto_test.sh
deleted file mode 100755
index d6733cad..00000000
--- a/tools/nngcat/nngcat_need_proto_test.sh
+++ /dev/null
@@ -1,23 +0,0 @@
-#!/bin/sh
-
-#
-# Copyright 2018 Staysail Systems, Inc. <info@staysail.tech>
-# Copyright 2018 Capitar IT Group BV <info@capitar.com>
-#
-# This software is supplied under the terms of the MIT License, a
-# copy of which should be located in the distribution where this
-# file was obtained (LICENSE.txt). A copy of the license may also be
-# found online at https://opensource.org/licenses/MIT.
-#
-
-NNGCAT=${NNGCAT:=$1}
-NNGCAT=${NNGCAT:-./nngcat}
-
-echo -n "Verify a protocol is needed: "
-if ${NNGCAT} --dial=tcp://127.0.0.1:8989 >/dev/null 2>&1
-then
- echo "Failed: protocol should be required"
- exit 1
-fi
-echo "pass"
-exit 0
diff --git a/tools/nngcat/nngcat_pubsub_test.sh b/tools/nngcat/nngcat_pubsub_test.sh
deleted file mode 100755
index b9ba90ed..00000000
--- a/tools/nngcat/nngcat_pubsub_test.sh
+++ /dev/null
@@ -1,45 +0,0 @@
-#!/bin/bash
-
-#
-# Copyright 2018 Staysail Systems, Inc. <info@staysail.tech>
-# Copyright 2018 Capitar IT Group BV <info@capitar.com>
-#
-# This software is supplied under the terms of the MIT License, a
-# copy of which should be located in the distribution where this
-# file was obtained (LICENSE.txt). A copy of the license may also be
-# found online at https://opensource.org/licenses/MIT.
-#
-
-NNGCAT=${NNGCAT:=$1}
-NNGCAT=${NNGCAT:-./nngcat}
-ADDR="ipc:///tmp/nngcat_pub_sub_test"
-OUTPUT=/tmp/nngcat_pubsub_test.$$.out
-
-echo -n "Verify pub sub: "
-
-trap "rm $OUTPUT" 0
-
-${NNGCAT} --listen ${ADDR} --count=3 --recv-timeout=20 --sub0 --subscribe=one --subscribe=two --quoted > $OUTPUT 2>/dev/null &
-sleep 1
-# for speed of execution, run these in the background, they should be ignored
-${NNGCAT} -d 1 --connect ${ADDR} --pub0 --data "xyz" &
-${NNGCAT} -d 1 --connect ${ADDR} --pub0 -D "none swam" &
-# these we care about, due to ordering (checksum) so run them serially
-${NNGCAT} -d 1 --connect ${ADDR} --pub0 -D "one flew"
-${NNGCAT} -d 1 --connect ${ADDR} --pub0 --data "twofer test"
-${NNGCAT} -d 1 --connect ${ADDR} --pub0 --data "one more"
-
-wait $bgid 2>/dev/null
-
-sum=$(cksum ${OUTPUT})
-sum=${sum%% *}
-if [[ ${sum} == 3929078614 ]]
-then
- echo "pass"
- exit 0
-fi
-echo "FAIL: Checksum failed (Wanted 3929078614 got ${sum})"
-echo "OUTPUT:"
-cat ${OUTPUT}
-
-exit 1
diff --git a/tools/nngcat/nngcat_recvmaxsz_test.sh b/tools/nngcat/nngcat_recvmaxsz_test.sh
deleted file mode 100755
index b5d4ff4a..00000000
--- a/tools/nngcat/nngcat_recvmaxsz_test.sh
+++ /dev/null
@@ -1,46 +0,0 @@
-#!/bin/bash
-
-#
-# Copyright 2018 Staysail Systems, Inc. <info@staysail.tech>
-# Copyright 2018 Capitar IT Group BV <info@capitar.com>
-#
-# This software is supplied under the terms of the MIT License, a
-# copy of which should be located in the distribution where this
-# file was obtained (LICENSE.txt). A copy of the license may also be
-# found online at https://opensource.org/licenses/MIT.
-#
-
-NNGCAT=${NNGCAT:=$1}
-NNGCAT=${NNGCAT:-./nngcat}
-ADDR="ipc:///tmp/nngcat_recvmaxsz_test"
-OUTPUT=/tmp/nngcat_recvmaxsz_test.$$.out
-
-echo -n "Verify maximum receive size: "
-
-trap "rm $OUTPUT" 0
-
-${NNGCAT} --listen ${ADDR} --count=3 --recv-maxsz=5 --pull0 --quoted > $OUTPUT 2>/dev/null &
-sleep 1
-# for speed of execution, run these in the background, they should be ignored
-${NNGCAT} --connect ${ADDR} --push0 --data "one"
-${NNGCAT} --connect ${ADDR} --push0 --data "55555"
-${NNGCAT} --connect ${ADDR} --push0 --data "666666"
-${NNGCAT} --connect ${ADDR} --push0 --data "7777777"
-${NNGCAT} --connect ${ADDR} --push0 --data "88888"
-
-wait $bgid 2>/dev/null
-
-sum=$(cksum ${OUTPUT})
-sum=${sum%% *}
-
-# This matches 3 lines of "one", "55555", "88888".
-if [[ ${sum} == 4122906158 ]]
-then
- echo "pass"
- exit 0
-fi
-echo "FAIL: Checksum failed (Wanted 3929078614 got ${sum})"
-echo "OUTPUT:"
-cat ${OUTPUT}
-
-exit 1
diff --git a/tools/nngcat/nngcat_stdin_pipe_test.sh b/tools/nngcat/nngcat_stdin_pipe_test.sh
deleted file mode 100755
index 5fec0ab7..00000000
--- a/tools/nngcat/nngcat_stdin_pipe_test.sh
+++ /dev/null
@@ -1,44 +0,0 @@
-#!/bin/bash
-
-#
-# Copyright 2018 Staysail Systems, Inc. <info@staysail.tech>
-# Copyright 2018 Capitar IT Group BV <info@capitar.com>
-# Copyright 2020 Lager Data, Inc. <support@lagerdata.com>
-#
-# This software is supplied under the terms of the MIT License, a
-# copy of which should be located in the distribution where this
-# file was obtained (LICENSE.txt). A copy of the license may also be
-# found online at https://opensource.org/licenses/MIT.
-#
-
-NNGCAT=${NNGCAT:=$1}
-NNGCAT=${NNGCAT:-./nngcat}
-ADDR="ipc:///tmp/nngcat_stdin_pipe_test"
-OUTPUT=/tmp/nngcat_stdin_pipe_test.$$.out
-
-echo -n "Verify reading from stdin pipe: "
-
-trap "rm $OUTPUT" 0
-
-${NNGCAT} --listen ${ADDR} --count=1 --recv-timeout=3 --recv-maxsz=0 --pull0 --raw > $OUTPUT 2>/dev/null &
-bgid=$!
-
-sleep 1
-# for speed of execution, run these in the background, they should be ignored
-echo "hello world" | ${NNGCAT} --connect ${ADDR} --delay=1 --push0 --file -
-wait "$bgid" 2>/dev/null
-
-sum=$(cksum ${OUTPUT})
-sum=${sum%% *}
-
-# This matches "hello world\n" since echo adds a trailing newline
-if [[ ${sum} == 3733384285 ]]
-then
- echo "pass"
- exit 0
-fi
-echo "FAIL: Checksum failed (Wanted 3733384285 got ${sum})"
-echo "OUTPUT:"
-ls -la ${OUTPUT}
-
-exit 1
diff --git a/tools/nngcat/nngcat_unlimited_test.sh b/tools/nngcat/nngcat_unlimited_test.sh
deleted file mode 100755
index 0486b9b1..00000000
--- a/tools/nngcat/nngcat_unlimited_test.sh
+++ /dev/null
@@ -1,46 +0,0 @@
-#!/bin/bash
-
-#
-# Copyright 2018 Staysail Systems, Inc. <info@staysail.tech>
-# Copyright 2018 Capitar IT Group BV <info@capitar.com>
-#
-# This software is supplied under the terms of the MIT License, a
-# copy of which should be located in the distribution where this
-# file was obtained (LICENSE.txt). A copy of the license may also be
-# found online at https://opensource.org/licenses/MIT.
-#
-
-NNGCAT=${NNGCAT:=$1}
-NNGCAT=${NNGCAT:-./nngcat}
-ADDR="ipc:///tmp/nngcat_unlimited_test"
-INPUT=/tmp/nngcat_unlimited_test.$$.in
-OUTPUT=/tmp/nngcat_unlimited_test.$$.out
-
-echo -n "Verify unlimited receive size: "
-
-trap "rm $OUTPUT $INPUT" 0
-
-# 4 MB
-dd if=/dev/urandom of=${INPUT} bs=1024 count=4096 >/dev/null 2>&1
-goodsum=$(cksum ${INPUT})
-goodsum=${goodsum%% *}
-
-${NNGCAT} --listen ${ADDR} --count=1 --recv-maxsz=0 --pull0 --raw > $OUTPUT 2>/dev/null &
-sleep 1
-# for speed of execution, run these in the background, they should be ignored
-${NNGCAT} --connect ${ADDR} --delay=1 --push0 --file ${INPUT}
-wait $bgid 2>/dev/null
-
-sum=$(cksum ${OUTPUT})
-sum=${sum%% *}
-
-if [[ ${sum} == ${goodsum} ]]
-then
- echo "pass"
- exit 0
-fi
-echo "FAIL: Checksum failed (Wanted ${goodsum} got ${sum})"
-echo "OUTPUT:"
-ls -la ${OUTPUT}
-
-exit 1
diff --git a/tools/pubrefman/README.adoc b/tools/pubrefman/README.adoc
deleted file mode 100644
index a8929df9..00000000
--- a/tools/pubrefman/README.adoc
+++ /dev/null
@@ -1,10 +0,0 @@
-= pubrefman
-
-This directory contains a tool to publish (update) the reference manual
-on the NNG documentation site.
-
-Run it with --help for options. You can build it with Go.
-
-It normally uploads to github, and will require a working SSH agent.
-
-If you're not a project maintainer, you probably don't need this tool.
diff --git a/tools/pubrefman/go.mod b/tools/pubrefman/go.mod
deleted file mode 100644
index b181f172..00000000
--- a/tools/pubrefman/go.mod
+++ /dev/null
@@ -1,11 +0,0 @@
-module go.nanomsg.org/nng/pubrefman
-
-go 1.14
-
-require (
- github.com/bytesparadise/libasciidoc v0.3.1-0.20200802124845-5dcda3220c31
- github.com/go-git/go-billy/v5 v5.0.0
- github.com/go-git/go-git/v5 v5.1.0
- github.com/google/uuid v1.1.1
- github.com/spf13/jwalterweatherman v1.0.0
-)
diff --git a/tools/pubrefman/go.sum b/tools/pubrefman/go.sum
deleted file mode 100644
index 3d9237e3..00000000
--- a/tools/pubrefman/go.sum
+++ /dev/null
@@ -1,277 +0,0 @@
-cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
-github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
-github.com/OneOfOne/xxhash v1.2.2/go.mod h1:HSdplMjZKSmBqAxg5vPj2TmRDmfkzw+cTzAElWljhcU=
-github.com/alcortesm/tgz v0.0.0-20161220082320-9c5fe88206d7 h1:uSoVVbwJiQipAclBbw+8quDsfcvFjOpI5iCf4p/cqCs=
-github.com/alcortesm/tgz v0.0.0-20161220082320-9c5fe88206d7/go.mod h1:6zEj6s6u/ghQa61ZWa/C2Aw3RkjiTBOix7dkqa1VLIs=
-github.com/alecthomas/assert v0.0.0-20170929043011-405dbfeb8e38 h1:smF2tmSOzy2Mm+0dGI2AIUHY+w0BUc+4tn40djz7+6U=
-github.com/alecthomas/assert v0.0.0-20170929043011-405dbfeb8e38/go.mod h1:r7bzyVFMNntcxPZXK3/+KdruV1H5KSlyVY0gc+NgInI=
-github.com/alecthomas/chroma v0.7.1 h1:G1i02OhUbRi2nJxcNkwJaY/J1gHXj9tt72qN6ZouLFQ=
-github.com/alecthomas/chroma v0.7.1/go.mod h1:gHw09mkX1Qp80JlYbmN9L3+4R5o6DJJ3GRShh+AICNc=
-github.com/alecthomas/colour v0.0.0-20160524082231-60882d9e2721 h1:JHZL0hZKJ1VENNfmXvHbgYlbUOvpzYzvy2aZU5gXVeo=
-github.com/alecthomas/colour v0.0.0-20160524082231-60882d9e2721/go.mod h1:QO9JBoKquHd+jz9nshCh40fOfO+JzsoXy8qTHF68zU0=
-github.com/alecthomas/kong v0.2.1-0.20190708041108-0548c6b1afae/go.mod h1:+inYUSluD+p4L8KdviBSgzcqEjUQOfC5fQDRFuc36lI=
-github.com/alecthomas/repr v0.0.0-20180818092828-117648cd9897 h1:p9Sln00KOTlrYkxI1zYWl1QLnEqAqEARBEYa8FQnQcY=
-github.com/alecthomas/repr v0.0.0-20180818092828-117648cd9897/go.mod h1:xTS7Pm1pD1mvyM075QCDSRqH6qRLXylzS24ZTpRiSzQ=
-github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
-github.com/alecthomas/units v0.0.0-20151022065526-2efee857e7cf/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0=
-github.com/anmitsu/go-shlex v0.0.0-20161002113705-648efa622239 h1:kFOfPq6dUM1hTo4JG6LR5AXSUEsOjtdm0kw0FtQtMJA=
-github.com/anmitsu/go-shlex v0.0.0-20161002113705-648efa622239/go.mod h1:2FmKhYUyUczH0OGQWaF5ceTx0UBShxjsH6f8oGKYe2c=
-github.com/armon/consul-api v0.0.0-20180202201655-eb2c6b5be1b6/go.mod h1:grANhF5doyWs3UAsr3K4I6qtAmlQcZDesFNEHPZAzj8=
-github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5 h1:0CwZNZbxp69SHPdPJAN/hZIm0C4OItdklCFmMRWYpio=
-github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5/go.mod h1:wHh0iHkYZB8zMSxRWpUBQtwG5a7fFgvEO+odwuTv2gs=
-github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q=
-github.com/beorn7/perks v1.0.0/go.mod h1:KWe93zE9D1o94FZ5RNwFwVgaQK1VOXiVxmqh+CedLV8=
-github.com/bytesparadise/libasciidoc v0.3.1-0.20200802124845-5dcda3220c31 h1:Rf+HhYMHL9wl4nKv8Jgy5ss8Pksii1TWCgZIP6Cr1qE=
-github.com/bytesparadise/libasciidoc v0.3.1-0.20200802124845-5dcda3220c31/go.mod h1:kWkgc6KJVCDUT2QlPbYIlYspvy0+3vuWriL0kV2NDig=
-github.com/cespare/xxhash v1.1.0/go.mod h1:XrSqR1VqqWfGrhpAt58auRo0WTKS1nRRg3ghfAqPWnc=
-github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
-github.com/coreos/bbolt v1.3.2/go.mod h1:iRUV2dpdMOn7Bo10OQBFzIJO9kkE559Wcmn+qkEiiKk=
-github.com/coreos/etcd v3.3.10+incompatible/go.mod h1:uF7uidLiAD3TWHmW31ZFd/JWoc32PjwdhPthX9715RE=
-github.com/coreos/go-semver v0.2.0/go.mod h1:nnelYz7RCh+5ahJtPPxZlU+153eP4D4r3EedlOD2RNk=
-github.com/coreos/go-systemd v0.0.0-20190321100706-95778dfbb74e/go.mod h1:F5haX7vjVVG0kc13fIWeqUViNPyEJxv/OmvnBo0Yme4=
-github.com/coreos/pkg v0.0.0-20180928190104-399ea9e2e55f/go.mod h1:E3G3o1h8I7cfcXa63jLwjI0eiQQMgzzUDFVpN/nH/eA=
-github.com/cpuguy83/go-md2man/v2 v2.0.0/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU=
-github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
-github.com/danwakefield/fnmatch v0.0.0-20160403171240-cbb64ac3d964 h1:y5HC9v93H5EPKqaS1UYVg1uYah5Xf51mBfIoWehClUQ=
-github.com/danwakefield/fnmatch v0.0.0-20160403171240-cbb64ac3d964/go.mod h1:Xd9hchkHSWYkEqJwUGisez3G1QY8Ryz0sdWrLPMGjLk=
-github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
-github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/dgrijalva/jwt-go v3.2.0+incompatible/go.mod h1:E3ru+11k8xSBh+hMPgOLZmtrrCbhqsmaPHjLKYnJCaQ=
-github.com/dgryski/go-sip13 v0.0.0-20181026042036-e10d5fee7954/go.mod h1:vAd38F8PWV+bWy6jNmig1y/TA+kYO4g3RSRF0IAv0no=
-github.com/dlclark/regexp2 v1.1.6 h1:CqB4MjHw0MFCDj+PHHjiESmHX+N7t0tJzKvC6M97BRg=
-github.com/dlclark/regexp2 v1.1.6/go.mod h1:2pZnwuY/m+8K6iRw6wQdMtk+rH5tNGR1i55kozfMjCc=
-github.com/emirpasic/gods v1.12.0 h1:QAUIPSaCu4G+POclxeqb3F+WPpdKqFGlw36+yOzGlrg=
-github.com/emirpasic/gods v1.12.0/go.mod h1:YfzfFFoVP/catgzJb4IKIqXjX78Ha8FMSDh3ymbK86o=
-github.com/flynn/go-shlex v0.0.0-20150515145356-3f9db97f8568 h1:BHsljHzVlRcyQhjrss6TZTdY2VfCqZPbv5k3iBFa2ZQ=
-github.com/flynn/go-shlex v0.0.0-20150515145356-3f9db97f8568/go.mod h1:xEzjJPgXI435gkrCt3MPfRiAkVrwSbHsst4LCFVfpJc=
-github.com/fsnotify/fsnotify v1.4.7 h1:IXs+QLmnXW2CcXuY+8Mzv/fWEsPGWxqefPtCP5CnV9I=
-github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
-github.com/ghodss/yaml v1.0.0/go.mod h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04=
-github.com/gliderlabs/ssh v0.2.2 h1:6zsha5zo/TWhRhwqCD3+EarCAgZ2yN28ipRnGPnwkI0=
-github.com/gliderlabs/ssh v0.2.2/go.mod h1:U7qILu1NlMHj9FlMhZLlkCdDnU1DBEAqr0aevW3Awn0=
-github.com/go-git/gcfg v1.5.0 h1:Q5ViNfGF8zFgyJWPqYwA7qGFoMTEiBmdlkcfRmpIMa4=
-github.com/go-git/gcfg v1.5.0/go.mod h1:5m20vg6GwYabIxaOonVkTdrILxQMpEShl1xiMF4ua+E=
-github.com/go-git/go-billy/v5 v5.0.0 h1:7NQHvd9FVid8VL4qVUMm8XifBK+2xCoZ2lSk0agRrHM=
-github.com/go-git/go-billy/v5 v5.0.0/go.mod h1:pmpqyWchKfYfrkb/UVH4otLvyi/5gJlGI4Hb3ZqZ3W0=
-github.com/go-git/go-git-fixtures/v4 v4.0.1 h1:q+IFMfLx200Q3scvt2hN79JsEzy4AmBTp/pqnefH+Bc=
-github.com/go-git/go-git-fixtures/v4 v4.0.1/go.mod h1:m+ICp2rF3jDhFgEZ/8yziagdT1C+ZpZcrJjappBCDSw=
-github.com/go-git/go-git/v5 v5.1.0 h1:HxJn9g/E7eYvKW3Fm7Jt4ee8LXfPOm/H1cdDu8vEssk=
-github.com/go-git/go-git/v5 v5.1.0/go.mod h1:ZKfuPUoY1ZqIG4QG9BDBh3G4gLM5zvPuSJAozQrZuyM=
-github.com/go-kit/kit v0.8.0/go.mod h1:xBxKIO96dXMWWy0MnWVtmwkA9/13aqxPnvrjFYMA2as=
-github.com/go-logfmt/logfmt v0.3.0/go.mod h1:Qt1PoO58o5twSAckw1HlFXLmHsOX5/0LbT9GBnD5lWE=
-github.com/go-logfmt/logfmt v0.4.0/go.mod h1:3RMwSq7FuexP4Kalkev3ejPJsZTpXXBr9+V4qmtdjCk=
-github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY=
-github.com/gogo/protobuf v1.1.1/go.mod h1:r8qH/GZQm5c6nD/R0oafs1akxWv10x8SbQlK7atdtwQ=
-github.com/gogo/protobuf v1.2.1/go.mod h1:hp+jE20tsWTFYpLwKvXlhS1hjn+gTNwPg2I6zVXpSg4=
-github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q=
-github.com/golang/groupcache v0.0.0-20190129154638-5b532d6fd5ef/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc=
-github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
-github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
-github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
-github.com/golang/protobuf v1.3.2 h1:6nsPYzhq5kReh6QImI3k5qWzO4PEbvbIW2cwSfR/6xs=
-github.com/golang/protobuf v1.3.2/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
-github.com/google/btree v1.0.0/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
-github.com/google/go-cmp v0.2.0/go.mod h1:oXzfMopK8JAjlY9xF4vHSVASa0yLyX7SntLO5aqRK0M=
-github.com/google/go-cmp v0.3.0 h1:crn/baboCvb5fXaQ0IJ1SGTsTVrWpDsCWC8EGETZijY=
-github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
-github.com/google/uuid v1.1.1 h1:Gkbcsh/GbpXz7lPftLA3P6TYMwjCLYm83jiFQZF/3gY=
-github.com/google/uuid v1.1.1/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
-github.com/gorilla/websocket v1.4.0/go.mod h1:E7qHFY5m1UJ88s3WnNqhKjPHQ0heANvMoAMk2YaljkQ=
-github.com/grpc-ecosystem/go-grpc-middleware v1.0.0/go.mod h1:FiyG127CGDf3tlThmgyCl78X/SZQqEOJBCDaAfeWzPs=
-github.com/grpc-ecosystem/go-grpc-prometheus v1.2.0/go.mod h1:8NvIoxWQoOIhqOTXgfV/d3M/q6VIi02HzZEHgUlZvzk=
-github.com/grpc-ecosystem/grpc-gateway v1.9.0/go.mod h1:vNeuVxBJEsws4ogUvrchl83t/GYV9WGTSLVdBhOQFDY=
-github.com/hashicorp/hcl v1.0.0/go.mod h1:E5yfLk+7swimpb2L/Alb/PJmXilQ/rhwaUYs4T20WEQ=
-github.com/hpcloud/tail v1.0.0 h1:nfCOvKYfkgYP8hkirhJocXT2+zOD8yUNjXaWfTlyFKI=
-github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=
-github.com/imdario/mergo v0.3.9 h1:UauaLniWCFHWd+Jp9oCEkTBj8VO/9DKg3PV3VCNMDIg=
-github.com/imdario/mergo v0.3.9/go.mod h1:2EnlNZ0deacrJVfApfmtdGgDfMuh/nq6Ok1EcJh5FfA=
-github.com/inconshreveable/mousetrap v1.0.0/go.mod h1:PxqpIevigyE2G7u3NXJIT2ANytuPF1OarO4DADm73n8=
-github.com/jbenet/go-context v0.0.0-20150711004518-d14ea06fba99 h1:BQSFePA1RWJOlocH6Fxy8MmwDt+yVQYULKfN0RoTN8A=
-github.com/jbenet/go-context v0.0.0-20150711004518-d14ea06fba99/go.mod h1:1lJo3i6rXxKeerYnT8Nvf0QmHCRC1n8sfWVwXF2Frvo=
-github.com/jessevdk/go-flags v1.4.0/go.mod h1:4FA24M0QyGHXBuZZK/XkWh8h0e1EYbRYJSGM75WSRxI=
-github.com/jonboulle/clockwork v0.1.0/go.mod h1:Ii8DK3G1RaLaWxj9trq07+26W01tbo22gdxWY5EU2bo=
-github.com/julienschmidt/httprouter v1.2.0/go.mod h1:SYymIcj16QtmaHHD7aYtjjsJG7VTCxuUUipMqKk8s4w=
-github.com/kevinburke/ssh_config v0.0.0-20190725054713-01f96b0aa0cd h1:Coekwdh0v2wtGp9Gmz1Ze3eVRAWJMLokvN3QjdzCHLY=
-github.com/kevinburke/ssh_config v0.0.0-20190725054713-01f96b0aa0cd/go.mod h1:CT57kijsi8u/K/BOFA39wgDQJ9CxiF4nAY/ojJ6r6mM=
-github.com/kisielk/errcheck v1.1.0/go.mod h1:EZBBE59ingxPouuu3KfxchcWSUPOHkagtvWXihfKN4Q=
-github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
-github.com/konsorten/go-windows-terminal-sequences v1.0.1 h1:mweAR1A6xJ3oS2pRaGiHgQ4OO8tzTaLawm8vnODuwDk=
-github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
-github.com/konsorten/go-windows-terminal-sequences v1.0.3 h1:CE8S1cTafDpPvMhIxNJKvHsGVBgn1xWYf1NbHQhywc8=
-github.com/konsorten/go-windows-terminal-sequences v1.0.3/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
-github.com/kr/logfmt v0.0.0-20140226030751-b84e30acd515/go.mod h1:+0opPa2QZZtGFBFZlji/RkVcI2GknAs/DXo4wKdlNEc=
-github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
-github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
-github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
-github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
-github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
-github.com/magiconair/properties v1.8.0/go.mod h1:PppfXfuXeibc/6YijjN8zIbojt8czPbwD3XqdrwzmxQ=
-github.com/mattn/go-colorable v0.0.9/go.mod h1:9vuHe8Xs5qXnSaW/c/ABM9alt+Vo+STaOChaDxuIBZU=
-github.com/mattn/go-isatty v0.0.4/go.mod h1:M+lRXTBqGeGNdLjl/ufCoiOlB5xdOkqRJdNxMWT7Zi4=
-github.com/mattn/go-isatty v0.0.12 h1:wuysRhFDzyxgEmMf5xjvJ2M9dZoWAXNNr5LSBS7uHXY=
-github.com/mattn/go-isatty v0.0.12/go.mod h1:cbi8OIDigv2wuxKPP5vlRcQ1OAZbq2CE4Kysco4FUpU=
-github.com/matttproud/golang_protobuf_extensions v1.0.1/go.mod h1:D8He9yQNgCq6Z5Ld7szi9bcBfOoFv/3dc6xSMkL2PC0=
-github.com/mitchellh/go-homedir v1.1.0 h1:lukF9ziXFxDFPkA1vsr5zpc1XuPDn/wFntq5mG+4E0Y=
-github.com/mitchellh/go-homedir v1.1.0/go.mod h1:SfyaCUpYCn1Vlf4IUYiD9fPX4A5wJrkLzIz1N1q0pr0=
-github.com/mitchellh/mapstructure v1.1.2/go.mod h1:FVVH3fgwuzCH5S8UJGiWEs2h04kUh9fWfEaFds41c1Y=
-github.com/mna/pigeon v1.0.1-0.20200224192238-18953b277063 h1:V7s6vhIrNeOqocziAmRoVJh6gnPPx83ovlpT7Hf5shI=
-github.com/mna/pigeon v1.0.1-0.20200224192238-18953b277063/go.mod h1:rkFeDZ0gc+YbnrXPw0q2RlI0QRuKBBPu67fgYIyGRNg=
-github.com/modocache/gover v0.0.0-20171022184752-b58185e213c5 h1:8Q0qkMVC/MmWkpIdlvZgcv2o2jrlF6zqVOh7W5YHdMA=
-github.com/modocache/gover v0.0.0-20171022184752-b58185e213c5/go.mod h1:caMODM3PzxT8aQXRPkAt8xlV/e7d7w8GM5g0fa5F0D8=
-github.com/mwitkow/go-conntrack v0.0.0-20161129095857-cc309e4a2223/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
-github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e h1:fD57ERR4JtEqsWbfPhv4DMiApHyliiK5xCTNVSPiaAs=
-github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod h1:zD1mROLANZcx1PVRCS0qkT7pwLkGfwJo4zjcN/Tysno=
-github.com/oklog/ulid v1.3.1/go.mod h1:CirwcVhetQ6Lv90oh/F+FBtV6XMibvdAFo93nm5qn4U=
-github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
-github.com/onsi/ginkgo v1.12.0 h1:Iw5WCbBcaAAd0fpRb1c9r5YCylv4XDoCSigm1zLevwU=
-github.com/onsi/ginkgo v1.12.0/go.mod h1:oUhWkIvk5aDxtKvDDuw8gItl8pKl42LzjC9KZE0HfGg=
-github.com/onsi/gomega v1.7.1/go.mod h1:XdKZgCCFLUoM/7CFJVPcG8C1xQ1AJ0vpAezJrB7JYyY=
-github.com/onsi/gomega v1.9.0 h1:R1uwffexN6Pr340GtYRIdZmAiN4J+iw6WG4wog1DUXg=
-github.com/onsi/gomega v1.9.0/go.mod h1:Ho0h+IUsWyvy1OpqCwxlQ/21gkhVunqlU8fDGcoTdcA=
-github.com/pelletier/go-toml v1.2.0/go.mod h1:5z9KED0ma1S8pY6P1sdut58dfprrGBbd/94hg7ilaic=
-github.com/pkg/errors v0.8.0/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
-github.com/pkg/errors v0.8.1 h1:iURUrRGxPUNPdy5/HRSm+Yj6okJ6UtLINN0Q9M4+h3I=
-github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
-github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
-github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
-github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
-github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/prometheus/client_golang v0.9.1/go.mod h1:7SWBe2y4D6OKWSNQJUaRYU/AaXPKyh/dDVn+NZz0KFw=
-github.com/prometheus/client_golang v0.9.3/go.mod h1:/TN21ttK/J9q6uSwhBd54HahCDft0ttaMvbicHlPoso=
-github.com/prometheus/client_model v0.0.0-20180712105110-5c3871d89910/go.mod h1:MbSGuTsp3dbXC40dX6PRTWyKYBIrTGTE9sqQNg2J8bo=
-github.com/prometheus/client_model v0.0.0-20190129233127-fd36f4220a90/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
-github.com/prometheus/common v0.0.0-20181113130724-41aa239b4cce/go.mod h1:daVV7qP5qjZbuso7PdcryaAu0sAZbrN9i7WWcTMWvro=
-github.com/prometheus/common v0.4.0/go.mod h1:TNfzLD0ON7rHzMJeJkieUDPYmFC7Snx/y86RQel1bk4=
-github.com/prometheus/procfs v0.0.0-20181005140218-185b4288413d/go.mod h1:c3At6R/oaqEKCNdg8wHV1ftS6bRYblBhIjjI8uT2IGk=
-github.com/prometheus/procfs v0.0.0-20190507164030-5867b95ac084/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsTZCD3I8kEA=
-github.com/prometheus/tsdb v0.7.1/go.mod h1:qhTCs0VvXwvX/y3TZrWD7rabWM+ijKTux40TwIPHuXU=
-github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6SoW27p1b0cqNHllgS5HIMJraePCO15w5zCzIWYg=
-github.com/russross/blackfriday/v2 v2.0.1/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
-github.com/sergi/go-diff v1.0.0/go.mod h1:0CfEIISq7TuYL3j771MWULgwwjU+GofnZX9QAmXWZgo=
-github.com/sergi/go-diff v1.1.0 h1:we8PVUC3FE2uYfodKH/nBHMSetSfHDR6scGdBi+erh0=
-github.com/sergi/go-diff v1.1.0/go.mod h1:STckp+ISIX8hZLjrqAeVduY0gWCT9IjLuqbuNXdaHfM=
-github.com/shurcooL/sanitized_anchor_name v1.0.0/go.mod h1:1NzhyTcUVG4SuEtjjoZeVRXNmyL/1OwPU0+IJeTBvfc=
-github.com/sirupsen/logrus v1.2.0 h1:juTguoYk5qI21pwyTXY3B3Y5cOTH3ZUyZCg1v/mihuo=
-github.com/sirupsen/logrus v1.2.0/go.mod h1:LxeOpSwHxABJmUn/MG1IvRgCAasNZTLOkJPxbbu5VWo=
-github.com/sirupsen/logrus v1.6.0 h1:UBcNElsrwanuuMsnGSlYmtmgbb23qDR5dG+6X6Oo89I=
-github.com/sirupsen/logrus v1.6.0/go.mod h1:7uNnSEd1DgxDLC74fIahvMZmmYsHGZGEOFrfsX/uA88=
-github.com/soheilhy/cmux v0.1.4/go.mod h1:IM3LyeVVIOuxMH7sFAkER9+bJ4dT7Ms6E4xg4kGIyLM=
-github.com/sozorogami/gover v0.0.0-20171022184752-b58185e213c5 h1:TAPeDBsd52dRWoWzf5trgBzxzMYHTYjYI+4xNyCdoCU=
-github.com/sozorogami/gover v0.0.0-20171022184752-b58185e213c5/go.mod h1:nHNlDYIQZn44RvqH0kCpl/dMMVWXkav0QIgzGxV1Ab4=
-github.com/spaolacci/murmur3 v0.0.0-20180118202830-f09979ecbc72/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=
-github.com/spf13/afero v1.1.2/go.mod h1:j4pytiNVoe2o6bmDsKpLACNPDBIoEAkihy7loJ1B0CQ=
-github.com/spf13/cast v1.3.0/go.mod h1:Qx5cxh0v+4UWYiBimWS+eyWzqEqokIECu5etghLkUJE=
-github.com/spf13/cobra v1.0.0/go.mod h1:/6GTrnGXV9HjY+aR4k0oJ5tcvakLuG6EuKReYlHNrgE=
-github.com/spf13/jwalterweatherman v1.0.0 h1:XHEdyB+EcvlqZamSM4ZOMGlc93t6AcsBEu9Gc1vn7yk=
-github.com/spf13/jwalterweatherman v1.0.0/go.mod h1:cQK4TGJAtQXfYWX+Ddv3mKDzgVb68N+wFjFa4jdeBTo=
-github.com/spf13/pflag v1.0.3/go.mod h1:DYY7MBk1bdzusC3SYhjObp+wFpr4gzcvqqNjLnInEg4=
-github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
-github.com/spf13/viper v1.4.0/go.mod h1:PTJ7Z/lr49W6bUbkmS1V3by4uWynFiR9p7+dSq/yZzE=
-github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
-github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
-github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
-github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
-github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
-github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0=
-github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
-github.com/tmc/grpc-websocket-proxy v0.0.0-20190109142713-0ad062ec5ee5/go.mod h1:ncp9v5uamzpCO7NfCPTXjqaC+bZgJeR0sMTm6dMHP7U=
-github.com/ugorji/go v1.1.4/go.mod h1:uQMGLiO92mf5W77hV/PUCpI3pbzQx3CRekS0kk+RGrc=
-github.com/xanzy/ssh-agent v0.2.1 h1:TCbipTQL2JiiCprBWx9frJ2eJlCYT00NmctrHxVAr70=
-github.com/xanzy/ssh-agent v0.2.1/go.mod h1:mLlQY/MoOhWBj+gOGMQkOeiEvkx+8pJSI+0Bx9h2kr4=
-github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2/go.mod h1:UETIi67q53MR2AWcXfiuqkDkRtnGDLqkBTpCHuJHxtU=
-github.com/xordataexchange/crypt v0.0.3-0.20170626215501-b2862e3d0a77/go.mod h1:aYKd//L2LvnjZzWKhF00oedf4jCCReLcmhLdhm1A27Q=
-github.com/yuin/goldmark v1.1.32/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
-go.etcd.io/bbolt v1.3.2/go.mod h1:IbVyRI1SCnLcuJnV2u8VeU0CEYM7e686BmAb1XKL+uU=
-go.uber.org/atomic v1.4.0/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
-go.uber.org/multierr v1.1.0/go.mod h1:wR5kodmAFQ0UK8QlbwjlSNy0Z68gJhDJUG5sjR94q/0=
-go.uber.org/zap v1.10.0/go.mod h1:vwi/ZaCAaUcBkycHslxD9B2zi4UTXhF60s6SWpuDF0Q=
-golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
-golang.org/x/crypto v0.0.0-20190219172222-a4c6cb3142f2/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
-golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
-golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
-golang.org/x/crypto v0.0.0-20200302210943-78000ba7a073 h1:xMPOj6Pz6UipU1wXLkrtqpHbR0AVFnyPEQq/wRWz9lM=
-golang.org/x/crypto v0.0.0-20200302210943-78000ba7a073/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
-golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9 h1:psW17arqaxU48Z5kZ0CQnkZWQJsqcURM6tKiBApRjXI=
-golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
-golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
-golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
-golang.org/x/mod v0.3.0 h1:RM4zey1++hCTbCVQfnWeKs9/IEsaBLA8vTkd0WVtmH4=
-golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
-golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
-golang.org/x/net v0.0.0-20180906233101-161cd47e91fd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
-golang.org/x/net v0.0.0-20181114220301-adae6a3d119a/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
-golang.org/x/net v0.0.0-20181220203305-927f97764cc3/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
-golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
-golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
-golang.org/x/net v0.0.0-20190522155817-f3200d17e092/go.mod h1:HSz+uSET+XFnRR8LxR5pz3Of3rY3CfYBVs4xY44aLks=
-golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
-golang.org/x/net v0.0.0-20200301022130-244492dfa37a h1:GuSPYbZzB5/dcLNCwLQLsg3obCJtX9IJhpXkvY7kzk0=
-golang.org/x/net v0.0.0-20200301022130-244492dfa37a/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
-golang.org/x/net v0.0.0-20200625001655-4c5254603344 h1:vGXIOMxbNfDTk/aXCmfdLgkrSV+Z2tcbze+pEc3v5W4=
-golang.org/x/net v0.0.0-20200625001655-4c5254603344/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA=
-golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
-golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.0.0-20200625203802-6e8e738ad208/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
-golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
-golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
-golang.org/x/sys v0.0.0-20181107165924-66b7b1311ac8/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
-golang.org/x/sys v0.0.0-20181116152217-5ac8a444bdc5/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
-golang.org/x/sys v0.0.0-20181128092732-4ed8d59d0b35/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
-golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
-golang.org/x/sys v0.0.0-20190221075227-b4e8571b14e0/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
-golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20190422165155-953cdadca894/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20191120155948-bd437916bb0e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20200116001909-b77594299b42/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20200302150141-5c8b2ff67527 h1:uYVVQ9WP/Ds2ROhcaGPeIdVq0RIXVLwsHlnvJ+cT1So=
-golang.org/x/sys v0.0.0-20200302150141-5c8b2ff67527/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd h1:xhmwyvizuTgC2qz7ZlMluP20uW+C3Rm0FD/WLDX8884=
-golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
-golang.org/x/text v0.3.2 h1:tW2bmiBqwgJj/UpqtC8EpXEZVYOwU0yG4iWbprSVAcs=
-golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk=
-golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
-golang.org/x/tools v0.0.0-20180221164845-07fd8470d635/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
-golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
-golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
-golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
-golang.org/x/tools v0.0.0-20190830223141-573d9926052a/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
-golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
-golang.org/x/tools v0.0.0-20200717024301-6ddee64345a6 h1:nULzSsKgihxFGLnQFv2T7lE5vIhOtg8ZPpJHapEt7o0=
-golang.org/x/tools v0.0.0-20200717024301-6ddee64345a6/go.mod h1:njjCfa9FT2d7l9Bc6FUM5FLjQPp3cFF28FI3qnDFljA=
-golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
-golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM=
-google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
-google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
-google.golang.org/grpc v1.21.0/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM=
-gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLkstjWtayDeSgw=
-gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f h1:BLraFXnmrev5lT+xlilqcH8XK9/i0At2xKjWk4p6zsU=
-gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/fsnotify.v1 v1.4.7 h1:xOHLXZwVvI9hhs+cLKq5+I5onOuwQLhQwiu63xxlHs4=
-gopkg.in/fsnotify.v1 v1.4.7/go.mod h1:Tz8NjZHkW78fSQdbUxIjBTcgA1z1m8ZHf0WmKUhAMys=
-gopkg.in/resty.v1 v1.12.0/go.mod h1:mDo4pnntr5jdWRML875a/NmxYqAlA73dVijT2AXvQQo=
-gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 h1:uRGJdciOHaEIrze2W8Q3AKkepLTh2hOroT7a+7czfdQ=
-gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7/go.mod h1:dt/ZhP58zS4L8KSrWDmTeBkI65Dw0HsyUHuEVlX15mw=
-gopkg.in/warnings.v0 v0.1.2 h1:wFXVbFY8DY5/xOe1ECiWdKCzZlxgshcYVNkBHstARME=
-gopkg.in/warnings.v0 v0.1.2/go.mod h1:jksf8JmL6Qr/oQM2OXTHunEvvTAsrWBLb6OOjuVWRNI=
-gopkg.in/yaml.v2 v2.0.0-20170812160011-eb3733d160e7/go.mod h1:JAlM8MvJe8wmxCU4Bli9HhUf9+ttbYbLASfIpnQbh74=
-gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
-gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
-gopkg.in/yaml.v2 v2.2.4 h1:/eiJrUcujPVeJ3xlSWaiNi3uSVmDGBK1pDHUHAnao1I=
-gopkg.in/yaml.v2 v2.2.4/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
-gopkg.in/yaml.v2 v2.3.0 h1:clyUAQHOM3G0M3f5vQj7LuJrETvjVot3Z5el9nffUtU=
-gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
-gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo=
-gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
-honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
diff --git a/tools/pubrefman/pubrefman.go b/tools/pubrefman/pubrefman.go
deleted file mode 100644
index 9ed3f5af..00000000
--- a/tools/pubrefman/pubrefman.go
+++ /dev/null
@@ -1,493 +0,0 @@
-// Copyright 2020 Staysail Systems, Inc.
-//
-// This software is supplied under the terms of the MIT License, a
-// copy of which should be located in the distribution where this
-// file was obtained (LICENSE.txt). A copy of the license may also be
-// found online at https://opensource.org/licenses/MIT.
-//
-
-package main
-
-import (
- "context"
- "flag"
- "fmt"
- "io/ioutil"
- "log"
- "os"
- "path"
- "sort"
- "strings"
- "time"
-
- "github.com/bytesparadise/libasciidoc"
- "github.com/bytesparadise/libasciidoc/pkg/configuration"
- "github.com/go-git/go-billy/v5"
- "github.com/go-git/go-billy/v5/memfs"
- "github.com/go-git/go-git/v5"
- "github.com/go-git/go-git/v5/plumbing"
- "github.com/go-git/go-git/v5/plumbing/object"
- "github.com/go-git/go-git/v5/storage/memory"
- "github.com/google/uuid"
- jww "github.com/spf13/jwalterweatherman"
-)
-
-type Configuration struct {
- Version string
- Debug bool
- Trace bool
- Quiet bool
- DryRun bool
- Author string
- Email string
- Url string
- Message string
-}
-
-var Config Configuration
-
-func init() {
- flag.StringVar(&Config.Version, "v", "tip", "Version to publish")
- flag.BoolVar(&Config.Debug, "d", false, "Enable debugging")
- flag.BoolVar(&Config.Trace, "t", false, "Enable tracing")
- flag.BoolVar(&Config.Quiet, "q", false, "Run quietly")
- flag.BoolVar(&Config.DryRun, "n", false, "Dry run, does not push changes")
- flag.StringVar(&Config.Url, "u", "ssh://git@github.com/nanomsg/nng.git", "URL of repo to publish from")
- flag.StringVar(&Config.Email, "E", "info@staysail.tech", "Author email for commit")
- flag.StringVar(&Config.Author, "A", "Staysail Systems, Inc.", "Author name for commit")
- flag.StringVar(&Config.Message, "m", "", "Commit message")
-}
-
-func (g *Global) CheckError(err error, prefix string, args ...interface{}) {
- if err == nil {
- g.Log.TRACE.Printf("%s: ok", fmt.Sprintf(prefix, args...))
- return
- }
- g.Log.FATAL.Fatalf("Error: %s: %v", fmt.Sprintf(prefix, args...), err)
-}
-
-func (g *Global) Fatal(format string, args ...interface{}) {
- g.Log.FATAL.Fatalf("Error: %s", fmt.Sprintf(format, args...))
-}
-
-type Section struct {
- Name string
- Synopsis string
- Description string
- Pages []*Page
-}
-
-type Page struct {
- Name string
- Section string
- Description string
- Content string
-}
-
-type Global struct {
- Config Configuration
- SrcFs billy.Filesystem
- DstFs billy.Filesystem
- DstDir string
- LaConfig configuration.Configuration
- Sections map[string]*Section
- Pages map[string]*Page
- Repo *git.Repository
- Index string
- ToC string
- Added map[string]bool
- WorkTree *git.Worktree
- Branch string
- OldHash plumbing.Hash
- NewHash plumbing.Hash
- Log *jww.Notepad
-}
-
-func (g *Global) Init() {
- g.Config = Config
- g.Sections = make(map[string]*Section)
- g.Pages = make(map[string]*Page)
- g.Added = make(map[string]bool)
- g.SrcFs = memfs.New()
- g.DstFs = memfs.New()
- g.DstDir = path.Join("man", g.Config.Version)
- g.LaConfig = configuration.Configuration{
- AttributeOverrides: map[string]string{
- "nofooter": "yes",
- "icons": "font",
- "linkcss": "yes",
- "source-highlighter": "pygments",
- },
- }
- thresh := jww.LevelInfo
- if g.Config.Quiet {
- thresh = jww.LevelError
- }
- if g.Config.Debug {
- thresh = jww.LevelDebug
- }
- if g.Config.Trace {
- thresh = jww.LevelTrace
- }
- g.Log = jww.NewNotepad(thresh, thresh, os.Stdout, ioutil.Discard, "", log.Ldate|log.Ltime)
-}
-
-func (g *Global) Destroy() {
-}
-
-func (g *Global) Debug(format string, args ...interface{}) {
- g.Log.DEBUG.Printf(format, args...)
-}
-
-func (g *Global) Print(format string, args ...interface{}) {
- g.Log.INFO.Printf(format, args...)
-}
-
-func (g *Global) CloneSource() {
- tag := g.Config.Version
- if tag == "" || tag == "tip" {
- tag = "master"
- }
- ref := plumbing.NewBranchReferenceName(tag)
- if strings.HasPrefix(tag, "v") {
- ref = plumbing.NewTagReferenceName(tag)
- }
- ctx, cancel := context.WithTimeout(context.Background(), time.Minute)
- defer cancel()
-
- now := time.Now()
- _, err := git.CloneContext(ctx, memory.NewStorage(), g.SrcFs, &git.CloneOptions{
- URL: g.Config.Url,
- ReferenceName: ref,
- })
- g.CheckError(err, "clone source")
- g.Debug("Cloned source (%s) in %v", tag, time.Since(now))
-}
-
-func (g *Global) ClonePages() {
- ref := plumbing.NewBranchReferenceName("gh-pages")
- ctx, cancel := context.WithTimeout(context.Background(), time.Minute)
- defer cancel()
-
- now := time.Now()
- repo, err := git.CloneContext(ctx, memory.NewStorage(), g.DstFs, &git.CloneOptions{
- URL: g.Config.Url,
- ReferenceName: ref,
- RemoteName: "origin",
- })
- g.CheckError(err, "clone gh-pages")
- g.Repo = repo
- g.Debug("Cloned pages in %v", time.Since(now))
-}
-
-func (g *Global) ProcessManPage(page os.FileInfo) {
- source := g.ReadFile(page.Name())
- // Let's look for the description
- inName := false
- desc := ""
- name := ""
- for _, line := range strings.Split(source, "\n") {
- line = strings.TrimRight(line, " \t\r")
- if line == "" {
- continue
- }
- if line == "== NAME" {
- inName = true
- continue
- }
- if inName {
- w := strings.SplitN(line, " - ", 2)
- if len(w) != 2 || w[1] == "" {
- g.Fatal("page %s NAME malformed", page.Name())
- }
- name = w[0]
- desc = w[1]
- strings.TrimSpace(name)
- strings.TrimSpace(desc)
- break
- }
- }
-
- if desc == "" {
- g.Fatal("page %s NAME missing", page.Name())
- }
-
- html := &strings.Builder{}
-
- // Emit the title, as we are not letting libasciidoc do it (stripping headers)
- cfg := g.LaConfig
- cfg.Filename = page.Name()
- cfg.LastUpdated = page.ModTime()
- metadata, err := libasciidoc.Convert(strings.NewReader(source), html, cfg)
- g.CheckError(err, "processing page %s", page.Name())
- w := strings.SplitN(metadata.Title, "(", 2)
- sect := strings.TrimSuffix(w[1], ")")
- if len(w) != 2 || name != w[0] || !strings.HasSuffix(w[1], ")") {
- g.Fatal("page %s title incorrect (%s)", page.Name(), name)
- }
- if page.Name() != name+"."+sect+".adoc" {
- g.Fatal("page %s(%s) does not match file name %s", name, sect, page.Name())
- }
- result := &strings.Builder{}
- _, _ = fmt.Fprintf(result, "---\n")
- _, _ = fmt.Fprintf(result, "version: %s\n", g.Config.Version)
- _, _ = fmt.Fprintf(result, "layout: %s\n", "manpage_v2")
- _, _ = fmt.Fprintf(result, "---\n")
- _, _ = fmt.Fprintf(result, "<h1>%s(%s)</h1>\n", name, sect)
- result.WriteString(html.String())
-
- g.Pages[page.Name()] = &Page{
- Name: name,
- Section: sect,
- Description: desc,
- Content: result.String(),
- }
- g.Log.TRACE.Printf("HTML for %s:\n%s\n", name, result.String())
-}
-
-func (g *Global) ReadFile(name string) string {
- f, err := g.SrcFs.Open(path.Join("docs/man", name))
- g.CheckError(err, "open file %s", name)
- b, err := ioutil.ReadAll(f)
- g.CheckError(err, "read file %s", name)
- return string(b)
-}
-
-func (g *Global) LoadSection(name string) {
- section := strings.TrimPrefix(name, "man")
-
- g.Sections[section] = &Section{
- Name: section,
- Synopsis: g.ReadFile(name + ".sect"),
- Description: g.ReadFile(name + ".desc"),
- }
-}
-
-func (g *Global) ProcessSource() {
- pages, err := g.SrcFs.ReadDir("docs/man")
- g.CheckError(err, "reading source directory")
- count := 0
- g.Debug("Total of %d files in man directory", len(pages))
- now := time.Now()
- for _, page := range pages {
- if page.IsDir() {
- continue
- }
- if strings.HasSuffix(page.Name(), ".sect") {
- g.LoadSection(strings.TrimSuffix(page.Name(), ".sect"))
- }
- if !strings.HasSuffix(page.Name(), ".adoc") {
- continue
- }
- g.ProcessManPage(page)
- count++
- }
- g.Debug("Processed %d pages in %v", count, time.Since(now))
-}
-
-func (g *Global) GenerateToC() {
- toc := &strings.Builder{}
- idx := &strings.Builder{}
-
- for _, page := range g.Pages {
- if sect := g.Sections[page.Section]; sect == nil {
- g.Fatal("page %s section %s not found", page.Name, page.Section)
- } else {
- sect.Pages = append(sect.Pages, page)
- }
- }
-
- var sects []string
- for name, sect := range g.Sections {
- sects = append(sects, name)
- sort.Slice(sect.Pages, func(i, j int) bool { return sect.Pages[i].Name < sect.Pages[j].Name })
- }
- sort.Strings(sects)
-
- // And also the index page.
-
- // Emit the toc leader part
- toc.WriteString("<nav id=\"toc\" class=\"toc2\">\n")
- toc.WriteString("<div id=\"toctitle\">Table of Contents</div>\n")
- toc.WriteString("<ul class=\"sectlevel1\n\">\n")
-
- idx.WriteString("= NNG Reference Manual\n")
-
- for _, sect := range sects {
- s := g.Sections[sect]
- _, _ = fmt.Fprintf(toc, "<li>%s</li>\n", s.Synopsis)
- _, _ = fmt.Fprintf(toc, "<ul class=\"sectlevel2\">\n")
-
- _, _ = fmt.Fprintf(idx, "\n== Section %s: %s\n\n", s.Name, s.Synopsis)
- _, _ = fmt.Fprintln(idx, s.Description)
- _, _ = fmt.Fprintln(idx, "\n[cols=\"3,5\"]\n|===")
-
- for _, page := range s.Pages {
- _, _ = fmt.Fprintf(toc, "<li><a href=\"%s.%s.html\">%s</a></li>\n",
- page.Name, page.Section, page.Name)
- _, _ = fmt.Fprintf(idx, "|xref:%s.%s.adoc[%s(%s)]\n", page.Name, page.Section,
- page.Name, page.Section)
- _, _ = fmt.Fprintf(idx, "|%s\n", page.Description)
- }
-
- _, _ = fmt.Fprintf(toc, "</ul>\n")
- _, _ = fmt.Fprintln(idx, "|===")
- }
- _, _ = fmt.Fprintf(toc, "</ul>\n")
- _, _ = fmt.Fprintf(toc, "</nav>\n")
-
- index := &strings.Builder{}
- _, _ = fmt.Fprintf(index, "---\n")
- _, _ = fmt.Fprintf(index, "version: %s\n", g.Config.Version)
- _, _ = fmt.Fprintf(index, "layout: %s\n", "manpage_v2")
- _, _ = fmt.Fprintf(index, "---\n")
- _, _ = fmt.Fprintf(index, "<h1>NNG Reference Manual</h1>\n")
-
- cfg := g.LaConfig
- cfg.Filename = "index.adoc"
- _, err := libasciidoc.Convert(strings.NewReader(idx.String()), index, cfg)
- g.CheckError(err, "formatting index")
- g.Index = index.String()
- g.ToC = toc.String()
-}
-
-func (g *Global) CreateBranch() {
- brName := uuid.New().String()
- var err error
-
- refName := plumbing.ReferenceName("refs/heads/" + brName)
- g.Branch = brName
-
- g.WorkTree, err = g.Repo.Worktree()
- g.CheckError(err, "getting worktree")
-
- err = g.WorkTree.Checkout(&git.CheckoutOptions{
- Branch: refName,
- Create: true,
- })
- g.CheckError(err, "creating branch")
- g.Print("Checked out branch %v", brName)
- pr, err := g.Repo.Head()
- g.CheckError(err, "getting head hash")
- g.OldHash = pr.Hash()
-}
-
-func (g *Global) WriteFile(name string, content string) {
- full := path.Join(g.DstDir, name)
- f, err := g.DstFs.Create(full)
- g.CheckError(err, "creating file %s", name)
- _, err = f.Write([]byte(content))
- g.CheckError(err, "writing file %s", name)
- err = f.Close()
- g.CheckError(err, "closing file %s", name)
- g.Add(name)
-}
-
-func (g *Global) Add(name string) {
- g.Log.TRACE.Printf("Adding file %s", name)
- g.Added[name] = true
-}
-
-func (g *Global) Delete(name string) {
- g.Debug("Removing file %s", name)
- _, err := g.WorkTree.Remove(path.Join(g.DstDir, name))
- g.CheckError(err, "removing file %s", name)
-}
-
-func (g *Global) Commit() {
- if status, err := g.WorkTree.Status(); status == nil {
- g.CheckError(err, "obtaining status")
- } else if status.IsClean() {
- g.Print("No changes to commit.")
- return
- }
- message := g.Config.Message
- if message == "" {
- message = "Manual page updates for " + g.Config.Version
- }
- var err error
- g.NewHash, err = g.WorkTree.Commit(message, &git.CommitOptions{
- Author: &object.Signature{
- Email: g.Config.Email,
- Name: g.Config.Author,
- When: time.Now(),
- },
- })
- g.CheckError(err, "committing branch")
-}
-
-func (g *Global) Push() {
- if g.NewHash.IsZero() {
- g.Print("Nothing to push.")
- return
- }
-
- ci, err := g.Repo.Log(&git.LogOptions{
- From: g.NewHash,
- })
- g.CheckError(err, "getting commit log")
- commit, err := ci.Next()
- g.CheckError(err,"getting single commit")
- if commit != nil {
- g.Print(commit.String())
- if fs, _ := commit.Stats(); fs != nil {
- g.Debug(fs.String())
- }
- }
- if g.Config.DryRun {
- g.Print("Not pushing changes (dry-run mode.)")
- } else {
- err := g.Repo.Push(&git.PushOptions{
- RemoteName: "origin",
- })
- g.CheckError(err, "pushing changes")
- g.Print("Pushed branch %v\n", g.Branch)
- }
-}
-
-func (g *Global) WriteOutput() {
-
- for _, p := range g.Pages {
- fName := fmt.Sprintf("%s.%s.html", p.Name, p.Section)
- g.WriteFile(fName, p.Content)
- }
- g.WriteFile("_toc.html", g.ToC)
- g.WriteFile("index.html", g.Index)
-
- _, err := g.WorkTree.Add(g.DstDir)
- g.CheckError(err, "adding directory")
- files, err := g.DstFs.ReadDir(g.DstDir)
- g.CheckError(err, "scanning destination directory")
- for _, file := range files {
- if file.IsDir() {
- continue
- }
- if g.Added[file.Name()] {
- continue
- }
- g.Delete(file.Name())
- }
- status, err := g.WorkTree.Status()
- g.CheckError(err, "obtaining commit status")
- if !status.IsClean() {
- g.Debug("No changes.")
- } else {
- g.Debug(status.String())
- }
-}
-
-func main() {
- g := &Global{}
- flag.Parse()
- g.Init()
- defer g.Destroy()
-
- g.CloneSource()
- g.ClonePages()
- g.ProcessSource()
- g.GenerateToC()
- g.CreateBranch()
- g.WriteOutput()
- g.Commit()
- g.Push()
-}
generated by cgit v1.2.3-70-g09d2 (git 2.46.0) at 2026-01-19 09:06:08 +0000