123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211 |
- /*
- * Copyright (c) 2020, Andreas Kling <kling@serenityos.org>
- *
- * SPDX-License-Identifier: BSD-2-Clause
- */
- #include <AK/JsonValue.h>
- #include <AK/MemoryStream.h>
- #include <AK/URL.h>
- #include <LibCore/AnonymousBuffer.h>
- #include <LibCore/DateTime.h>
- #include <LibCore/Proxy.h>
- #include <LibIPC/Decoder.h>
- #include <LibIPC/Dictionary.h>
- #include <LibIPC/File.h>
- #include <fcntl.h>
- namespace IPC {
- ErrorOr<void> Decoder::decode(bool& value)
- {
- m_stream >> value;
- return m_stream.try_handle_any_error();
- }
- ErrorOr<void> Decoder::decode(u8& value)
- {
- m_stream >> value;
- return m_stream.try_handle_any_error();
- }
- ErrorOr<void> Decoder::decode(u16& value)
- {
- m_stream >> value;
- return m_stream.try_handle_any_error();
- }
- ErrorOr<void> Decoder::decode(unsigned& value)
- {
- m_stream >> value;
- return m_stream.try_handle_any_error();
- }
- ErrorOr<void> Decoder::decode(unsigned long& value)
- {
- m_stream >> value;
- return m_stream.try_handle_any_error();
- }
- ErrorOr<void> Decoder::decode(unsigned long long& value)
- {
- m_stream >> value;
- return m_stream.try_handle_any_error();
- }
- ErrorOr<void> Decoder::decode(i8& value)
- {
- m_stream >> value;
- return m_stream.try_handle_any_error();
- }
- ErrorOr<void> Decoder::decode(i16& value)
- {
- m_stream >> value;
- return m_stream.try_handle_any_error();
- }
- ErrorOr<void> Decoder::decode(i32& value)
- {
- m_stream >> value;
- return m_stream.try_handle_any_error();
- }
- ErrorOr<void> Decoder::decode(i64& value)
- {
- m_stream >> value;
- return m_stream.try_handle_any_error();
- }
- ErrorOr<void> Decoder::decode(float& value)
- {
- m_stream >> value;
- return m_stream.try_handle_any_error();
- }
- ErrorOr<void> Decoder::decode(double& value)
- {
- m_stream >> value;
- return m_stream.try_handle_any_error();
- }
- ErrorOr<void> Decoder::decode(String& value)
- {
- i32 length;
- TRY(decode(length));
- if (length < 0) {
- value = {};
- return {};
- }
- if (length == 0) {
- value = String::empty();
- return {};
- }
- char* text_buffer = nullptr;
- auto text_impl = StringImpl::create_uninitialized(static_cast<size_t>(length), text_buffer);
- m_stream >> Bytes { text_buffer, static_cast<size_t>(length) };
- value = *text_impl;
- return m_stream.try_handle_any_error();
- }
- ErrorOr<void> Decoder::decode(ByteBuffer& value)
- {
- i32 length;
- TRY(decode(length));
- if (length < 0) {
- value = {};
- return {};
- }
- if (length == 0) {
- value = {};
- return {};
- }
- value = TRY(ByteBuffer::create_uninitialized(length));
- m_stream >> value.bytes();
- return m_stream.try_handle_any_error();
- }
- ErrorOr<void> Decoder::decode(JsonValue& value)
- {
- String string;
- TRY(decode(string));
- value = TRY(JsonValue::from_string(string));
- return {};
- }
- ErrorOr<void> Decoder::decode(URL& value)
- {
- String string;
- TRY(decode(string));
- value = URL(string);
- return {};
- }
- ErrorOr<void> Decoder::decode(Dictionary& dictionary)
- {
- u64 size;
- TRY(decode(size));
- if (size >= (size_t)NumericLimits<i32>::max())
- VERIFY_NOT_REACHED();
- for (size_t i = 0; i < size; ++i) {
- String key;
- TRY(decode(key));
- String value;
- TRY(decode(value));
- dictionary.add(move(key), move(value));
- }
- return {};
- }
- ErrorOr<void> Decoder::decode([[maybe_unused]] File& file)
- {
- int fd = TRY(m_socket.receive_fd(O_CLOEXEC));
- file = File(fd, File::ConstructWithReceivedFileDescriptor);
- return {};
- }
- template<>
- ErrorOr<void> decode(Decoder& decoder, Core::AnonymousBuffer& buffer)
- {
- bool valid;
- TRY(decoder.decode(valid));
- if (!valid) {
- buffer = {};
- return {};
- }
- u32 size;
- TRY(decoder.decode(size));
- IPC::File anon_file;
- TRY(decoder.decode(anon_file));
- buffer = TRY(Core::AnonymousBuffer::create_from_anon_fd(anon_file.take_fd(), size));
- return {};
- }
- template<>
- ErrorOr<void> decode(Decoder& decoder, Core::DateTime& datetime)
- {
- i64 timestamp;
- TRY(decoder.decode(timestamp));
- datetime = Core::DateTime::from_timestamp(static_cast<time_t>(timestamp));
- return {};
- }
- template<>
- ErrorOr<void> decode(Decoder& decoder, Core::ProxyData& data)
- {
- UnderlyingType<decltype(data.type)> type;
- TRY(decoder.decode(type));
- data.type = static_cast<Core::ProxyData::Type>(type);
- TRY(decoder.decode(data.host_ipv4));
- TRY(decoder.decode(data.port));
- return {};
- }
- }
|