vdr-plugin-restfulapi/recordingexecution.cpp at master · yavdr/vdr-plugin-restfulapi · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
#include "recordingexecution.h"

namespace {

bool sameRevision(
  const RecordingMutationRevision& left,
  const RecordingMutationRevision& right)
{
  return left.recordingFile == right.recordingFile
    && left.recordingsState == right.recordingsState
    && left.timersState == right.timersState;
}

}

RecordingTrashExecutionGate::RecordingTrashExecutionGate(
  const RecordingTrashAnalyzer& analyzer,
  const RecordingMutationPlanner& planner)
  : analyzer(analyzer),
    planner(planner)
{
}

RecordingTrashExecutionGateResult RecordingTrashExecutionGate::validate(
  const std::string& recordingFile,
  const RecordingMutationRevision& expectedRevision,
  const RecordingMutationPolicy& policy) const
{
  RecordingTrashExecutionGateResult result;
  result.recordingFile = recordingFile;
  result.expectedRevision = expectedRevision;

  const RecordingMutationAnalysis analysis = analyzer.analyze(recordingFile);
  const RecordingMutationPlan plan = planner.buildTrashPlan(analysis, policy);

  result.currentRevision = analysis.revision;
  result.blockers = plan.blockers;
  result.warnings = plan.warnings;

  if (!sameRevision(expectedRevision, analysis.revision)) {
    result.status = RecordingTrashExecutionGateStatus::Conflict;
    return result;
  }

  if (!plan.executable) {
    result.status = RecordingTrashExecutionGateStatus::Blocked;
    return result;
  }

  result.status = RecordingTrashExecutionGateStatus::Ready;
  return result;
}

const char* RecordingTrashExecutionGateStatusName(
  RecordingTrashExecutionGateStatus status)
{
  switch (status) {
    case RecordingTrashExecutionGateStatus::Ready:
      return "ready";
    case RecordingTrashExecutionGateStatus::Conflict:
      return "conflict";
    case RecordingTrashExecutionGateStatus::Blocked:
      return "blocked";
  }

  return "blocked";
}