Index: sources/device/DeviceController.cpp =================================================================== diff -u -r52bd89b3860281744d9794f0f003c36c4d59a2dc -r0958534c2bc010c3cb02a2e08803a6e2bdd7a0d2 --- sources/device/DeviceController.cpp (.../DeviceController.cpp) (revision 52bd89b3860281744d9794f0f003c36c4d59a2dc) +++ sources/device/DeviceController.cpp (.../DeviceController.cpp) (revision 0958534c2bc010c3cb02a2e08803a6e2bdd7a0d2) @@ -122,8 +122,8 @@ connect(&_Logger , SIGNAL(didLogBackup (const QString &)), this , SLOT( onLogBackup (const QString &))); - connect(&_CloudSyncController , SIGNAL(didLogUpload (const QString &)), - this , SLOT( onLogUpload (const QString &))); + connect(&_CloudSyncController , SIGNAL(didLogUpload (const QString &, const quint32 &, const quint32 &)), + this , SLOT( onLogUpload (const QString &, const quint32 &, const quint32 &))); DEVICE_DEV_INIT_CONNECTIONS_LIST @@ -1003,7 +1003,10 @@ if ( gLogCompress ) { ok = FileHandler::backupFile(fileSrc); } - ok = QFile::rename(fileSrc + gzipSufx, fileDest + gzipSufx); + QString fileDestGz = fileDest + gzipSufx; + logTally(QString(), fileDestGz); + ok = QFile::rename(fileSrc + gzipSufx, fileDestGz); + LOG_DEBUG(QString("Pending Log: %1, %2").arg(fileSrc, fileDestGz)); // Now the serial received and the system is logging in the log with the serial number, // therefore it is not bootPOST. @@ -1013,8 +1016,12 @@ fileDest.replace( _Logger.logFileNameHDSN(), _Logger.logFileNameHDSN() + _Logger.fileSeparator() + _Logger.logFileNameHDSN_default() ); if ( ! QFile::exists(fileSrc) ) goto lOut; - ok = FileHandler::backupFile(fileSrc); - ok = QFile::rename(fileSrc + gzipSufx, fileDest + gzipSufx); + if ( gLogCompress ) { + ok = FileHandler::backupFile(fileSrc); + } + QString fileDestGz = fileDest + gzipSufx; + logTally(QString(), fileDestGz); + ok = QFile::rename(fileSrc + gzipSufx, fileDestGz); } lOut: @@ -1038,29 +1045,66 @@ QFileInfo fileInfo(vFileName); QString filePath; QString fileBase(fileInfo.baseName()); + QString regstr = "u\\d*."; + QRegExp reg(regstr); + QString uploadExt; + QString pendingExt; + QString fileSufx; + QString fileDest; + Logger::LogType logType; - const QString pendingExt = _Logger.logFileNamePendingSubExt(); - const QString uploadExt = _Logger.logFileNameUploadedSubExt(); - const QString fileSufx(fileInfo.completeSuffix().replace(pendingExt, uploadExt)); + if (reg.indexIn(fileInfo.completeSuffix()) != -1) { pendingExt = reg.cap(0);} else {ok = false; goto lOut;} - QString fileDest = QString("%1.%2").arg(fileBase, fileSufx); + uploadExt = _Logger.logFileNameUploadedSubExt(); + fileSufx = fileInfo.completeSuffix().replace(pendingExt, uploadExt); - Logger::LogType logType = _Logger.logFileLogType(vFileName, filePath); + fileDest = QString("%1.%2").arg(fileBase, fileSufx); + + logType = _Logger.logFileLogType(vFileName, filePath); ok = logType != Logger::eLogNone; if ( ! ok ) { LOG_APPED_UI(QString("CS Incorrect log upload type [%1]").arg(fileSufx)); goto lOut; } // DEBUG qDebug() << __FUNCTION__ << "\n" << vFileName << "\n" << fileDest; + logTally(filePath, fileDest); + + LOG_DEBUG(QString("Uploaded Log: %1, %2").arg(vFileName, fileDest)); ok = QFile::rename(filePath + vFileName, filePath + fileDest); lOut: return ok; } -void DeviceController::onLogUpload(const QString &vFileName) +quint8 DeviceController::logTally(const QString &vFilePath, QString &vFileDest) { + if ( ! gLogUpload ) return false; // no log Uploaded rename + + QString tFileDest = vFileDest; + quint8 tally = 0; + + do { //do while used incase no c*. exists + tFileDest = ((tally == 0) ? vFileDest.arg("") : vFileDest.arg(tally)); + ++tally; + LOG_DEBUG(QString("Tally: %1, %2, %3, %4").arg(tally).arg(vFilePath,vFileDest,tFileDest)); + } while (QFile::exists(vFilePath + tFileDest)); + + vFileDest = tFileDest; +// qDebug() << __FUNCTION__ << "\n" << vFilePath << "\n" << vFileDest; + + return tally; +} + +void DeviceController::onLogUpload(const QString &vFileName, const quint32 &vAccepted, const quint32 &vRejectReason) +{ if ( ! gLogUpload ) return; // no log uploaded rename ( slot ) bool ok = true; - ok = logUpload( vFileName); + if (vAccepted) ok = logUpload( vFileName); + else{ + switch (vRejectReason){ + case CloudSyncController::LogUploadRejectReason_Enum::eLogUpload_NoConnectivity : ok = false; break; //Connectivity Error + case CloudSyncController::LogUploadRejectReason_Enum::eLogUpload_NoCredentials : ok = false; _logUpload = false; break; //Credential Error + case CloudSyncController::LogUploadRejectReason_Enum::eLogUpload_Duplicate : logUpload( vFileName); break; //Duplicate Error + } + } emit didLogUpload(ok, vFileName); } @@ -1106,6 +1150,7 @@ */ void DeviceController::findPendingLogs() { + if ( ! _logUpload ) return; if ( ! gLogUpload ) return; // no log upload pending detection static QString pendingLog = ""; @@ -1119,7 +1164,7 @@ QFileInfoList pendingFiles; QString logLoc = Log_Folder_Base; - QString logExt = QString("*.%1*").arg(_Logger.logFileNamePendingSubExt()); // "*.u.*"; + QString logExt = QString("*.%1*").arg(_Logger.logFileNamePendingSubExt("*")); // "*.u*.*"; for( auto logFolder : { Log_Folder_Application, Log_Folder_Service/*, Log_Folder_CloudSync*/ } ) { pendingFiles = Storage::FileHandler::find( logLoc + logFolder, { logExt } ); // look into the list.