TLSPacketBuilder.h 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. /*
  2. * Copyright (c) 2020, Ali Mohammad Pur <mpfard@serenityos.org>
  3. *
  4. * SPDX-License-Identifier: BSD-2-Clause
  5. */
  6. #pragma once
  7. #include <AK/ByteBuffer.h>
  8. #include <AK/ByteReader.h>
  9. #include <AK/Endian.h>
  10. #include <AK/Types.h>
  11. #include <LibTLS/Extensions.h>
  12. namespace TLS {
  13. class PacketBuilder {
  14. public:
  15. PacketBuilder(ContentType type, u16 version, size_t size_hint = 0xfdf)
  16. : PacketBuilder(type, (ProtocolVersion)version, size_hint)
  17. {
  18. }
  19. PacketBuilder(ContentType type, ProtocolVersion version, size_t size_hint = 0xfdf)
  20. {
  21. // FIXME: Handle possible OOM situation.
  22. m_packet_data = ByteBuffer::create_uninitialized(size_hint + 16).release_value_but_fixme_should_propagate_errors();
  23. m_current_length = 5;
  24. m_packet_data[0] = (u8)type;
  25. ByteReader::store(m_packet_data.offset_pointer(1), AK::convert_between_host_and_network_endian((u16)version));
  26. }
  27. inline void append(u16 value)
  28. {
  29. value = AK::convert_between_host_and_network_endian(value);
  30. append((u8 const*)&value, sizeof(value));
  31. }
  32. inline void append(u8 value)
  33. {
  34. append((u8 const*)&value, sizeof(value));
  35. }
  36. inline void append(ReadonlyBytes data)
  37. {
  38. append(data.data(), data.size());
  39. }
  40. inline void append_u24(u32 value)
  41. {
  42. u8 buf[3];
  43. buf[0] = value / 0x10000;
  44. value %= 0x10000;
  45. buf[1] = value / 0x100;
  46. value %= 0x100;
  47. buf[2] = value;
  48. append(buf, 3);
  49. }
  50. inline void append(u8 const* data, size_t bytes)
  51. {
  52. if (bytes == 0)
  53. return;
  54. auto old_length = m_current_length;
  55. m_current_length += bytes;
  56. if (m_packet_data.size() < m_current_length) {
  57. m_packet_data.resize(m_current_length);
  58. }
  59. m_packet_data.overwrite(old_length, data, bytes);
  60. }
  61. inline ByteBuffer build()
  62. {
  63. auto length = m_current_length;
  64. m_current_length = 0;
  65. // FIXME: Propagate errors.
  66. return MUST(m_packet_data.slice(0, length));
  67. }
  68. inline void set(size_t offset, u8 value)
  69. {
  70. VERIFY(offset < m_current_length);
  71. m_packet_data[offset] = value;
  72. }
  73. size_t length() const { return m_current_length; }
  74. private:
  75. ByteBuffer m_packet_data;
  76. size_t m_current_length;
  77. };
  78. }