/*
 * Copyright (C) 2013 Red Hat, Inc.
 * SPDX-License-Identifier: LGPL-2.1-or-later
 */

#ifndef __WEB_SOCKET_PRIVATE_H__
#define __WEB_SOCKET_PRIVATE_H__

#include <gio/gio.h>

G_BEGIN_DECLS

gboolean     _web_socket_util_parse_url         (const gchar *url,
                                                 gchar **out_scheme,
                                                 gchar **out_host,
                                                 gchar **out_path,
                                                 GError **error);

gboolean     _web_socket_util_header_equals     (GHashTable *headers,
                                                 const gchar *name,
                                                 const gchar *want);

gboolean     _web_socket_util_header_contains   (GHashTable *headers,
                                                 const gchar *name,
                                                 const gchar *word);

gboolean     _web_socket_util_header_empty      (GHashTable *headers,
                                                 const gchar *name);

typedef enum {
  WEB_SOCKET_QUEUE_NORMAL = 0,
  WEB_SOCKET_QUEUE_URGENT = 1 << 0,
  WEB_SOCKET_QUEUE_LAST = 1 << 1,
} WebSocketQueueFlags;

void             _web_socket_connection_queue             (WebSocketConnection *conn,
                                                           WebSocketQueueFlags flags,
                                                           gpointer frame,
                                                           gsize length,
                                                           gsize buffered_amount);

GMainContext *   _web_socket_connection_get_main_context  (WebSocketConnection *self);

gboolean         _web_socket_connection_error             (WebSocketConnection *self,
                                                           GError *error);

void             _web_socket_connection_error_and_close   (WebSocketConnection *self,
                                                           GError *error,
                                                           gboolean prejudice);

void             _web_socket_connection_take_io_stream    (WebSocketConnection *self,
                                                           GIOStream *io_stream);

void             _web_socket_connection_take_incoming     (WebSocketConnection *self,
                                                           GByteArray *input_buffer);

gboolean         _web_socket_connection_choose_protocol   (WebSocketConnection *self,
                                                           const gchar **protocols,
                                                           const gchar *value);

gchar *          _web_socket_complete_accept_key_rfc6455  (const gchar *key);

G_END_DECLS

#endif /* __WEB_SOCKET_PRIVATE_H__ */