src/chess/pgn.c

/*
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
 *
 * Copyright 2016 Mike Becker. All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 *   1. Redistributions of source code must retain the above copyright
 *      notice, this list of conditions and the following disclaimer.
 *
 *   2. Redistributions in binary form must reproduce the above copyright
 *      notice, this list of conditions and the following disclaimer in the
 *      documentation and/or other materials provided with the distribution.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
 * POSSIBILITY OF SUCH DAMAGE.
 *
 */

#include "pgn.h"

#include <stdlib.h>
#include <ctype.h>
#include <string.h>
#include <sys/time.h>
#include <time.h>

static const char* pgn_error_strings[] = {
    "No Error.",
    "Tag values must be enclosed in double-quotes.",
    "Missing closing brace '}' for comment.",
    "Tags must be enclosed in square brackets: '[Key \"Value\"]'.",
    "Move numbers must be terminated with a dot (e.g. '13.' - not '13').",
    "Move is syntactically incorrect.",
    "Move is not valid according to chess rules.",
    "Result syntax is incorrect. Expected 1-0, 0-1, 1/2-1/2, or *.",
    "Result at end of move text does not match result in tag roster.",
    "Unexpected end of data.",
};

const char* pgn_error_str(int code) {
    return pgn_error_strings[code];
}

size_t pgn_error_pos;

size_t pgn_error_position(void) {
    return pgn_error_pos;
}

static const char *pgn_result(GameState *gamestate) {
    if (gamestate->stalemate || gamestate->remis) {
        return "1/2-1/2";
    } else if (gamestate->wresign) {
        return "0-1";
    } else if (gamestate->bresign) {
        return "1-0";
    } else if (gamestate->checkmate) {
        if (current_color(gamestate) == BLACK) {
            return "1-0";
        } else {
            return "0-1";
        }
    } else {
        return "*";
    }
}

#define return(code) pgn_error_pos = pgndata - pgndata0; return code

