/* packet-websocket.c

 * Routines for WebSocket dissection

 * Copyright 2012, Alexis La Goutte <alexis.lagoutte@gmail.com>

 *           2015, Peter Wu <peter@lekensteyn.nl>

 *

 * Wireshark - Network traffic analyzer

 * By Gerald Combs <gerald@wireshark.org>

 * Copyright 1998 Gerald Combs

 *

 * SPDX-License-Identifier: GPL-2.0-or-later

 */

#include "config.h"

#include <wsutil/wslog.h>

#include <epan/addr_resolv.h>

#include <epan/conversation.h>

#include <epan/follow.h>

#include <epan/proto_data.h>

#include <epan/packet.h>

#include <epan/expert.h>

#include <epan/prefs.h>

#include <epan/reassemble.h>

#include <wsutil/strtoi.h>

#include <wsutil/zlib_compat.h>

#include "packet-http.h"

#include "packet-tcp.h"

/*

 * The information used comes from:

 * RFC6455: The WebSocket Protocol

 * http://www.iana.org/assignments/websocket (last updated 2012-04-12)

 */

void proto_register_websocket(void);

void proto_reg_handoff_websocket(void);

static dissector_handle_t websocket_handle;

static dissector_handle_t websocket_tcp_handle;

static dissector_handle_t text_lines_handle;

static dissector_handle_t json_handle;

static dissector_handle_t sip_handle;

#define WEBSOCKET_NONE 0

#define WEBSOCKET_TEXT 1

#define WEBSOCKET_JSON 2

#define WEBSOCKET_SIP 3

/* Use key values counting down from UINT32_MAX to avoid clash with pkt_info proto_data key */

#define FRAG_DATA_KEY (UINT32_MAX - 0)

static int   pref_text_type             = WEBSOCKET_NONE;

static bool pref_decompress         = true;

#define DEFAULT_MAX_UNMASKED_LEN        (1024 * 256)

static unsigned pref_max_unmasked_len      = DEFAULT_MAX_UNMASKED_LEN;

typedef struct {

  const char   *subprotocol;

  uint16_t      server_port;

  bool          permessage_deflate;

#ifdef USE_ZLIB_OR_ZLIBNG

  bool          permessage_deflate_ok;

  int8_t        server_wbits;

  int8_t        client_wbits;

  zlib_streamp  server_take_over_context;

  zlib_streamp  client_take_over_context;

#endif /* USE_ZLIB_OR_ZLIBNG */

  uint32_t      frag_id;

  /* The following two parameters are only valid on the first linear pass. */

  uint8_t       first_frag_opcode;

  bool          first_frag_pmc;

  uint8_t       http_version;

} websocket_conv_t;

#ifdef USE_ZLIB_OR_ZLIBNG

typedef struct {

  uint8_t *decompr_payload;

  unsigned decompr_len;

} websocket_packet_t;

#endif /* USE_ZLIB_OR_ZLIBNG */

static int websocket_follow_tap;

/* Initialize the protocol and registered fields */

static int proto_websocket;

static int hf_ws_fin;

static int hf_ws_reserved;

static int hf_ws_pmc;

static int hf_ws_opcode;

static int hf_ws_mask;

static int hf_ws_payload_length;

static int hf_ws_payload_length_ext_16;

static int hf_ws_payload_length_ext_64;

static int hf_ws_masking_key;

static int hf_ws_payload;

static int hf_ws_masked_payload;

static int hf_ws_payload_continue;

static int hf_ws_payload_text;

static int hf_ws_payload_close;

static int hf_ws_payload_close_status_code;

static int hf_ws_payload_close_reason;

static int hf_ws_payload_ping;

static int hf_ws_payload_pong;

static int hf_ws_payload_unknown;

static int hf_ws_fragments;

static int hf_ws_fragment;

static int hf_ws_fragment_overlap;

static int hf_ws_fragment_overlap_conflict;

static int hf_ws_fragment_multiple_tails;

static int hf_ws_fragment_too_long_fragment;

static int hf_ws_fragment_error;

static int hf_ws_fragment_count;

static int hf_ws_reassembled_length;

static int ett_ws;

static int ett_ws_pl;

static int ett_ws_mask;

static int ett_ws_control_close;

static int ett_ws_fragments;

static int ett_ws_fragment;

static expert_field ei_ws_payload_unknown;

static expert_field ei_ws_decompression_failed;

static expert_field ei_ws_not_fully_unmasked;

#define WS_CONTINUE 0x0

#define WS_TEXT     0x1

#define WS_BINARY   0x2

#define WS_CLOSE    0x8

#define WS_PING     0x9

#define WS_PONG     0xA

