GerhardHoffmann/UpdatePTUDevCtrl
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
5427844977
UpdatePTUDevCtrl/ismas/ismas_client.cpp

889 lines
33 KiB
C++
Raw Normal View History

Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
#include "ismas/ismas_client.h"
#include <cstring>
#include <cstdio>
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
#include <errno.h>
#include <arpa/inet.h> // inet_addr()
#include <netdb.h>
#include <stdio.h>
#include <stdlib.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <string.h>
#include <strings.h> // bzero()
#include <sys/socket.h>
#include <unistd.h> // read(), write(), close()
#include <fcntl.h>
#include <QThread>
#include <QJsonDocument>
#include <QJsonObject>
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
#if 0
# $1: EVENT: U0001 update finished: 100%
# U0002 reset TRG
# U0003 error
# U0010 for update process
# $2: PERCENT : "only for ISMAS: 0-100%",
# $3: RESULTCODE : "only for ISMAS",
# 0: Success
# 1: no Update nessesary
# 2: Backup failed
# 3: Package error/ Wrong package
# 4: Install Error
# $4: STEP : "running step (only for us): update_psa...",
# $5: STEP_RESULT : "error and result text",
# $6: VERSION : "opkg and conf info; what will be updated"
#
#endif
#include <QDateTime>
#include <QDebug>
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
void IsmasClient::printDebugMessage(int port,
QString const &clientIP,
int clientPort,
QString const &message) {
qDebug().noquote()
<< "\n"
<< "SEND-REQUEST-RECEIVE-RESPONSE ..." << "\n"
<< "hostname ........" << "127.0.0.1" << "\n"
<< "port ............" << port << "\n"
<< "local address ..." << clientIP << "\n"
<< "local port ......" << clientPort << "\n"
<< message;
}
void IsmasClient::printInfoMessage(int port,
QString const &clientIP,
int clientPort,
QString const &message) {
qInfo().noquote()
<< "\n"
<< "SEND-REQUEST-RECEIVE-RESPONSE ..." << "\n"
<< "hostname ........" << "127.0.0.1" << "\n"
<< "port ............" << port << "\n"
<< "local address ..." << clientIP << "\n"
<< "local port ......" << clientPort << "\n"
<< message;
}
void IsmasClient::printErrorMessage(int port,
QString const &clientIP,
int clientPort,
QString const &message) {
qCritical().noquote()
<< "\n"
<< "SEND-REQUEST-RECEIVE-RESPONSE ..." << "\n"
<< "hostname ........" << "127.0.0.1" << "\n"
<< "port ............" << port << "\n"
<< "local address ..." << clientIP << "\n"
<< "local port ......" << clientPort << "\n"
<< message;
}
std::optional<QString>
IsmasClient::sendRequestReceiveResponse(int port, QString const &request) {
qInfo() << "REQUEST" << request;
int sockfd;
int r;
errno = 0;
// socket create and verification
if ((sockfd = ::socket(AF_INET, SOCK_STREAM, 0)) == -1) {
qCritical().noquote()
<< "\n"
<< "SEND-REQUEST-RECEIVE-RESPONSE ..." << "\n"
<< "SOCKET CREATION FAILED (" << strerror(errno) << ")";
return std::nullopt;
}
struct sockaddr_in servAddr;
bzero(&servAddr, sizeof(servAddr));
// assign IP, PORT
servAddr.sin_family = AF_INET;
servAddr.sin_addr.s_addr = inet_addr("127.0.0.1");
servAddr.sin_port = htons(port);
// connect the client socket to server socket
if ((r = ::connect(sockfd, (struct sockaddr *)(&servAddr), sizeof(servAddr))) != 0) {
qCritical().noquote()
<< "\n"
<< "SEND-REQUEST-RECEIVE-RESPONSE ..." << "\n"
<< "CONNECTION WITH SERVER FAILED (" << strerror(r) << ")";
::close(sockfd);
return std::nullopt;
}
struct sockaddr_in clientAddr;
bzero(&clientAddr, sizeof(clientAddr));
socklen_t sockLen = sizeof(clientAddr);
char clientIP[16];
bzero(&clientIP, sizeof(clientIP));
getsockname(sockfd, (struct sockaddr *)(&clientAddr), &sockLen);
inet_ntop(AF_INET, &clientAddr.sin_addr, clientIP, sizeof(clientIP));
unsigned int clientPort = ntohs(clientAddr.sin_port);
printDebugMessage(port, clientIP, clientPort, QString("CONNECTED TO SERVER"));
struct timeval tv;
tv.tv_sec = 10; /* 10 secs timeout for read and write */
struct linger so_linger;
so_linger.l_onoff = 1;
so_linger.l_linger = 0;
SO_SNDTIMEO and SO_RCVTIMEO socket options have turned out not to be reliable. Use select() for detecting timeout on socket (read and write).
2023-08-14 14:35:54 +02:00
int maxfdp1;
fd_set rset;
fd_set wset;
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
setsockopt(sockfd, SOL_SOCKET, SO_LINGER, &so_linger, sizeof(so_linger));
SO_SNDTIMEO and SO_RCVTIMEO socket options have turned out not to be reliable. Use select() for detecting timeout on socket (read and write).
2023-08-14 14:35:54 +02:00
// no reliable, but does not harm, as we use select() as well
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
setsockopt(sockfd, SOL_SOCKET, SO_SNDTIMEO, &tv, sizeof(tv));
setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv));
int flag = 1;
setsockopt(sockfd, IPPROTO_TCP, TCP_NODELAY, (char *) &flag, sizeof(int));
static char buf[1024*8];
bzero(buf, sizeof(buf));
int const bytesToWrite = strlen(request.toStdString().c_str());
strncpy(buf, request.toStdString().c_str(), sizeof(buf)-1);
For the error EWOULDBLOCK try again 10 times until quitting.
2023-08-07 13:50:59 +02:00
int loop = 0;
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
int bytesWritten = 0;
while (bytesWritten < bytesToWrite) {
SO_SNDTIMEO and SO_RCVTIMEO socket options have turned out not to be reliable. Use select() for detecting timeout on socket (read and write).
2023-08-14 14:35:54 +02:00
errno = 0;
FD_ZERO(&wset);
FD_SET(sockfd, &wset);
maxfdp1 = sockfd + 1;
tv.tv_sec = 60; /* 60 secs timeout for read and write -> APISM cuts the connection after 30s */
tv.tv_usec = 0;
int const w = select(maxfdp1, NULL, &wset, NULL, &tv);
if (w < 0) { // error
if (errno == EINTR) {
printErrorMessage(port, clientIP, clientPort,
QString("INTERRUPTED BY SIGNAL (1) (") + strerror(errno) + ")");
continue;
} else {
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
printErrorMessage(port, clientIP, clientPort,
SO_SNDTIMEO and SO_RCVTIMEO socket options have turned out not to be reliable. Use select() for detecting timeout on socket (read and write).
2023-08-14 14:35:54 +02:00
QString("SELECT-ERROR (WRITE) %1(").arg(loop) + strerror(errno) + ")");
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
::close(sockfd);
return std::nullopt;
SO_SNDTIMEO and SO_RCVTIMEO socket options have turned out not to be reliable. Use select() for detecting timeout on socket (read and write).
2023-08-14 14:35:54 +02:00
}
} else
if (w == 0) { // timeout
printErrorMessage(port, clientIP, clientPort,
QString("SELECT-TIMEOUT (WRITE) %1(").arg(loop) + strerror(errno) + ")");
if (++loop < 10) {
QThread::msleep(500);
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
continue;
}
SO_SNDTIMEO and SO_RCVTIMEO socket options have turned out not to be reliable. Use select() for detecting timeout on socket (read and write).
2023-08-14 14:35:54 +02:00
::close(sockfd);
return std::nullopt;
} else
if (w > 0) {
int n = ::sendto(sockfd, buf+bytesWritten, bytesToWrite-bytesWritten, 0, NULL, 0);
if (n >= 0) {
bytesWritten += n;
} else {
if (errno == EWOULDBLOCK) {
if (++loop < 10) {
QThread::msleep(500);
continue;
}
printErrorMessage(port, clientIP, clientPort,
QString("WRITE TIMEOUT %1(").arg(loop) + strerror(errno) + ")");
::close(sockfd);
return std::nullopt;
} else
if (errno == EINTR) {
printErrorMessage(port, clientIP, clientPort,
QString("WRITE INTERRUPTED BY SIGNAL (1) (") + strerror(errno) + ")");
continue;
}
}
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
}
}
// DO NOT USE SHUTDOWN! APISM CAN NOT COPE WITH IT
// errno = 0;
// if (shutdown(sockfd, SHUT_WR) < 0) {
// printErrorMessage(port, clientIP, clientPort,
// QString("CANNOT CLOSE WRITING END (") + strerror(errno) + ")");
// }
Extended some debug output
2023-08-18 11:42:47 +02:00
printInfoMessage(port, clientIP, clientPort, QString("MESSAGE SENT <<<") + buf + ">>>");
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
For the error EWOULDBLOCK try again 10 times until quitting.
2023-08-07 13:50:59 +02:00
loop = 0;
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
bzero(buf, sizeof(buf));
int bytesToRead = sizeof(buf)-1;
int bytesRead = 0;
while (bytesRead < bytesToRead) {
errno = 0;
SO_SNDTIMEO and SO_RCVTIMEO socket options have turned out not to be reliable. Use select() for detecting timeout on socket (read and write).
2023-08-14 14:35:54 +02:00
FD_ZERO(&rset);
FD_SET(sockfd, &rset);
maxfdp1 = sockfd + 1;
tv.tv_sec = 60; /* 60 secs timeout for read and write */
tv.tv_usec = 0;
Insert last commit-id, message and date of last commit into sendLastVersion-message to ISMAS.
2023-08-16 10:34:55 +02:00
QString const selectStart = QDateTime::currentDateTime().toString(Qt::ISODateWithMs);
SO_SNDTIMEO and SO_RCVTIMEO socket options have turned out not to be reliable. Use select() for detecting timeout on socket (read and write).
2023-08-14 14:35:54 +02:00
int const r = select(maxfdp1, &rset, NULL, NULL, &tv);
if (r < 0) { // error
if (errno == EINTR) {
printErrorMessage(port, clientIP, clientPort,
QString("INTERRUPTED BY SIGNAL (2) (") + strerror(errno) + ")");
continue;
} else {
printErrorMessage(port, clientIP, clientPort,
QString("SELECT-ERROR (READ) %1(").arg(loop) + strerror(errno) + ")");
::close(sockfd);
return std::nullopt;
}
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
} else
SO_SNDTIMEO and SO_RCVTIMEO socket options have turned out not to be reliable. Use select() for detecting timeout on socket (read and write).
2023-08-14 14:35:54 +02:00
if (r == 0) { // timeout
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
printErrorMessage(port, clientIP, clientPort,
SO_SNDTIMEO and SO_RCVTIMEO socket options have turned out not to be reliable. Use select() for detecting timeout on socket (read and write).
2023-08-14 14:35:54 +02:00
QString("SELECT-TIMEOUT (READ) %1(").arg(loop) + strerror(errno) + ")");
if (++loop < 10) {
QThread::msleep(500);
continue;
}
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
::close(sockfd);
return std::nullopt;
} else
SO_SNDTIMEO and SO_RCVTIMEO socket options have turned out not to be reliable. Use select() for detecting timeout on socket (read and write).
2023-08-14 14:35:54 +02:00
if (r > 0) {
if (FD_ISSET(sockfd, &rset)) {
int n = ::recvfrom(sockfd, buf+bytesRead, bytesToRead-bytesRead,
0, NULL, NULL);
if (n > 0) { //
bytesRead += n;
} else
if (n == 0) {
// The return value will be 0 when the peer has performed an orderly shutdown.
printErrorMessage(port, clientIP, clientPort,
Insert last commit-id, message and date of last commit into sendLastVersion-message to ISMAS.
2023-08-16 10:34:55 +02:00
QString("PEER CLOSED CONNECTION (") + strerror(errno) + ") START AT" +
selectStart + " NOW " + QDateTime::currentDateTime().toString(Qt::ISODateWithMs));
SO_SNDTIMEO and SO_RCVTIMEO socket options have turned out not to be reliable. Use select() for detecting timeout on socket (read and write).
2023-08-14 14:35:54 +02:00
::close(sockfd);
return std::nullopt;
} else
if (n < 0) {
if (errno == EWOULDBLOCK) { // check just in case
if (++loop < 10) {
QThread::msleep(500);
continue;
}
printErrorMessage(port, clientIP, clientPort,
QString("READ TIMEOUT %1(").arg(loop) + strerror(errno) + ")");
::close(sockfd);
return std::nullopt;
}
if (errno == EINTR) {
printErrorMessage(port, clientIP, clientPort,
QString("INTERRUPTED BY SIGNAL (2) (") + strerror(errno) + ")");
continue;
}
For the error EWOULDBLOCK try again 10 times until quitting.
2023-08-07 13:50:59 +02:00
}
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
}
}
printInfoMessage(port, clientIP, clientPort, QString("MESSAGE RECEIVED ") + buf);
QString response(buf);
if (int idx = response.indexOf("{\"error\":\"ISMAS is offline\"}")) {
response = response.mid(0, idx);
} else
Only check for keyword RECORD to be more general.
2023-08-09 15:01:43 +02:00
if (response.contains("RECORD")) { // RECORD SAVED or RECORD WRITE ABORTED
printInfoMessage(port, clientIP, clientPort, QString("IGNORED '") + response + "' RESPONSE");
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
::close(sockfd);
return std::nullopt;
}
QJsonParseError parseError;
QJsonDocument document(QJsonDocument::fromJson(response.toUtf8(), &parseError));
if (parseError.error == QJsonParseError::NoError) {
if (document.isObject()) { // done: received valid APISM response
printInfoMessage(port, clientIP, clientPort,
QString("VALID APISM RESPONSE .. \n") + response);
::close(sockfd);
return response;
} else {
printInfoMessage(port, clientIP, clientPort,
QString("CORRUPTED RESPONSE ") + response);
::close(sockfd);
return std::nullopt;
}
} else {
printDebugMessage(port, clientIP, clientPort,
QString("PARSE ERROR ") + response + " " + parseError.errorString());
::close(sockfd);
return std::nullopt;
}
}
return std::nullopt;
}
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
QString IsmasClient::updateNewsToIsmas(char const *event,
int percent,
int resultCode,
char const *step,
char const *step_result,
char const *version) {
char buf[1024];
memset(buf, 0, sizeof(buf));
QString const ts = QDateTime::currentDateTime().toString(Qt::ISODateWithMs);
snprintf(buf, sizeof(buf)-1,
"{"
"\"REASON\":\"SW_UP\","
"\"TIMESTAMP\":\"%s\","
"\"EVENT_ID\":\"0\","
"\"EVENT\":\"%s\","
"\"EVENTSTATE\":1,"
"\"PARAMETER\": {"
"\"PERCENT\" : %d,"
"\"RESULTCODE\" : %d,"
"\"STEP\" : \"%s\","
"\"STEP_RESULT\" : \"%s\","
"\"VERSION\" : \"%s\""
"}"
"}", ts.toStdString().c_str(), event, percent, resultCode,
step, step_result, version);
return buf;
}
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
QString IsmasClient::errorBackendNotConnected(QString const &info,
QString const &version) {
return updateNewsToIsmas("U0003",
m_progressInPercent,
RESULT_CODE::INSTALL_ERROR,
"CHECK BACKEND CONNECTIVITY",
info.toStdString().c_str(),
version.toStdString().c_str());
Added errorGitClone().
2023-08-07 13:51:47 +02:00
}
QString IsmasClient::errorGitClone(int percent, QString const &info, QString const &version) {
return updateNewsToIsmas("U0003",
percent,
RESULT_CODE::INSTALL_ERROR,
"CLONE CUSTOMER REPOSITORY FAILED",
info.toStdString().c_str(),
version.toStdString().c_str());
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
}
QString IsmasClient::backendConnected(QString const &info, QString const &version) {
return updateNewsToIsmas("U0010",
m_progressInPercent,
RESULT_CODE::SUCCESS,
"CHECK BACKEND CONNECTIVITY",
info.toStdString().c_str(),
version.toStdString().c_str());
}
QString IsmasClient::execOpkgCommand(QString const &info, QString const &version) {
return updateNewsToIsmas("U0010",
m_progressInPercent,
RESULT_CODE::SUCCESS,
"EXECUTE OPKG COMMAND",
info.toStdString().c_str(),
version.toStdString().c_str());
}
Added rsyncFile() method.
2023-08-23 16:26:11 +02:00
QString IsmasClient::rsyncFile(QString const &info, QString const &version) {
return updateNewsToIsmas("U0010",
m_progressInPercent,
RESULT_CODE::SUCCESS,
"RSYNC FILE",
info.toStdString().c_str(),
version.toStdString().c_str());
}
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
QString IsmasClient::updateTriggerSet(QString const &info, QString const &version) {
return updateNewsToIsmas("U0010",
m_progressInPercent,
RESULT_CODE::SUCCESS,
"CHECK UPDATE TRIGGER",
info.toStdString().c_str(),
version.toStdString().c_str());
}
QString IsmasClient::errorUpdateTrigger(QString const &info, QString const &version) {
return updateNewsToIsmas("U0003",
m_progressInPercent,
RESULT_CODE::INSTALL_ERROR,
"CHECK UPDATE TRIGGER",
info.toStdString().c_str(),
version.toStdString().c_str());
}
Add struct PSAInstalled. Changed interface of updateOfPSASendVersion into QString updateOfPSASendVersion(PSAInstalled const &psa); Re-implemented updateOfPSASendVersion().
2023-07-19 16:48:42 +02:00
QString IsmasClient::updateOfPSASendVersion(PSAInstalled const &psa) {
//static int const constexpr SIZE = 4096*8;
static char buf[4096*2];
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
memset(buf, 0, sizeof(buf));
// local data="#M=APISM#C=CMD_SENDVERSION#J=
snprintf(buf, sizeof(buf)-1,
"{"
"\"VERSION_INFO\" : {"
Insert last commit-id, message and date of last commit into sendLastVersion-message to ISMAS.
2023-08-16 10:34:55 +02:00
"\"REASON\":\"%s\","
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
"\"CREATED\":\"%s\","
"\"HASH\":\"%s\""
"},"
"\"TARIFF\" : {"
"\"VERSION\" : \"%s\","
"\"PROJECT\" : \"%s\","
"\"ZONE\" : %d,"
"\"INFO\" : \"%s\","
Add struct PSAInstalled. Changed interface of updateOfPSASendVersion into QString updateOfPSASendVersion(PSAInstalled const &psa); Re-implemented updateOfPSASendVersion().
2023-07-19 16:48:42 +02:00
"\"BLOB\" : \"%s\","
Add last-commit for traiff and add info for opkg_commands.
2023-08-22 13:47:57 +02:00
"\"LAST-COMMIT\" : \"%s\","
"\"SIZE\" : %d,"
"\"LOADED\" : \"%s\""
"},"
"\"OPKG_COMMANDS\" : {"
"\"BLOB\" : \"%s\","
"\"LAST-COMMIT\" : \"%s\","
Add struct PSAInstalled. Changed interface of updateOfPSASendVersion into QString updateOfPSASendVersion(PSAInstalled const &psa); Re-implemented updateOfPSASendVersion().
2023-07-19 16:48:42 +02:00
"\"SIZE\" : %d,"
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
"\"LOADED\" : \"%s\""
"},"
Add struct PSAInstalled. Changed interface of updateOfPSASendVersion into QString updateOfPSASendVersion(PSAInstalled const &psa); Re-implemented updateOfPSASendVersion().
2023-07-19 16:48:42 +02:00
"\"JSON\" : {"
"\"DC2C_CASH\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_CONF\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_DEVICE\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_01\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_02\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_03\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_04\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_05\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_06\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_07\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_08\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_09\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_10\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_11\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_12\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_13\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_14\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_15\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_16\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_17\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_18\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_19\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_20\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_21\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_22\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_23\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_24\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_25\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_26\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_27\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_28\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_29\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_30\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_31\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"},"
"\"DC2C_PRINT_32\" : {"
"\"BLOB\" : \"%s\","
"\"SIZE\" : %d"
"}"
"},"
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
"\"HARDWARE\" : {"
"\"DEVICES\" : [\"PTU5\", \"DC\", \"PRINTER\", \"BNA\"]"
"},"
"\"OS\" : {"
"\"Linux\": \"%s\""
"},"
"\"CONFIG\" : {"
"\"PTU5\" : {"
"\"CPU_SERIAL\" : \"%s\""
"},"
"\"DC\" : {"
Add struct PSAInstalled. Changed interface of updateOfPSASendVersion into QString updateOfPSASendVersion(PSAInstalled const &psa); Re-implemented updateOfPSASendVersion().
2023-07-19 16:48:42 +02:00
"\"HW-VERSION\" : \"%s\","
"\"SW-VERSION\" : \"%s\","
"\"SIZE\" : %d,"
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
"\"GITBLOB\" : \"%s\","
"\"GITLASTCOMMIT\" : \"%s\""
"},"
"\"PRINTER\" : {"
"},"
"\"BNA\" : {"
"}"
"},"
"\"SOFTWARE\": {"
"\"RAUC\" : \"%s\","
"\"OPKG\" : \"%s\","
"\"ATBQT\" : {"
Add struct PSAInstalled. Changed interface of updateOfPSASendVersion into QString updateOfPSASendVersion(PSAInstalled const &psa); Re-implemented updateOfPSASendVersion().
2023-07-19 16:48:42 +02:00
"\"VERSION\" : \"%s\""
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
"}"
"},"
"\"PLUGINS\" : {"
"\"libATBDeviceControllerPlugin.so\" : {"
"\"VERSION\" : \"%s\""
"},"
"\"libIngenicoISelf_CCPlugin.so\" : {"
"\"VERSION\" : \"%s\""
"},"
"\"libMOBILISIS_CalculatePricePlugin.so\" : {"
"\"VERSION\" : \"%s\""
"},"
"\"libMOBILISIS_CalculatePricePlugin_ConfigUi.so\" : {"
"\"VERSION\" : \"%s\""
"},"
"\"libPRM_CalculatePricePlugin.so\" : {"
"\"VERSION\" : \"%s\""
"},"
"\"libPRM_CalculatePricePlugin_ConfigUi.so\" : {"
"\"VERSION\" : \"%s\""
"},"
"\"libTCP_ZVT_CCPlugin.so\" : {"
"\"VERSION\" : \"%s\""
"}"
"}"
"}",
Insert last commit-id, message and date of last commit into sendLastVersion-message to ISMAS.
2023-08-16 10:34:55 +02:00
psa.versionInfo.reason.toStdString().c_str(),
psa.versionInfo.created.toStdString().c_str(),
psa.versionInfo.lastCommit.toStdString().c_str(),
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
Add struct PSAInstalled. Changed interface of updateOfPSASendVersion into QString updateOfPSASendVersion(PSAInstalled const &psa); Re-implemented updateOfPSASendVersion().
2023-07-19 16:48:42 +02:00
psa.tariff.version.toStdString().c_str(),
psa.tariff.project.toStdString().c_str(),
psa.tariff.zone,
psa.tariff.info.toStdString().c_str(),
psa.tariff.blob.toStdString().c_str(),
Add last-commit for traiff and add info for opkg_commands.
2023-08-22 13:47:57 +02:00
psa.tariff.lastCommit.toStdString().c_str(),
Add struct PSAInstalled. Changed interface of updateOfPSASendVersion into QString updateOfPSASendVersion(PSAInstalled const &psa); Re-implemented updateOfPSASendVersion().
2023-07-19 16:48:42 +02:00
psa.tariff.size,
psa.tariff.loadTime.toStdString().c_str(),
Add last-commit for traiff and add info for opkg_commands.
2023-08-22 13:47:57 +02:00
psa.opkg.blob.toStdString().c_str(),
psa.opkg.lastCommit.toStdString().c_str(),
psa.opkg.size,
psa.opkg.loadTime.toStdString().c_str(),
Add struct PSAInstalled. Changed interface of updateOfPSASendVersion into QString updateOfPSASendVersion(PSAInstalled const &psa); Re-implemented updateOfPSASendVersion().
2023-07-19 16:48:42 +02:00
psa.cash.blob.toStdString().c_str(),
psa.cash.size,
psa.conf.blob.toStdString().c_str(),
psa.conf.size,
psa.device.blob.toStdString().c_str(),
psa.device.size,
psa.print[0].blob.toStdString().c_str(),
psa.print[0].size,
psa.print[1].blob.toStdString().c_str(),
psa.print[1].size,
psa.print[2].blob.toStdString().c_str(),
psa.print[2].size,
psa.print[3].blob.toStdString().c_str(),
psa.print[3].size,
psa.print[4].blob.toStdString().c_str(),
psa.print[4].size,
psa.print[5].blob.toStdString().c_str(),
psa.print[5].size,
psa.print[6].blob.toStdString().c_str(),
psa.print[6].size,
psa.print[7].blob.toStdString().c_str(),
psa.print[7].size,
psa.print[8].blob.toStdString().c_str(),
psa.print[8].size,
psa.print[9].blob.toStdString().c_str(),
psa.print[9].size,
psa.print[10].blob.toStdString().c_str(),
psa.print[10].size,
psa.print[11].blob.toStdString().c_str(),
psa.print[11].size,
psa.print[12].blob.toStdString().c_str(),
psa.print[12].size,
psa.print[13].blob.toStdString().c_str(),
psa.print[13].size,
psa.print[14].blob.toStdString().c_str(),
psa.print[14].size,
psa.print[15].blob.toStdString().c_str(),
psa.print[15].size,
psa.print[16].blob.toStdString().c_str(),
psa.print[16].size,
psa.print[17].blob.toStdString().c_str(),
psa.print[17].size,
psa.print[18].blob.toStdString().c_str(),
psa.print[18].size,
psa.print[19].blob.toStdString().c_str(),
psa.print[19].size,
psa.print[20].blob.toStdString().c_str(),
psa.print[20].size,
psa.print[21].blob.toStdString().c_str(),
psa.print[21].size,
psa.print[22].blob.toStdString().c_str(),
psa.print[22].size,
psa.print[23].blob.toStdString().c_str(),
psa.print[23].size,
psa.print[24].blob.toStdString().c_str(),
psa.print[24].size,
psa.print[25].blob.toStdString().c_str(),
psa.print[25].size,
psa.print[26].blob.toStdString().c_str(),
psa.print[26].size,
psa.print[27].blob.toStdString().c_str(),
psa.print[27].size,
psa.print[28].blob.toStdString().c_str(),
psa.print[28].size,
psa.print[29].blob.toStdString().c_str(),
psa.print[29].size,
psa.print[30].blob.toStdString().c_str(),
psa.print[30].size,
psa.print[31].blob.toStdString().c_str(),
psa.print[31].size,
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
Add struct PSAInstalled. Changed interface of updateOfPSASendVersion into QString updateOfPSASendVersion(PSAInstalled const &psa); Re-implemented updateOfPSASendVersion().
2023-07-19 16:48:42 +02:00
psa.hw.linuxVersion.toStdString().c_str(),
psa.hw.cpuSerial.toStdString().c_str(),
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
Add struct PSAInstalled. Changed interface of updateOfPSASendVersion into QString updateOfPSASendVersion(PSAInstalled const &psa); Re-implemented updateOfPSASendVersion().
2023-07-19 16:48:42 +02:00
psa.dc.versionHW.toStdString().c_str(),
psa.dc.versionSW.toStdString().c_str(),
psa.dc.size,
psa.dc.gitBlob.toStdString().c_str(),
psa.dc.gitLastCommit.toStdString().c_str(),
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
Add struct PSAInstalled. Changed interface of updateOfPSASendVersion into QString updateOfPSASendVersion(PSAInstalled const &psa); Re-implemented updateOfPSASendVersion().
2023-07-19 16:48:42 +02:00
psa.sw.raucVersion.toStdString().c_str(),
psa.sw.opkgVersion.toStdString().c_str(),
psa.sw.atbQTVersion.toStdString().c_str(),
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
Add struct PSAInstalled. Changed interface of updateOfPSASendVersion into QString updateOfPSASendVersion(PSAInstalled const &psa); Re-implemented updateOfPSASendVersion().
2023-07-19 16:48:42 +02:00
psa.pluginVersion.deviceController.toStdString().c_str(),
psa.pluginVersion.ingenicoISelfCC.toStdString().c_str(),
psa.pluginVersion.mobilisisCalculatePrice.toStdString().c_str(),
psa.pluginVersion.mobilisisCalculatePriceConfigUi.toStdString().c_str(),
psa.pluginVersion.prmCalculatePrice.toStdString().c_str(),
psa.pluginVersion.prmCalculatePriceConfigUi.toStdString().c_str(),
psa.pluginVersion.tcpZVT.toStdString().c_str());
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
qInfo() << buf;
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
return buf;
}
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
QString IsmasClient::updateOfPSAContinues(QString currentStage,
QString currentStageInfo,
QString const &version) {
return updateNewsToIsmas("U0010",
m_progressInPercent,
RESULT_CODE::SUCCESS,
currentStage.toStdString().c_str(),
currentStageInfo.toStdString().c_str(),
version.toStdString().c_str());
}
QString IsmasClient::updateOfPSAStarted(QString const &version) {
return updateNewsToIsmas("U0010",
m_progressInPercent,
RESULT_CODE::SUCCESS,
"START",
"detected WAIT state: start update process",
version.toStdString().c_str());
}
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
QString IsmasClient::checkoutBranch(QString const &info, QString const &version) {
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
return updateNewsToIsmas("U0010",
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
m_progressInPercent,
RESULT_CODE::SUCCESS,
"BRANCH-CHECKOUT",
info.toStdString().c_str(),
version.toStdString().c_str());
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
}
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
QString IsmasClient::cloneAndCheckoutCustomerRepository(QString const &info, QString const &version) { // clone and checkout customer repository
return updateNewsToIsmas("U0010",
m_progressInPercent,
RESULT_CODE::SUCCESS,
"CLONE-CHECKOUT",
info.toStdString().c_str(),
version.toStdString().c_str());
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
}
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
QString IsmasClient::gitFetch(QString const &info, QString const &version) {
return updateNewsToIsmas("U0010",
m_progressInPercent,
RESULT_CODE::SUCCESS,
"GIT-FETCH",
info.toStdString().c_str(),
version.toStdString().c_str());
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
}
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
QString IsmasClient::errorGitFetch(int resultCode, QString const &info, QString const &version) {
return updateNewsToIsmas("U0003",
m_progressInPercent,
resultCode,
"GIT-FETCH-FAILED",
info.toStdString().c_str(),
version.toStdString().c_str());
}
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
QString IsmasClient::updateOfPSAActivated(QString const &version) { // sent even after success
m_progressInPercent = 0;
return updateNewsToIsmas("U0002",
m_progressInPercent,
RESULT_CODE::SUCCESS,
"UPDATE ACTIVATED",
"reset WAIT state",
version.toStdString().c_str());
}
QString IsmasClient::updateOfPSASucceeded(QString const &version) {
m_progressInPercent = 0;
return updateNewsToIsmas("U0001",
m_progressInPercent,
RESULT_CODE::SUCCESS,
"UPDATE SUCCESS",
"update process succeeded",
version.toStdString().c_str());
}
Started ISMASClient providing the data to be sent to ISMAS. It does not send to ISMAS itself.
2023-07-14 13:28:41 +02:00
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
QString IsmasClient::sanityCheckFailed(int resultCode, QString reason, QString const &version) {
return updateNewsToIsmas("U0003",
m_progressInPercent,
resultCode,
"SANITY-CHECK-FAILED",
reason.toStdString().c_str(),
version.toStdString().c_str());
}
Added lastCommit to tariff-struct. Added jsonParseFailed().
2023-08-11 11:09:51 +02:00
QString IsmasClient::jsonParseFailed(int resultCode, QString reason, QString const &version) {
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
return updateNewsToIsmas("U0003",
m_progressInPercent,
resultCode,
Added lastCommit to tariff-struct. Added jsonParseFailed().
2023-08-11 11:09:51 +02:00
"JSON-PARSE-ERROR",
reason.toStdString().c_str(),
version.toStdString().c_str());
}
Added finalResult() -> send final message to ISMAS in any case.
2023-08-11 12:19:10 +02:00
std::optional<QString> IsmasClient::finalResult(int resultCode, QString reason, QString const &version) {
m_progressInPercent = 0;
if (resultCode == RESULT_CODE::SUCCESS) {
return updateNewsToIsmas("U0002",
m_progressInPercent,
RESULT_CODE::SUCCESS,
"FINAL-UPDATE-RESULT",
"(re-)set WAIT state",
version.toStdString().c_str());
}
if (resultCode == RESULT_CODE::INSTALL_ERROR) {
return updateNewsToIsmas("U0003",
m_progressInPercent,
resultCode,
"FINAL-UPDATE-RESULT",
reason.toStdString().c_str(),
version.toStdString().c_str());
}
return std::nullopt;
}
Added lastCommit to tariff-struct. Added jsonParseFailed().
2023-08-11 11:09:51 +02:00
QString IsmasClient::updateOfPSAFailed(int resultCode, QString step,
QString reason, QString const &version) {
return updateNewsToIsmas("U0003",
m_progressInPercent,
resultCode,
step.toStdString().c_str(),
Added sendRequestReceiveResponse(): static member for communication with APISM, on ports 7777 and 7778. Each request is immediately handled in a synchronous fashion. Added several helper functions to format messages to be sent to APISM/ISMAS.
2023-08-02 15:13:05 +02:00
reason.toStdString().c_str(),
version.toStdString().c_str());
}
Reference in New Issue Copy Permalink