dcf77pi.c

// Copyright 2013-2020 René Ladan
// SPDX-License-Identifier: BSD-2-Clause

#include "bits1to14.h"
#include "calendar.h"
#include "decode_alarm.h"
#include "decode_time.h"
#include "input.h"
#include "mainloop.h"
#include "setclock.h"

#include "json_object.h"
#include "json_util.h"

#include <curses.h>
#include <errno.h>
#include <stdarg.h>
#include <stdbool.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sysexits.h>
#include <time.h>

#define MAXBUF 255

static char *logfilename;
static int old_bitpos = -1; /* timer for statusbar inactive */
static int input_mode;      /* normal input (statusbar) or string input */
static char keybuf[MAXBUF]; /* accumulator for string input */
static bool show_utc;       /* show time in UTC */
static bool set_time;       /* set host time, copy from mlr in [post_]process_input() */
static bool toosmall;       /* terminal is less than 80x25 after a KEY_RESIZE */

static void
statusbar(int bitpos, const char * const fmt, ...)
{
	va_list ap;

	old_bitpos = bitpos;

	if (toosmall) {
		return;
	}

	move(24, 0);
	va_start(ap, fmt);
	vw_printw(stdscr, fmt, ap);
	va_end(ap);
	clrtoeol();
	refresh();
}

static void
draw_keys(void)
{
	if (toosmall) {
		return;
	}

	mvprintw(24, 0,
	    "[Q] quit [L] change log file [S] time sync %s "
	    "[u] UTC display %s", set_time ? "off" : "on ",
	    show_utc ? "off" : "on ");
	clrtoeol();
	mvchgat(24, 1, 1, A_NORMAL, 5, NULL); /* [Q] */
	mvchgat(24, 10, 1, A_NORMAL, 5, NULL); /* [L] */
	mvchgat(24, 30, 1, A_NORMAL, 5, NULL); /* [S] */
	mvchgat(24, 48, 1, A_NORMAL, 5, NULL); /* [u] */
	refresh();
}

static void
client_cleanup(const char * const reason)
{
	/* Caller is supposed to exit the program after this */
	endwin();
	if (reason != NULL) {
		printf("%s\n", reason);
		cleanup();
	}
	free(logfilename);
	logfilename = NULL;
}

static void
draw_initial_screen(void)
{
	mvprintw(0, 0, "old");
	mvprintw(1, 28, "(");
	mvprintw(1, 46, ")   txcall dst leap");
	mvchgat(1, 50, 15, A_NORMAL, 8, NULL);

	mvprintw(3, 0, "Third party buffer  :");
	mvprintw(4, 0, "Third party contents:");

	mvprintw(6, 0, "new");
	mvprintw(8, 0, "bit    act  last0  total   "
	    "realfreq         b0        b20 state     radio");

	toosmall = false;
	draw_keys();
}

