Index: sources/canbus/MessageInterpreter.cpp
===================================================================
diff -u -rde5d54c6f66a8276fae1cb4bbdfe7902535cfa93 -r14c541d2b780b0a244bc84860aa565cf8dd7fe4b
--- sources/canbus/MessageInterpreter.cpp	(.../MessageInterpreter.cpp)	(revision de5d54c6f66a8276fae1cb4bbdfe7902535cfa93)
+++ sources/canbus/MessageInterpreter.cpp	(.../MessageInterpreter.cpp)	(revision 14c541d2b780b0a244bc84860aa565cf8dd7fe4b)
@@ -144,9 +144,9 @@
     QString mActionIdHexString = Format::toHexString(vMessage.actionId, false, eLenMessageIDDigits);
     QString logMessage = tr("Unhandled Message ID (HD)") + '\n' +
                          QString("%1 # %2   %3")
-                         .arg(int(vMessage.can_id), 3, 16, QChar('0'))
-                         .arg(mActionIdHexString)
-                         .arg(QString(vMessage.data.toHex('.')));
+                             .arg(int(vMessage.can_id), 3, 16, QChar('0'))
+                             .arg(mActionIdHexString)
+                             .arg(QString(vMessage.data.toHex('.')));
     LOG_DEBUG(logMessage);
 }
 
@@ -187,6 +187,7 @@
     vPayload.clear();
     int length = vData.length();
 
+    LOG_EVENT(QString("%0").arg(vActionId));
     switch (vActionId) { // notice we are in transmit mode
     case Gui::GuiActionType::ID_Acknow: // len: 0, can have zero len
         break; // No data, Just registered
@@ -259,20 +260,41 @@
         LOG_EVENT(AlarmSilenceRequestData::toString(vData));
         break;
 
-    case Gui::GuiActionType::ID_CreateTreatmentReq: {
+    case Gui::GuiActionType::ID_AlarmUserAckReq:
         if ( ! length ) { logInvalidLength(vActionId); return false; }
         vPayload = Format::fromVariant(vData);
-        MAdjustTreatmentParametersRequest params;
-        params.fromVariantList(vData);
-        LOG_EVENT(params.toString());
-    } break;
+        LOG_EVENT(AlarmAcknowledgeRequestData::toString(vData));
+        break;
 
-    default: {
+    case Gui::GuiActionType::ID_StartTreatmentReq:
+        if ( ! length ) { logInvalidLength(vActionId); return false; }
+        vPayload = Format::fromVariant(vData);
+        LOG_EVENT(StartTreatmentRequestData::toString(vData));
+        break;
+
+    case Gui::GuiActionType::ID_ConfirmTreatmentReq:
+        if ( ! length ) { logInvalidLength(vActionId); return false; }
+        vPayload = Format::fromVariant(vData);
+        LOG_EVENT(ConfirmTreatmentRequestData::toString(vData));
+        break;
+
+    case Gui::GuiActionType::ID_EndTreatmentReq:
+        if ( length != 0 ) { logInvalidLength(vActionId); return false; }
+        vPayload = Format::fromVariant(vData);
+        LOG_EVENT(EndTreatmentRequestData::toString(vData));
+        break;
+
+    case Gui::GuiActionType::ID_CreateTreatmentReq:
+        if ( ! length ) { logInvalidLength(vActionId); return false; }
+        vPayload = Format::fromVariant(vData);
+        LOG_EVENT(AdjustTreatmentParametersRequestData::toString(vData));
+        break;
+
+    default:
         QString mActionIdHexString = Format::toHexString(vActionId);
         LOG_DEBUG(mSenderID + tr("Unknown transmit Message with ID '%1'").arg(mActionIdHexString));
         ok = false;
-    } break;
-
+        break;
     }
     return ok;
 }
