Method HandleRecording

Source/URLab/Private/Bridge/RpcDispatcher.cpp:3012–3082

// =============================================================================

TSharedPtr<FJsonObject> FURLabRpcDispatcher::HandleRecording(const FString& Op, const TSharedPtr<FJsonObject>& Req)
{
	AAMjManager* Mgr = OwnerMgr.Get();
	if (!Mgr)
		return MakeError(TEXT("not_ready"), TEXT("Manager missing"));
	// Use the game-thread-cached pointer; TActorIterator from this worker
	// thread would assert IsInGameThread() and crash.
	AMjReplayManager* RM = CachedReplayManager.Get();
	if (!RM)
		return MakeError(TEXT("not_ready"), TEXT("AMjReplayManager not present in scene"));

	if (Op.Equals(TEXT("recording_start")))
	{
		if (RM->bIsRecording)
			return MakeError(TEXT("recording_already_active"), TEXT("Recording already active"));
		double MaxDur = 0.0;
		if (Req->TryGetNumberField(TEXT("max_duration_s"), MaxDur))
			RM->MaxRecordDuration = (float)MaxDur;
		else
			RM->MaxRecordDuration = FLT_MAX;
		RM->StartRecording();
		TSharedPtr<FJsonObject> Reply = MakeShared<FJsonObject>();
		Reply->SetStringField(TEXT("op"), TEXT("recording_start_ok"));
		Reply->SetStringField(TEXT("name"), AMjReplayManager::LiveSessionName);
		Reply->SetNumberField(TEXT("max_duration_s"), RM->MaxRecordDuration);
		return Reply;
	}
	if (Op.Equals(TEXT("recording_stop")))
	{
		if (!RM->bIsRecording)
			return MakeError(TEXT("recording_not_active"), TEXT("Recording is not active"));
		RM->StopRecording();
		TSharedPtr<FJsonObject> Reply = MakeShared<FJsonObject>();
		Reply->SetStringField(TEXT("op"), TEXT("recording_stop_ok"));
		Reply->SetStringField(TEXT("name"), AMjReplayManager::LiveSessionName);
		// Populate the summary fields the Python client maps to
		// RecordingSummary. Recording has been stopped (StopRecording
		// above set bIsRecording=false) so the OnPostStep hook isn't
		// mutating Frames in parallel.
		Reply->SetNumberField(TEXT("frame_count"), static_cast<double>(RM->GetLiveFrameCount()));
		Reply->SetNumberField(TEXT("sim_duration_s"), RM->GetLiveSimDurationS());
		return Reply;
	}
	if (Op.Equals(TEXT("recording_save")))
	{
		FString Path;
		Req->TryGetStringField(TEXT("path"), Path);
		FString FileName = Path.IsEmpty() ? TEXT("recording.json") : FPaths::GetCleanFilename(Path);
		if (Path.IsEmpty())
			Path = FileName;
		bool bOk = RM->SaveRecordingToFile(FileName);
		// ResolveReplayPath now matches the manager's
		// ProjectSavedDir/URLab/Replays/ output dir, so the absolute_path
		// returned to the client points at the file the manager actually wrote.
		FString Abs = ResolveReplayPath(Path);
		TSharedPtr<FJsonObject> Reply = MakeShared<FJsonObject>();
		Reply->SetStringField(TEXT("op"), bOk ? TEXT("recording_save_ok") : TEXT("error"));
		Reply->SetStringField(TEXT("absolute_path"), Abs);