static const value_string ws_opcode_vals[] = {

  { WS_CONTINUE, "Continuation" },

  { WS_TEXT, "Text" },

  { WS_BINARY, "Binary" },

  { WS_CLOSE, "Connection Close" },

  { WS_PING, "Ping" },

  { WS_PONG, "Pong" },

  { 0, NULL}

};

#define MASK_WS_FIN 0x80

#define MASK_WS_RSV 0x70

#define MASK_WS_RSV1 0x40

#define MASK_WS_OPCODE 0x0F

#define MASK_WS_MASK 0x80

#define MASK_WS_PAYLOAD_LEN 0x7F

static const value_string ws_close_status_code_vals[] = {

  { 1000, "Normal Closure" },

  { 1001, "Going Away" },

  { 1002, "Protocol error" },

  { 1003, "Unsupported Data" },

  { 1004, "---Reserved----" },

  { 1005, "No Status Rcvd" },

  { 1006, "Abnormal Closure" },

  { 1007, "Invalid frame payload data" },

  { 1008, "Policy Violation" },

  { 1009, "Message Too Big" },

  { 1010, "Mandatory Ext." },

  { 1011, "Internal Server" },

  { 1015, "TLS handshake" },

  { 0,    NULL}

};

static const fragment_items ws_frag_items = {

    &ett_ws_fragments,

    &ett_ws_fragment,

    &hf_ws_fragments,

    &hf_ws_fragment,

    &hf_ws_fragment_overlap,

    &hf_ws_fragment_overlap_conflict,

    &hf_ws_fragment_multiple_tails,

    &hf_ws_fragment_too_long_fragment,

    &hf_ws_fragment_error,

    &hf_ws_fragment_count,

    NULL,

    &hf_ws_reassembled_length,

    /* Reassembled data field */

    NULL,

    "websocket fragments"

};

typedef struct {

  uint8_t opcode;

  bool    pmc;

} websocket_frag_t;

static dissector_table_t port_subdissector_table;

static dissector_table_t protocol_subdissector_table;

static heur_dissector_list_t heur_subdissector_list;

static reassembly_table ws_reassembly_table;

static tvbuff_t *

tvb_unmasked(tvbuff_t *tvb, packet_info *pinfo, const unsigned offset, unsigned payload_length, const uint8_t *masking_key)

{

  uint8_t       *data_unmask;

  unsigned      i;

  const uint8_t *data_mask;

  unsigned      unmasked_length = payload_length > pref_max_unmasked_len ? pref_max_unmasked_len : payload_length;

  data_unmask = (uint8_t*)wmem_alloc(pinfo->pool, unmasked_length);

  data_mask   = tvb_get_ptr(tvb, offset, unmasked_length);

  /* Unmasked(XOR) Data... */

  for(i=0; i < unmasked_length; i++) {

    data_unmask[i] = data_mask[i] ^ masking_key[i%4];

  }

  return tvb_new_child_real_data(tvb, data_unmask, unmasked_length, payload_length);

}

#ifdef USE_ZLIB_OR_ZLIBNG

static int8_t

websocket_extract_wbits(const char *str)

{

  uint8_t wbits;

  const char *end;

  if (str && ws_strtou8(str, &end, &wbits) &&

      (*end == '\0' || strchr(";\t ", *end))) {

    if (wbits < 8) {

      wbits = 8;

    } else if (wbits > 15) {

      wbits = 15;

    }

  } else {

    wbits = 15;

  }

  return -wbits;

}

static void *

websocket_zalloc(void *opaque _U_, unsigned int items, unsigned int size)

{

  return wmem_alloc(wmem_file_scope(), items*size);

}

static void

websocket_zfree(void *opaque _U_, void *addr)

{

  wmem_free(wmem_file_scope(), addr);

}

static zlib_streamp

websocket_init_z_stream_context(int8_t wbits)

{

  zlib_streamp z_strm = wmem_new0(wmem_file_scope(), zlib_stream);

  z_strm->zalloc = websocket_zalloc;

  z_strm->zfree = websocket_zfree;

  if (ZLIB_PREFIX(inflateInit2)(z_strm, wbits) != Z_OK) {

    ZLIB_PREFIX(inflateEnd)(z_strm);

    wmem_free(wmem_file_scope(), z_strm);

    return NULL;

  }

  return z_strm;

}

/*

 * Decompress the given buffer using the given zlib context. On success, the

 * (possibly empty) buffer is stored as "proto data" and true is returned.

 * Otherwise false is returned.

 */

/* Because the stream, or at least the sliding window, has to be reused

 * between messages, this doesn't call the functions in tvbuff_zlib.

 * XXX - Would it make sense to provide a tvbuff_zlib API call that

 * takes either a zlib stream pointer or a sliding window/dictionary,

 * in order to consolidate some code? */

