code: /*
   * Copyright (c) 2022 Airbyte, Inc., all rights reserved.
   */
  
  package io.airbyte.workers.temporal.scheduling;
  
  import io.temporal.testing.WorkflowReplayer;
  import java.io.File;
  import java.net.URL;
  import org.junit.jupiter.api.Test;
  
  // TODO: Auto generation of the input and more scenario coverage
  @SuppressWarnings("PMD.JUnitTestsShouldIncludeAssert")
  class WorkflowReplayingTest {
  
    @Test
    void replaySimpleSuccessfulWorkflow() throws Exception {
      // This test ensures that a new version of the workflow doesn't break an in-progress execution
      // This JSON file is exported from Temporal directly (e.g.
      // `http://${temporal-ui}/namespaces/default/workflows/connection_manager_-${uuid}/${uuid}/history`)
      // and export
      final URL historyPath = getClass().getClassLoader().getResource("workflowHistory.json");
  
      final File historyFile = new File(historyPath.toURI());
  
      WorkflowReplayer.replayWorkflowExecution(historyFile, ConnectionManagerWorkflowImpl.class);
    }
  
  }
  