int parse_pgn(const char *pgndata, GameState *gamestate) {
    const char * const pgndata0 = pgndata;
    int i;
    char c;
    
    char result[8] = {0};
    
    char tagkey[32];
    char tagvalue[128];
    
    /* read tag pairs */
    while (true) {
        while (isspace(c = *(pgndata++)));
        if (c == '1') {
            break;
        }
        if (c != '[') {
            return(pgn_error_missing_bracket);
        }
        while (isspace(c = *(pgndata++)));
        i = 0;
        do {
            tagkey[i++] = c;
        } while (!isspace(c = *(pgndata++)));
        tagkey[i] = '\0';
        while (isspace(c = *(pgndata++)));
        if (c != '"') {
            return(pgn_error_missing_quote);
        }
        i = 0;
        while ((c = *(pgndata++)) != '"') {
            if (c == '\n' || c == 0) {
                return(pgn_error_missing_quote);
            }
            tagvalue[i++] = c;
        }
        tagvalue[i] = '\0';
        if (*(pgndata++) != ']') {
            return(pgn_error_missing_bracket);
        }

        // TODO: read clock info

        if (strcmp("Result", tagkey) == 0) {
            memcpy(result, tagvalue, 8);
        }
    }
    
    /* read moves */
    if (*(pgndata++) != '.') {
        return(pgn_error_missing_dot);
    }
    
    char movestr[10];
    Move move;
    uint8_t curcol = WHITE;
    bool movetext_ends_with_result = false;
    
    while (true) {
        /* move */
        while (isspace(c = *(pgndata++)));
        i = 0;
        do {
            movestr[i++] = c;
            if (i >= 10) {
                return(pgn_error_move_syntax);
            }
        } while (!isspace(c = *(pgndata++)));
        movestr[i] = '\0';
        if (eval_move(gamestate, movestr, &move, curcol)
                != VALID_MOVE_SYNTAX) {
            return(pgn_error_move_syntax);
        }
        if (validate_move(gamestate, &move) != VALID_MOVE_SEMANTICS) {
            return(pgn_error_move_semantics);
        }
        apply_move(gamestate, &move);
        
        /* skip spaces */
        while (isspace(c = *(pgndata++)));
        
        /* parse possible comment */
        if (c == '{') {
            // TODO: interpret comment (may contain clock info)
            do {
                c = *(pgndata++);
            } while (c != '}' && c != 0);
            if (c == 0) {
                return(pgn_error_missing_brace);
            }
            /* skip spaces */
            while (isspace(c = *(pgndata++)));
        }
        
        /* end of game data encountered */
        if (c == 0) {
            break;
        }
        if (c == '1' || c == '0') {
            c = *(pgndata++);
            // TODO: #842 - allow games to be continued if possible
            if (c == '-') {
                if (!gamestate->checkmate) {
                    // TODO: maybe we should not parse this here;
                    //       there is an unused result string from the STR
                    c = *(pgndata++);
                    if (c == '1') {
                        gamestate->wresign = true;
                    } else if (c == '0') {
                        gamestate->bresign = true;
                    } else {
                        return(pgn_error_result_syntax);
                    }
                }
                movetext_ends_with_result = true;
                break;
            } else if (c == '/') {
                gamestate->remis = !gamestate->stalemate;
                movetext_ends_with_result = true;
                break;
            } else {
                /* oops, it was a move number, go back! */
                pgndata--;
            }
        }
        
        /* we have eaten the next valuable byte, so go back */
        pgndata--;
        
        /* skip move number after black move */
        if (curcol == BLACK) {
            while (isdigit(c = *(pgndata++)));
            if (c != '.') {
                return(pgn_error_missing_dot);
            }
        }
        curcol = opponent_color(curcol);
    }

    /* sanity check result - if it was specified */
    if (movetext_ends_with_result && result[0]) {
        if (strncmp(result, pgn_result(gamestate), 8) != 0) {
            return(pgn_error_result_mismatch);
        }
    }
    
    return(pgn_no_error);
}

#undef return

int read_pgn(FILE *stream, GameState *gamestate) {
    fseek(stream, 0, SEEK_END);
    long int size = ftell(stream);
    fseek(stream, 0, SEEK_SET);
    char *data = malloc(size + 1);
    memset(data, 0, size + 1);
    size_t read = 0;
    do {
        size_t r = fread(data + read, 1, size - read, stream);
        if (r == 0) {
            pgn_error_pos = read;
            return pgn_error_unexpected_eof;
        }
        read += r;
    } while (read < size);
    int result = parse_pgn(data, gamestate);
    free(data);
    return result;
}

static void pgn_insert_newlines(char *block) {
    size_t pos = 0;
    size_t last_space_pos = 0;
    size_t line_len = 0;
    while (block[pos] != '\0') {
        if (block[pos] == 0x1f) {
            block[pos++] = ' ';
            continue;
        }
        if (block[pos] == ' ') {
            last_space_pos = pos;
        }
        line_len++;
        if (line_len > 80) {
            block[last_space_pos] = '\n';
            line_len = pos - last_space_pos;
        }
        pos++;
    }
}

static const char *pgn_date(GameState *gamestate) {
    static char date[16];
    time_t dateseconds;
    if (gamestate->movecount == 0) {
        struct timeval curtimestamp;
        gettimeofday(&curtimestamp, NULL);
        dateseconds = curtimestamp.tv_sec;
    } else {
        dateseconds = (time_t) gamestate->moves[0].timestamp.tv_sec;
    }
    struct tm *tm = gmtime(&dateseconds);
    if (tm == NULL) {
        /* fallback - should never happen in reality */
        strncpy(date, "????.??.??", sizeof(date));
    } else {
        int year = tm->tm_year + 1900;
        int month = tm->tm_mon + 1;
        int day = tm->tm_mday;
#ifdef __GNUC__
        /* this is required to tell GCC that it does not need to warn
         * about the small buffer size of the date string.
         */
        if (year < 1900 || year > 9999) __builtin_unreachable();
        if (month < 1 || month > 12) __builtin_unreachable();
        if (day < 1 || day > 31) __builtin_unreachable();
#endif
        snprintf(date, sizeof(date), "%04d.%02d.%02d",
            year, month, day);
    }
    return date;
}