/* Same constants as tvbuff_zlib.c */

#define TVB_Z_MIN_BUFSIZ 32768

#define TVB_Z_MAX_BUFSIZ 1048576 * 10

static bool

websocket_uncompress(tvbuff_t* tvb, packet_info* pinfo, zlib_streamp z_strm, tvbuff_t** uncompressed_tvb, uint32_t key)

{

  /*

   * Decompressing a message: append "0x00 0x00 0xff 0xff" to the end of

   * message, then apply DEFLATE to the result.

   * https://tools.ietf.org/html/rfc7692#section-7.2.2

   */

  uint8_t  *decompr_payload = NULL;

  unsigned  decompr_len = 0;

  unsigned  compr_len, decompr_buf_len;

  uint8_t  *compr_payload, *decompr_buf;

  int       err;

  compr_len = tvb_captured_length(tvb) + 4;

  compr_payload = (uint8_t *)wmem_alloc(pinfo->pool, compr_len);

  tvb_memcpy(tvb, compr_payload, 0, compr_len-4);

  compr_payload[compr_len-4] = compr_payload[compr_len-3] = 0x00;

  compr_payload[compr_len-2] = compr_payload[compr_len-1] = 0xff;

  if (ckd_mul(&decompr_buf_len, compr_len, 2)) {

    decompr_buf_len = TVB_Z_MAX_BUFSIZ;

  } else {

    decompr_buf_len = CLAMP(decompr_buf_len, TVB_Z_MIN_BUFSIZ, TVB_Z_MAX_BUFSIZ);

  }

  decompr_buf = (uint8_t *)wmem_alloc(pinfo->pool, decompr_buf_len);

  z_strm->next_in = compr_payload;

  z_strm->avail_in = compr_len;

  /* Decompress all available data. */

  do {

    z_strm->next_out = decompr_buf;

    z_strm->avail_out = decompr_buf_len;

    err = ZLIB_PREFIX(inflate)(z_strm, Z_SYNC_FLUSH);

    if (err == Z_OK || err == Z_STREAM_END || err == Z_BUF_ERROR) {

      unsigned avail_bytes = decompr_buf_len - z_strm->avail_out;

      /* Note z_strm, and thus z_strm->total_out, does not necessarily get reset

       * between messages because the same sliding window may be used. */

      if (decompr_len + avail_bytes > INT_MAX) {

        /* Out of room (various tvb and Qt API functions will fail on anything

         * bigger than a signed int. We could lower this more. (Because the

         * size of the decompression buffer is clamped, this can't overflow.) */

        err = ZLIB_PREFIX(inflateSync)(z_strm);

        /* This should succeed and find the 00 00 FF FF at the end, but if the

         * flush point is a sync flush point and not a full flush point, i.e.

         * the siding window needs to be used for the next message, the stream

         * probably gets left in a bad state.  */

        continue;

      }

      if (avail_bytes) {

        decompr_payload = (uint8_t *)wmem_realloc(wmem_file_scope(), decompr_payload,

                                                 decompr_len + avail_bytes);

        memcpy(&decompr_payload[decompr_len], decompr_buf, avail_bytes);

        decompr_len += avail_bytes;

      }

    }

  } while (err == Z_OK);

  if (err == Z_STREAM_END || err == Z_BUF_ERROR) {

    /* Data was (partially) uncompressed. */

    websocket_packet_t *pkt_info = wmem_new0(wmem_file_scope(), websocket_packet_t);

    if (decompr_len > 0) {

      pkt_info->decompr_payload = decompr_payload;

      pkt_info->decompr_len = decompr_len;

      *uncompressed_tvb = tvb_new_child_real_data(tvb, decompr_payload, decompr_len, decompr_len);

    }

    p_add_proto_data(wmem_file_scope(), pinfo, proto_websocket, key, pkt_info);

    return true;

  } else {

    /* decompression failed */

    wmem_free(wmem_file_scope(), decompr_payload);

    return false;

  }

}

#endif /* USE_ZLIB_OR_ZLIBNG */

static void

dissect_websocket_control_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, uint8_t opcode)