static void
display_bit(struct GB_result bit, int bitpos)
{
	int bp, xpos;
	struct bitinfo bitinf;

	if (toosmall) {
		return;
	}

	bitinf = get_bitinfo();

	mvprintw(9, 1, "%2u %6i %6i %6u %10.3f %10.3f %10.3f",
	    bitpos, bitinf.tlow, bitinf.tlast0, bitinf.t, bitinf.realfreq / 1e6,
	    bitinf.bit0 / 1e6, bitinf.bit20 / 1e6);
	mvchgat(9, 25, 10, A_NORMAL, bitinf.freq_reset ? 3 : 7, NULL);
	mvchgat(9, 36, 21, A_NORMAL, bitinf.bitlen_reset ? 3 : 7, NULL);

	if (bit.marker == emark_minute && bit.bitval != ebv_none) {
		mvprintw(9, 58, "minute   ");
		mvchgat(9, 58, 6, A_NORMAL, 2, NULL);
	} else if (bit.marker == emark_none && bit.bitval != ebv_none) {
		mvprintw(9, 58, "OK       ");
		mvchgat(9, 58, 2, A_NORMAL, 2, NULL);
	} else {
		mvprintw(9, 58, "?        ");
		mvchgat(9, 58, 1, A_NORMAL, 3, NULL);
	}
	if (bit.bitval == ebv_none) {
		mvprintw(9, 58, "read     ");
		mvchgat(9, 58, 4, A_NORMAL, 1, NULL);
	}

	if (bit.hwstat == ehw_receive) {
		mvprintw(9, 68, "receive ");
		mvchgat(9, 68, 7, A_NORMAL, 1, NULL);
	} else if (bit.hwstat == ehw_transmit) {
		mvprintw(9, 68, "transmit");
		mvchgat(9, 68, 8, A_NORMAL, 1, NULL);
	} else if (bit.hwstat == ehw_random) {
		mvprintw(9, 68, "random  ");
		mvchgat(9, 68, 6, A_NORMAL, 1, NULL);
	} else if (bit.bad_io) {
		mvprintw(9, 68, "IO      ");
		mvchgat(9, 68, 2, A_NORMAL, 1, NULL);
	} else {
		/* bit.hwstat == ehw_ok */
		mvprintw(9, 68, "OK      ");
		mvchgat(9, 68, 2, A_NORMAL, 2, NULL);
	}

	for (xpos = bitpos + 4, bp = 0; bp <= bitpos; bp++) {
		if (is_space_bit(bp)) {
			xpos++;
		}
	}

	mvprintw(6, xpos, "%u", get_buffer()[bitpos]);
	if (bit.bitval == ebv_none) {
		mvchgat(6, xpos, 1, A_NORMAL, 3, NULL);
	}

	mvprintw(1, 29, "%10u", get_acc_minlen());
	refresh();
}

static void
display_time(struct DT_result dt, struct tm time)
{

	if (toosmall) {
		return;
	}

	if (show_utc) {
		time = get_utctime(time);
	}

	/* color bits depending on the results */
	mvchgat(0, 4, 1, A_NORMAL, dt.bit0_ok ? 2 : 1, NULL);
	mvchgat(0, 24, 2, A_NORMAL,
	    dt.dst_status == eDST_error ? 1 : 2, NULL);
	mvchgat(0, 29, 1, A_NORMAL, dt.bit20_ok ? 2 : 1, NULL);
	mvchgat(0, 39, 1, A_NORMAL,
	    dt.minute_status == eval_parity ? 1 :
	    dt.minute_status == eval_bcd ? 3 : 2, NULL);
	mvchgat(0, 48, 1, A_NORMAL,
	    dt.hour_status == eval_parity ? 1 :
	    dt.hour_status == eval_bcd ? 3 : 2, NULL);
	mvchgat(0, 76, 1, A_NORMAL,
	    dt.mday_status == eval_parity ? 1 :
	    (dt.mday_status == eval_bcd || dt.wday_status == eval_bcd ||
	    dt.month_status == eval_bcd || dt.year_status == eval_bcd) ? 3 : 2,
	    NULL);
	if (dt.leapsecond_status == els_one) {
		mvchgat(0, 78, 1, A_NORMAL, 3, NULL);
	}

	/* display date and time */
	mvprintw(1, 0, "%s %04d-%02d-%02d %s %02d:%02d",
	    time.tm_isdst == 1 ? "summer" : time.tm_isdst == 0 ? "winter" :
	    time.tm_isdst == -2 ? "UTC   " : "?     ", time.tm_year,
	    time.tm_mon, time.tm_mday, weekday[time.tm_wday], time.tm_hour,
	    time.tm_min);

	/* color date/time string value depending on the results */
	mvchgat(1, 0, 6, A_NORMAL, dt.dst_status == eDST_jump ? 3 : 7, NULL);
	mvchgat(1, 7, 4, A_NORMAL, dt.year_status == eval_jump ? 3 : 7, NULL);
	mvchgat(1, 12, 2, A_NORMAL, dt.month_status == eval_jump ? 3 : 7, NULL);
	mvchgat(1, 15, 2, A_NORMAL, dt.mday_status == eval_jump ? 3 : 7, NULL);
	mvchgat(1, 18, 3, A_NORMAL, dt.wday_status == eval_jump ? 3 : 7, NULL);
	mvchgat(1, 22, 2, A_NORMAL, dt.hour_status == eval_jump ? 3 : 7, NULL);
	mvchgat(1, 25, 2, A_NORMAL, dt.minute_status == eval_jump ? 3 : 7,
	    NULL);

	/* flip lights depending on the results */
	mvchgat(1, 50, 6, A_NORMAL, dt.transmit_call ? 7 : 8, NULL);
	mvchgat(1, 57, 3, A_NORMAL, !dt.dst_announce ? 8 :
	    dt.dst_status == eDST_done ? 2 : 7, NULL);
	mvchgat(1, 61, 4, A_NORMAL, !dt.leap_announce ? 8 :
	    dt.leapsecond_status == els_done ? 2 : 7, NULL);
	if (dt.minute_length == emin_long) {
		mvprintw(1, 67, "long ");
		mvchgat(1, 67, 5, A_NORMAL, 1, NULL);
	} else if (dt.minute_length == emin_short) {
		mvprintw(1, 67, "short");
		mvchgat(1, 67, 5, A_NORMAL, 1, NULL);
	} else {
		mvchgat(1, 67, 5, A_NORMAL, 8, NULL);
	}

	refresh();
}

