kc3-lang/kc3/http/http_response.c

Tag - branch -callablemasterconfigurefnfractionsfractions-rebaselinuxratio-rebasev0.1- tag -v0.1.9v0.1.8v0.1.7v0.1.6v0.1.5v0.1.4v0.1.3v0.1.2v0.1.13v0.1.12v0.1.11v0.1.10v0.1.1v0.1.0v0HTTPd-v0.1.1HTTPd-v0.1.0

• Show log

  Commit

• Hash : 78879ff8
  Author :
  Date : 2024-08-03T12:52:30
  

  deleted useless printf

Download

• http/http_response.c

• /* kc3
   * Copyright 2022,2023,2024 kmx.io <contact@kmx.io>
   *
   * Permission is hereby granted to use this software granted the above
   * copyright notice and this permission paragraph are included in all
   * copies and substantial portions of this software.
   *
   * THIS SOFTWARE IS PROVIDED "AS-IS" WITHOUT ANY GUARANTEE OF
   * PURPOSE AND PERFORMANCE. IN NO EVENT WHATSOEVER SHALL THE
   * AUTHOR BE CONSIDERED LIABLE FOR THE USE AND PERFORMANCE OF
   * THIS SOFTWARE.
   */
  #include <string.h>
  #include <libkc3/kc3.h>
  #include "http_response.h"
  #include "socket.h"
  
  sw http_response_buf_write (const s_http_response *response,
                              s_buf *buf)
  {
    sw    content_length = -1;
    s_str content_length_str = {0};
    s_tag default_messages = {0};
    s_ident ident = {0};
    s_tag *key = NULL;
    const s_list *l = NULL;
    s_str protocol = {0};
    sw r = 0;
    sw result = 0;
    s_tag tag_code = {0};
    s_tag tag_message = {0};
    s_tag *value = NULL;
    assert(response);
    assert(buf);
    if (! response->protocol.size)
      str_init_1(&protocol, NULL, "HTTP/1.1");
    else
      protocol = response->protocol;
    if ((r = buf_write_str(buf, &protocol)) < 0)
      return r;
    result += r;
    if ((r = buf_write_1(buf, " ")) < 0)
      return r;
    result += r;
    tag_code.type = TAG_U16;
    tag_code.data.u16 = response->code;
    if (! tag_code.data.u16)
      tag_code.data.u16 = 200;
    if (tag_code.data.u16 < 100 || tag_code.data.u16 > 999) {
      err_puts("http_response_buf_write: invalid response code");
      return -1;
    }
    if ((r = buf_inspect_u16_decimal(buf, &tag_code.data.u16)) < 0)
      return r;
    result += r;
    if ((r = buf_write_1(buf, " ")) < 0)
      return r;
    result += r;
    if (! response->message.size) {
      ident_init(&ident, sym_1("HTTP.Response"), sym_1("default_messages"));
      ident_get(&ident, &default_messages);
      if (! tag_is_alist(&default_messages)) {
        err_puts("http_response_buf_write: invalid default_messages:"
                 " not an AList");
        return -1;
      }
      if (alist_get((const s_list * const *) &default_messages.data.list,
                    &tag_code, &tag_message)) {
        if (tag_message.type != TAG_STR) {
          err_puts("http_response_buf_write: invalid default message:"
                   " not a Str");
          tag_clean(&tag_message);
          return -1;
        }
      }
    }
    else {
      tag_message.type = TAG_STR;
      tag_message.data.str = response->message;
      tag_message.data.str.free.p = NULL;
    }
    if ((r = buf_write_str(buf, &tag_message.data.str)) < 0)
      return r;
    result += r;
    tag_clean(&tag_message);
    if ((r = buf_write_1(buf, "\r\n")) < 0)
      return r;
    result += r;
    str_init_1(&content_length_str, NULL, "Content-Length");
    l = response->headers;
    while (l) {
      if (l->tag.type != TAG_TUPLE ||
          l->tag.data.tuple.count != 2) {
        err_puts("http_response_buf_write: invalid header: not a Tuple");
        return -1;
      }
      key = l->tag.data.tuple.tag;
      value = key + 1;
      if (key->type != TAG_STR || value->type != TAG_STR) {
        err_puts("http_response_buf_write: invalid header: not a Str");
        return -1;
      }
      if (! compare_str(&content_length_str, &key->data.str))
        sw_init_str(&content_length, &value->data.str);
      if ((r = buf_write_str(buf, &key->data.str)) < 0)
        return r;
      result += r;
      if ((r = buf_write_1(buf, ": ")) < 0)
        return r;
      result += r;
      if ((r = buf_write_str(buf, &value->data.str)) < 0)
        return r;
      result += r;
      if ((r = buf_write_1(buf, "\r\n")) < 0)
        return r;
      result += r;
      l = list_next(l);
    }
    if (content_length < 0) {
      if ((r = buf_write_str(buf, &content_length_str)) < 0)
        return r;
      result += r;
      if ((r = buf_write_1(buf, ": ")) < 0)
        return r;
      result += r;
      if ((r = buf_inspect_sw_decimal(buf, &content_length)) < 0)
        return r;
      result += r;
      if ((r = buf_write_1(buf, "\r\n")) < 0)
        return r;
      result += r;
    }
    if ((r = buf_write_1(buf, "\r\n")) < 0)
      return r;
    result += r;
    if ((r = buf_write_str(buf, &response->body)) < 0)
      return r;
    result += r;
    return result;
  }
  

Download