HardCompound/src/main.c

#include <duckdb.h>
#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/stat.h>

#include "exit_code.h"
#include "lapinfo.h"

bool is_valid_path(const char *path) {
    if (path == NULL) {
        return false;
    }

    const char *dot = strrchr(path, '.'); // find the last dot which is for the extension
    if (!dot || strcmp(dot, ".duckdb") != 0) {
        return false;
    }

    struct stat path_stat;
    if (stat(path, &path_stat) != 0) {
        return false; // path does not exist
    }

    if (!S_ISREG(path_stat.st_mode)) {
        return false; // checks if it is a regular file
    }

    return true;
}

void get_data_from_db(const char *query, duckdb_connection *conn, TelemetryInfo *info) {
    duckdb_result result;

    duckdb_query(*conn, query, &result);

    while (true) {
        duckdb_data_chunk data_chunk = duckdb_fetch_chunk(result);
        if (!data_chunk) {
            break;
        }

        idx_t row_count = duckdb_data_chunk_get_size(data_chunk); // number of rows from the data chunk

        // set column
        duckdb_vector col1 = duckdb_data_chunk_get_vector(data_chunk, 0);
        void *col1_data = duckdb_vector_get_data(col1);
        uint64_t *col1_validity = duckdb_vector_get_validity(col1);

        for (idx_t row = 0; row < row_count; row++) {
            if (duckdb_validity_row_is_valid(col1_validity, row)) {
                switch (info->type) {
                case FLOAT:
                    ((float *)info->data)[info->data_last_index] = ((float *)col1_data)[row];
                    info->data_last_index++;
                    break;
                case BOOL:
                    ((bool *)info->data)[info->data_last_index] = ((bool *)col1_data)[row];
                    info->data_last_index++;
                    break;
                case DOUBLE:
                    ((double *)info->data)[info->data_last_index] = ((double *)col1_data)[row];
                    info->data_last_index++;
                    break;
                case INT:
                    ((int32_t *)info->data)[info->data_last_index] = ((int32_t *)col1_data)[row];
                    info->data_last_index++;
                    break;
                }
                // printf("%f, ", ((float *)col1_data)[row]);
            } else {
                printf("NULL");
            }
        }

        duckdb_destroy_data_chunk(&data_chunk);
    }
    duckdb_destroy_result(&result);
}

int main(int argc, char **argv) {
    printf("\nHello from HardCompound!\n");

    if (argc < 2) {
        printf("You need to specify a duckdb file path! Terminating!\n");
        exit(ERR_ARGUMENT);
    }

    if (!is_valid_path(argv[1])) {
        printf("The file you gave is not valid. Exiting!");
        exit(ERR_FILE);
    }

    printf("First argument: %s\n", argv[1]);

    duckdb_database db;
    if (duckdb_open(argv[1], &db) == DuckDBError) {
        printf("Error opening duckdb file, terminating!\n");
        exit(ERR_DATABASE);
    }

    duckdb_connection conn;
    if (duckdb_connect(db, &conn) == DuckDBError) {
        printf("Error connecting to the duckdb database! Terminating!\n");
        duckdb_close(&db);
        exit(ERR_CONNECTION);
    }

    // get how many laps is in the session and  allocate that many LapInfo-s
    duckdb_result lap_count_res;
    int32_t lap_count = 0;
    duckdb_query(conn, "Select count(value) from Lap\n", &lap_count_res);

    duckdb_data_chunk data_chunk = duckdb_fetch_chunk(lap_count_res);
    if (!data_chunk) {
        printf("Error in retrieving laps");
        duckdb_disconnect(&conn);
        duckdb_close(&db);
        exit(ERR_QUERY);
    }

    // set column
    duckdb_vector col1 = duckdb_data_chunk_get_vector(data_chunk, 0);
    int32_t *col1_data = (int32_t *)duckdb_vector_get_data(col1);
    uint64_t *col1_validity = duckdb_vector_get_validity(col1);
    idx_t row_count = duckdb_data_chunk_get_size(data_chunk); // number of rows from the data chunk

    for (idx_t row = 0; row < row_count; row++) {
        if (duckdb_validity_row_is_valid(col1_validity, 0)) {
            lap_count = col1_data[0];
        }
    }

    duckdb_destroy_data_chunk(&data_chunk);
    duckdb_destroy_result(&lap_count_res);

    printf("Lap count: %d\n", lap_count);
    LapInfo *session_data = calloc(lap_count, sizeof(LapInfo));
    double *lap_timestamps = calloc(lap_count, sizeof(double));

    if (!session_data) {
        printf("Session data failed to allocate!");
        exit(ERR_MEMORY);
    }

    if (!lap_timestamps) {
        printf("Lap timestaps array failed to init!");
        exit(ERR_MEMORY);
    }

    duckdb_result lap_timestamps_res;
    if (duckdb_query(conn, "Select ts as DOUBLE from Lap\n", &lap_timestamps_res) == DuckDBError) {
        exit(ERR_QUERY);
    }

    int current_index = 0;
    while (true) {
        duckdb_data_chunk data_chunk_2 = duckdb_fetch_chunk(lap_timestamps_res);
        if (!data_chunk_2) {
            break;
        }

        idx_t current_chunk_size = duckdb_data_chunk_get_size(data_chunk_2);

        duckdb_vector col2 = duckdb_data_chunk_get_vector(data_chunk_2, 0);
        double *ts_data = (double *)duckdb_vector_get_data(col2);
        uint64_t *col2_validity = duckdb_vector_get_validity(col2);

        for (idx_t row = 0; row < current_chunk_size; row++) {
            if (!col2_validity || duckdb_validity_row_is_valid(col2_validity, row)) {
                if (current_index < lap_count) {
                    lap_timestamps[current_index++] = ts_data[row];
                }
            }
        }

        duckdb_destroy_data_chunk(&data_chunk_2);
    }

    duckdb_destroy_result(&lap_timestamps_res);

    for (int i = 0; i < lap_count; i++) {
        printf("%f, ", lap_timestamps[i]);
    }
    printf("\n");

    free(session_data);
    printf("Shutting down HardCompound!\n");

    printf("Closing database and any connection.\n");
    duckdb_disconnect(&conn);
    duckdb_close(&db);

    return EXIT_OK;
}