Compare commits
	
		
			9 Commits
		
	
	
		
			1.5.6
			...
			removed-ap
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 5a2ced4a96 | |||
| 3b3456196f | |||
| c63fa92ff7 | |||
| 42624409ba | |||
| c49ff5045b | |||
| 358fd80c47 | |||
| 8a2d710cf8 | |||
| 1ea1cdc3e6 | |||
| 
						
						
							
						
						348fb15508
	
				 | 
					
					
						
@@ -147,7 +147,10 @@ DEFINES += QT_DEPRECATED_WARNINGS
 | 
				
			|||||||
# 1.5.5   : Call into binary ptuPackageVersion to get installed package
 | 
					# 1.5.5   : Call into binary ptuPackageVersion to get installed package
 | 
				
			||||||
#           versions.
 | 
					#           versions.
 | 
				
			||||||
# 1.5.6   : Show additional update progress info in status bar.
 | 
					# 1.5.6   : Show additional update progress info in status bar.
 | 
				
			||||||
VERSION="1.5.6"
 | 
					# 1.5.7   : Add support for dynamic portrait / landscape.
 | 
				
			||||||
 | 
					# 1.5.8   : Use EVENT_ID=<pid of update-tool> for CMD_EVENT.
 | 
				
			||||||
 | 
					# 1.5.9   : Removed restart of Apism if ISMAS unreachable.
 | 
				
			||||||
 | 
					VERSION="1.5.9"
 | 
				
			||||||
# 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
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -21,6 +21,7 @@
 | 
				
			|||||||
#include <QThread>
 | 
					#include <QThread>
 | 
				
			||||||
#include <QJsonDocument>
 | 
					#include <QJsonDocument>
 | 
				
			||||||
#include <QJsonObject>
 | 
					#include <QJsonObject>
 | 
				
			||||||
 | 
					#include <QCoreApplication>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
#if 0
 | 
					#if 0
 | 
				
			||||||
########################
 | 
					########################
 | 
				
			||||||
@@ -380,7 +381,7 @@ QString IsmasClient::updateNewsToIsmas(char const *event,
 | 
				
			|||||||
        "{"
 | 
					        "{"
 | 
				
			||||||
            "\"REASON\":\"SW_UP\","
 | 
					            "\"REASON\":\"SW_UP\","
 | 
				
			||||||
            "\"TIMESTAMP\":\"%s\","
 | 
					            "\"TIMESTAMP\":\"%s\","
 | 
				
			||||||
            "\"EVENT_ID\":\"0\","
 | 
					            "\"EVENT_ID\":\"%d\","
 | 
				
			||||||
            "\"EVENT\":\"%s\","
 | 
					            "\"EVENT\":\"%s\","
 | 
				
			||||||
            "\"EVENTSTATE\":1,"
 | 
					            "\"EVENTSTATE\":1,"
 | 
				
			||||||
            "\"PARAMETER\": {"
 | 
					            "\"PARAMETER\": {"
 | 
				
			||||||
@@ -390,7 +391,7 @@ QString IsmasClient::updateNewsToIsmas(char const *event,
 | 
				
			|||||||
                "\"STEP_RESULT\" : \"%s\","
 | 
					                "\"STEP_RESULT\" : \"%s\","
 | 
				
			||||||
                "\"VERSION\" : \"%s\""
 | 
					                "\"VERSION\" : \"%s\""
 | 
				
			||||||
            "}"
 | 
					            "}"
 | 
				
			||||||
        "}", ts.toStdString().c_str(), event, percent, resultCode,
 | 
					        "}", ts.toStdString().c_str(), static_cast<int>(QCoreApplication::applicationPid()), event, percent, resultCode,
 | 
				
			||||||
             step, step_result, version);
 | 
					             step, step_result, version);
 | 
				
			||||||
    return buf;
 | 
					    return buf;
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -12,6 +12,9 @@
 | 
				
			|||||||
#include <QScrollBar>
 | 
					#include <QScrollBar>
 | 
				
			||||||
#include <QEvent>
 | 
					#include <QEvent>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					#include <QScreen>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
