plac

Unofficial Roon clients

  1. 1
  2. 2
  3. 3
  4. 4
  5. 5
  6. 6
  7. 7
  8. 8
  9. 9
  10. 10
  11. 11
  12. 12
  13. 13
  14. 14
  15. 15
  16. 16
  17. 17
  18. 18
  19. 19
  20. 20
  21. 21
  22. 22
  23. 23
  24. 24
  25. 25
  26. 26
  27. 27
  28. 28
  29. 29
  30. 30
  31. 31
  32. 32
  33. 33
  34. 34
  35. 35
  36. 36
  37. 37
  38. 38
  39. 39
  40. 40
  41. 41
  42. 42
  43. 43
  44. 44
  45. 45
  46. 46
  47. 47
  48. 48
  49. 49
  50. 50
  51. 51
  52. 52
  53. 53
  54. 54
  55. 55
  56. 56
  57. 57
  58. 58
  59. 59
  60. 60
  61. 61
  62. 62
  63. 63
  64. 64
  65. 65
  66. 66
  67. 67
  68. 68
  69. 69
  70. 70
  71. 71
  72. 72
  73. 73
  74. 74
  75. 75
  76. 76
  77. 77
  78. 78
  79. 79
  80. 80
  81. 81
  82. 82
  83. 83
  84. 84
  85. 85
  86. 86
  87. 87
  88. 88
  89. 89
  90. 90
  91. 91
  92. 92
  93. 93
  94. 94
  95. 95
  96. 96
  97. 97
  98. 98
  99. 99
  100. 100
  101. 101
  102. 102
  103. 103
  104. 104
  105. 105
  106. 106
  107. 107
  108. 108
  109. 109
  110. 110
  111. 111
  112. 112
  113. 113
  114. 114
  115. 115
  116. 116
  117. 117
  118. 118
  119. 119
  120. 120
  121. 121
  122. 122
  123. 123
  124. 124
  125. 125
  126. 126
  127. 127
  128. 128
  129. 129
  130. 130
  131. 131
  132. 132
  133. 133
  134. 134
  135. 135
  136. 136
  137. 137
  138. 138
  139. 139
// Copyright 2025 Shota FUJI
//
// 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.
//
// SPDX-License-Identifier: Apache-2.0

namespace Moo {
	public errordomain HeadersParseError {
		NO_PARSING_CONTEXT,
		NO_DELIMITER,
		EMPTY_KEY,
		NON_ASCII_KEY,
		NON_UTF8_VALUE,
	}

	public class Headers : Object {
		private Gee.HashMap<string, Gee.ArrayList<string> >map;

		public int last_byte_index { get; construct; default = -1; }

		public int size { get { return map.size; } }

		public string? content_type {
			owned get {
				var entry = map["content-type"];
				if (entry == null) {
					return null;
				}

				return entry[0];
			}
		}

		public uint64 content_length {
			get {
				var entry = map["content-length"];
				if (entry == null) {
					return 0;
				}

				var value = entry[0];
				if (value == null) {
					return 0;
				}

				return uint64.parse(value);
			}
		}

		public uint64 request_id {
			get {
				var entry = map["request-id"];
				if (entry == null) {
					return 0;
				}

				var value = entry[0];
				if (value == null) {
					return 0;
				}

				return uint64.parse(value);
			}
		}

		/**
		 * Parses `src`.
		 *
		 * Header keys will be ASCII lowercased.
		 *
		 * Throws an `NO_PARSING_CONTEXT` if `meta` is not created by
		 * `Metadata.from_string()`.
		 */
		public Headers.from_string(string src, Metadata meta) throws HeadersParseError {
			if (meta.last_byte_index < 0) {
				throw new HeadersParseError.NO_PARSING_CONTEXT("Metadata does not contain parsed length.");
			}

			var map = new Gee.HashMap<string, Gee.ArrayList<string> >();

			int i = meta.last_byte_index;

			while (i + 1 <= src.length) {
				var lf = src.index_of_char('\n', i);
				if (lf == i) {
					i += 1;
					break;
				}

				var line = src.slice(i, lf < 0 ? src.length : lf);
				i = lf < 0 ? i + line.length : lf + 1;

				var parts = line.split(":", 2);
				if (parts.length < 2) {
					throw new HeadersParseError.NO_DELIMITER("Header delimiter does not found.");
				}

				var key = parts[0].ascii_down().strip();
				if (key.length == 0) {
					throw new HeadersParseError.EMPTY_KEY("Found an empty header key.");
				}
				if (!key.is_ascii()) {
					throw new HeadersParseError.NON_ASCII_KEY("Found a header key containing non-ASCII character.");
				}

				var value = parts[1].strip();
				if (!value.validate()) {
					throw new HeadersParseError.NON_UTF8_VALUE("Found a header with non-UTF8 value.");
				}

				var existing = map[key];
				if (existing != null) {
					existing.add(value);
				} else {
					var entry = new Gee.ArrayList<string>();
					entry.add(value);
					map[key] = entry;
				}
			}

			Object(last_byte_index: i);
			this.map = map;
		}

		public new Gee.ArrayList<string>? @get(string key) {
			return map[key];
		}
	}
}