const char *pgn_player_name(GameState *gamestate, uint8_t color) {
    const char *name = color == WHITE ? gamestate->wname : gamestate->bname;
    return name[0] != '\0' ? name : "Anonymous";
}

void write_pgn(FILE* stream, GameState *gamestate, bool export_comments) {
    /* STR tag pairs */
    fprintf(stream, "[Event \"%s\"]\n", "terminal-chess game");
    fprintf(stream, "[Site \"%s\"]\n", "Somewhere on Earth");
    fprintf(stream, "[Date \"%s\"]\n", pgn_date(gamestate));
    fprintf(stream, "[Round \"%s\"]\n", "-");
    fprintf(stream, "[White \"%s\"]\n", pgn_player_name(gamestate, WHITE));
    fprintf(stream, "[Black \"%s\"]\n", pgn_player_name(gamestate, BLACK));
    const char *result = pgn_result(gamestate);
    fprintf(stream, "[Result \"%s\"]\n\n", result);

    // TODO: add optional clock info
    
    /* moves */
    size_t moveblkcap = 4096;
    char *moveblk = malloc(moveblkcap);
    char *moveblkptr = moveblk;
    if (moveblk == NULL) {
        // TODO: error handling (for the entire function actually)
        abort();
    }
    for (unsigned i = 0 ; i < gamestate->movecount ; i++) {
        /* reallocate move block buffer if needed */
        {
            size_t moveblksize = moveblkptr - moveblk;
            if (moveblksize + 128 > moveblkcap) {
                moveblkcap *= 2;
                char *newmoveblk = realloc(moveblk, moveblkcap);
                if (newmoveblk == NULL) {
                    free(moveblk);
                    abort();
                }
                moveblk = newmoveblk;
                moveblkptr = moveblk + moveblksize;
            }
        }

        int snpr; /* return value of printf calls */

        if (i % 2 == 0) {
            snpr = snprintf(moveblkptr, 16, "%d.\x1f%s",
                1+i/2, gamestate->moves[i].string);
        } else {
            snpr = snprintf(moveblkptr, 16, "%s",
                gamestate->moves[i].string);
        }
        moveblkptr += snpr;

        if (!export_comments) {
            *(moveblkptr++) = ' ';
            continue;
        }

        /* add clock times when the game was under time control */
        if (gamestate->info.timecontrol) {
            memcpy(moveblkptr, " {[%clk ", 8);
            moveblkptr += 8;
            unsigned clkmv = i + 2; /* time for the next move! */
            uint16_t clk = remaining_movetime2(gamestate, clkmv);
            snpr = print_clk(clk, moveblkptr, true);
            moveblkptr += snpr;
            *(moveblkptr++) = ']';
            *(moveblkptr++) = '}';
            
            /* elapsed move time */
            memcpy(moveblkptr, " {[%emt ", 8);
            moveblkptr += 8;
            uint16_t emt = gamestate->moves[i].movetime.tv_sec;
            snpr = print_clk(emt, moveblkptr, true);
            moveblkptr += snpr;
            *(moveblkptr++) = ']';
            *(moveblkptr++) = '}';
        }
        
        *(moveblkptr++) = ' ';
    }
    
    if (result[0] != '*') {
        size_t rlen = strlen(result);
        memcpy(moveblkptr, result, rlen);
        moveblkptr += rlen;
    }
    *(moveblkptr++) = '\n';
    *moveblkptr = 0;

    pgn_insert_newlines(moveblk);
    fputs(moveblk, stream);

    free(moveblk);
}