@@ -339,6 +361,7 @@
     case Gui::GuiActionType::ID_TreatmentRanges                 : ok = notify<Model::MTreatmentRanges             >(vMessage, vData, Gui::GuiActionType::ID_TreatmentRanges        ); break;
     case Gui::GuiActionType::ID_PressureOcclusion               : ok = notify<Model::MPressureOcclusion           >(vMessage, vData, Gui::GuiActionType::ID_PressureOcclusion      ); break;
     case Gui::GuiActionType::ID_TreatmentStates                 : ok = notify<Model::MTreatmentStates             >(vMessage, vData, Gui::GuiActionType::ID_TreatmentStates        ); break;
+    case Gui::GuiActionType::ID_PrimingData                     : ok = notify<Model::MPrimingData                 >(vMessage, vData, Gui::GuiActionType::ID_PrimingData            ); break;
     case Gui::GuiActionType::ID_Saline                          : ok = notify<Model::MTreatmentSaline             >(vMessage, vData, Gui::GuiActionType::ID_Saline                 ); break;
 
     // ----- Events
@@ -351,6 +374,7 @@
     case Gui::GuiActionType::ID_AlarmStatus                     : ok = alarmStatus                  (vMessage, vData); break; // TODO : implement notify<>()
     case Gui::GuiActionType::ID_AlarmTriggered                  : ok = alarmTriggered               (vMessage, vData); break; // TODO : implement notify<>()
     case Gui::GuiActionType::ID_AlarmCleared                    : ok = alarmCleared                 (vMessage, vData); break; // TODO : implement notify<>()
+    case Gui::GuiActionType::ID_CreateTreatmentRsp              : ok = notify<Model::MTreatmentParametersResponse >(vMessage, vData, Gui::GuiActionType::ID_CreateTreatmentRsp     ); break;
 
     // Adjustment Response Messages
     case Gui::GuiActionType::ID_AdjustDurationRsp               : ok = notify<Model::MAdjustDurationResponse                >(vMessage, vData, Gui::GuiActionType::ID_AdjustDurationRsp             ); break;
@@ -363,11 +387,12 @@
     case Gui::GuiActionType::ID_AdjustUltrafiltrationEditRsp    : ok = adjustUltrafiltrationEdit    (vMessage, vData); break; // TODO : implement notify<>()
     case Gui::GuiActionType::ID_AdjustUltrafiltrationConfirmRsp : ok = adjustUltrafiltrationConfirm (vMessage, vData); break; // TODO : implement notify<>()
 
-    case Gui::GuiActionType::ID_CreateTreatmentRsp              : ok = createTreatmentRespData      (vMessage, vData); break;
-    // unhandles messages: these will only be logged as received message
+    case Gui::GuiActionType::ID_StartTreatmentRsp               : ok = notify<Model::MStartTreatmentResponse>      (vMessage, vData, Gui::GuiActionType::ID_StartTreatmentRsp      ); break;
+    case Gui::GuiActionType::ID_EndTreatmentRsp                 : ok = notify<Model::MEndTreatmentResponse>        (vMessage, vData, Gui::GuiActionType::ID_EndTreatmentRsp        ); break;
 
+    // unhandles messages: these will only be logged as received message
     // there has nothing been defined for these messages.
-    default                                                     :      printUnhandled                   (vMessage       ); break;
+    default                                                 :      printUnhandled                   (vMessage       ); break;
     }
 
     return ok;
@@ -573,24 +598,3 @@
 
     return ok;
 }
-
-/*!
- * \brief   MessageInterpreter::createTreatmentRespData
- *  Checks the validity of the create treatment response data.
- * \param   vMessage - The message
- * \param   vData    - the output data
- * \return  true if ok, false otherwise
- */
-bool MessageInterpreter::createTreatmentRespData(const Message &vMessage, QVariantList &vData) {
-    bool ok = false;
-    if ( ! isValidMessage(vMessage, Gui::GuiActionType::ID_CreateTreatmentRsp) ) return ok;
-
-    Model::MTreatmentParametersResponse mData;
-    ok = mData.fromByteArray(vMessage.data);
-    LOG_DATUM(mData.toString());
-
-    mData.toVariantList(vData);
-    emit didActionReceive(mData.data());
-
-    return ok;
-}