{

  proto_item         *ti;

  proto_tree         *subtree;

  const unsigned      offset = 0, length = tvb_reported_length(tvb);

  switch (opcode) {

    case WS_CLOSE: /* Close */

      ti = proto_tree_add_item(tree, hf_ws_payload_close, tvb, offset, length, ENC_NA);

      subtree = proto_item_add_subtree(ti, ett_ws_control_close);

      /* Close frame MAY contain a body. */

      if (length >= 2) {

        proto_tree_add_item(subtree, hf_ws_payload_close_status_code, tvb, offset, 2, ENC_BIG_ENDIAN);

        if (length > 2)

          proto_tree_add_item(subtree, hf_ws_payload_close_reason, tvb, offset+2, length-2, ENC_UTF_8);

      }

      break;

    case WS_PING: /* Ping */

      proto_tree_add_item(tree, hf_ws_payload_ping, tvb, offset, length, ENC_NA);

      break;

    case WS_PONG: /* Pong */

      proto_tree_add_item(tree, hf_ws_payload_pong, tvb, offset, length, ENC_NA);

      break;

    default: /* Unknown */

      ti = proto_tree_add_item(tree, hf_ws_payload_unknown, tvb, offset, length, ENC_NA);

      expert_add_info_format(pinfo, ti, &ei_ws_payload_unknown, "Dissector for Websocket Opcode (%d)"

        " code not implemented, Contact Wireshark developers"

        " if you want this supported", opcode);

      break;

  }

}

static void

dissect_websocket_data_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, proto_tree *pl_tree, uint8_t opcode, websocket_conv_t *websocket_conv, bool pmc _U_, int raw_offset _U_, bool from_server _U_)

{

  proto_item         *ti;

  dissector_handle_t  handle = NULL;

  heur_dtbl_entry_t  *hdtbl_entry;

  if (pinfo->fragmented) {

    /* Skip dissecting fragmented payload data. */

    return;

  }

  /* try to find a dissector which accepts the data. */

  if (websocket_conv->subprotocol) {

    handle = dissector_get_string_handle(protocol_subdissector_table, websocket_conv->subprotocol);

  } else if (websocket_conv->server_port) {

    handle = dissector_get_uint_handle(port_subdissector_table, websocket_conv->server_port);

  }

#ifdef USE_ZLIB_OR_ZLIBNG

  if (websocket_conv->permessage_deflate_ok && pmc) {

    tvbuff_t   *uncompressed = NULL;

    bool        uncompress_ok = false;

    if (!PINFO_FD_VISITED(pinfo)) {

      zlib_streamp z_strm;

      int8_t wbits;

      if (from_server) {

        z_strm = websocket_conv->server_take_over_context;

        wbits = websocket_conv->server_wbits;

      } else {

        z_strm = websocket_conv->client_take_over_context;

        wbits = websocket_conv->client_wbits;

      }

      if (z_strm) {

        uncompress_ok = websocket_uncompress(tvb, pinfo, z_strm, &uncompressed, raw_offset);

      } else {

        /* no context take over, initialize a new context */

        z_strm = wmem_new0(pinfo->pool, zlib_stream);

        if (ZLIB_PREFIX(inflateInit2)(z_strm, wbits) == Z_OK) {

          uncompress_ok = websocket_uncompress(tvb, pinfo, z_strm, &uncompressed, raw_offset);

        }

        ZLIB_PREFIX(inflateEnd)(z_strm);

      }

    } else {

      websocket_packet_t *pkt_info =

          (websocket_packet_t *)p_get_proto_data(wmem_file_scope(), pinfo, proto_websocket, raw_offset);

      if (pkt_info) {

        uncompress_ok = true;

        if (pkt_info->decompr_len > 0) {

          uncompressed = tvb_new_child_real_data(tvb, pkt_info->decompr_payload, pkt_info->decompr_len, pkt_info->decompr_len);

        }

      }

    }

    if (!uncompress_ok) {

      proto_tree_add_expert_remaining(tree, pinfo, &ei_ws_decompression_failed, tvb, 0);

      return;

    }

    if (uncompressed) {

      add_new_data_source(pinfo, uncompressed, "Decompressed payload");

      tvb = uncompressed;

    }

  }

#endif /* USE_ZLIB_OR_ZLIBNG */

  if (have_tap_listener(websocket_follow_tap)) {

    tap_queue_packet(websocket_follow_tap, pinfo, tvb);

  }

  if (handle) {

    call_dissector_only(handle, tvb, pinfo, tree, NULL);

    return; /* handle found, assume dissector took care of it. */

  } else if (dissector_try_heuristic(heur_subdissector_list, tvb, pinfo, tree, &hdtbl_entry, NULL)) {

    return; /* heuristics dissector handled it. */

  }

  /* no dissector wanted it, try to print something appropriate. */

  switch (opcode) {

    case WS_TEXT: /* Text */

    {

      proto_tree_add_item(pl_tree, hf_ws_payload_text, tvb, 0, -1, ENC_UTF_8);

      const char   *saved_match_string = pinfo->match_string;

      pinfo->match_string = NULL;

      switch (pref_text_type) {

      case WEBSOCKET_TEXT:

      case WEBSOCKET_NONE:

      default:

        /* Assume that most text protocols are line-based. */

        call_dissector(text_lines_handle, tvb, pinfo, tree);

        break;

      case WEBSOCKET_JSON:

        call_dissector(json_handle, tvb, pinfo, tree);

        break;

      case WEBSOCKET_SIP:

        call_dissector(sip_handle, tvb, pinfo, tree);

        break;

      }

      pinfo->match_string = saved_match_string;

    }

    break;

    case WS_BINARY: /* Binary */

      call_data_dissector(tvb, pinfo, tree);

      break;

    default: /* Unknown */

      ti = proto_tree_add_item(pl_tree, hf_ws_payload_unknown, tvb, 0, -1, ENC_NA);

      expert_add_info_format(pinfo, ti, &ei_ws_payload_unknown, "Dissector for Websocket Opcode (%d)"

        " code not implemented, Contact Wireshark developers"

        " if you want this supported", opcode);

      break;

  }

}