static void
display_thirdparty_buffer(const unsigned tpbuf[])
{
	if (toosmall) {
		return;
	}

	for (int i = 0; i < TPBUFLEN; i++) {
		mvprintw(3, i + 22, "%u", tpbuf[i]);
	}
	clrtoeol();
	refresh();
}

/*
 * In live mode, reaching this point likely means a decoding error as alarm
 * messages were only broadcasted as tests between 2003-10-13 and 2003-12-10.
 */
static void
display_alarm(struct alm alarm)
{
	int i;

	if (toosmall) {
		return;
	}

	mvprintw(4, 22, "German civil warning (decoding error?)");
	clrtoeol();
	mvchgat(4, 22, -1, A_NORMAL, 3, NULL);

	for (i = 11; i < 23; i++) {
		move(i, 0);
		clrtoeol();
	}

	mvprintw(19, 0, "Regions: %s", get_region_name(alarm));
	for (i = 0; i < 2; i++) {
		mvprintw(20 + i, 0, "%u Regions: %x %x %x %x parities %x %x",
		    i, alarm.region[i].r1, alarm.region[i].r2,
		    alarm.region[i].r3, alarm.region[i].r4,
		    alarm.parity[i].ps, alarm.parity[i].pl);
	}

	refresh();
}

static void
display_unknown(void)
{
	if (toosmall) {
		return;
	}

	mvprintw(4, 22, "unknown contents");
	clrtoeol();
	mvchgat(4, 22, -1, A_NORMAL, 1, NULL);
	refresh();
}

static void
display_weather(void)
{
	if (toosmall) {
		return;
	}

	mvprintw(4, 22, "Meteotime weather");
	clrtoeol();
	mvchgat(4, 22, -1, A_NORMAL, 2, NULL);
	refresh();
}

