mirror of
https://github.com/datarhei/core.git
synced 2025-10-06 08:27:08 +08:00
Fix missing process data if process has been deleted meanwhile
This commit is contained in:
@@ -992,23 +992,32 @@ func (h *RestreamHandler) getProcess(id app.ProcessID, filter filter) (api.Proce
|
|||||||
}
|
}
|
||||||
|
|
||||||
if filter.state {
|
if filter.state {
|
||||||
if state, err := h.restream.GetProcessState(id); err == nil {
|
state, err := h.restream.GetProcessState(id)
|
||||||
|
if err != nil {
|
||||||
|
return api.Process{}, err
|
||||||
|
}
|
||||||
|
|
||||||
info.State = &api.ProcessState{}
|
info.State = &api.ProcessState{}
|
||||||
info.State.Unmarshal(state)
|
info.State.Unmarshal(state)
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
if filter.report {
|
if filter.report {
|
||||||
if log, err := h.restream.GetProcessLog(id); err == nil {
|
log, err := h.restream.GetProcessLog(id)
|
||||||
|
if err != nil {
|
||||||
|
return api.Process{}, err
|
||||||
|
}
|
||||||
|
|
||||||
info.Report = &api.ProcessReport{}
|
info.Report = &api.ProcessReport{}
|
||||||
info.Report.Unmarshal(log)
|
info.Report.Unmarshal(log)
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
if filter.metadata {
|
if filter.metadata {
|
||||||
if data, err := h.restream.GetProcessMetadata(id, ""); err == nil {
|
data, err := h.restream.GetProcessMetadata(id, "")
|
||||||
info.Metadata = api.NewMetadata(data)
|
if err != nil {
|
||||||
|
return api.Process{}, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
info.Metadata = api.NewMetadata(data)
|
||||||
}
|
}
|
||||||
|
|
||||||
return info, nil
|
return info, nil
|
Reference in New Issue
Block a user