static void

websocket_parse_extensions(websocket_conv_t *websocket_conv, const char *str)

{

  /*

   * Grammar for the header:

   *

   *    Sec-WebSocket-Extensions = extension-list

   *    extension-list = 1#extension

   *    extension = extension-token *( ";" extension-param )

   *    extension-token = registered-token

   *    registered-token = token

   *    extension-param = token [ "=" (token | quoted-string) ]

   */

  /*

   * RFC 7692 permessage-deflate parsing.

   * "x-webkit-deflate-frame" is an alias used by some versions of Safari browser

   */

  websocket_conv->permessage_deflate = !!strstr(str, "permessage-deflate")

      || !!strstr(str, "x-webkit-deflate-frame");

#ifdef USE_ZLIB_OR_ZLIBNG

  websocket_conv->permessage_deflate_ok = pref_decompress &&

       websocket_conv->permessage_deflate;

  if (websocket_conv->permessage_deflate_ok) {

    websocket_conv->server_wbits =

        websocket_extract_wbits(strstr(str, "server_max_window_bits="));

    if (!strstr(str, "server_no_context_takeover")) {

      websocket_conv->server_take_over_context =

          websocket_init_z_stream_context(websocket_conv->server_wbits);

    }

    websocket_conv->client_wbits =

        websocket_extract_wbits(strstr(str, "client_max_window_bits="));

    if (!strstr(str, "client_no_context_takeover")) {

      websocket_conv->client_take_over_context =

          websocket_init_z_stream_context(websocket_conv->client_wbits);

    }

  }

#endif /* USE_ZLIB_OR_ZLIBNG */

}

static void

dissect_websocket_payload(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, proto_tree *ws_tree, bool fin, uint8_t opcode, websocket_conv_t *websocket_conv, bool pmc, int raw_offset, unsigned masked_payload_length, bool from_server)