static struct ML_result
process_input(struct ML_result in_ml, int bitpos)
{
	static unsigned input_count;
	static int input_xpos;

	struct ML_result mlr;
	int inkey;

	mlr = in_ml;
	inkey = getch();
	if (input_mode == 0 && inkey != ERR) {
		switch (inkey) {
		case 'Q':
			mlr.quit = true; /* quit main loop */
			break;
		case 'L':
			if (toosmall) {
				break;
			}
			inkey = ERR; /* prevent key repeat */
			mvprintw(23, 0, "Current log (.): %s",
			    (mlr.logfilename != NULL &&
			    strlen(mlr.logfilename) > 0) ? mlr.logfilename :
			    "(none)");
			mvprintw(24, 0, "Log file (empty for none):");
			clrtoeol();
			refresh();
			input_mode = 1;
			input_count = 0;
			input_xpos = 26;
			mlr.change_logfile = true;
			break;
		case 'S':
			if (toosmall) {
				break;
			}
			mlr.settime = !mlr.settime;
			set_time = mlr.settime;
			mvprintw(24, 43, mlr.settime ? "off" : "on ");
			refresh();
			break;
		case 'u':
			if (toosmall) {
				break;
			}
			show_utc = !show_utc;
			mvprintw(24, 63, show_utc ? "off" : "on ");
			refresh();
			break;
		case KEY_RESIZE:
			endwin();
			if (toosmall && getmaxx(stdscr) >= 80 &&
			    getmaxy(stdscr) >= 25) {
				/*
				 * Restore parts of the screen which were wiped
				 * when the screen was too small.
				*/
				draw_initial_screen();
			} else {
				refresh();
			}
			toosmall = (getmaxx(stdscr) < 80) ||
			    (getmaxy(stdscr) < 25);
			break;
		default:
			break;
		}
	}

	while (!toosmall && input_mode == 1 && inkey != ERR) {
		char dispbuf[80];

		if (input_count > 0 &&
		    (inkey == KEY_BACKSPACE || inkey == '\b' || inkey == 127)) {
			input_count--;
			input_xpos--;
			if (input_xpos > 78) {
				/* Shift display line one character to right */
				(void)strncpy(dispbuf, keybuf +
				    (input_xpos - 79), 53);
				dispbuf[54] = '\0';
				mvprintw(24, 27, "%s", dispbuf);
			} else {
				move(24, input_xpos + 1);
				clrtoeol();
			}
			refresh();
		} else if (input_count == MAXBUF - 1 ||
		    (inkey == KEY_ENTER || inkey == '\r' || inkey == '\n')) {
			/* terminate to prevent overflow */
			keybuf[input_count] = '\0';
			draw_keys();
			input_mode = -1;
		} else {
			keybuf[input_count++] = inkey;
			input_xpos++;
			if (input_xpos > 79) {
				/* Shift displayed line one character left */
				(void)strncpy(dispbuf, keybuf +
				    (input_xpos - 79), 53);
				dispbuf[54] = '\0';
				mvprintw(24, 27, "%s", dispbuf);
			} else {
				mvprintw(24, input_xpos, "%c", inkey);
			}
			refresh();
		}
		inkey = getch();
	}
	return mlr;
}

static struct ML_result
post_process_input(struct ML_result in_ml, int bitpos)
{
	struct ML_result mlr;

	mlr = in_ml;

	if (old_bitpos != -1 && (bitpos % 60 == (old_bitpos + 4) % 60 ||
	    (old_bitpos > 4 && bitpos == 1))) {
		/*
		 * Time for status text passed, cannot use *sleep() in
		 * statusbar() because that pauses reception
		 */
		old_bitpos = -1;
		draw_keys();
	}
	if (!toosmall && input_mode == -1) {
		if (in_ml.change_logfile) {
			char *old_logfilename;

			move(23, 0);
			clrtoeol();
			refresh();

			if (in_ml.logfilename == NULL) {
				mlr.logfilename = strdup("");
			}
			old_logfilename = strdup(mlr.logfilename);
			free(mlr.logfilename);
			mlr.logfilename = strdup(keybuf);
			if (strcmp(mlr.logfilename, ".") == 0) {
				free(mlr.logfilename);
				mlr.logfilename = strdup(old_logfilename);
			}

			if (strcmp(old_logfilename, mlr.logfilename) != 0) {
				if (strlen(old_logfilename) > 0 &&
				    close_logfile() != 0) {
					statusbar(bitpos,
					    "Error closing old log file");
					mlr.quit = true; /* error */
				}
				if (strlen(mlr.logfilename) > 0) {
					int res;

					res = append_logfile(mlr.logfilename);
					if (res != 0) {
						statusbar(bitpos,
						    strerror(res));
						mlr.quit = true; /* error */
					}
				}
			}
			free(old_logfilename);
			mlr.change_logfile = false;
		}
		input_mode = 0;
	}
	refresh();
	return mlr;
}

