vdr-plugin-restfulapi/recordingpreview.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
68
69
70
71
72
73
74
75
#include "recordingpreview.h"

#include "recordinganalysis.h"
#include "recordingmutation.h"
#include "recordingpreflight.h"
#include "tools.h"

#include <cxxtools/jsonserializer.h>

void RecordingTrashPreviewResponder::reply(
  std::ostream& out,
  cxxtools::http::Request& request,
  cxxtools::http::Reply& reply)
{
  QueryHandler::addHeader(reply);

  if (request.method() == "OPTIONS") {
    reply.addHeader("Allow", "POST");
    reply.httpReturn(200, "OK");
    return;
  }

  if (request.method() != "POST") {
    reply.httpReturn(501, "Only POST method is supported by the /recordings/trash/preview service.");
    return;
  }

  QueryHandler query("/recordings/trash/preview", request);
  const std::string recordingFile = query.getBodyAsString("file");

  if (recordingFile.empty()) {
    reply.httpReturn(400, "Recording file is missing.");
    return;
  }

  RecordingMutationPolicy policy;
  policy.allowRecordingHandlerStop = query.getBodyAsBool("allow_recording_handler_stop");
  policy.allowReplayStop = query.getBodyAsBool("allow_replay_stop");
  policy.allowLocalTimerStop = query.getBodyAsBool("allow_local_timer_stop");
  policy.allowRemoteTimerStop = query.getBodyAsBool("allow_remote_timer_stop");

  VdrRecordingLookup recordingLookup;
  VdrRecordingReplayLookup replayLookup;
  VdrRecordingHandlerLookup recordingHandlerLookup;
  VdrRecordingLocalTimerLookup localTimerLookup;
  VdrRecordingRemoteTimerLookup remoteTimerLookup;
  VdrRecordingSearchTimerLookup searchTimerLookup;

  RecordingTrashAnalyzer analyzer(
    recordingLookup,
    replayLookup,
    recordingHandlerLookup,
    localTimerLookup,
    remoteTimerLookup,
    searchTimerLookup);

  RecordingMutationPlanner planner;
  RecordingTrashPreflightService preflightService(analyzer, planner);
  const RecordingTrashPreflightResult result =
    preflightService.preview(recordingFile, policy);

  reply.addHeader("Content-Type", "application/json; charset=utf-8");

  cxxtools::JsonSerializer serializer(out);
  serializer.serialize(result.executable, "executable");
  serializer.serialize(result.recordingFile, "recording_file");
  serializer.serialize(result.constraints, "constraints");
  serializer.serialize(result.blockers, "blockers");
  serializer.serialize(result.warnings, "warnings");
  serializer.serialize(result.steps, "steps");
  serializer.serialize(result.revision.recordingFile, "revision_recording_file");
  serializer.serialize(result.revision.recordingsState, "revision_recordings_state");
  serializer.serialize(result.revision.timersState, "revision_timers_state");
  serializer.finish();
}