{

  const unsigned      offset = 0, length = tvb_reported_length(tvb);

  const unsigned      capture_length = tvb_captured_length(tvb);

  proto_item         *ti;

  proto_tree         *pl_tree;

  tvbuff_t           *tvb_appdata;

  tvbuff_t           *frag_tvb = NULL;

  /* Payload */

  ti = proto_tree_add_item(ws_tree, hf_ws_payload, tvb, offset, length, ENC_NA);

  pl_tree = proto_item_add_subtree(ti, ett_ws_pl);

  if (masked_payload_length > capture_length) {

    expert_add_info_format(pinfo, ti, &ei_ws_not_fully_unmasked, "Payload not fully unmasked. "

      "%u bytes not yet unmasked due to the preference of max unmasked length limit (%u bytes).",

      masked_payload_length - capture_length, pref_max_unmasked_len);

  }

  /* Extension Data */

  /* TODO: Add dissector of Extension (not extension available for the moment...) */

  if (opcode & 8) { /* Control frames have MSB set. */

    dissect_websocket_control_frame(tvb, pinfo, pl_tree, opcode);

    return;

  }

  /* According to RFC 6455 5.5, control frames can be interjected in the

   * middle of a fragmented message, can have a payload, and MUST NOT be

   * fragmented. So we do not save the first frag opcode and pmc until now.

   */

  if (!PINFO_FD_VISITED(pinfo) && opcode != WS_CONTINUE && !fin) {

    /* This is a first frame of a multifragment message. The first time

     * we see this frame, store information needed for later fragments

     * of the same message.

     */

    websocket_conv->first_frag_opcode = opcode;

    websocket_conv->first_frag_pmc = pmc;

  }

  bool save_fragmented = pinfo->fragmented;

  if (!fin || opcode == WS_CONTINUE) {

    /* Fragmented data frame */

    fragment_head *frag_msg;

    pinfo->fragmented = true;

    /* XXX - The same fragment ID is used for all reassemblies on this

     * conversation. Note this doesn't work properly if more than one

     * reassembly for the same conversation completes in the same frame

     * in the capture file. That should be rare in practice, though.

     * (This is a common issue with fragment_add_seq_next.)

     */

    frag_msg = fragment_add_seq_next(&ws_reassembly_table, tvb, offset,

              pinfo, websocket_conv->frag_id,

              NULL, tvb_captured_length_remaining(tvb, offset),

              !fin);

    frag_tvb = process_reassembled_data(tvb, offset, pinfo,

      "Reassembled Message", frag_msg, &ws_frag_items,

      NULL, tree);

  }

  if (frag_tvb) {

    /* Fragments were fully reassembled. */

    tvb_appdata = frag_tvb;

    websocket_frag_t *frag_data;

    if (!PINFO_FD_VISITED(pinfo)) {

      /* First time fragments fully reassembled, store opcode from first fragment */

      frag_data = wmem_new(wmem_file_scope(), websocket_frag_t);

      frag_data->opcode = websocket_conv->first_frag_opcode;

      frag_data->pmc = websocket_conv->first_frag_pmc;

      p_add_proto_data(wmem_file_scope(), pinfo, proto_websocket, FRAG_DATA_KEY, frag_data);

    } else {

      /* Lookup opcode and pmc from first fragment */

      frag_data = p_get_proto_data(wmem_file_scope(), pinfo, proto_websocket, FRAG_DATA_KEY);

      DISSECTOR_ASSERT(frag_data);

    }

    opcode = frag_data->opcode;

    pmc = frag_data->pmc;

  } else {

    /* Right now this is exactly the same, this may change when exts. are added.

    tvb_appdata = tvb_new_subset_length(tvb, offset, length);

    */

    tvb_appdata = tvb;

  }

  /* Application Data */

  if (pinfo->fragmented && opcode == WS_CONTINUE) {

    /* Not last fragment, dissect continue fragment as is */

    proto_tree_add_item(tree, hf_ws_payload_continue, tvb_appdata, offset, length, ENC_NA);

    return;

  }

  dissect_websocket_data_frame(tvb_appdata, pinfo, tree, pl_tree, opcode, websocket_conv, pmc, raw_offset, from_server);

  pinfo->fragmented = save_fragmented;

}

static int

dissect_websocket_frame(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, void *data)