static void
wipe_input()
{
	if (!toosmall && get_bitpos() == 0) {
		move(6, 3);
		clrtoeol();
		refresh();
	}
}

static void
display_long_minute(void)
{
	if (toosmall) {
		return;
	}

	mvprintw(9, 58, "no minute");
	mvchgat(9, 58, 9, A_NORMAL, 1, NULL);
}

static void
display_minute(int minlen)
{
	int bp, cutoff, xpos;

	if (toosmall) {
		return;
	}

	/* display bits of previous minute */
	for (xpos = 4, bp = 0; bp < minlen && bp < 60; bp++, xpos++) {
		if (is_space_bit(bp)) {
			xpos++;
		}
		mvprintw(0, xpos, "%u", get_buffer()[bp]);
	}
	clrtoeol();
	mvchgat(0, 0, -1, A_NORMAL, 7, NULL);

	/* display minute cutoff value */
	cutoff = get_cutoff();
	if (cutoff < 10000 || cutoff > 30000) {
		mvprintw(1, 40, "?     ");
		mvchgat(1, 40, 1, A_NORMAL, 3, NULL);
	} else {
		mvprintw(1, 40, "%6.4f", cutoff / 1e4);
		mvchgat(1, 40, 6, A_NORMAL, 7, NULL);
	}

	refresh();
}

static struct ML_result
process_setclock_result(struct ML_result in_ml, int bitpos)
{
	struct ML_result mlr;

	mlr = in_ml;
	mlr.quit = false;
	switch (mlr.settime_result) {
	case esc_invalid:
		statusbar(bitpos, "mktime() failed");
		mlr.quit = true; /* error */
		break;
	case esc_fail:
		statusbar(bitpos, "clock_settime(): %s", strerror(errno));
		mlr.quit = true; /* error */
		break;
	case esc_unsafe:
		statusbar(bitpos, "Too early or unsafe to set the time");
		break;
	case esc_ok:
		statusbar(bitpos, "Time set");
		break;
	}
	return mlr;
}

int
main(int argc, char *argv[])
{
	struct json_object *config, *value;
	int res;

	config = json_object_from_file(ETCDIR "/config.json");
	if (config == NULL) {
		/* non-existent file? */
		client_cleanup(NULL);
		return EX_NOINPUT;
	}
	if (json_object_object_get_ex(config, "outlogfile", &value)) {
		logfilename = (char *)json_object_get_string(value);
	}
	if (logfilename != NULL && strlen(logfilename) != 0) {
		res = append_logfile(logfilename);
		if (res != 0) {
			perror("fopen(logfile)");
			client_cleanup(NULL);
			return res;
		}
	}
	res = set_mode_live(config);
	if (res != 0) {
		/* something went wrong */
		client_cleanup("set_mode_live() failed");
		return res;
	}

	initscr();
	if (has_colors() == FALSE || start_color() == ERR) {
		client_cleanup("No required color support.");
		return 0;
	}
	if (getmaxx(stdscr) < 80 || getmaxy(stdscr) < 25) {
		client_cleanup("Window too small, minimum is 80 columns by 25 rows.");
		return 0;
	}

	init_pair(1, COLOR_RED, COLOR_BLACK);
	init_pair(2, COLOR_GREEN, COLOR_BLACK);
	init_pair(3, COLOR_YELLOW, COLOR_BLACK);
	init_pair(5, COLOR_MAGENTA, COLOR_BLACK);
	init_pair(7, COLOR_WHITE, COLOR_BLACK);
	init_pair(8, COLOR_BLACK, COLOR_BLACK); /* A_INVIS does not work */

	noecho();
	nonl();
	cbreak();
	nodelay(stdscr, TRUE);
	keypad(stdscr, TRUE);
	curs_set(0);

	draw_initial_screen();

	mainloop(logfilename, get_bit_live, display_bit, display_long_minute,
	    display_minute, wipe_input, display_alarm, display_unknown,
	    display_weather, display_time, display_thirdparty_buffer,
	    process_setclock_result, process_input, post_process_input);

	client_cleanup(NULL);
	return res;
}