#ifndef QUICKMEDIA_PROGRAM_HPP
#define QUICKMEDIA_PROGRAM_HPP

#include <sys/types.h>
#include <thread>

struct ReadProgram {
    pid_t pid = -1;
    int read_fd = -1;
};

int accumulate_string(char *data, int size, void *userdata);

/* Return 0 if you want to continue reading. @data is null-terminated */
typedef int (*ProgramOutputCallback)(char *data, int size, void *userdata);

/*
    @args need to have at least 2 arguments. The first which is the program name
    and the last which is NULL, which indicates end of args
*/
int exec_program_pipe(const char **args, ReadProgram *read_program);

/*
    @args need to have at least 2 arguments. The first which is the program name
    and the last which is NULL, which indicates end of args.
    |buffer_size| has to be between 1 and 65536.
*/
int exec_program_write_stdin(const char **args, const char *str, size_t size, ProgramOutputCallback output_callback, void *userdata, int buffer_size = 16384);

/*
    @args need to have at least 2 arguments. The first which is the program name
    and the last which is NULL, which indicates end of args.
    |buffer_size| has to be between 1 and 65536.
*/
int exec_program(const char **args, ProgramOutputCallback output_callback, void *userdata, int buffer_size = 16384);
int exec_program(const char **args, ProgramOutputCallback output_callback, void *userdata, int *allowed_exit_status, int num_allowed_exit_status, int buffer_size = 16384);

// Return the exit status, or a negative value if waiting failed
int wait_program(pid_t process_id);

/* Returns 1 if the program quit and exited properly (non-0 exit codes also count as exiting properly) */
int wait_program_non_blocking(pid_t process_id, int *status);

/*
    @args need to have at least 2 arguments. The first which is the program name
    and the last which is NULL, which indicates end of args.
    @result_process_id should be set to NULL if you are not interested in the exit status of the child process
    and you want the child process to be cleaned up automatically when it dies.
*/
int exec_program_async(const char **args, pid_t *result_process_id);

void program_clear_current_thread();
void program_kill_in_thread(std::thread::id thread_id);
bool program_is_dead_in_thread(std::thread::id thread_id);
bool program_is_dead_in_current_thread();

#endif /* QUICKMEDIA_PROGRAM_HPP */