[plomrogue] / src / client / io.c

/* src/client/io.c */

#include "io.h"
#include <errno.h> /* global errno */
#include <fcntl.h> /* open() */
#include <limits.h> /* PIPE_BUF */
#include <ncurses.h> /* halfdelay(), getch() */
#include <stddef.h> /* NULL */
#include <stdint.h> /* uint8_t, uint16_t, uint32_t */
#include <stdio.h> /* FILE, sprintf(), fseek() */
#include <string.h> /* strcmp(), strlen(), memcpy() */
#include <stdlib.h> /* free(), atoi() */
#include <sys/stat.h> /* stat() */
#include <unistd.h> /* access(), write() */
#include "../common/try_malloc.h" /* try_malloc() */
#include "../common/rexit.h" /* exit_trouble(), exit_err() */
#include "../common/readwrite.h" /* try_fopen(), try_fclose(), try_fgets(),
                                  * try_fgetc(), textfile_width()
                                  */
#include "control.h" /* try_key() */
#include "map.h" /* map_center() */
#include "misc.h" /* reset_windows() */
#include "windows.h" /* reset_windows_on_winch(), draw_all_wins() */
#include "world.h" /* world global */



/* Read next lines of "file" up to (and excluding) a line "%\n" into the
 * world.player_inventory string.
 */
static void read_inventory(char * read_buf, uint32_t linemax, FILE * file);

/* Read the next characters in "file" into world.map.cells. In detail: Read
 * world.map.size.y times world.map.size.x characters, followed by one ignored
 * character (that we assume is a newline).
 */
static void read_map_cells(FILE * file);

/* Repeatedly use try_fgets() with given arguments to read the remaining lines
 * of "file" into the world.log string.
 */
static void read_log(char * read_buf, uint32_t linemax, FILE * file);

/* Return value seen by atoi() in next line of "file" when passed to try_fgets()
 * with the given arguments.
 */
static uint16_t read_value_from_line(char * read_buf, uint32_t linemax,
                                     FILE * file);

/* If the server's out file has changed since the last read_world(), return a
 * pointer to its file descriptor; else, return NULL.
 *
 * Two tests are performed to check for a file change. The file's last data
 * modification time in seconds via stat() is compared against world.last_update
 * (and if it is changed, world.last_update is re-set to it). If this does not
 * verify a change, the first bytes of the file are read to compare the game
 * turn number described therein to the last read turn number in world.turn.
 *
 * The stat() check is mostly useless, for it only detects file updates once a
 * second. But the turn check fails if a new world is generated from turn 1 on:
 * the new world also starts in turn 1, not signifying any world change to the
 * turn check. The stat() check detects this change with at most 1 second delay.
 */
static FILE * changed_server_out_file(char * path);

/* Attempt to read the server's out file as representation of the game world in
 * a hard-coded serialization format. Returns 1 on success and 0 if the out file
 * wasn't read for supposedly not having changed since a last read_world() call.
 *
 * map_center() is triggered by the first successful read_world() or on turn 1,
 * so the client focuses the map window on the player on client and world start.
 */
static uint8_t read_world();



static void read_inventory(char * read_buf, uint32_t linemax, FILE * file)
{
    char * f_name = "read_inventory()";
    char * delimiter = "%\n";
    free(world.player_inventory);
    world.player_inventory = NULL;          /* Avoids illegal strlen() below. */
    while (1)
    {
        try_fgets(read_buf, linemax + 1, file, f_name);
        if (!(strcmp(read_buf, delimiter)))
        {
            break;
        }
        int old_size = 0;
        if (NULL != world.player_inventory)
        {
            old_size = strlen(world.player_inventory);
        }
        int new_size = strlen(read_buf);
        char * new_inventory = try_malloc(old_size + new_size + 1, f_name);
        memcpy(new_inventory, world.player_inventory, old_size);
        sprintf(new_inventory + old_size, "%s", read_buf);
        free(world.player_inventory);
        world.player_inventory = new_inventory;
    }
    world.player_inventory[strlen(world.player_inventory) - 1] = '\0';
    world.player_inventory_select = 0;
}



static void read_map_cells(FILE * file)
{
    char * f_name = "read_map_cells()";
    free(world.map.cells);
    world.map.cells = try_malloc(world.map.size.y * world.map.size.x, f_name);
    uint16_t y, x;
    for (y = 0; y < world.map.size.y; y++)
    {
        for (x = 0; x < world.map.size.x; x++)
        {
            char c = try_fgetc(file, f_name);
            world.map.cells[(y * world.map.size.x) + x] = c;
        }
        try_fgetc(file, f_name);
    }
}



