tyler.durden
/
icinga2
mirror of https://github.com/Icinga/icinga2.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Set CheckResult to execeution

This commit is contained in:
Mattia Codato 2020-07-10 16:56:35 +02:00
parent 15159b1632
commit fa4aebbfd2
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
lib/icinga/clusterevents.cpp
View File

@ -1002,6 +1002,14 @@ Value ClusterEvents::ExecutedCommandAPIHandler(const MessageOrigin::Ptr& origin,
return Empty; return Empty;
} }
if (!params->Contains("check_result")) {
Log(LogNotice, "ClusterEvents")
<< "Discarding 'update executions API handler' message for checkable '" << checkable->GetName()
<< "' from '" << origin->FromClient->GetIdentity() << "': No check result available.";
return Empty;
}
CheckResult::Ptr cr = params->Get("check_result");
Dictionary::Ptr execution = executions->Get(uuid); Dictionary::Ptr execution = executions->Get(uuid);
if (!execution) { if (!execution) {
Log(LogNotice, "ClusterEvents") Log(LogNotice, "ClusterEvents")
@ -1011,8 +1019,7 @@ Value ClusterEvents::ExecutedCommandAPIHandler(const MessageOrigin::Ptr& origin,
} }
execution->Set("pending", false); execution->Set("pending", false);
execution->Set("check_result", cr);
/* TODO update execution with the command result */
/* Broadcast the update */ /* Broadcast the update */
Dictionary::Ptr executionsToBroadcast = new Dictionary(); Dictionary::Ptr executionsToBroadcast = new Dictionary();
@ -1030,7 +1037,7 @@ Value ClusterEvents::ExecutedCommandAPIHandler(const MessageOrigin::Ptr& origin,
listener->RelayMessage(origin, checkable, updateMessage, true); listener->RelayMessage(origin, checkable, updateMessage, true);
return "Not implemented"; return Empty;
} }
Value ClusterEvents::UpdateExecutionsAPIHandler(const MessageOrigin::Ptr& origin, const Dictionary::Ptr& params) Value ClusterEvents::UpdateExecutionsAPIHandler(const MessageOrigin::Ptr& origin, const Dictionary::Ptr& params)