{

  static uint32_t frag_id_counter = 0;

  proto_item       *ti, *ti_len;

  uint8_t           opcode;

  bool              mask, fin, pmc = false;

  unsigned          short_length, payload_length;

  unsigned          payload_offset, mask_offset;

  proto_tree       *ws_tree;

  const uint8_t    *masking_key = NULL;

  tvbuff_t         *tvb_payload;

  conversation_t   *conv;

  websocket_conv_t *websocket_conv;

  const http_upgrade_info_t *http_info = (http_upgrade_info_t *)data;

  /*

   * If this is a new Websocket session, try to parse HTTP Sec-Websocket-*

   * headers once.

   */

  conv = find_or_create_conversation(pinfo);

  websocket_conv = (websocket_conv_t *)conversation_get_proto_data(conv, proto_websocket);

  if (!websocket_conv) {

    websocket_conv = wmem_new0(wmem_file_scope(), websocket_conv_t);

    websocket_conv->frag_id = ++frag_id_counter;

    if (http_info) {

      /* The header value may be packet scope (HTTP/2, HTTP/3). */

      websocket_conv->subprotocol = wmem_strdup(wmem_file_scope(),

          http_info->get_header_value(pinfo, "sec-websocket-protocol", !http_info->from_server));

      websocket_conv->server_port = http_info->server_port;

      const char *websocket_extensions = http_info->get_header_value(pinfo, "sec-websocket-extensions", !http_info->from_server);

      if (websocket_extensions) {

        websocket_parse_extensions(websocket_conv, websocket_extensions);

      }

      websocket_conv->http_version = http_info->http_version;

    } else if (pinfo->match_uint == pinfo->srcport || pinfo->match_uint == pinfo->destport) {

      /* The session was not set up by HTTP upgrade, but by Decode As.

       * Assume the matched port is the server port. */

      websocket_conv->server_port = (uint16_t)pinfo->match_uint;

    } else {

      /* match_uint is not one of the ports, which means the session was

       * set up by the heuristic Websocket dissector. */

      uint32_t low_port, high_port;

      if (pinfo->srcport > pinfo->destport) {

        low_port = pinfo->destport;

        high_port = pinfo->srcport;

      } else {

        low_port = pinfo->srcport;

        high_port = pinfo->destport;

      }

      if (dissector_get_uint_handle(port_subdissector_table, low_port)) {

        websocket_conv->server_port = (uint16_t)low_port;

      } else if (dissector_get_uint_handle(port_subdissector_table, high_port)) {

        websocket_conv->server_port = (uint16_t)high_port;

      }

    }

    conversation_add_proto_data(conv, proto_websocket, websocket_conv);

  }

  const bool from_server = http_info ? http_info->from_server : websocket_conv->server_port == pinfo->srcport;

  short_length = tvb_get_uint8(tvb, 1) & MASK_WS_PAYLOAD_LEN;

  mask_offset = 2;

  if (short_length == 126) {

    payload_length = tvb_get_ntohs(tvb, 2);

    mask_offset += 2;

  } else if (short_length == 127) {

    /* warning C4244: '=' : conversion from 'uint64_t' to 'unsigned ', possible loss of data */

    payload_length = (unsigned)tvb_get_ntoh64(tvb, 2);

    mask_offset += 8;

  } else {

    payload_length = short_length;

  }

  /* Mask */

  mask = (tvb_get_uint8(tvb, 1) & MASK_WS_MASK) != 0;

  payload_offset = mask_offset + (mask ? 4 : 0);

  /* HTTP/2 and HTTP/3 can carry more than one protocol in a given packet */

  if (websocket_conv->http_version < 2) {

    col_set_str(pinfo->cinfo, COL_PROTOCOL, "WebSocket");

    col_set_str(pinfo->cinfo, COL_INFO, "WebSocket");

  } else {

    col_append_str(pinfo->cinfo, COL_INFO, ", WebSocket");

  }

  ti = proto_tree_add_item(tree, proto_websocket, tvb, 0, payload_offset, ENC_NA);

  ws_tree = proto_item_add_subtree(ti, ett_ws);

  /* Flags */

  proto_tree_add_item_ret_boolean(ws_tree, hf_ws_fin, tvb, 0, 1, ENC_NA, &fin);

  proto_tree_add_item(ws_tree, hf_ws_reserved, tvb, 0, 1, ENC_BIG_ENDIAN);

  if (websocket_conv->permessage_deflate) {

    /* RSV1 is Per-Message Compressed bit (RFC 7692). */

    proto_tree_add_item_ret_boolean(ws_tree, hf_ws_pmc, tvb, 0, 1, ENC_BIG_ENDIAN, &pmc);

  }

  /* Opcode */

  proto_tree_add_item_ret_uint8(ws_tree, hf_ws_opcode, tvb, 0, 1, ENC_BIG_ENDIAN, &opcode);

  col_append_fstr(pinfo->cinfo, COL_INFO, " %s", val_to_str_const(opcode, ws_opcode_vals, "Unknown Opcode"));

  col_append_str(pinfo->cinfo, COL_INFO, fin ? " [FIN]" : "[FRAGMENT] ");

  /* Add Mask bit to the tree */

  proto_tree_add_item(ws_tree, hf_ws_mask, tvb, 1, 1, ENC_NA);

  col_append_str(pinfo->cinfo, COL_INFO, mask ? " [MASKED]" : " ");

  /* (Extended) Payload Length */

  ti_len = proto_tree_add_item(ws_tree, hf_ws_payload_length, tvb, 1, 1, ENC_BIG_ENDIAN);

  if (short_length == 126) {

    proto_item_append_text(ti_len, " Extended Payload Length (16 bits)");

    proto_tree_add_item(ws_tree, hf_ws_payload_length_ext_16, tvb, 2, 2, ENC_BIG_ENDIAN);

  }

  else if (short_length == 127) {

    proto_item_append_text(ti_len, " Extended Payload Length (64 bits)");

    proto_tree_add_item(ws_tree, hf_ws_payload_length_ext_64, tvb, 2, 8, ENC_BIG_ENDIAN);

  }

  /* Masking-key */

  if (mask) {

    proto_tree_add_item(ws_tree, hf_ws_masking_key, tvb, mask_offset, 4, ENC_NA);

    masking_key = tvb_get_ptr(tvb, mask_offset, 4);

  }

  if (payload_length > 0) {

    /* Always unmask payload data before analysing it. */

    if (mask) {

      proto_tree_add_item(ws_tree, hf_ws_masked_payload, tvb, payload_offset, payload_length, ENC_NA);

      tvb_payload = tvb_unmasked(tvb, pinfo, payload_offset, payload_length, masking_key);

      add_new_data_source(pinfo, tvb_payload, "Unmasked data");

    } else {

      tvb_payload = tvb_new_subset_length(tvb, payload_offset, payload_length);

    }

    dissect_websocket_payload(tvb_payload, pinfo, tree, ws_tree, fin, opcode, websocket_conv, pmc, tvb_raw_offset(tvb), (mask ? payload_length : 0), from_server);

  }

  return tvb_captured_length(tvb);

}

