Compare commits
23 Commits
Author | SHA1 | Date | |
---|---|---|---|
18d04d15cf | |||
b81120f8dc | |||
8b2fcb25db | |||
698cf74516 | |||
20681b0d6c | |||
763647c145 | |||
4aad14b181 | |||
0a03228dea | |||
23551066c1 | |||
24f2ba7c44 | |||
2ed6768953 | |||
a1327388bc | |||
8d18ae10fe | |||
31bc2d0fa2 | |||
175b8fd3a1 | |||
a57fa6c31e | |||
c22c924e38 | |||
bdc64920a2 | |||
7bc9fa0c04 | |||
334da1fe4a | |||
5c152c9dc2 | |||
367ffaa3a1 | |||
2fd004f249 |
@@ -34,6 +34,11 @@ contains( CONFIG, PTU5 ) {
|
|||||||
lessThan(QT_MAJOR_VERSION, 5): PKGCONFIG += qextserialport
|
lessThan(QT_MAJOR_VERSION, 5): PKGCONFIG += qextserialport
|
||||||
QMAKE_CXXFLAGS += -O2 -std=c++17 # for GCC >= 4.7
|
QMAKE_CXXFLAGS += -O2 -std=c++17 # for GCC >= 4.7
|
||||||
# QMAKE_CXXFLAGS += -Wno-deprecated-copy
|
# QMAKE_CXXFLAGS += -Wno-deprecated-copy
|
||||||
|
PTU5BASEPATH = /opt/devel/ptu5
|
||||||
|
|
||||||
|
INCLUDEPATH += $$PTU5BASEPATH/qt/libs/devicecontroller/include
|
||||||
|
LIBS += -L$$PTU5BASEPATH/qt/libs/devicecontroller/library
|
||||||
|
|
||||||
ARCH = PTU5
|
ARCH = PTU5
|
||||||
DEFINES+=PTU5
|
DEFINES+=PTU5
|
||||||
}
|
}
|
||||||
|
@@ -39,6 +39,12 @@ contains( CONFIG, PTU5 ) {
|
|||||||
lessThan(QT_MAJOR_VERSION, 5): PKGCONFIG += qextserialport
|
lessThan(QT_MAJOR_VERSION, 5): PKGCONFIG += qextserialport
|
||||||
QMAKE_CXXFLAGS += -O2 -std=c++17 # for GCC >= 4.7
|
QMAKE_CXXFLAGS += -O2 -std=c++17 # for GCC >= 4.7
|
||||||
# QMAKE_CXXFLAGS += -Wno-deprecated-copy
|
# QMAKE_CXXFLAGS += -Wno-deprecated-copy
|
||||||
|
|
||||||
|
PTU5BASEPATH = /opt/devel/ptu5
|
||||||
|
|
||||||
|
INCLUDEPATH += $$PTU5BASEPATH/qt/libs/devicecontroller/include
|
||||||
|
LIBS += -L$$PTU5BASEPATH/qt/libs/devicecontroller/library
|
||||||
|
|
||||||
ARCH = PTU5
|
ARCH = PTU5
|
||||||
DEFINES+=PTU5
|
DEFINES+=PTU5
|
||||||
}
|
}
|
||||||
@@ -72,7 +78,6 @@ SOURCES += \
|
|||||||
|
|
||||||
HEADERS += \
|
HEADERS += \
|
||||||
message_handler.h \
|
message_handler.h \
|
||||||
plugins/interfaces.h \
|
|
||||||
process/command.h
|
process/command.h
|
||||||
|
|
||||||
OTHER_FILES += \
|
OTHER_FILES += \
|
||||||
|
@@ -4,7 +4,7 @@
|
|||||||
#include <QByteArray>
|
#include <QByteArray>
|
||||||
|
|
||||||
#include "message_handler.h"
|
#include "message_handler.h"
|
||||||
#include "plugins/interfaces.h"
|
#include <DeviceController/interfaces.h>
|
||||||
|
|
||||||
|
|
||||||
//#include <unistd.h>
|
//#include <unistd.h>
|
||||||
|
@@ -109,7 +109,14 @@ DEFINES += QT_DEPRECATED_WARNINGS
|
|||||||
# the same after an rsync. They might be noy after a change of the
|
# the same after an rsync. They might be noy after a change of the
|
||||||
# customer-number.
|
# customer-number.
|
||||||
# 1.4.3 : Use global directory for device-controller interfaces.h-file.
|
# 1.4.3 : Use global directory for device-controller interfaces.h-file.
|
||||||
VERSION="1.4.3"
|
# 1.4.4 : Add additional debug messages when downloading json-files.
|
||||||
|
# Move rsyncing of the customer-repository after the actual fetching
|
||||||
|
# of the repository. Otherwise, the update of, for instance
|
||||||
|
# tariff-files, would always be a step behind.
|
||||||
|
# 1.4.5 : In case a new branch has been created in a remote
|
||||||
|
# customer-repository (e.g. origin/zg1/zone101), then fetch/pull
|
||||||
|
# this branch before switching to this now locally existen branch.
|
||||||
|
VERSION="1.4.5"
|
||||||
# PLANNED TODOS:
|
# PLANNED TODOS:
|
||||||
# 1: Das Repository wird repariert bwz. neu geklont. Unabhaengig vom WAIT.
|
# 1: Das Repository wird repariert bwz. neu geklont. Unabhaengig vom WAIT.
|
||||||
# 2: Wenn der WAIT-Button aktiv ist, dann wird ein Repository repariert (neu
|
# 2: Wenn der WAIT-Button aktiv ist, dann wird ein Repository repariert (neu
|
||||||
|
@@ -6,6 +6,7 @@
|
|||||||
#include <QRegularExpression>
|
#include <QRegularExpression>
|
||||||
#include <QDebug>
|
#include <QDebug>
|
||||||
#include <QDir>
|
#include <QDir>
|
||||||
|
#include <QStringList>
|
||||||
|
|
||||||
|
|
||||||
GitClient::GitClient(QString const &customerNrStr,
|
GitClient::GitClient(QString const &customerNrStr,
|
||||||
@@ -290,6 +291,100 @@ bool GitClient::gitFsck() {
|
|||||||
}
|
}
|
||||||
return r;
|
return r;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
bool GitClient::branchExistsRemotely() {
|
||||||
|
bool remoteBranchExists = false;
|
||||||
|
if (QDir(m_customerRepository).exists()) {
|
||||||
|
qInfo() << "BRANCH NAME" << m_branchName;
|
||||||
|
QString const cmd = QString("git ls-remote --exit-code --heads origin %1").arg(m_branchName);
|
||||||
|
Command c(cmd);
|
||||||
|
if (c.execute(m_customerRepository)) {
|
||||||
|
// expected result: c16c833c8778c1b3691a74afee5a469177e4e69b refs/heads/zg1/zone1000
|
||||||
|
QString const s = c.getCommandResult().trimmed();
|
||||||
|
|
||||||
|
|
||||||
|
if (!s.isEmpty()) {
|
||||||
|
// the result is only one line
|
||||||
|
if ((remoteBranchExists = s.contains(m_branchName)) == true) {
|
||||||
|
qCritical() << "(" << __func__ << ":" << __LINE__ << ") branch"
|
||||||
|
<< m_branchName << "EXISTS REMOTELY. (" << s << ")";
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
Utils::printCriticalErrorMsg(QString("EMPTY RESULT FOR CMD %1").arg(cmd));
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
Utils::printCriticalErrorMsg(QString("FAILED TO EXEC '%1'").arg(cmd));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return remoteBranchExists;
|
||||||
|
}
|
||||||
|
|
||||||
|
bool GitClient::branchExistsLocally() {
|
||||||
|
Command c("git branch -l");
|
||||||
|
if (c.execute(m_customerRepository)) {
|
||||||
|
QString const s = c.getCommandResult().trimmed();
|
||||||
|
if (!s.isEmpty()) {
|
||||||
|
QStringList lines = Update::split(s, '\n');
|
||||||
|
if (!lines.empty()) {
|
||||||
|
for (int i=0; i < lines.size(); ++i) {
|
||||||
|
QString line = lines.at(i);
|
||||||
|
// expected: * [new branch] zg1/zone12 -> origin/zg1/zone12"
|
||||||
|
if (line.contains(m_branchName)) {
|
||||||
|
if (m_worker) {
|
||||||
|
QStringList lst(QString("BRANCH-NAME %1 CONTAINED IN RESULT %2").arg(m_branchName).arg(s));
|
||||||
|
m_worker->CONSOLE(lst) << Worker::UPDATE_STEP::PULL_NEW_BRANCH;
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (m_worker) {
|
||||||
|
QStringList lst(QString("BRANCH-NAME %1 NOT CONTAINED IN RESULT %2").arg(m_branchName).arg(s));
|
||||||
|
m_worker->CONSOLE(lst) << Worker::UPDATE_STEP::PULL_NEW_BRANCH_FAILURE;
|
||||||
|
}
|
||||||
|
|
||||||
|
} else {
|
||||||
|
if (m_worker) {
|
||||||
|
QStringList lst(QString("'git branch -l' RETURNED NO LINES"));
|
||||||
|
m_worker->CONSOLE(lst) << Worker::UPDATE_STEP::PULL_NEW_BRANCH_FAILURE;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
if (m_worker) {
|
||||||
|
QStringList lst(QString("'git branch -l' RETURNED EMPTY RESULT"));
|
||||||
|
m_worker->CONSOLE(lst) << Worker::UPDATE_STEP::PULL_NEW_BRANCH_FAILURE;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
if (m_worker) {
|
||||||
|
QStringList lst(QString("FAILED TO EXEC 'git branch -l'"));
|
||||||
|
m_worker->CONSOLE(lst) << Worker::UPDATE_STEP::PULL_NEW_BRANCH_FAILURE;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
bool GitClient::gitPullNewBranches() {
|
||||||
|
|
||||||
|
if (QDir(m_customerRepository).exists()) {
|
||||||
|
Command c("git pull");
|
||||||
|
if (c.execute(m_customerRepository)) {
|
||||||
|
QString const s = c.getCommandResult().trimmed();
|
||||||
|
// expected: Already up-to-date.
|
||||||
|
if (!s.isEmpty()) {
|
||||||
|
QStringList lst;
|
||||||
|
QString msg(QString("GIT-PULL-NEW-BRANCH. RESULT=%1").arg(s));
|
||||||
|
if (m_worker) {
|
||||||
|
m_worker->CONSOLE(lst) << Worker::UPDATE_STEP::PULL_NEW_BRANCH;
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Hat sich nichts geaendert, so werden auch keine Commits <>..<> angezeigt
|
Hat sich nichts geaendert, so werden auch keine Commits <>..<> angezeigt
|
||||||
*/
|
*/
|
||||||
@@ -316,6 +411,31 @@ std::optional<QString> GitClient::gitPull() {
|
|||||||
// 6ed893f..5d9882c zg1/zone2 -> origin/zg1/zone2
|
// 6ed893f..5d9882c zg1/zone2 -> origin/zg1/zone2
|
||||||
// 4384d17..77045d8 zg1/zone3 -> origin/zg1/zone3
|
// 4384d17..77045d8 zg1/zone3 -> origin/zg1/zone3
|
||||||
// 89d2812..36a0d74 zg1/zone5 -> origin/zg1/zone5
|
// 89d2812..36a0d74 zg1/zone5 -> origin/zg1/zone5
|
||||||
|
//
|
||||||
|
// More exactly:
|
||||||
|
// remote: Counting objects: 382, done.
|
||||||
|
// remote: Compressing objects: 100% (203/203), done.
|
||||||
|
// remote: Total 278 (delta 177), reused 103 (delta 59)
|
||||||
|
// Receiving objects: 100% (278/278), 4.89 MiB | 539 KiB/s, done.
|
||||||
|
// Resolving deltas: 100% (177/177), completed with 40 local objects.
|
||||||
|
// From ssh://longair@pacific.mpi-cbg.de/srv/git/fiji
|
||||||
|
// 3036acc..9eb5e40 debian-release-20081030 -> origin/debian-release-20081030
|
||||||
|
// * [new branch] debian-release-20081112 -> origin/debian-release-20081112
|
||||||
|
// * [new branch] debian-release-20081112.1 -> origin/debian-release-20081112.1
|
||||||
|
// 3d619e7..6260626 master -> origin/master
|
||||||
|
//
|
||||||
|
// The most important bits here are the lines like these:
|
||||||
|
//
|
||||||
|
// 3036acc..9eb5e40 debian-release-20081030 -> origin/debian-release-20081030
|
||||||
|
// * [new branch] debian-release-20081112 -> origin/debian-release-20081112
|
||||||
|
//
|
||||||
|
// The first line of these two shows that your remote-tracking branch
|
||||||
|
// origin/debian-release-20081030 has been advanced from the commit 3036acc to 9eb5e40.
|
||||||
|
// The bit before the arrow is the name of the branch in the remote repository.
|
||||||
|
// The second line similarly show that since we last did this, a new remote tracking
|
||||||
|
// branch has been created. (git fetch may also fetch new tags if they have appeared
|
||||||
|
// in the remote repository.)
|
||||||
|
|
||||||
bool found = false;
|
bool found = false;
|
||||||
for (int i=0; i < lines.size(); ++i) {
|
for (int i=0; i < lines.size(); ++i) {
|
||||||
if (lines.at(i).contains(m_branchName)) {
|
if (lines.at(i).contains(m_branchName)) {
|
||||||
|
@@ -57,6 +57,10 @@ class GitClient : public QObject {
|
|||||||
static QString gitBlob(QString fileName);
|
static QString gitBlob(QString fileName);
|
||||||
QString gitCommitForBlob(QString blob);
|
QString gitCommitForBlob(QString blob);
|
||||||
bool gitIsFileTracked(QString file2name);
|
bool gitIsFileTracked(QString file2name);
|
||||||
|
|
||||||
|
bool branchExistsRemotely();
|
||||||
|
bool branchExistsLocally();
|
||||||
|
bool gitPullNewBranches();
|
||||||
};
|
};
|
||||||
|
|
||||||
#endif // GIT_CLIENT_H_INCLUDED
|
#endif // GIT_CLIENT_H_INCLUDED
|
||||||
|
@@ -400,17 +400,26 @@ bool Update::downloadJson(enum FileTypeJson type,
|
|||||||
qDebug() << "SET AUTO-REQUEST=TRUE";
|
qDebug() << "SET AUTO-REQUEST=TRUE";
|
||||||
QThread::sleep(1); // make sure the auto-request flag is acknowledged
|
QThread::sleep(1); // make sure the auto-request flag is acknowledged
|
||||||
|
|
||||||
|
QStringList lst;
|
||||||
bool ready = false;
|
bool ready = false;
|
||||||
int nTry = 25;
|
int nTry = 25;
|
||||||
while ((ready = m_hw->sys_ready4sending()) == false) {
|
while ((ready = m_hw->sys_ready4sending()) == false) {
|
||||||
QThread::msleep(200);
|
QThread::msleep(200);
|
||||||
if (--nTry <= 0) {
|
if (--nTry <= 0) {
|
||||||
Utils::printCriticalErrorMsg("SYS NOT READY FOR SENDING AFTER 5 SECONDS");
|
QString msg("SYS NOT READY FOR SENDING AFTER 5 SECONDS");
|
||||||
|
Utils::printCriticalErrorMsg(msg);
|
||||||
|
lst << msg;
|
||||||
|
|
||||||
|
if (m_worker) {
|
||||||
|
m_worker->ISMAS(lst) << (m_worker->GUI(lst) << (m_worker->CONSOLE(lst) << Worker::UPDATE_STEP::DOWNLOAD_FILES_TO_PSA_HARDWARE));
|
||||||
|
}
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
bool ret = false;
|
bool ret = false;
|
||||||
|
QString msg;
|
||||||
|
lst.clear();
|
||||||
if (ready) {
|
if (ready) {
|
||||||
QFile file(jsFileToSendToDC);
|
QFile file(jsFileToSendToDC);
|
||||||
QFileInfo fi(jsFileToSendToDC); // max. size of template file is 800 bytes
|
QFileInfo fi(jsFileToSendToDC); // max. size of template file is 800 bytes
|
||||||
@@ -452,20 +461,48 @@ bool Update::downloadJson(enum FileTypeJson type,
|
|||||||
qCritical() << length << "MACHINE ID =" << ba.toHex(':');
|
qCritical() << length << "MACHINE ID =" << ba.toHex(':');
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
if (m_worker) {
|
||||||
|
m_worker->ISMAS(lst) << (m_worker->GUI(lst) << (m_worker->CONSOLE(lst) << Worker::UPDATE_STEP::DOWNLOAD_FILES_TO_PSA_HARDWARE));
|
||||||
|
}
|
||||||
|
|
||||||
ret = true;
|
ret = true;
|
||||||
|
} else {
|
||||||
|
msg = QString("ERROR SEND JSON-FILE %1 TO DC").arg(file.fileName());
|
||||||
|
Utils::printCriticalErrorMsg(msg);
|
||||||
|
lst << msg;
|
||||||
|
if (m_worker) {
|
||||||
|
m_worker->ISMAS(lst) << (m_worker->GUI(lst) << (m_worker->CONSOLE(lst)
|
||||||
|
<< Worker::UPDATE_STEP::DOWNLOAD_FILES_TO_PSA_HARDWARE));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
Utils::printCriticalErrorMsg(
|
msg = QString("SIZE OF %1 TOO BIG (%2 BYTES)").arg(jsFileToSendToDC).arg(fi.size());
|
||||||
QString("SIZE OF %1 TOO BIG (%2 BYTES)")
|
Utils::printCriticalErrorMsg(msg);
|
||||||
.arg(jsFileToSendToDC).arg(fi.size()));
|
lst << msg;
|
||||||
|
if (m_worker) {
|
||||||
|
m_worker->ISMAS(lst) << (m_worker->GUI(lst) << (m_worker->CONSOLE(lst)
|
||||||
|
<< Worker::UPDATE_STEP::DOWNLOAD_FILES_TO_PSA_HARDWARE));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
Utils::printCriticalErrorMsg(
|
msg = QString("CAN NOT OPEN ") + jsFileToSendToDC + " FOR READING";
|
||||||
QString("CAN NOT OPEN ") + jsFileToSendToDC + " FOR READING");
|
Utils::printCriticalErrorMsg(msg);
|
||||||
|
lst << msg;
|
||||||
|
|
||||||
|
if (m_worker) {
|
||||||
|
m_worker->ISMAS(lst) << (m_worker->GUI(lst) << (m_worker->CONSOLE(lst)
|
||||||
|
<< Worker::UPDATE_STEP::DOWNLOAD_FILES_TO_PSA_HARDWARE));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
Utils::printCriticalErrorMsg(
|
msg = QString(jsFileToSendToDC) + " DOES NOT EXIST";
|
||||||
QString(jsFileToSendToDC) + " DOES NOT EXIST");
|
Utils::printCriticalErrorMsg(msg);
|
||||||
|
lst << msg;
|
||||||
|
|
||||||
|
if (m_worker) {
|
||||||
|
m_worker->ISMAS(lst) << (m_worker->GUI(lst) << (m_worker->CONSOLE(lst)
|
||||||
|
<< Worker::UPDATE_STEP::DOWNLOAD_FILES_TO_PSA_HARDWARE));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -633,9 +670,17 @@ bool Update::checkDownloadedJsonVersions(QStringList const& jsonFileNames) {
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
bool Update::doUpdate(int &displayIndex, QStringList const &filesToWorkOn) {
|
bool Update::doUpdate(int &displayIndex, QStringList const &filesToWorkOn) {
|
||||||
if (m_sys_areDCdataValid == false) {
|
|
||||||
qCritical() << "ERROR!!! DC DATA NOT VALID -> CA-MASTER-PLUGIN NOT CONNECTED";
|
int tries = 20;
|
||||||
return false;
|
while ((m_sys_areDCdataValid = m_hw->sys_areDCdataValid()) == false) {
|
||||||
|
// must deliver 'true', only then are all data from hwapi valid
|
||||||
|
if (--tries < 0) {
|
||||||
|
Utils::printCriticalErrorMsg("ERROR!!! DC DATA NOT VALID -> CA-SLAVE-PLUGIN NOT CONNECTED");
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
Utils::printCriticalErrorMsg("DC DATA NOT VALID -> CA-SLAVE-PLUGIN NOT CONNECTED");
|
||||||
|
m_hw->dc_autoRequest(true);
|
||||||
|
QThread::msleep(500);
|
||||||
}
|
}
|
||||||
|
|
||||||
bool res = false;
|
bool res = false;
|
||||||
|
@@ -277,21 +277,24 @@ bool Utils::sameFilesInDirs(QDir const &dir1, QDir const &dir2,
|
|||||||
fileNameLst2 << i2.next().fileName();
|
fileNameLst2 << i2.next().fileName();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
QString dirPath1 = dir1.absolutePath();
|
||||||
|
QString dirPath2 = dir2.absolutePath();
|
||||||
|
|
||||||
if (fileNameLst1.isEmpty()) {
|
if (fileNameLst1.isEmpty()) {
|
||||||
qCritical() << "DIR1" << dir1.dirName() << " DOES NOT CONTAIN EXPECTED FILES";
|
qCritical() << "DIR1" << dirPath1 << " DOES NOT CONTAIN EXPECTED FILES";
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
if (fileNameLst2.isEmpty()) {
|
if (fileNameLst2.isEmpty()) {
|
||||||
qCritical() << "DIR1" << dir2.dirName() << " DOES NOT CONTAIN EXPECTED FILES";
|
qCritical() << "DIR1" << dirPath2 << " DOES NOT CONTAIN EXPECTED FILES";
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
if (fileNameLst1 != fileNameLst2) {
|
if (fileNameLst1 != fileNameLst2) {
|
||||||
printCriticalErrorMsg(dir1.dirName() + " AND " + dir2.dirName()
|
printCriticalErrorMsg(dirPath1 + " AND " + dirPath2
|
||||||
+ " DIFFER: [" + fileNameLst1.join(',') + "],["
|
+ " DIFFER: [" + fileNameLst1.join(',') + "],["
|
||||||
+ fileNameLst2.join(',') + "]");
|
+ fileNameLst2.join(',') + "]");
|
||||||
return false;
|
return false;
|
||||||
} else {
|
} else {
|
||||||
printInfoMsg(dir1.dirName() + " AND " + dir2.dirName()
|
printInfoMsg(dirPath1 + " AND " + dirPath2
|
||||||
+ " ARE EQUAL: [" + fileNameLst1.join(',') + "]");
|
+ " ARE EQUAL: [" + fileNameLst1.join(',') + "]");
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -307,21 +310,21 @@ bool Utils::sameFilesInDirs(QDir const &dir1, QDir const &dir2,
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (gitBlobLst1.isEmpty()) {
|
if (gitBlobLst1.isEmpty()) {
|
||||||
qCritical() << "DIR1" << dir1.dirName() << " DOES NOT CONTAIN EXPECTED FILES";
|
qCritical() << "DIR1" << dirPath1 << " DOES NOT CONTAIN EXPECTED FILES";
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
if (gitBlobLst2.isEmpty()) {
|
if (gitBlobLst2.isEmpty()) {
|
||||||
qCritical() << "DIR1" << dir2.dirName() << " DOES NOT CONTAIN EXPECTED FILES";
|
qCritical() << "DIR1" << dirPath2 << " DOES NOT CONTAIN EXPECTED FILES";
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (gitBlobLst1 != gitBlobLst2) {
|
if (gitBlobLst1 != gitBlobLst2) {
|
||||||
printCriticalErrorMsg(dir1.dirName() + " AND " + dir2.dirName()
|
printCriticalErrorMsg(dirPath1 + " AND " + dirPath2
|
||||||
+ " DIFFER: [" + gitBlobLst1.join(',') + "],["
|
+ " DIFFER: [" + gitBlobLst1.join(',') + "],["
|
||||||
+ gitBlobLst2.join(',') + "]");
|
+ gitBlobLst2.join(',') + "]");
|
||||||
return false;
|
return false;
|
||||||
} else {
|
} else {
|
||||||
printInfoMsg(dir1.dirName() + " AND " + dir2.dirName()
|
printInfoMsg(dirPath1 + " AND " + dirPath2
|
||||||
+ " CONTAIN SAME GIT-BLOBS FOR FILES: [" + fileNameLst1.join(',') + "]");
|
+ " CONTAIN SAME GIT-BLOBS FOR FILES: [" + fileNameLst1.join(',') + "]");
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -56,6 +56,9 @@ const QMap<UPDATE_STEP, const char*> Worker::smap (
|
|||||||
INSERT_ELEMENT(UPDATE_STEP::CHECK_ISMAS_TRIGGER_FAILURE),
|
INSERT_ELEMENT(UPDATE_STEP::CHECK_ISMAS_TRIGGER_FAILURE),
|
||||||
INSERT_ELEMENT(UPDATE_STEP::INITIAL_CLONE_WITHOUT_ACTIVE_ISMAS_TRIGGER),
|
INSERT_ELEMENT(UPDATE_STEP::INITIAL_CLONE_WITHOUT_ACTIVE_ISMAS_TRIGGER),
|
||||||
INSERT_ELEMENT(UPDATE_STEP::INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER),
|
INSERT_ELEMENT(UPDATE_STEP::INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER),
|
||||||
|
INSERT_ELEMENT(UPDATE_STEP::PULL_NEW_BRANCH),
|
||||||
|
INSERT_ELEMENT(UPDATE_STEP::PULL_NEW_BRANCH_FAILURE),
|
||||||
|
INSERT_ELEMENT(UPDATE_STEP::PULL_NEW_BRANCH_SUCCESS),
|
||||||
INSERT_ELEMENT(UPDATE_STEP::CHECKOUT_BRANCH),
|
INSERT_ELEMENT(UPDATE_STEP::CHECKOUT_BRANCH),
|
||||||
INSERT_ELEMENT(UPDATE_STEP::CHECKOUT_BRANCH_SUCCESS),
|
INSERT_ELEMENT(UPDATE_STEP::CHECKOUT_BRANCH_SUCCESS),
|
||||||
INSERT_ELEMENT(UPDATE_STEP::CHECKOUT_BRANCH_FAILURE),
|
INSERT_ELEMENT(UPDATE_STEP::CHECKOUT_BRANCH_FAILURE),
|
||||||
@@ -330,6 +333,7 @@ void Worker::privateUpdate() {
|
|||||||
m_clone = false;
|
m_clone = false;
|
||||||
m_repairClone = false;
|
m_repairClone = false;
|
||||||
m_initialClone = false;
|
m_initialClone = false;
|
||||||
|
m_pulledNewBranch = false;
|
||||||
// the customer repository is cloned or
|
// the customer repository is cloned or
|
||||||
// repaired/re-cloned without checking the
|
// repaired/re-cloned without checking the
|
||||||
// ISMAS-trigger (WAIT-)button.
|
// ISMAS-trigger (WAIT-)button.
|
||||||
@@ -439,17 +443,6 @@ void Worker::privateUpdate() {
|
|||||||
ISMAS(lst) << (CONSOLE(lst) << UPDATE_STEP::CHECKOUT_BRANCH);
|
ISMAS(lst) << (CONSOLE(lst) << UPDATE_STEP::CHECKOUT_BRANCH);
|
||||||
setProgress(_CHECKOUT_BRANCH_SUCCESS);
|
setProgress(_CHECKOUT_BRANCH_SUCCESS);
|
||||||
|
|
||||||
////////////////////////////////////////////////////////////////////////////
|
|
||||||
//
|
|
||||||
// (R)SYNC THE REPOSITORY WITH THE LOCAL FILEYSTEM
|
|
||||||
//
|
|
||||||
////////////////////////////////////////////////////////////////////////////
|
|
||||||
if ((continueUpdate = syncCustomerRepositoryAndFS()) == false) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
lst = QStringList(QString(smap[UPDATE_STEP::SYNC_CUSTOMER_REPOSITORY_SUCCESS]));
|
|
||||||
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << UPDATE_STEP::SYNC_CUSTOMER_REPOSITORY_SUCCESS));
|
|
||||||
setProgress(_SYNC_CUSTOMER_REPOSITORY_SUCCESS);
|
|
||||||
|
|
||||||
////////////////////////////////////////////////////////////////////////////
|
////////////////////////////////////////////////////////////////////////////
|
||||||
//
|
//
|
||||||
@@ -464,6 +457,18 @@ void Worker::privateUpdate() {
|
|||||||
ISMAS() << (GUI() << (CONSOLE() << UPDATE_STEP::UPDATE_REPOSITORY));
|
ISMAS() << (GUI() << (CONSOLE() << UPDATE_STEP::UPDATE_REPOSITORY));
|
||||||
setProgress(_UPDATE_REPOSITORY_SUCCESS);
|
setProgress(_UPDATE_REPOSITORY_SUCCESS);
|
||||||
|
|
||||||
|
////////////////////////////////////////////////////////////////////////////
|
||||||
|
//
|
||||||
|
// (R)SYNC THE REPOSITORY WITH THE LOCAL FILEYSTEM
|
||||||
|
//
|
||||||
|
////////////////////////////////////////////////////////////////////////////
|
||||||
|
if ((continueUpdate = syncCustomerRepositoryAndFS()) == false) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
lst = QStringList(QString(smap[UPDATE_STEP::SYNC_CUSTOMER_REPOSITORY_SUCCESS]));
|
||||||
|
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << UPDATE_STEP::SYNC_CUSTOMER_REPOSITORY_SUCCESS));
|
||||||
|
setProgress(_SYNC_CUSTOMER_REPOSITORY_SUCCESS);
|
||||||
|
|
||||||
|
|
||||||
////////////////////////////////////////////////////////////////////////////
|
////////////////////////////////////////////////////////////////////////////
|
||||||
//
|
//
|
||||||
@@ -518,6 +523,8 @@ bool Worker::updateTriggerSet() {
|
|||||||
|
|
||||||
GUI() << (CONSOLE() << UPDATE_STEP::CHECK_ISMAS_TRIGGER);
|
GUI() << (CONSOLE() << UPDATE_STEP::CHECK_ISMAS_TRIGGER);
|
||||||
|
|
||||||
|
bool const automaticUpdate = (QDateTime::currentDateTime().time().hour() < 4);
|
||||||
|
|
||||||
QString triggerValue("NOT CHECKED YET");
|
QString triggerValue("NOT CHECKED YET");
|
||||||
static constexpr int const repeats = 15;
|
static constexpr int const repeats = 15;
|
||||||
for (int repeat = 1; repeat <= repeats; ++repeat) {
|
for (int repeat = 1; repeat <= repeats; ++repeat) {
|
||||||
@@ -639,9 +646,17 @@ bool Worker::updateTriggerSet() {
|
|||||||
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::CHECK_ISMAS_TRIGGER_WRONG_VALUE)));
|
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::CHECK_ISMAS_TRIGGER_WRONG_VALUE)));
|
||||||
// if the customer repository has just been cloned
|
// if the customer repository has just been cloned
|
||||||
return false; // it is OK the ISMAS trigger might not be 'WAIT'
|
return false; // it is OK the ISMAS trigger might not be 'WAIT'
|
||||||
} else {
|
|
||||||
CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::CHECK_ISMAS_TRIGGER_FAILURE);
|
|
||||||
}
|
}
|
||||||
|
// not a clone and empty update-trigger
|
||||||
|
if (automaticUpdate) {
|
||||||
|
// do not inform ISMAS in case of automatic update, because the
|
||||||
|
// update is not necessary as the trigger-button is not set to WAIT.
|
||||||
|
GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::CHECK_ISMAS_TRIGGER_WRONG_VALUE));
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::CHECK_ISMAS_TRIGGER_FAILURE);
|
||||||
|
|
||||||
QThread::sleep(6);
|
QThread::sleep(6);
|
||||||
continue;
|
continue;
|
||||||
} else {
|
} else {
|
||||||
@@ -649,11 +664,21 @@ bool Worker::updateTriggerSet() {
|
|||||||
if (m_clone) {
|
if (m_clone) {
|
||||||
m_ismasTriggerStatusMessage = QStringList(QString("TRIGGER-VALUE='%1' != 'WAIT'").arg(triggerValue));
|
m_ismasTriggerStatusMessage = QStringList(QString("TRIGGER-VALUE='%1' != 'WAIT'").arg(triggerValue));
|
||||||
QStringList lst = m_ismasTriggerStatusMessage;
|
QStringList lst = m_ismasTriggerStatusMessage;
|
||||||
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::CHECK_ISMAS_TRIGGER_WRONG_VALUE)));
|
if (automaticUpdate) {
|
||||||
|
// do not inform ISMAS in case of automatic update
|
||||||
|
GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::CHECK_ISMAS_TRIGGER_WRONG_VALUE));
|
||||||
|
} else {
|
||||||
|
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::CHECK_ISMAS_TRIGGER_WRONG_VALUE)));
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
m_ismasTriggerStatusMessage = QStringList(QString("TRIGGER-VALUE='%1' != 'WAIT'").arg(triggerValue));
|
m_ismasTriggerStatusMessage = QStringList(QString("TRIGGER-VALUE='%1' != 'WAIT'").arg(triggerValue));
|
||||||
QStringList lst = m_ismasTriggerStatusMessage;
|
QStringList lst = m_ismasTriggerStatusMessage;
|
||||||
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::CHECK_ISMAS_TRIGGER_FAILURE)));
|
if (automaticUpdate) {
|
||||||
|
// do not inform ISMAS in case of automatic update
|
||||||
|
GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::CHECK_ISMAS_TRIGGER_WRONG_VALUE));
|
||||||
|
} else {
|
||||||
|
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::CHECK_ISMAS_TRIGGER_FAILURE)));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
@@ -703,6 +728,35 @@ bool Worker::customerEnvironment() {
|
|||||||
ISMAS() << (GUI() << (CONSOLE() << UPDATE_STEP::CHECKOUT_BRANCH));
|
ISMAS() << (GUI() << (CONSOLE() << UPDATE_STEP::CHECKOUT_BRANCH));
|
||||||
|
|
||||||
if (QDir(m_customerRepository).exists()) {
|
if (QDir(m_customerRepository).exists()) {
|
||||||
|
if (m_clone == false) {
|
||||||
|
if (m_gc.branchExistsRemotely()) {
|
||||||
|
QString msg("PULL NEW BRANCH " + m_branchName);
|
||||||
|
QStringList lst(msg);
|
||||||
|
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << UPDATE_STEP::PULL_NEW_BRANCH));
|
||||||
|
if (!m_gc.branchExistsLocally()) {
|
||||||
|
msg = QString("PULLING OF NEW BRANCH " + m_branchName + " DOES NOT EXIST LOCALLY");
|
||||||
|
QStringList lst(msg);
|
||||||
|
CONSOLE(lst) << UPDATE_STEP::PULL_NEW_BRANCH;
|
||||||
|
if (!m_gc.gitPullNewBranches()) {
|
||||||
|
msg = QString("PULLING OF NEW BRANCH " + m_branchName + "FAILED");
|
||||||
|
QStringList lst(msg);
|
||||||
|
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::PULL_NEW_BRANCH_FAILURE)));
|
||||||
|
return false;
|
||||||
|
} else {
|
||||||
|
msg = QString("PULLING OF NEW BRANCH " + m_branchName + "SUCCESS");
|
||||||
|
QStringList lst(msg);
|
||||||
|
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::PULL_NEW_BRANCH_SUCCESS)));
|
||||||
|
m_pulledNewBranch = true;
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
msg = QString("PULLING ALREADY EXISTING LOCAL BRANCH " + m_branchName + "SUCCESS");
|
||||||
|
QStringList lst(msg);
|
||||||
|
ISMAS(lst) << (GUI(lst) << (CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::PULL_NEW_BRANCH_SUCCESS)));
|
||||||
|
m_pulledNewBranch = true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if (m_gc.gitCheckoutBranch()) {
|
if (m_gc.gitCheckoutBranch()) {
|
||||||
return true;
|
return true;
|
||||||
} else {
|
} else {
|
||||||
@@ -726,7 +780,7 @@ bool Worker::filesToUpdate() {
|
|||||||
// always execute contents of opkg_commands-file
|
// always execute contents of opkg_commands-file
|
||||||
m_filesToUpdate << "etc/psa_update/opkg_commands";
|
m_filesToUpdate << "etc/psa_update/opkg_commands";
|
||||||
|
|
||||||
if (m_clone && m_alwaysDownloadConfig) {
|
if ((m_clone || m_pulledNewBranch) && m_alwaysDownloadConfig) {
|
||||||
// always download all json-config files, even if none of them have been
|
// always download all json-config files, even if none of them have been
|
||||||
// changed in the git repository. useful for first installation.
|
// changed in the git repository. useful for first installation.
|
||||||
QDir dir(QDir::cleanPath(m_customerRepository + QDir::separator() + "etc/psa_config"));
|
QDir dir(QDir::cleanPath(m_customerRepository + QDir::separator() + "etc/psa_config"));
|
||||||
@@ -740,7 +794,7 @@ bool Worker::filesToUpdate() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (m_clone && m_alwaysDownloadDC) {
|
if ((m_clone || m_pulledNewBranch) && m_alwaysDownloadConfig) {
|
||||||
// always download the last dc-binary, even if not changed in the
|
// always download the last dc-binary, even if not changed in the
|
||||||
// git repository. useful for first installation.
|
// git repository. useful for first installation.
|
||||||
QDir dir(QDir::cleanPath(m_customerRepository + QDir::separator() + "etc/dc"));
|
QDir dir(QDir::cleanPath(m_customerRepository + QDir::separator() + "etc/dc"));
|
||||||
@@ -908,7 +962,7 @@ bool Worker::downloadFilesToPSAHardware() {
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
CONSOLE(QStringList("NO FILES TO DOWNLOAD TO PSA-HW")) << (m_lastFailedUpdateStep = UPDATE_STEP::DOWNLOAD_FILES_TO_PSA_HARDWARE_FAILURE);
|
CONSOLE(lst) << (m_lastFailedUpdateStep = UPDATE_STEP::DOWNLOAD_FILES_TO_PSA_HARDWARE_FAILURE);
|
||||||
setProgress(_DOWNLOAD_FILES_TO_PSA_HARDWARE_FAILURE);
|
setProgress(_DOWNLOAD_FILES_TO_PSA_HARDWARE_FAILURE);
|
||||||
|
|
||||||
return false;
|
return false;
|
||||||
|
@@ -53,38 +53,41 @@
|
|||||||
#define _CHECK_ISMAS_TRIGGER_WRONG_VALUE (19)
|
#define _CHECK_ISMAS_TRIGGER_WRONG_VALUE (19)
|
||||||
#define _CHECK_ISMAS_TRIGGER_SUCCESS (20)
|
#define _CHECK_ISMAS_TRIGGER_SUCCESS (20)
|
||||||
#define _CHECK_ISMAS_TRIGGER_FAILURE (21)
|
#define _CHECK_ISMAS_TRIGGER_FAILURE (21)
|
||||||
#define _CHECKOUT_BRANCH (22)
|
#define _PULL_NEW_BRANCH (22)
|
||||||
#define _CHECKOUT_BRANCH_FAILURE (23)
|
#define _PULL_NEW_BRANCH_FAILURE (23)
|
||||||
#define _CHECKOUT_BRANCH_SUCCESS (24)
|
#define _PULL_NEW_BRANCH_SUCCESS (24)
|
||||||
#define _UPDATE_REPOSITORY (25)
|
#define _CHECKOUT_BRANCH (25)
|
||||||
#define _UPDATE_REPOSITORY_FAILURE (26)
|
#define _CHECKOUT_BRANCH_FAILURE (26)
|
||||||
#define _UPDATE_REPOSITORY_SUCCESS (27)
|
#define _CHECKOUT_BRANCH_SUCCESS (27)
|
||||||
#define _CHECK_FOR_REPOSITORY_CHANGES (28)
|
#define _UPDATE_REPOSITORY (28)
|
||||||
#define _CHECK_FOR_REPOSITORY_CHANGES_SUCCESS (29)
|
#define _UPDATE_REPOSITORY_FAILURE (29)
|
||||||
#define _SYNC_CUSTOMER_REPOSITORY (30)
|
#define _UPDATE_REPOSITORY_SUCCESS (30)
|
||||||
#define _SYNC_CUSTOMER_REPOSITORY_FAILURE (31)
|
#define _CHECK_FOR_REPOSITORY_CHANGES (31)
|
||||||
#define _SYNC_CUSTOMER_REPOSITORY_SUCCESS (32)
|
#define _CHECK_FOR_REPOSITORY_CHANGES_SUCCESS (32)
|
||||||
#define _FILES_TO_UPDATE (33)
|
#define _SYNC_CUSTOMER_REPOSITORY (33)
|
||||||
#define _CHECK_FOR_REPOSITORY_CHANGES_FAILURE (34)
|
#define _SYNC_CUSTOMER_REPOSITORY_FAILURE (34)
|
||||||
#define _FILES_TO_DOWNLOAD (35)
|
#define _SYNC_CUSTOMER_REPOSITORY_SUCCESS (35)
|
||||||
#define _EXEC_OPKG_COMMANDS (41)
|
#define _FILES_TO_UPDATE (36)
|
||||||
#define _EXEC_OPKG_COMMAND_1 (42)
|
#define _CHECK_FOR_REPOSITORY_CHANGES_FAILURE (37)
|
||||||
#define _EXEC_OPKG_COMMAND_2 (43)
|
#define _FILES_TO_DOWNLOAD (38)
|
||||||
#define _EXEC_OPKG_COMMAND_3 (44)
|
#define _EXEC_OPKG_COMMANDS (39)
|
||||||
#define _EXEC_OPKG_COMMAND_4 (45)
|
#define _EXEC_OPKG_COMMAND_1 (40)
|
||||||
#define _EXEC_OPKG_COMMAND_5 (46)
|
#define _EXEC_OPKG_COMMAND_2 (41)
|
||||||
#define _EXEC_OPKG_COMMAND_6 (47)
|
#define _EXEC_OPKG_COMMAND_3 (42)
|
||||||
#define _EXEC_OPKG_COMMAND_7 (48)
|
#define _EXEC_OPKG_COMMAND_4 (43)
|
||||||
#define _EXEC_OPKG_COMMAND_8 (49)
|
#define _EXEC_OPKG_COMMAND_5 (44)
|
||||||
#define _EXEC_OPKG_COMMAND_9 (50)
|
#define _EXEC_OPKG_COMMAND_6 (45)
|
||||||
#define _EXEC_OPKG_COMMAND_LAST (51)
|
#define _EXEC_OPKG_COMMAND_7 (46)
|
||||||
#define _EXEC_OPKG_COMMAND_FAILURE (52)
|
#define _EXEC_OPKG_COMMAND_8 (47)
|
||||||
#define _EXEC_OPKG_COMMAND_SUCCESS (53)
|
#define _EXEC_OPKG_COMMAND_9 (48)
|
||||||
#define _DOWNLOAD_FILES_TO_PSA_HARDWARE (54)
|
#define _EXEC_OPKG_COMMAND_LAST (49)
|
||||||
#define _DOWNLOAD_CONFIG_FILE (55)
|
#define _EXEC_OPKG_COMMAND_FAILURE (50)
|
||||||
#define _DOWNLOAD_CONFIG_FILE_SUCCESS (56)
|
#define _EXEC_OPKG_COMMAND_SUCCESS (51)
|
||||||
#define _DOWNLOAD_CONFIG_FILE_FAILURE (57)
|
#define _DOWNLOAD_FILES_TO_PSA_HARDWARE (60)
|
||||||
#define _DOWNLOAD_DEVICE_CONTROLLER (65)
|
#define _DOWNLOAD_CONFIG_FILE (61)
|
||||||
|
#define _DOWNLOAD_CONFIG_FILE_SUCCESS (62)
|
||||||
|
#define _DOWNLOAD_CONFIG_FILE_FAILURE (63)
|
||||||
|
#define _DOWNLOAD_DEVICE_CONTROLLER (64)
|
||||||
#define _DOWNLOAD_DEVICE_CONTROLLER_SUCCESS (85)
|
#define _DOWNLOAD_DEVICE_CONTROLLER_SUCCESS (85)
|
||||||
#define _DOWNLOAD_DEVICE_CONTROLLER_FAILURE (86)
|
#define _DOWNLOAD_DEVICE_CONTROLLER_FAILURE (86)
|
||||||
#define _DOWNLOAD_FILES_TO_PSA_HARDWARE_FAILURE (87)
|
#define _DOWNLOAD_FILES_TO_PSA_HARDWARE_FAILURE (87)
|
||||||
@@ -162,6 +165,7 @@ class Worker : public QThread{
|
|||||||
bool m_ismasTriggerActive = false;
|
bool m_ismasTriggerActive = false;
|
||||||
bool m_updateNotNecessary = false;
|
bool m_updateNotNecessary = false;
|
||||||
bool m_automaticUpdate = false;
|
bool m_automaticUpdate = false;
|
||||||
|
bool m_pulledNewBranch = false;
|
||||||
QStringList m_ismasTriggerStatusMessage;
|
QStringList m_ismasTriggerStatusMessage;
|
||||||
|
|
||||||
MainWindow *m_mainWindow;
|
MainWindow *m_mainWindow;
|
||||||
@@ -225,7 +229,8 @@ class Worker : public QThread{
|
|||||||
m_worker->setProgress(_FINISHED);
|
m_worker->setProgress(_FINISHED);
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
QStringList lst = m_worker->m_ismasTriggerStatusMessage;
|
// QStringList lst = m_worker->m_ismasTriggerStatusMessage;
|
||||||
|
QStringList lst;
|
||||||
UPDATE_STEP last = m_worker->m_lastFailedUpdateStep;
|
UPDATE_STEP last = m_worker->m_lastFailedUpdateStep;
|
||||||
if (m_worker->smap.contains(last)) {
|
if (m_worker->smap.contains(last)) {
|
||||||
lst << QString(" (last failed step: %1)").arg(m_worker->smap[last]);
|
lst << QString(" (last failed step: %1)").arg(m_worker->smap[last]);
|
||||||
@@ -280,6 +285,9 @@ public:
|
|||||||
CHECK_ISMAS_TRIGGER_FAILURE = _CHECK_ISMAS_TRIGGER_FAILURE,
|
CHECK_ISMAS_TRIGGER_FAILURE = _CHECK_ISMAS_TRIGGER_FAILURE,
|
||||||
INITIAL_CLONE_WITHOUT_ACTIVE_ISMAS_TRIGGER = _INITIAL_CLONE_WITHOUT_ACTIVE_ISMAS_TRIGGER,
|
INITIAL_CLONE_WITHOUT_ACTIVE_ISMAS_TRIGGER = _INITIAL_CLONE_WITHOUT_ACTIVE_ISMAS_TRIGGER,
|
||||||
INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER = _INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER,
|
INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER = _INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER,
|
||||||
|
PULL_NEW_BRANCH = _PULL_NEW_BRANCH,
|
||||||
|
PULL_NEW_BRANCH_FAILURE = _PULL_NEW_BRANCH_FAILURE,
|
||||||
|
PULL_NEW_BRANCH_SUCCESS = _PULL_NEW_BRANCH_SUCCESS,
|
||||||
CHECKOUT_BRANCH = _CHECKOUT_BRANCH,
|
CHECKOUT_BRANCH = _CHECKOUT_BRANCH,
|
||||||
CHECKOUT_BRANCH_SUCCESS = _CHECKOUT_BRANCH_SUCCESS,
|
CHECKOUT_BRANCH_SUCCESS = _CHECKOUT_BRANCH_SUCCESS,
|
||||||
CHECKOUT_BRANCH_FAILURE = _CHECKOUT_BRANCH_FAILURE,
|
CHECKOUT_BRANCH_FAILURE = _CHECKOUT_BRANCH_FAILURE,
|
||||||
@@ -553,6 +561,18 @@ private:
|
|||||||
break;
|
break;
|
||||||
case UPDATE_STEP::INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER:
|
case UPDATE_STEP::INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER:
|
||||||
break;
|
break;
|
||||||
|
case UPDATE_STEP::PULL_NEW_BRANCH: {
|
||||||
|
lst << instance->m_debugMsg;
|
||||||
|
Utils::printUpdateStatusMsg(debug, lst);
|
||||||
|
} break;
|
||||||
|
case UPDATE_STEP::PULL_NEW_BRANCH_FAILURE: {
|
||||||
|
lst << instance->m_debugMsg;
|
||||||
|
Utils::printUpdateStatusMsg(debug, lst);
|
||||||
|
} break;
|
||||||
|
case UPDATE_STEP::PULL_NEW_BRANCH_SUCCESS: {
|
||||||
|
lst << instance->m_debugMsg;
|
||||||
|
Utils::printUpdateStatusMsg(debug, lst);
|
||||||
|
} break;
|
||||||
case UPDATE_STEP::CHECKOUT_BRANCH:
|
case UPDATE_STEP::CHECKOUT_BRANCH:
|
||||||
lst << instance->m_debugMsg;
|
lst << instance->m_debugMsg;
|
||||||
Utils::printUpdateStatusMsg(debug, lst);
|
Utils::printUpdateStatusMsg(debug, lst);
|
||||||
@@ -871,6 +891,51 @@ private:
|
|||||||
case UPDATE_STEP::INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER:
|
case UPDATE_STEP::INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER:
|
||||||
ismasClient.setProgressInPercent(_INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER);
|
ismasClient.setProgressInPercent(_INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER);
|
||||||
break;
|
break;
|
||||||
|
case UPDATE_STEP::PULL_NEW_BRANCH: {
|
||||||
|
ismasClient.setProgressInPercent(_PULL_NEW_BRANCH);
|
||||||
|
QString const &ismasUpdateNews =
|
||||||
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
|
ismasClient.updateNewsToIsmas(
|
||||||
|
"U0010",
|
||||||
|
_PULL_NEW_BRANCH,
|
||||||
|
IsmasClient::RESULT_CODE::SUCCESS,
|
||||||
|
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
||||||
|
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
||||||
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
|
ismasClient.sendRequestReceiveResponse(
|
||||||
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case UPDATE_STEP::PULL_NEW_BRANCH_FAILURE: {
|
||||||
|
ismasClient.setProgressInPercent(_PULL_NEW_BRANCH_FAILURE);
|
||||||
|
QString const &ismasUpdateNews =
|
||||||
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
|
ismasClient.updateNewsToIsmas(
|
||||||
|
"U0003",
|
||||||
|
_PULL_NEW_BRANCH_FAILURE,
|
||||||
|
IsmasClient::RESULT_CODE::INSTALL_ERROR,
|
||||||
|
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
||||||
|
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
||||||
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
|
ismasClient.sendRequestReceiveResponse(
|
||||||
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case UPDATE_STEP::PULL_NEW_BRANCH_SUCCESS: {
|
||||||
|
ismasClient.setProgressInPercent(_PULL_NEW_BRANCH_SUCCESS);
|
||||||
|
QString const &ismasUpdateNews =
|
||||||
|
QString("#M=APISM#C=CMD_EVENT#J=") +
|
||||||
|
ismasClient.updateNewsToIsmas(
|
||||||
|
"U0010",
|
||||||
|
_PULL_NEW_BRANCH_SUCCESS,
|
||||||
|
IsmasClient::RESULT_CODE::SUCCESS,
|
||||||
|
smap[UPDATE_STEP::CHECKOUT_BRANCH],
|
||||||
|
instance->m_ismasMsg.join(' ').toStdString().c_str(),
|
||||||
|
instance->m_versionInfo.size() >= 1 ? instance->m_versionInfo.at(0).toUtf8().constData() : "N/A");
|
||||||
|
ismasClient.sendRequestReceiveResponse(
|
||||||
|
IsmasClient::APISM::DB_PORT, ismasUpdateNews);
|
||||||
|
}
|
||||||
|
break;
|
||||||
case UPDATE_STEP::CHECKOUT_BRANCH: {
|
case UPDATE_STEP::CHECKOUT_BRANCH: {
|
||||||
ismasClient.setProgressInPercent(_CHECKOUT_BRANCH);
|
ismasClient.setProgressInPercent(_CHECKOUT_BRANCH);
|
||||||
QString const &ismasUpdateNews =
|
QString const &ismasUpdateNews =
|
||||||
@@ -1304,6 +1369,12 @@ private:
|
|||||||
break;
|
break;
|
||||||
case UPDATE_STEP::INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER:
|
case UPDATE_STEP::INITIAL_CLONE_WITH_ACTIVE_ISMAS_TRIGGER:
|
||||||
break;
|
break;
|
||||||
|
case UPDATE_STEP::PULL_NEW_BRANCH:
|
||||||
|
break;
|
||||||
|
case UPDATE_STEP::PULL_NEW_BRANCH_FAILURE:
|
||||||
|
break;
|
||||||
|
case UPDATE_STEP::PULL_NEW_BRANCH_SUCCESS:
|
||||||
|
break;
|
||||||
case UPDATE_STEP::CHECKOUT_BRANCH:
|
case UPDATE_STEP::CHECKOUT_BRANCH:
|
||||||
emit worker->appendText("\nPrepare customer environment ...");
|
emit worker->appendText("\nPrepare customer environment ...");
|
||||||
break;
|
break;
|
||||||
|
Reference in New Issue
Block a user