main.c File Reference

Go to the source code of this file.

Data Structures
struct	api_server_t
struct	api_render_job

Typedefs
typedef struct api_render_job	api_render_job_t

Functions
int	api_server_main (void)

Typedef Documentation

api_render_job_t

typedef struct api_render_job api_render_job_t

Definition at line 20 of file api-server/main.c.

Function Documentation

api_server_main()

int api_server_main

(

void

)

Definition at line 492 of file api-server/main.c.

                          {
  http_server_t *server = NULL;
  api_server_t api = {0};
  quic_endpoint_t *http3_endpoint = NULL;
  quic_endpoint_t *http3_endpoint6 = NULL;
  const char *tls_cert = GET_OPTION(tls_cert);
  const char *tls_key = GET_OPTION(tls_key);
  const char *tls_password = GET_OPTION(tls_key_password);
  if (!tls_cert || !*tls_cert)
    tls_cert = NULL;
  if (!tls_key || !*tls_key)
    tls_key = NULL;
  if (!tls_password || !*tls_password)
    tls_password = NULL;
  http_server_config_t config = {.bind_address = GET_OPTION(address),
                                 .bind_address6 = GET_OPTION(address6),
                                 .port = (uint16_t)GET_OPTION(port),
                                 .enable_http1 = true,
                                 .enable_http2 = true,
                                 .enable_http3 = false,
                                 .tls_cert_path = tls_cert,
                                 .tls_key_path = tls_key,
                                 .tls_key_password = tls_password,
                                 .max_connections = (size_t)GET_OPTION(max_clients),
                                 .max_request_body_bytes = 10u * 1024u * 1024u,
                                 .max_response_body_bytes = 8u * 1024u * 1024u,
                                 .on_request = api_request,
                                 .on_wakeup = api_wakeup};
  if (!config.max_connections)
    config.max_connections = 1;
  asciichat_error_t err = ASCIICHAT_OK;
  http_renderer_config_t renderer_config = {.max_jobs = (unsigned)config.max_connections,
                                            .max_input_bytes = config.max_request_body_bytes,
                                            .max_output_bytes = config.max_response_body_bytes,
                                            .timeout_ms = 10000,
                                            .restricted = true,
                                            .on_complete = api_render_complete,
                                            .on_error = api_render_error,
                                            .user_data = &api};
  err = http_renderer_init(&api.renderer, &renderer_config);
  if (err != ASCIICHAT_OK)
    return err;
  config.on_request = api_request;
  config.user_data = &api;
  err = http_server_init(&server, &config);
  if (err != ASCIICHAT_OK) {
    LOG_ERRNO_IF_SET("API HTTP server initialization failed");
    http_renderer_destroy(&api.renderer);
    return err;
  }
  api.http = server;
  if (tls_cert && tls_key) {
    struct sockaddr_storage bind_address;
    socklen_t bind_length = 0;
    err = parse_numeric_socket_address(GET_OPTION(address), (uint16_t)GET_OPTION(port), &bind_address, &bind_length);
    if (err == ASCIICHAT_OK) {
      quic_config_t quic_config = {.alpn = "h3",
                                   .certificate_file = tls_cert,
                                   .private_key_file = tls_key,
                                   .enable_http3 = true,
                                   .http_server = server};
      err =
          quic_endpoint_open((const struct sockaddr *)&bind_address, bind_length, true, &quic_config, &http3_endpoint);
      if (err == ASCIICHAT_OK && GET_OPTION(address6) && *GET_OPTION(address6)) {
        struct sockaddr_storage bind_address6;
        socklen_t bind_length6 = 0;
        err = parse_numeric_socket_address(GET_OPTION(address6), (uint16_t)GET_OPTION(port), &bind_address6,
                                           &bind_length6);
        if (err == ASCIICHAT_OK)
          err = quic_endpoint_open((const struct sockaddr *)&bind_address6, bind_length6, true, &quic_config,
                                   &http3_endpoint6);
      }
    }
    if (err != ASCIICHAT_OK) {
      LOG_ERRNO_IF_SET("API HTTP/3 listener initialization failed");
      http_server_destroy(&server);
      http_renderer_destroy(&api.renderer);
      return err;
    }
  }
  err = http_server_start(server);
  if (err != ASCIICHAT_OK) {
    LOG_ERRNO_IF_SET("API HTTP server start failed");
    if (http3_endpoint) {
      (void)quic_endpoint_stop(http3_endpoint);
      (void)quic_endpoint_destroy(&http3_endpoint);
    }
    if (http3_endpoint6) {
      (void)quic_endpoint_stop(http3_endpoint6);
      (void)quic_endpoint_destroy(&http3_endpoint6);
    }
    http_server_destroy(&server);
    http_renderer_destroy(&api.renderer);
    return err;
  }
  platform_systemd_notify_status("API HTTP listener started");
  platform_systemd_notify_ready();
  while (!APP_CALLBACK_BOOL(should_exit))
    uv_sleep(16);
  http_server_stop(server);
  if (http3_endpoint) {
    (void)quic_endpoint_stop(http3_endpoint);
    (void)quic_endpoint_destroy(&http3_endpoint);
  }
  if (http3_endpoint6) {
    (void)quic_endpoint_stop(http3_endpoint6);
    (void)quic_endpoint_destroy(&http3_endpoint6);
  }
  http_renderer_destroy(&api.renderer);
  api_discard_jobs(&api);
  http_server_destroy(&server);
  return ASCIICHAT_OK;
}

References APP_CALLBACK_BOOL, ASCIICHAT_OK, GET_OPTION, api_server_t::http, http_renderer_destroy(), http_renderer_init(), http_server_destroy(), http_server_init(), http_server_start(), http_server_stop(), LOG_ERRNO_IF_SET, http_server_config_t::max_connections, http_server_config_t::max_request_body_bytes, http_server_config_t::max_response_body_bytes, http_server_config_t::on_request, parse_numeric_socket_address(), quic_endpoint_destroy(), quic_endpoint_open(), quic_endpoint_stop(), api_server_t::renderer, should_exit(), and http_server_config_t::user_data.