text: /*
   * Copyright (c) 2022 Cisco and/or its affiliates.
   * Licensed under the Apache License, Version 2.0 (the "License");
   * you may not use this file except in compliance with the License.
   * You may obtain a copy of the License at:
   *
   *     http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   * See the License for the specific language governing permissions and
   * limitations under the License.
   */
  
  #ifndef SRC_PLUGINS_HTTP_HTTP_H_
  #define SRC_PLUGINS_HTTP_HTTP_H_
  
  #include <vnet/plugin/plugin.h>
  #include <vpp/app/version.h>
  
  #include <vppinfra/time_range.h>
  
  #include <vnet/session/application_interface.h>
  #include <vnet/session/application.h>
  #include <http/http_buffer.h>
  
  #define HTTP_DEBUG 0
  
  #if HTTP_DEBUG
  #define HTTP_DBG(_lvl, _fmt, _args...)                                        \
    if (_lvl <= HTTP_DEBUG)                                                     \
    clib_warning (_fmt, ##_args)
  #else
  #define HTTP_DBG(_lvl, _fmt, _args...)
  #endif
  
  typedef struct http_conn_id_
  {
    union
    {
      session_handle_t app_session_handle;
      u32 parent_app_api_ctx;
    };
    session_handle_t tc_session_handle;
    u32 parent_app_wrk_index;
  } http_conn_id_t;
  
  STATIC_ASSERT (sizeof (http_conn_id_t) <= TRANSPORT_CONN_ID_LEN,
  	       "ctx id must be less than TRANSPORT_CONN_ID_LEN");
  
  typedef enum http_state_
  {
    HTTP_CONN_STATE_LISTEN,
    HTTP_CONN_STATE_CONNECTING,
    HTTP_CONN_STATE_ESTABLISHED,
    HTTP_CONN_STATE_TRANSPORT_CLOSED,
    HTTP_CONN_STATE_APP_CLOSED,
    HTTP_CONN_STATE_CLOSED
  } http_conn_state_t;
  
  typedef enum http_req_state_
  {
    HTTP_REQ_STATE_WAIT_METHOD,
    HTTP_REQ_STATE_WAIT_APP,
    HTTP_REQ_STATE_SEND_MORE_DATA,
    HTTP_REQ_N_STATES,
  } http_req_state_t;
  
  typedef enum http_req_method_
  {
    HTTP_REQ_GET = 0,
    HTTP_REQ_POST,
  } http_req_method_t;
  
  typedef enum http_msg_type_
  {
    HTTP_MSG_REQUEST,
    HTTP_MSG_REPLY
  } http_msg_type_t;
  
  #define foreach_http_content_type                                             \
    _ (TEXT_HTML, "text/html")                                                  \
    _ (TEXT_CSS, "text/css")                                                    \
    _ (TEXT_JS, "text/javascript")                                              \
    _ (APP_JSON, "application/json")                                            \
    _ (APP_OCTET_STREAM, "application/octet-stream")
  
  typedef enum http_content_type_
  {
  #define _(s, str) HTTP_CONTENT_##s,
    foreach_http_content_type
  #undef _
  } http_content_type_t;
  
  #define foreach_http_status_code                                              \
    _ (200, OK, "200 OK")                                                       \
    _ (400, BAD_REQUEST, "400 Bad Request")                                     \
    _ (404, NOT_FOUND, "404 Not Found")                                         \
    _ (405, METHOD_NOT_ALLOWED, "405 Method Not Allowed")                       \
    _ (500, INTERNAL_ERROR, "500 Internal Server Error")
  
  typedef enum http_status_code_
  {
  #define _(c, s, str) HTTP_STATUS_##s,
    foreach_http_status_code
  #undef _
      HTTP_N_STATUS
  } http_status_code_t;
  
  typedef enum http_msg_data_type_
  {
    HTTP_MSG_DATA_INLINE,
    HTTP_MSG_DATA_PTR
  } http_msg_data_type_t;
  
  typedef struct http_msg_data_
  {
    http_msg_data_type_t type;
    u64 len;
    u8 data[0];
  } http_msg_data_t;
  
  typedef struct http_msg_
  {
    http_msg_type_t type;
    union
    {
      http_req_method_t method_type;
      http_status_code_t code;
    };
    http_content_type_t content_type;
    http_msg_data_t data;
  } http_msg_t;
  
  typedef struct http_tc_
  {
    union
    {
      transport_connection_t connection;
      http_conn_id_t c_http_conn_id;
    };
  #define h_tc_session_handle c_http_conn_id.tc_session_handle
  #define h_pa_wrk_index	    c_http_conn_id.parent_app_wrk_index
  #define h_pa_session_handle c_http_conn_id.app_session_handle
  #define h_hc_index	    connection.c_index
  
    http_conn_state_t state;
    u32 timer_handle;
  
    /*
     * Current request
     */
    http_req_state_t req_state;
    http_req_method_t method;
    u8 *rx_buf;
    u32 rx_buf_offset;
    http_buffer_t tx_buf;
  } http_conn_t;
  
  typedef struct http_worker_
  {
    http_conn_t *conn_pool;
  } http_worker_t;
  
  typedef struct http_main_
  {
    http_worker_t *wrk;
    http_conn_t *listener_pool;
    u32 app_index;
  
    clib_timebase_t timebase;
  
    /*
     * Runtime config
     */
    u8 debug_level;
  
    /*
     * Config
     */
    u64 first_seg_size;
    u64 add_seg_size;
    u32 fifo_size;
  } http_main_t;
  
  #endif /* SRC_PLUGINS_HTTP_HTTP_H_ */
  
  /*
   * fd.io coding-style-patch-verification: ON
   *
   * Local Variables:
   * eval: (c-set-style "gnu")
   * End:
   */
  