mirror of
https://github.com/LadybirdBrowser/ladybird.git
synced 2024-12-27 05:05:32 +03:00
5e1499d104
This commit un-deprecates DeprecatedString, and repurposes it as a byte
string.
As the null state has already been removed, there are no other
particularly hairy blockers in repurposing this type as a byte string
(what it _really_ is).
This commit is auto-generated:
$ xs=$(ack -l \bDeprecatedString\b\|deprecated_string AK Userland \
Meta Ports Ladybird Tests Kernel)
$ perl -pie 's/\bDeprecatedString\b/ByteString/g;
s/deprecated_string/byte_string/g' $xs
$ clang-format --style=file -i \
$(git diff --name-only | grep \.cpp\|\.h)
$ gn format $(git ls-files '*.gn' '*.gni')
98 lines
3.0 KiB
C++
98 lines
3.0 KiB
C++
/*
|
|
* Copyright (c) 2021, Dex♪ <dexes.ttp@gmail.com>
|
|
* Copyright (c) 2022, Ali Mohammad Pur <mpfard@serenityos.org>
|
|
* Copyright (c) 2022, the SerenityOS developers.
|
|
* Copyright (c) 2022, Andreas Kling <kling@serenityos.org>
|
|
*
|
|
* SPDX-License-Identifier: BSD-2-Clause
|
|
*/
|
|
|
|
#include "WebSocketImplQt.h"
|
|
#include "StringUtils.h"
|
|
#include <LibCore/EventLoop.h>
|
|
#include <QSslSocket>
|
|
#include <QTcpSocket>
|
|
|
|
namespace Ladybird {
|
|
|
|
WebSocketImplQt::~WebSocketImplQt() = default;
|
|
WebSocketImplQt::WebSocketImplQt() = default;
|
|
|
|
bool WebSocketImplQt::can_read_line()
|
|
{
|
|
return m_socket->canReadLine();
|
|
}
|
|
|
|
bool WebSocketImplQt::send(ReadonlyBytes bytes)
|
|
{
|
|
auto bytes_written = m_socket->write(reinterpret_cast<char const*>(bytes.data()), bytes.size());
|
|
if (bytes_written == -1)
|
|
return false;
|
|
VERIFY(static_cast<size_t>(bytes_written) == bytes.size());
|
|
return true;
|
|
}
|
|
|
|
bool WebSocketImplQt::eof()
|
|
{
|
|
return m_socket->state() == QTcpSocket::SocketState::UnconnectedState
|
|
&& !m_socket->bytesAvailable();
|
|
}
|
|
|
|
void WebSocketImplQt::discard_connection()
|
|
{
|
|
m_socket = nullptr;
|
|
}
|
|
|
|
void WebSocketImplQt::connect(WebSocket::ConnectionInfo const& connection_info)
|
|
{
|
|
VERIFY(!m_socket);
|
|
VERIFY(on_connected);
|
|
VERIFY(on_connection_error);
|
|
VERIFY(on_ready_to_read);
|
|
|
|
if (connection_info.is_secure()) {
|
|
auto ssl_socket = make<QSslSocket>();
|
|
ssl_socket->connectToHostEncrypted(
|
|
qstring_from_ak_string(MUST(connection_info.url().serialized_host())),
|
|
connection_info.url().port_or_default());
|
|
QObject::connect(ssl_socket.ptr(), &QSslSocket::alertReceived, [this](QSsl::AlertLevel level, QSsl::AlertType, QString const&) {
|
|
if (level == QSsl::AlertLevel::Fatal)
|
|
on_connection_error();
|
|
});
|
|
m_socket = move(ssl_socket);
|
|
} else {
|
|
m_socket = make<QTcpSocket>();
|
|
m_socket->connectToHost(
|
|
qstring_from_ak_string(MUST(connection_info.url().serialized_host())),
|
|
connection_info.url().port_or_default());
|
|
}
|
|
|
|
QObject::connect(m_socket.ptr(), &QTcpSocket::readyRead, [this] {
|
|
on_ready_to_read();
|
|
});
|
|
|
|
QObject::connect(m_socket.ptr(), &QTcpSocket::connected, [this] {
|
|
on_connected();
|
|
});
|
|
}
|
|
|
|
ErrorOr<ByteBuffer> WebSocketImplQt::read(int max_size)
|
|
{
|
|
auto buffer = TRY(ByteBuffer::create_uninitialized(max_size));
|
|
auto bytes_read = m_socket->read(reinterpret_cast<char*>(buffer.data()), buffer.size());
|
|
if (bytes_read == -1)
|
|
return Error::from_string_literal("WebSocketImplQt::read(): Error reading from socket");
|
|
return buffer.slice(0, bytes_read);
|
|
}
|
|
|
|
ErrorOr<ByteString> WebSocketImplQt::read_line(size_t size)
|
|
{
|
|
auto buffer = TRY(ByteBuffer::create_uninitialized(size));
|
|
auto bytes_read = m_socket->readLine(reinterpret_cast<char*>(buffer.data()), buffer.size());
|
|
if (bytes_read == -1)
|
|
return Error::from_string_literal("WebSocketImplQt::read_line(): Error reading from socket");
|
|
return ByteString::copy(buffer.span().slice(0, bytes_read));
|
|
}
|
|
|
|
}
|