static void read_log(char * read_buf, uint32_t linemax, FILE * file)
{
    char * f_name = "read_log()";
    free(world.log);
    world.log = NULL;
    while (try_fgets(read_buf, linemax + 1, file, f_name))
    {
        int old_size = 0;
        if (NULL != world.log)
        {
            old_size = strlen(world.log);
        }
        int new_size = strlen(read_buf);
        char * new_log = try_malloc(old_size + new_size + 1, f_name);
        memcpy(new_log, world.log, old_size);
        sprintf(new_log + old_size, "%s", read_buf);
        free(world.log);
        world.log = new_log;
    }
}



static uint16_t read_value_from_line(char * read_buf, uint32_t linemax,
                                     FILE * file)
{
    char * f_name = "read_value_from_line()";
    try_fgets(read_buf, linemax + 1, file, f_name);
    return atoi(read_buf);
}



static FILE * changed_server_out_file(char * path)
{
    char * f_name = "changed_server_out_file()";
    struct stat stat_buf;
    exit_trouble(stat(path, &stat_buf), f_name, "stat()");
    if (stat_buf.st_mtime != world.last_update)
    {
        world.last_update = stat_buf.st_mtime;
        return try_fopen(path, "r", f_name);
    }
    FILE * file = try_fopen(path, "r", f_name);
    char turn_string[6];
    try_fgets(turn_string, 6, file, f_name);
    if (world.turn == atoi(turn_string))
    {
        try_fclose(file, f_name);
        return NULL;
    }
    exit_trouble(fseek(file, 0, SEEK_SET), f_name, "fseek()");
    return file;
}



static uint8_t read_world()
{
    char * f_name = "read_world()";
    char * path = "server/out";
    char * quit_msg = "No server out file found to read. Server may be down.";
    static uint8_t first_read = 1;
    exit_err(access(path, F_OK), quit_msg);
    FILE * file = changed_server_out_file(path);
    if (!file)
    {
        return 0;
    }
    uint32_t linemax = textfile_width(file);
    char * read_buf = try_malloc(linemax + 1, f_name);
    world.turn = read_value_from_line(read_buf, linemax, file);
    world.player_lifepoints = read_value_from_line(read_buf, linemax, file);
    read_inventory(read_buf, linemax, file);
    world.player_pos.y = read_value_from_line(read_buf, linemax, file);
    world.player_pos.x = read_value_from_line(read_buf, linemax, file);
    if (1 == world.turn || first_read)
    {
        map_center();
        first_read = 0;
    }
    world.map.size.y = read_value_from_line(read_buf, linemax, file);
    world.map.size.x = read_value_from_line(read_buf, linemax, file);
    read_map_cells(file);
    read_log(read_buf, linemax, file);
    free(read_buf);
    try_fclose(file, f_name);
    return 1;
}



extern void try_send(char * msg)
{
    char * f_name = "try_send()";
    uint32_t msg_size = strlen(msg) + 1;
    char * err = "try_send() tries to send message larger than PIPE_BUF bytes.";
    exit_err(msg_size > PIPE_BUF, err);
    int fd_out;
    uint16_t j = 1;
    while (0 != j)
    {
        fd_out = open(world.path_server_in, O_WRONLY | O_NONBLOCK);
        if (fd_out > 0)
        {
            break;
        }
        exit_err(-1 == fd_out && ENXIO != errno, "Server fifo not found.");
        j++;
    }
    exit_err(0 == j, "Failed to open server fifo for writing.");
    j = 1;
    while (0 != j)
    {
        int test = write(fd_out, msg, msg_size);
        if (test > 0)
        {
            break;
        }
        j++;
    }
    exit_err(0 == j, "Failed to write to server fifo.");
    exit_trouble(-1 == close(fd_out), f_name, "close()");
}



extern char * io_loop()
{
    world.halfdelay = 1;            /* Ensures read_world() is only called 10 */
    halfdelay(world.halfdelay);     /* times a second during user inactivity. */
    uint8_t change_in_client = 0;
    while (1)
    {
        if (world.winch)
        {
            reset_windows_on_winch();
            world.winch = 0;
            change_in_client++;
        }
        if (read_world() || change_in_client)
        {
            draw_all_wins();
        }
        change_in_client = 0;
        int key = getch();
        if (ERR != key)
        {
            change_in_client = try_key((uint16_t) key);
            if (2 == change_in_client)
            {
                break;
            }
        }
    }
    try_send("QUIT");
    return "Sent QUIT to server.";
}