1// Copyright (C) 2016 The Qt Company Ltd.
2// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only OR GPL-2.0-only OR GPL-3.0-only
3
4#include "qnetworkreplyfileimpl_p.h"
5
6#include "QtCore/qdatetime.h"
7#include "qnetworkaccessmanager_p.h"
8#include <QtCore/QCoreApplication>
9#include <QtCore/QFileInfo>
10#include <QtCore/QThread>
11#include "qnetworkfile_p.h"
12#include "qnetworkrequest.h"
13
14QT_BEGIN_NAMESPACE
15
16using namespace Qt::StringLiterals;
17
18QT_IMPL_METATYPE_EXTERN_TAGGED(QNetworkRequest::KnownHeaders, QNetworkRequest__KnownHeaders)
19
20QNetworkReplyFileImplPrivate::QNetworkReplyFileImplPrivate()
21 : QNetworkReplyPrivate(), managerPrivate(nullptr), realFile(nullptr)
22{
23 qRegisterMetaType<QNetworkRequest::KnownHeaders>();
24 qRegisterMetaType<QNetworkReply::NetworkError>();
25}
26
27QNetworkReplyFileImpl::~QNetworkReplyFileImpl()
28{
29 QNetworkReplyFileImplPrivate *d = (QNetworkReplyFileImplPrivate*) d_func();
30 if (d->realFile) {
31 if (d->realFile->thread() == QThread::currentThread())
32 delete d->realFile;
33 else
34 QMetaObject::invokeMethod(obj: d->realFile, member: "deleteLater", c: Qt::QueuedConnection);
35 }
36}
37
38QNetworkReplyFileImpl::QNetworkReplyFileImpl(QNetworkAccessManager *manager, const QNetworkRequest &req, const QNetworkAccessManager::Operation op)
39 : QNetworkReply(*new QNetworkReplyFileImplPrivate(), manager)
40{
41 setRequest(req);
42 setUrl(req.url());
43 setOperation(op);
44 QNetworkReply::open(mode: QIODevice::ReadOnly);
45
46 QNetworkReplyFileImplPrivate *d = (QNetworkReplyFileImplPrivate*) d_func();
47
48 d->managerPrivate = manager->d_func();
49
50 QUrl url = req.url();
51 if (url.host() == "localhost"_L1)
52 url.setHost(host: QString());
53
54#if !defined(Q_OS_WIN)
55 // do not allow UNC paths on Unix
56 if (!url.host().isEmpty()) {
57 // we handle only local files
58 QString msg = QCoreApplication::translate(context: "QNetworkAccessFileBackend", key: "Request for opening non-local file %1").arg(a: url.toString());
59 setError(errorCode: QNetworkReply::ProtocolInvalidOperationError, errorString: msg);
60 setFinished(true); // We're finished, will emit finished() after ctor is done.
61 QMetaObject::invokeMethod(obj: this, member: "errorOccurred", c: Qt::QueuedConnection,
62 Q_ARG(QNetworkReply::NetworkError, QNetworkReply::ProtocolInvalidOperationError));
63 QMetaObject::invokeMethod(object: this, function: &QNetworkReplyFileImpl::fileOpenFinished, type: Qt::QueuedConnection, args: false);
64 return;
65 }
66#endif
67 if (url.path().isEmpty())
68 url.setPath(path: "/"_L1);
69 setUrl(url);
70
71 QString fileName = url.toLocalFile();
72 if (fileName.isEmpty()) {
73 const QString scheme = url.scheme();
74 if (scheme == "qrc"_L1) {
75 fileName = u':' + url.path();
76 } else {
77#if defined(Q_OS_ANDROID)
78 if (scheme == "assets"_L1)
79 fileName = "assets:"_L1 + url.path();
80 else
81#endif
82 fileName = url.toString(options: QUrl::RemoveAuthority | QUrl::RemoveFragment | QUrl::RemoveQuery);
83 }
84 }
85
86 if (req.attribute(code: QNetworkRequest::BackgroundRequestAttribute).toBool()) { // Asynchronous open
87 auto realFile = new QNetworkFile(fileName);
88 connect(sender: realFile, signal: &QNetworkFile::headerRead, context: this, slot: &QNetworkReplyFileImpl::setWellKnownHeader,
89 type: Qt::QueuedConnection);
90 connect(sender: realFile, signal: &QNetworkFile::networkError, context: this, slot: &QNetworkReplyFileImpl::setError,
91 type: Qt::QueuedConnection);
92 connect(asender: realFile, SIGNAL(finished(bool)), SLOT(fileOpenFinished(bool)),
93 atype: Qt::QueuedConnection);
94
95 realFile->moveToThread(thread: d->managerPrivate->createThread());
96 QMetaObject::invokeMethod(obj: realFile, member: "open", c: Qt::QueuedConnection);
97
98 d->realFile = realFile;
99 } else { // Synch open
100 setFinished(true);
101
102 QFileInfo fi(fileName);
103 if (fi.isDir()) {
104 QString msg = QCoreApplication::translate(context: "QNetworkAccessFileBackend", key: "Cannot open %1: Path is a directory").arg(a: url.toString());
105 setError(errorCode: QNetworkReply::ContentOperationNotPermittedError, errorString: msg);
106 QMetaObject::invokeMethod(obj: this, member: "errorOccurred", c: Qt::QueuedConnection,
107 Q_ARG(QNetworkReply::NetworkError, QNetworkReply::ContentOperationNotPermittedError));
108 QMetaObject::invokeMethod(obj: this, member: "finished", c: Qt::QueuedConnection);
109 return;
110 }
111 d->realFile = new QFile(fileName, this);
112 bool opened = d->realFile->open(flags: QIODevice::ReadOnly | QIODevice::Unbuffered);
113
114 // could we open the file?
115 if (!opened) {
116 QString msg = QCoreApplication::translate(context: "QNetworkAccessFileBackend", key: "Error opening %1: %2")
117 .arg(args: d->realFile->fileName(), args: d->realFile->errorString());
118
119 if (fi.exists()) {
120 setError(errorCode: QNetworkReply::ContentAccessDenied, errorString: msg);
121 QMetaObject::invokeMethod(obj: this, member: "errorOccurred", c: Qt::QueuedConnection,
122 Q_ARG(QNetworkReply::NetworkError, QNetworkReply::ContentAccessDenied));
123 } else {
124 setError(errorCode: QNetworkReply::ContentNotFoundError, errorString: msg);
125 QMetaObject::invokeMethod(obj: this, member: "errorOccurred", c: Qt::QueuedConnection,
126 Q_ARG(QNetworkReply::NetworkError, QNetworkReply::ContentNotFoundError));
127 }
128 QMetaObject::invokeMethod(obj: this, member: "finished", c: Qt::QueuedConnection);
129 return;
130 }
131 auto h = headers();
132 h.replaceOrAppend(name: QHttpHeaders::WellKnownHeader::LastModified,
133 newValue: QNetworkHeadersPrivate::toHttpDate(dt: fi.lastModified()));
134 h.replaceOrAppend(name: QHttpHeaders::WellKnownHeader::ContentLength,
135 newValue: QByteArray::number(fi.size()));
136 setHeaders(std::move(h));
137
138 QMetaObject::invokeMethod(obj: this, member: "metaDataChanged", c: Qt::QueuedConnection);
139 QMetaObject::invokeMethod(obj: this, member: "downloadProgress", c: Qt::QueuedConnection,
140 Q_ARG(qint64, fi.size()), Q_ARG(qint64, fi.size()));
141 QMetaObject::invokeMethod(obj: this, member: "readyRead", c: Qt::QueuedConnection);
142 QMetaObject::invokeMethod(obj: this, member: "finished", c: Qt::QueuedConnection);
143 }
144}
145
146void QNetworkReplyFileImpl::close()
147{
148 Q_D(QNetworkReplyFileImpl);
149 QNetworkReply::close();
150 if (d->realFile) {
151 if (d->realFile->thread() == thread())
152 d->realFile->close();
153 else
154 QMetaObject::invokeMethod(obj: d->realFile, member: "close", c: Qt::QueuedConnection);
155 }
156}
157
158void QNetworkReplyFileImpl::abort()
159{
160 close();
161}
162
163qint64 QNetworkReplyFileImpl::bytesAvailable() const
164{
165 Q_D(const QNetworkReplyFileImpl);
166 if (!d->isFinished || !d->realFile || !d->realFile->isOpen())
167 return QNetworkReply::bytesAvailable();
168 return QNetworkReply::bytesAvailable() + d->realFile->bytesAvailable();
169}
170
171bool QNetworkReplyFileImpl::isSequential () const
172{
173 return true;
174}
175
176qint64 QNetworkReplyFileImpl::size() const
177{
178 const auto totalSizeOpt = QNetworkHeadersPrivate::toInt(
179 value: headers().value(name: QHttpHeaders::WellKnownHeader::ContentLength));
180 return totalSizeOpt.value_or(u: 0);
181}
182
183/*!
184 \internal
185*/
186qint64 QNetworkReplyFileImpl::readData(char *data, qint64 maxlen)
187{
188 Q_D(QNetworkReplyFileImpl);
189 if (!d->isFinished || !d->realFile || !d->realFile->isOpen())
190 return -1;
191 qint64 ret = d->realFile->read(data, maxlen);
192 if (bytesAvailable() == 0)
193 d->realFile->close();
194 if (ret == 0 && bytesAvailable() == 0)
195 return -1;
196 else {
197 setAttribute(code: QNetworkRequest::HttpStatusCodeAttribute, value: 200);
198 setAttribute(code: QNetworkRequest::HttpReasonPhraseAttribute, value: "OK"_L1);
199 return ret;
200 }
201}
202
203void QNetworkReplyFileImpl::fileOpenFinished(bool isOpen)
204{
205 setFinished(true);
206 if (isOpen) {
207 const auto fileSize = size();
208 Q_EMIT metaDataChanged();
209 Q_EMIT downloadProgress(bytesReceived: fileSize, bytesTotal: fileSize);
210 Q_EMIT readyRead();
211 }
212 Q_EMIT finished();
213}
214
215QT_END_NAMESPACE
216
217#include "moc_qnetworkreplyfileimpl_p.cpp"
218
219

Provided by KDAB

Privacy Policy
Learn to use CMake with our Intro Training
Find out more

source code of qtbase/src/network/access/qnetworkreplyfileimpl.cpp