1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
// Copyright (C) 2023 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR BSD-3-Clause
#include "ftpcontrolchannel.h"
#include <QtCore/qcoreapplication.h>
FtpControlChannel::FtpControlChannel(QObject *parent) : QObject(parent)
{
connect(&m_socket, &QIODevice::readyRead,
this, &FtpControlChannel::onReadyRead);
connect(&m_socket, &QAbstractSocket::disconnected,
this, &FtpControlChannel::closed);
connect(&m_socket, &QAbstractSocket::connected, this, [this]() {
emit opened(m_socket.localAddress(), m_socket.localPort());
});
connect(&m_socket, &QAbstractSocket::errorOccurred,
this, &FtpControlChannel::error);
}
void FtpControlChannel::connectToServer(const QString &server)
{
m_socket.connectToHost(server, 21);
}
void FtpControlChannel::command(const QByteArray &command,
const QByteArray ¶ms)
{
QByteArray sendData = command;
if (!params.isEmpty())
sendData += " " + params;
m_socket.write(sendData + "\r\n");
}
void FtpControlChannel::onReadyRead()
{
m_buffer.append(m_socket.readAll());
int rn = -1;
while ((rn = m_buffer.indexOf("\r\n")) != -1) {
QByteArray received = m_buffer.mid(0, rn);
m_buffer = m_buffer.mid(rn + 2);
int space = received.indexOf(' ');
if (space != -1) {
int code = received.mid(0, space).toInt();
if (code == 0) {
qDebug() << "Info received: " << received.mid(space + 1);
emit info(received.mid(space + 1));
} else {
qDebug() << "Reply received: " << received.mid(space + 1);
emit reply(code, received.mid(space + 1));
}
} else {
emit invalidReply(received);
}
}
}
void FtpControlChannel::error(QAbstractSocket::SocketError error)
{
qWarning() << "Socket error:" << error;
QCoreApplication::exit();
}
|