MainWindow::MainWindow(Worker *worker, QWidget *parent)
 | 
					MainWindow::MainWindow(Worker *worker, QWidget *parent)
 | 
				
			||||||
    : QMainWindow(parent)
 | 
					    : QMainWindow(parent)
 | 
				
			||||||
@@ -30,6 +33,7 @@ MainWindow::MainWindow(Worker *worker, QWidget *parent)
 | 
				
			|||||||
    this->statusBar()->setFont(f);
 | 
					    this->statusBar()->setFont(f);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    ui->setupUi(this);
 | 
					    ui->setupUi(this);
 | 
				
			||||||
 | 
					    checkOrientation();
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    ui->updateProgress->setRange(0, 100);
 | 
					    ui->updateProgress->setRange(0, 100);
 | 
				
			||||||
    ui->updateProgress->reset();
 | 
					    ui->updateProgress->reset();
 | 
				
			||||||
@@ -98,6 +102,56 @@ MainWindow::~MainWindow() {
 | 
				
			|||||||
    delete ui;
 | 
					    delete ui;
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// ----------------------------- Ui::LAYOUT setting -------------------------------------
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					void MainWindow::checkOrientation()
 | 
				
			||||||
 | 
					{
 | 
				
			||||||
 | 
					    QScreen *screen = QGuiApplication::primaryScreen();
 | 
				
			||||||
 | 
					    Qt::ScreenOrientation orientation = screen->orientation();
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    switch (orientation) {
 | 
				
			||||||
 | 
					    case Qt::PrimaryOrientation:
 | 
				
			||||||
 | 
					        this->setLandscapeLayout();
 | 
				
			||||||
 | 
					        break;
 | 
				
			||||||
 | 
					    case Qt::LandscapeOrientation:
 | 
				
			||||||
 | 
					        this->setLandscapeLayout();
 | 
				
			||||||
 | 
					        break;
 | 
				
			||||||
 | 
					    case Qt::PortraitOrientation:
 | 
				
			||||||
 | 
					        this->setPortraitLayout();
 | 
				
			||||||
 | 
					        break;
 | 
				
			||||||
 | 
					    case Qt::InvertedLandscapeOrientation:
 | 
				
			||||||
 | 
					        this->setLandscapeLayout();
 | 
				
			||||||
 | 
					        break;
 | 
				
			||||||
 | 
					    case Qt::InvertedPortraitOrientation:
 | 
				
			||||||
 | 
					        this->setPortraitLayout();
 | 
				
			||||||
 | 
					        break;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    this->currentOrientation = orientation;
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					void MainWindow::setPortraitLayout()
 | 
				
			||||||
 | 
					{
 | 
				
			||||||
 | 
					    // Adjust layout for portrait mode (480x800)
 | 
				
			||||||
 | 
					    this->setFixedSize(480, 800);
 | 
				
			||||||
 | 
					    ui->centralwidget->setFixedSize(480, 800);
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					void MainWindow::setLandscapeLayout()
 | 
				
			||||||
 | 
					{
 | 
				
			||||||
 | 
					    // Adjust layout for landscape mode (800x480)
 | 
				
			||||||
 | 
					    this->setFixedSize(800, 480);
 | 
				
			||||||
 | 
					    ui->centralwidget->setFixedSize(800, 480);
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
void MainWindow::customEvent(QEvent *event) {
 | 
					void MainWindow::customEvent(QEvent *event) {
 | 
				
			||||||
    if (event->type() == ProgressEvent::type()) {
 | 
					    if (event->type() == ProgressEvent::type()) {
 | 
				
			||||||
        ProgressEvent *pevent = (ProgressEvent *)event;
 | 
					        ProgressEvent *pevent = (ProgressEvent *)event;
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -66,6 +66,12 @@ private:
 | 
				
			|||||||
    void onShowMessage(QString, QString);
 | 
					    void onShowMessage(QString, QString);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    Ui::MainWindow *ui;
 | 
					    Ui::MainWindow *ui;
 | 
				
			||||||
 | 
					    void checkOrientation();
 | 
				
			||||||
 | 
					    void setPortraitLayout();
 | 
				
			||||||
 | 
					    void setLandscapeLayout();
 | 
				
			||||||
 | 
					    Qt::ScreenOrientation currentOrientation;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    Worker *m_worker;
 | 
					    Worker *m_worker;
 | 
				
			||||||
    int const m_width;
 | 
					    int const m_width;
 | 
				
			||||||
    QTimer *m_startTimer;
 | 
					    QTimer *m_startTimer;
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -10,6 +10,12 @@
 | 
				
			|||||||
    <height>480</height>
 | 
					    <height>480</height>
 | 
				
			||||||
   </rect>
 | 
					   </rect>
 | 
				
			||||||
  </property>
 | 
					  </property>
 | 
				
			||||||
 | 
					  <property name="minimumSize">
 | 
				
			||||||
 | 
					   <size>
 | 
				
			||||||
 | 
					    <width>480</width>
 | 
				
			||||||
 | 
					    <height>480</height>
 | 
				
			||||||
 | 
					   </size>
 | 
				
			||||||
 | 
					  </property>
 | 
				
			||||||
  <property name="font">
 | 
					  <property name="font">
 | 
				
			||||||
   <font>
 | 
					   <font>
 | 
				
			||||||
    <family>Source Code Pro</family>
 | 
					    <family>Source Code Pro</family>
 | 
				
			||||||
@@ -19,55 +25,47 @@
 | 
				
			|||||||
   <string>MainWindow</string>
 | 
					   <string>MainWindow</string>
 | 
				
			||||||
  </property>
 | 
					  </property>
 | 
				
			||||||
  <widget class="QWidget" name="centralwidget">
 | 
					  <widget class="QWidget" name="centralwidget">
 | 
				
			||||||
   <widget class="QWidget" name="layoutWidget">
 | 
					   <layout class="QVBoxLayout" name="verticalLayout">
 | 
				
			||||||
    <property name="geometry">
 | 
					    <item>
 | 
				
			||||||
     <rect>
 | 
					     <layout class="QGridLayout" name="gridLayout">
 | 
				
			||||||
      <x>10</x>
 | 
					      <item row="3" column="2">
 | 
				
			||||||
      <y>10</y>
 | 
					       <widget class="QPushButton" name="exit">
 | 
				
			||||||
      <width>781</width>
 | 
					        <property name="text">
 | 
				
			||||||
      <height>441</height>
 | 
					         <string>Exit</string>
 | 
				
			||||||
     </rect>
 | 
					        </property>
 | 
				
			||||||
    </property>
 | 
					       </widget>
 | 
				
			||||||
    <layout class="QGridLayout" name="gridLayout">
 | 
					      </item>
 | 
				
			||||||
     <item row="3" column="2">
 | 
					      <item row="3" column="1">
 | 
				
			||||||
      <widget class="QPushButton" name="exit">
 | 
					       <widget class="QProgressBar" name="updateProgress">
 | 
				
			||||||
       <property name="text">
 | 
					        <property name="value">
 | 
				
			||||||
        <string>Exit</string>
 | 
					         <number>1</number>
 | 
				
			||||||
       </property>
 | 
					        </property>
 | 
				
			||||||
      </widget>
 | 
					       </widget>
 | 
				
			||||||
     </item>
 | 
					      </item>
 | 
				
			||||||
     <item row="3" column="1">
 | 
					      <item row="0" column="0" rowspan="3" colspan="3">
 | 
				
			||||||
      <widget class="QProgressBar" name="updateProgress">
 | 
					       <widget class="QTextEdit" name="updateStatus">
 | 
				
			||||||
       <property name="value">
 | 
					        <property name="enabled">
 | 
				
			||||||
        <number>1</number>
 | 
					         <bool>true</bool>
 | 
				
			||||||
       </property>
 | 
					        </property>
 | 
				
			||||||
      </widget>
 | 
					        <property name="font">
 | 
				
			||||||
     </item>
 | 
					         <font>
 | 
				
			||||||
     <item row="0" column="0" rowspan="3" colspan="3">
 | 
					          <family>Misc Fixed</family>
 | 
				
			||||||
      <widget class="QTextEdit" name="updateStatus">
 | 
					          <pointsize>11</pointsize>
 | 
				
			||||||
       <property name="enabled">
 | 
					          <weight>75</weight>
 | 
				
			||||||
        <bool>true</bool>
 | 
					          <bold>true</bold>
 | 
				
			||||||
       </property>
 | 
					         </font>
 | 
				
			||||||
       <property name="font">
 | 
					        </property>
 | 
				
			||||||
        <font>
 | 
					        <property name="verticalScrollBarPolicy">
 | 
				
			||||||
         <family>Misc Fixed</family>
 | 
					         <enum>Qt::ScrollBarAsNeeded</enum>
 | 
				
			||||||
         <pointsize>11</pointsize>
 | 
					        </property>
 | 
				
			||||||
         <bold>true</bold>
 | 
					        <property name="horizontalScrollBarPolicy">
 | 
				
			||||||
        </font>
 | 
					         <enum>Qt::ScrollBarAsNeeded</enum>
 | 
				
			||||||
       </property>
 | 
					        </property>
 | 
				
			||||||
       <property name="verticalScrollBarPolicy">
 | 
					       </widget>
 | 
				
			||||||
        <enum>Qt::ScrollBarAsNeeded</enum>
 | 
					      </item>
 | 
				
			||||||
       </property>
 | 
					     </layout>
 | 
				
			||||||
       <property name="horizontalScrollBarPolicy">
 | 
					    </item>
 | 
				
			||||||
        <enum>Qt::ScrollBarAsNeeded</enum>
 | 
					   </layout>
 | 
				
			||||||
       </property>
 | 
					 | 
				
			||||||
       <property name="sizeAdjustPolicy">
 | 
					 | 
				
			||||||
        <enum>QAbstractScrollArea::AdjustToContents</enum>
 | 
					 | 
				
			||||||
       </property>
 | 
					 | 
				
			||||||
      </widget>
 | 
					 | 
				
			||||||
     </item>
 | 
					 | 
				
			||||||
    </layout>
 | 
					 | 
				
			||||||
   </widget>
 | 
					 | 
				
			||||||
  </widget>
 | 
					  </widget>
 | 
				
			||||||
 </widget>
 | 
					 </widget>
 | 
				
			||||||
 <resources/>
 | 
					 <resources/>
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -584,16 +584,6 @@ bool Worker::updateTriggerSet() {
 | 
				
			|||||||
            CONSOLE(lst) << UPDATE_STEP::DEBUG;
 | 
					            CONSOLE(lst) << UPDATE_STEP::DEBUG;
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        if ((repeat % 8) == 0) {
 | 
					 | 
				
			||||||
            CONSOLE(QStringList(func) << "RESTART APISM") << UPDATE_STEP::DEBUG;
 | 
					 | 
				
			||||||
            Command c("systemctl restart apism");
 | 
					 | 
				
			||||||
            if (c.execute("/tmp")) {
 | 
					 | 
				
			||||||
                QThread::sleep(20); // give APISM some time to reconnect
 | 
					 | 
				
			||||||
                QStringList lst = (m_ismasTriggerStatusMessage = (QStringList(func) << "RESTART APISM DONE"));
 | 
					 | 
				
			||||||
                CONSOLE(lst) << UPDATE_STEP::DEBUG;
 | 
					 | 
				
			||||||
            }
 | 
					 | 
				
			||||||
        }
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
        if (std::optional<QString> result
 | 
					        if (std::optional<QString> result
 | 
				
			||||||
                = IsmasClient::sendRequestReceiveResponse(
 | 
					                = IsmasClient::sendRequestReceiveResponse(
 | 
				
			||||||
                    IsmasClient::APISM::DIRECT_PORT, "#M=APISM#C=REQ_ISMASPARAMETER#J={}")) {
 | 
					                    IsmasClient::APISM::DIRECT_PORT, "#M=APISM#C=REQ_ISMASPARAMETER#J={}")) {
 | 
				
			||||||
 
 | 
				
			|||||||
							
								
								
									
										184
									
								
								on_update_failure.sh
									
									
									
									
									
										Executable file
									
								
							
							
						
						
									
										184
									
								
								on_update_failure.sh
									
									
									
									
									
										Executable file
									
								
							@@ -0,0 +1,184 @@
 | 
				
			|||||||
 | 
					#!/bin/bash
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					# set -x
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					#
 | 
				
			||||||
 | 
					#############################################################################
 | 
				
			||||||
 | 
					# Check if the ATBUpdateTool(.service) did not send U0001 (sucess),
 | 
				
			||||||
 | 
					# U0002 (activated) or U0003 (error) to ISMAS, including the case that the
 | 
				
			||||||
 | 
					# tool did not crash or was not killed under other circumstances.
 | 
				
			||||||
 | 
					#
 | 
				
			||||||
 | 
					# This script will be called in the associated atbupdatetool.service (see
 | 
				
			||||||
 | 
					# /lib/systemd/system/atbupdatetool.service).
 | 
				
			||||||
 | 
					#
 | 
				
			||||||
 | 
					###############################################################################
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					readonly OUT_FILE=/tmp/out.txt
 | 
				
			||||||
 | 
					readonly SCRIPT_NAME=$(basename $0)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					if [ -z "$START_DATE" ]
 | 
				
			||||||
 | 
					then
 | 
				
			||||||
 | 
					    START_DATE=$(date +"%Y-%m-%d00:00:00")
 | 
				
			||||||
 | 
					fi
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					if [ -z "$STOP_DATE" ]
 | 
				
			||||||
 | 
					then
 | 
				
			||||||
 | 
					    STOP_DATE=$(date +"%Y-%m-%d%H:%M:%S")
 | 
				
			||||||
 | 
					fi
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					echo "EXIT_CODE=$EXIT_CODE"
 | 
				
			||||||
 | 
					echo "SERVICE_RESULT=$SERVICE_RESULT"
 | 
				
			||||||
 | 
					echo "EXIT_STATUS=$EXIT_STATUS"
 | 
				
			||||||
 | 
					echo "START_DATE=$START_DATE"
 | 
				
			||||||
 | 
					echo "STOP_DATE=$STOP_DATE"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					last_cmd_event () {
 | 
				
			||||||
 | 
					    # output json; look for start of CMD_EVENT; look for }}; extract everything between; finally re-add }}.
 | 
				
			||||||
 | 
					    # could also look for ">>>", but this might change in the future.
 | 
				
			||||||
 | 
					    local json=$(\
 | 
				
			||||||
 | 
						    journalctl -u atbupdatetool --since="$START_DATE" --until="$STOP_DATE" --output=json-pretty |\
 | 
				
			||||||
 | 
						    grep "#M=APISM#C=CMD_EVENT#J="                                                              |\
 | 
				
			||||||
 | 
						    awk '{split($0, a, "#M=APISM#C=CMD_EVENT#J="); print a[2]}'                                 |\
 | 
				
			||||||
 | 
						    awk '{split($0, a, /\}[\s]*\}/); print a[1]}'                                               |\
 | 
				
			||||||
 | 
						    tr -d '\\'                                                                                  |\
 | 
				
			||||||
 | 
						    tail -1)
 | 
				
			||||||
 | 
					    json+="}}"
 | 
				
			||||||
 | 
					    echo "$json"
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					last_percent_value () {
 | 
				
			||||||
 | 
					    echo $(cat $OUT_FILE | sed -n "s/\(^.*\)\(\"PERCENT\"\\s*:\)\(\\s*[0-9]\+\)\(.*$\)/\3/p" | xargs | awk '{print $NF}')
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					last_step () {
 | 
				
			||||||
 | 
					    echo $(cat $OUT_FILE | sed -n "s/\(^.*\)\(\"PERCENT\"\\s*:\)\(\\s*[0-9]\+\)\(.*$\)/\1\2\3\4/p" | tail -1 | awk '{split($0, a, ","); print a[8]}' | awk '{split($0, b, " : "); print b[2]}' | tr -d '"\\')
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					last_step_result () {
 | 
				
			||||||
 | 
					    echo $(cat $OUT_FILE | sed -n "s/\(^.*\)\(\"PERCENT\"\\s*:\)\(\\s*[0-9]\+\)\(.*$\)/\1\2\3\4/p" | tail -1 | awk '{split($0, a, ","); print a[9]}' | awk '{split($0, b, " : "); print b[2]}' | tr -d '"\\')
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					pid_atbupdatetool () {
 | 
				
			||||||
 | 
					    echo $(cat $OUT_FILE | sed -n "s/\(^.*\)\(ATBUpdateTool\[\)\(\\s*[0-9]\+\)\(\].*$\)/\3/p" | uniq)
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					last_event () {
 | 
				
			||||||
 | 
					    echo $(cat $OUT_FILE | sed -n "s/\(^.*\)\(\"PERCENT\"\\s*:\)\(\\s*[0-9]\+\)\(.*$\)/\1\2\3\4/p" | tail -1 | awk '{split($0, a, ","); print a[4]}' | awk '{split($0, b, ":"); print b[2]}' | tr -d ' ' | tr -d '"\\') 
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					sendU0003 () {
 | 
				
			||||||
 | 
					    LAST_CMD_EVENT=$(last_cmd_event)
 | 
				
			||||||
 | 
					    echo "LAST=$LAST_CMD_EVENT"
 | 
				
			||||||
 | 
					    
 | 
				
			||||||
 | 
					    local json_detected=0
 | 
				
			||||||
 | 
					    local temp
 | 
				
			||||||
 | 
					    local x
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    if [[ ! -z "$LAST_CMD_EVENT" ]]
 | 
				
			||||||
 | 
					    then
 | 
				
			||||||
 | 
					       temp=$(mktemp -p /tmp)
 | 
				
			||||||
 | 
					       echo "$LAST_CMD_EVENT" > "$temp"
 | 
				
			||||||
 | 
					       x=$(jq .EVENT $temp)
 | 
				
			||||||
 | 
					       if [ $? -eq 0 ]; then
 | 
				
			||||||
 | 
					           json_detected=1
 | 
				
			||||||
 | 
					       fi
 | 
				
			||||||
 | 
					    fi
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    if [ $json_detected -eq 1 ]
 | 
				
			||||||
 | 
					    then
 | 
				
			||||||
 | 
					        # local pid=$(jq .EVENT_ID $temp)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						# if json has been detected, use "jq".
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        x=$(jq .PARAMETER.PERCENT $temp | tr -d '"')
 | 
				
			||||||
 | 
					        [[ -z "$x" ]] && PERCENT=0 || PERCENT=$x
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        x=$(jq .PARAMETER.STEP $temp | tr -d '"')
 | 
				
			||||||
 | 
					        [[ -z "$x" ]] && STEP="unknown" || STEP="$x"
 | 
				
			||||||
 | 
					       
 | 
				
			||||||
 | 
					        x=$(jq .PARAMETER.STEP_RESULT $temp | tr -d '"')
 | 
				
			||||||
 | 
					        [[ -z "$x" ]] && STEP_RESULT="unknown" || STEP_RESULT="$x"
 | 
				
			||||||
 | 
					    
 | 
				
			||||||
 | 
					        x=$(pid_atbupdatetool)
 | 
				
			||||||
 | 
					        [[ -z "$x" ]] && PID=99999 || PID=$x
 | 
				
			||||||
 | 
					    
 | 
				
			||||||
 | 
					        x=$(last_event)
 | 
				
			||||||
 | 
					        [[ -z "$x" ]] && EVENT="unknown" || EVENT="$x"
 | 
				
			||||||
 | 
					    
 | 
				
			||||||
 | 
					    else 
 | 
				
			||||||
 | 
					        # cannot parse valid json. try original journal text file.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        x=$(last_percent_value)
 | 
				
			||||||
 | 
					        [[ -z "$x" ]] && PERCENT=0 || PERCENT=$x
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        x=$(last_step)
 | 
				
			||||||
 | 
					        [[ -z "$x" ]] && STEP="unknown" || STEP="$x"
 | 
				
			||||||
 | 
					    
 | 
				
			||||||
 | 
					        x=$(last_step_result)
 | 
				
			||||||
 | 
					        [[ -z "$x" ]] && STEP_RESULT="unknown" || STEP_RESULT="$x"
 | 
				
			||||||
 | 
					    
 | 
				
			||||||
 | 
					        x=$(pid_atbupdatetool)
 | 
				
			||||||
 | 
					        [[ -z "$x" ]] && PID=99999 || PID=$x
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        x=$(last_event)
 | 
				
			||||||
 | 
					        [[ -z "$x" ]] && EVENT="unknown" || EVENT="$x"
 | 
				
			||||||
 | 
					    fi
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    echo "PERCENT=$PERCENT"
 | 
				
			||||||
 | 
					    echo "STEP=$STEP"
 | 
				
			||||||
 | 
					    echo "STEP_RESULT=$STEP_RESULT"
 | 
				
			||||||
 | 
					    echo "PID=$PID"
 | 
				
			||||||
 | 
					    echo "EVENT=$EVENT"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    # build json to be sent to ISMAS with "U0003"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    CURRENT_DATE=$(date +"%Y-%m-%d %H:%M:%S.000%z")
 | 
				
			||||||
 | 
					    U0003Msg="{\
 | 
				
			||||||
 | 
					        \"REASON\":\"SW_UP\",\
 | 
				
			||||||
 | 
					        \"TIMESTAMP\":\"$CURRENT_DATE\",\
 | 
				
			||||||
 | 
					        \"EVENT_ID\":\"$PID\",\
 | 
				
			||||||
 | 
					        \"EVENT\":\"U0003\",\
 | 
				
			||||||
 | 
					        \"EVENTSTATE\":1,\
 | 
				
			||||||
 | 
					        \"PARAMETER\": {\
 | 
				
			||||||
 | 
					            \"PERCENT\" : $PERCENT,\
 | 
				
			||||||
 | 
					            \"RESULTCODE\" : 99,\
 | 
				
			||||||
 | 
					                    \"STEP\" : \"$1 -> monitored last step: $STEP\",\
 | 
				
			||||||
 | 
					                    \"STEP_RESULT\" : \"$1 -> monitored last step result: $STEP_RESULT\",\
 | 
				
			||||||
 | 
					            \"VERSION\" : \"\"\
 | 
				
			||||||
 | 
					        }\
 | 
				
			||||||
 | 
					    }"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    echo -e "U0003Msg=$U0003Msg"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    (echo "#M=APISM#C=CMD_EVENT#J=$U0003Msg"; sleep 5) | nc localhost 7777
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					# save journal for the last run of atbupdatetool in $OUT_FILE
 | 
				
			||||||
 | 
					echo $(journalctl -u atbupdatetool --since="$START_DATE" --until=$STOP_DATE) > $OUT_FILE
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					if [[ "$EXIT_CODE" = "exited" && "$SERVICE_RESULT" = "success" && "$EXIT_STATUS" = "0" ]]
 | 
				
			||||||
 | 
					then
 | 
				
			||||||
 | 
					    # almost normal run; at least there was no crash.	
 | 
				
			||||||
 | 
					    if cat $OUT_FILE | grep -o "U0003" | wc -l; then
 | 
				
			||||||
 | 
					        echo "$SCRIPT_NAME: Failure code U0003 already sent to ISMAS"
 | 
				
			||||||
 | 
					        exit 0
 | 
				
			||||||
 | 
					    fi
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    if cat $OUT_FILE | grep -o "U0002" | wc -l; then
 | 
				
			||||||
 | 
					        echo "$SCRIPT_NAME: Success code U0002 already sent to ISMAS"
 | 
				
			||||||
 | 
					        exit 0
 | 
				
			||||||
 | 
					    else
 | 
				
			||||||
 | 
					        sendU0003 "$SCRIPT_NAME: Success code U0002 not sent to ISMAS"
 | 
				
			||||||
 | 
					    fi
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    if cat $OUT_FILE | grep -o "U0001" | wc -l; then
 | 
				
			||||||
 | 
					        echo "$SCRIPT_NAME: Success code U0001 already sent to ISMAS"
 | 
				
			||||||
 | 
					        exit 0
 | 
				
			||||||
 | 
					    else
 | 
				
			||||||
 | 
					        sendU0003 "$SCRIPT_NAME: Success code U0001 not sent to ISMAS"
 | 
				
			||||||
 | 
					    fi
 | 
				
			||||||
 | 
					else
 | 
				
			||||||
 | 
					    # something unexpected has happened.
 | 
				
			||||||
 | 
					    sendU0003 "$SCRIPT_NAME: EXIT_CODE=$EXIT_CODE;SERVICE_RESULT=$SERVICE_RESULT;EXIT_STATUS=$EXIT_STATUS"
 | 
				
			||||||
 | 
					fi
 | 
				
			||||||
		Reference in New Issue
	
	Block a user