static unsigned

get_websocket_frame_length(packet_info *pinfo _U_, tvbuff_t *tvb, int offset, void *data _U_)

{

  unsigned      frame_length, payload_length;

  bool          mask;

  frame_length = 2;                 /* flags, opcode and Payload length */

  mask = tvb_get_uint8(tvb, offset + 1) & MASK_WS_MASK;

  payload_length = tvb_get_uint8(tvb, offset + 1) & MASK_WS_PAYLOAD_LEN;

  offset += 2; /* Skip flags, opcode and Payload length */

  /* Check for Extended Payload Length. */

  if (payload_length == 126) {

    if (tvb_reported_length_remaining(tvb, offset) < 2)

      return 0; /* Need more data. */

    payload_length = tvb_get_ntohs(tvb, offset);

    frame_length += 2;              /* Extended payload length */

  } else if (payload_length == 127) {

    if (tvb_reported_length_remaining(tvb, offset) < 8)

      return 0; /* Need more data. */

    payload_length = (unsigned)tvb_get_ntoh64(tvb, offset);

    frame_length += 8;              /* Extended payload length */

  }

  if (mask)

    frame_length += 4;              /* Masking-key */

  frame_length += payload_length;   /* Payload data */

  return frame_length;

}

static int

dissect_websocket(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, void *data)

{

  /* data is an http_upgrade_info_t only when HTTP, HTTP/2 or HTTP/3 hands

   * the connection over. Called by name otherwise (for example from an

   * Exported PDU, which can pass a struct tcpinfo), it is something else. */

  if (data && !proto_is_frame_protocol(pinfo->layers, "http") &&

      !proto_is_frame_protocol(pinfo->layers, "http2") &&

      !proto_is_frame_protocol(pinfo->layers, "http3")) {

    data = NULL;

  }

  /* Need at least two bytes for flags, opcode and Payload length. */

  tcp_dissect_pdus(tvb, pinfo, tree, true, 2,

                   get_websocket_frame_length, dissect_websocket_frame, data);

  return tvb_captured_length(tvb);

}

static int

dissect_websocket_tcp(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, void *data _U_)

{

  return dissect_websocket(tvb, pinfo, tree, NULL);

}

static bool

test_websocket(packet_info* pinfo _U_, tvbuff_t* tvb, int offset _U_, void* data _U_)

{

  unsigned buffer_length = tvb_captured_length(tvb);

  // At least 2 bytes are required for a websocket header

  if (buffer_length < 2)

  {

    return false;

  }

  uint8_t first_byte = tvb_get_uint8(tvb, 0);

  uint8_t second_byte = tvb_get_uint8(tvb, 1);

  // Reserved bits RSV1, RSV2 and RSV3 need to be 0

  if ((first_byte & 0x70) > 0)

  {

    return false;

  }

  uint8_t op_code = first_byte & 0x0F;

  // op_code must be one of WS_CONTINUE, WS_TEXT, WS_BINARY, WS_CLOSE, WS_PING or WS_PONG

  if (!(op_code == WS_CONTINUE || op_code == WS_TEXT || op_code == WS_BINARY || op_code == WS_CLOSE || op_code == WS_PING || op_code == WS_PONG))

  {

    return false;

  }

  // It is necessary to prevent that HTTP connection setups are treated as websocket.

  // If HTTP catches and it upgrades to websocket then HTTP takes care that websocket dissector gets called for this stream.

  // If first two byte start with printable characters from the alphabet it's likely that it is part of a HTTP connection setup.

  if (((first_byte >= 'a' && first_byte <= 'z') || (first_byte >= 'A' && first_byte <= 'Z')) &&

    ((second_byte >= 'a' && second_byte <= 'z') || (second_byte >= 'A' && second_byte <= 'Z')))

  {

    return false;

  }

  return true;

}

static bool

dissect_websocket_heur_tcp(tvbuff_t* tvb, packet_info* pinfo, proto_tree* tree, void* data)

{

  if (!test_websocket(pinfo, tvb, 0, data))

  {

    return false;

  }

  conversation_t* conversation = find_or_create_conversation(pinfo);

  conversation_set_dissector(conversation, websocket_tcp_handle);

  tcp_dissect_pdus(tvb, pinfo, tree, true, 2, get_websocket_frame_length, dissect_websocket_frame, NULL);

  return true;

}

void

proto_register_websocket(void)

{

  static hf_register_info hf[] = {