Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
22 changes: 22 additions & 0 deletions src/framework/network/internal/networkmanager.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -81,6 +81,8 @@ Ret NetworkManager::del(const QUrl& url, IncomingDevice* incomingData, const Req
Ret NetworkManager::execRequest(RequestType requestType, const QUrl& url, IncomingDevice* incomingData, OutgoingDevice* outgoingData,
const RequestHeaders& headers)
{
LOGI() << "Start: " << requestTypeToString(requestType) << ", url: " << url.toString();

if (outgoingData && outgoingData->device()) {
if (!openDevice(outgoingData->device(), QIODevice::ReadOnly)) {
return make_ret(Err::FiledOpenIODeviceRead);
Expand Down Expand Up @@ -129,13 +131,19 @@ Ret NetworkManager::execRequest(RequestType requestType, const QUrl& url, Incomi

m_progress.finish(ret);

if (reply) {
reply->disconnect();
}

if (outgoingData && outgoingData->device()) {
closeDevice(outgoingData->device());
}

closeDevice(m_incomingData);
m_incomingData = nullptr;

LOGI() << "Finish: " << requestTypeToString(requestType) << ", url: " << url.toString();

return ret;
}

Expand Down Expand Up @@ -307,3 +315,17 @@ Ret NetworkManager::errorFromReply(const QNetworkReply* reply) const

return ret;
}

String NetworkManager::requestTypeToString(RequestType type)
{
switch (type) {
case GET_REQUEST: return u"GET";
case HEAD_REQUEST: return u"HEAD";
case POST_REQUEST: return u"POST";
case PUT_REQUEST: return u"PUT";
case PATCH_REQUEST: return u"PATCH";
case DELETE_REQUEST: return u"DELETE";
}

return String();
}
3 changes: 2 additions & 1 deletion src/framework/network/internal/networkmanager.h
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,8 @@ class NetworkManager : public QObject, public INetworkManager, public Injectable
Ret waitForReplyFinished(QNetworkReply* reply, int timeoutMs);
Ret errorFromReply(const QNetworkReply* reply) const;

private:
static String requestTypeToString(RequestType type);

QNetworkAccessManager* m_manager = nullptr;
IncomingDevice* m_incomingData = nullptr;
QNetworkReply* m_reply = nullptr;
Expand Down
4 changes: 2 additions & 2 deletions src/musesounds/internal/musesoundscheckupdateservice.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -83,9 +83,9 @@ muse::RetVal<ReleaseInfo> MuseSoundsCheckUpdateService::checkForUpdate()

QBuffer buff;
QUrl url = configuration()->checkForMuseSoundsUpdateUrl();
m_networkManager = networkManagerCreator()->makeNetworkManager();
INetworkManagerPtr networkManager = networkManagerCreator()->makeNetworkManager();

Ret getUpdateInfo = m_networkManager->get(url, &buff);
Ret getUpdateInfo = networkManager->get(url, &buff);

if (!getUpdateInfo) {
LOGE() << getUpdateInfo.toString();
Expand Down
2 changes: 0 additions & 2 deletions src/musesounds/internal/musesoundscheckupdateservice.h
Original file line number Diff line number Diff line change
Expand Up @@ -64,8 +64,6 @@ class MuseSoundsCheckUpdateService : public IMuseSoundsCheckUpdateService, publi

muse::RetVal<muse::update::ReleaseInfo> m_lastCheckResult;
muse::io::path_t m_installatorPath;

muse::network::INetworkManagerPtr m_networkManager;
muse::Progress m_updateProgress;
};
}
Loading