writer.c

Go to the documentation of this file.

 
#include <ascii-chat/terminal/fd/writer.h>
#include <ascii-chat/platform/memory.h>
#include <ascii-chat/log/log.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <ascii-chat/platform/abstraction.h>
 
typedef struct terminal_fd_writer_s {
  FILE *fp; // File pointer created from FD
} terminal_fd_writer_t;
 
asciichat_error_t terminal_fd_writer_create(int fd, terminal_fd_writer_t **out) {
  if (fd < 0) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid fd: %d", fd);
  }
 
  FILE *fp = platform_fdopen("terminal_fd_writer", fd, "w");
  if (!fp) {
    return SET_ERRNO_SYS(ERROR_INVALID_PARAM, "fdopen failed for FD %d", fd);
  }
 
  terminal_fd_writer_t *writer = SAFE_CALLOC(1, sizeof(*writer), terminal_fd_writer_t *);
  writer->fp = fp;
 
  log_debug("terminal_fd_writer: created with fd=%d", fd);
  *out = writer;
  return ASCIICHAT_OK;
}
 
asciichat_error_t terminal_fd_writer_write(terminal_fd_writer_t *writer, const char *frame) {
  if (!writer) {
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid writer context");
  }
 
  if (!frame) {
    return ASCIICHAT_OK; // No-op for NULL frame
  }
 
  // Write frame and newline
  int ret = fprintf(writer->fp, "%s\n", frame);
  if (ret < 0) {
    return SET_ERRNO_SYS(ERROR_INVALID_PARAM, "fprintf failed");
  }
 
  // Flush to ensure output is visible immediately
  int flush_ret = fflush(writer->fp);
  if (flush_ret != 0) {
    return SET_ERRNO_SYS(ERROR_INVALID_PARAM, "fflush failed");
  }
 
  log_debug_every(NS_PER_SEC_INT, "terminal_fd_writer: wrote frame (%zu bytes)", strlen(frame));
  return ASCIICHAT_OK;
}
 
void terminal_fd_writer_destroy(terminal_fd_writer_t *writer) {
  if (!writer)
    return;
  if (writer->fp) {
    fclose(writer->fp);
    writer->fp = NULL;
  }
  SAFE_FREE(writer);
}