-
Notifications
You must be signed in to change notification settings - Fork 11
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
create and update of dataset flow for input and output flow directions
- Loading branch information
1 parent
87d72a8
commit 60e33d6
Showing
15 changed files
with
946 additions
and
1 deletion.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
14 changes: 14 additions & 0 deletions
14
src/main/java/io/github/jpmorganchase/fusion/model/Flow.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,14 @@ | ||
| package io.github.jpmorganchase.fusion.model; | ||
|
|
||
| import lombok.Builder; | ||
| import lombok.EqualsAndHashCode; | ||
| import lombok.ToString; | ||
| import lombok.Value; | ||
|
|
||
| @Builder | ||
| @Value | ||
| @EqualsAndHashCode() | ||
| @ToString() | ||
| public class Flow { | ||
| String flowDirection; | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
175 changes: 175 additions & 0 deletions
175
...est/java/io/github/jpmorganchase/fusion/parsing/GsonAPIResponseParserDatasetFlowTest.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,175 @@ | ||
| package io.github.jpmorganchase.fusion.parsing; | ||
|
|
||
| import static io.github.jpmorganchase.fusion.test.TestUtils.listOf; | ||
| import static org.hamcrest.MatcherAssert.assertThat; | ||
| import static org.hamcrest.Matchers.equalTo; | ||
| import static org.hamcrest.Matchers.is; | ||
|
|
||
| import io.github.jpmorganchase.fusion.api.APIManager; | ||
| import io.github.jpmorganchase.fusion.api.context.APIContext; | ||
| import io.github.jpmorganchase.fusion.model.Application; | ||
| import io.github.jpmorganchase.fusion.model.Dataset; | ||
| import java.net.URL; | ||
| import java.nio.charset.StandardCharsets; | ||
| import java.nio.file.Files; | ||
| import java.nio.file.Path; | ||
| import java.nio.file.Paths; | ||
| import java.util.Map; | ||
| import org.junit.jupiter.api.Test; | ||
| import org.mockito.Mockito; | ||
|
|
||
| public class GsonAPIResponseParserDatasetFlowTest { | ||
|
|
||
| private static final String singleDatasetInputFlowJson = | ||
| loadTestResource("single-dataset-input-flow-response.json"); | ||
| private static final String singleDatasetOutputFlowJson = | ||
| loadTestResource("single-dataset-output-flow-response.json"); | ||
| private static final String multipleDatasetJson = loadTestResource("multiple-dataset-flow-response.json"); | ||
|
|
||
| private final Dataset testDatasetInputFlow1 = Dataset.builder() | ||
| .identifier("SIF0001") | ||
| .description("Sample input flow description 1") | ||
| .linkedEntity("SIF0001/") | ||
| .frequency("Daily") | ||
| .apiManager(apiContext.getApiManager()) | ||
| .rootUrl(apiContext.getRootUrl()) | ||
| .catalogIdentifier(apiContext.getDefaultCatalog()) | ||
| .title("Sample Input Flow 1 | North America") | ||
| .varArg("category", listOf("Category 1")) | ||
| .varArg("createdDate", "2022-02-05") | ||
| .varArg("coverageStartDate", "2022-02-05") | ||
| .varArg("coverageEndDate", "2023-03-08") | ||
| .varArg("isThirdPartyData", Boolean.FALSE) | ||
| .varArg("isInternalOnlyDataset", Boolean.FALSE) | ||
| .varArg("language", "English") | ||
| .varArg("maintainer", "Maintainer 1") | ||
| .varArg("modifiedDate", "2023-03-08") | ||
| .varArg("publisher", "Publisher 1") | ||
| .varArg("region", listOf("North America")) | ||
| .varArg("source", listOf("Source System 1")) | ||
| .varArg("subCategory", listOf("Subcategory 1")) | ||
| .varArg("tag", listOf("Tag1")) | ||
| .varArg("isRestricted", Boolean.FALSE) | ||
| .varArg("isRawData", Boolean.FALSE) | ||
| .varArg("hasSample", Boolean.FALSE) | ||
| .applicationId(Application.builder().sealId("12345").build()) | ||
| .inputFlow( | ||
| Application.builder().sealId("123456").build(), | ||
| new Application[] {Application.builder().sealId("456789").build()}) | ||
| .build(); | ||
|
|
||
| private final Dataset testDatasetOutputFlow1 = Dataset.builder() | ||
| .identifier("SOF0001") | ||
| .description("Sample output flow description 1") | ||
| .linkedEntity("SOF0001/") | ||
| .frequency("Daily") | ||
| .apiManager(apiContext.getApiManager()) | ||
| .rootUrl(apiContext.getRootUrl()) | ||
| .catalogIdentifier(apiContext.getDefaultCatalog()) | ||
| .title("Sample Output Flow 1 | North America") | ||
| .varArg("category", listOf("Category 1")) | ||
| .varArg("createdDate", "2022-02-05") | ||
| .varArg("coverageStartDate", "2022-02-05") | ||
| .varArg("coverageEndDate", "2023-03-08") | ||
| .varArg("isThirdPartyData", Boolean.FALSE) | ||
| .varArg("isInternalOnlyDataset", Boolean.FALSE) | ||
| .varArg("language", "English") | ||
| .varArg("maintainer", "Maintainer 1") | ||
| .varArg("modifiedDate", "2023-03-08") | ||
| .varArg("publisher", "Publisher 1") | ||
| .varArg("region", listOf("North America")) | ||
| .varArg("source", listOf("Source System 1")) | ||
| .varArg("subCategory", listOf("Subcategory 1")) | ||
| .varArg("tag", listOf("Tag1")) | ||
| .varArg("isRestricted", Boolean.FALSE) | ||
| .varArg("isRawData", Boolean.FALSE) | ||
| .varArg("hasSample", Boolean.FALSE) | ||
| .applicationId(Application.builder().sealId("12345").build()) | ||
| .outputFlow( | ||
| Application.builder().sealId("123456").build(), | ||
| new Application[] {Application.builder().sealId("456789").build()}) | ||
| .build(); | ||
|
|
||
| private final Dataset testDatasetInputFlow2 = Dataset.builder() | ||
| .identifier("SIF0002") | ||
| .description("Sample input flow description 2") | ||
| .linkedEntity("SIF0002/") | ||
| .frequency("Daily") | ||
| .title("Sample Input Flow 2 | North America") | ||
| .apiManager(apiContext.getApiManager()) | ||
| .rootUrl(apiContext.getRootUrl()) | ||
| .catalogIdentifier(apiContext.getDefaultCatalog()) | ||
| .varArg("category", listOf("Category 2")) | ||
| .varArg("createdDate", "2022-02-06") | ||
| .varArg("coverageStartDate", "2022-02-06") | ||
| .varArg("coverageEndDate", "2023-03-09") | ||
| .varArg("isThirdPartyData", Boolean.FALSE) | ||
| .varArg("isInternalOnlyDataset", Boolean.FALSE) | ||
| .varArg("language", "English") | ||
| .varArg("maintainer", "Maintainer 2") | ||
| .varArg("modifiedDate", "2023-03-09") | ||
| .varArg("publisher", "Publisher 2") | ||
| .varArg("region", listOf("North America")) | ||
| .varArg("source", listOf("Source System 2")) | ||
| .varArg("subCategory", listOf("Subcategory 2")) | ||
| .varArg("tag", listOf("Tag2")) | ||
| .varArg("isRestricted", Boolean.FALSE) | ||
| .varArg("isRawData", Boolean.FALSE) | ||
| .varArg("hasSample", Boolean.FALSE) | ||
| .applicationId(Application.builder().sealId("12345").build()) | ||
| .inputFlow( | ||
| Application.builder().sealId("123456").build(), | ||
| new Application[] {Application.builder().sealId("456789").build()}) | ||
| .build(); | ||
|
|
||
| private static final APIContext apiContext = APIContext.builder() | ||
| .apiManager(Mockito.mock(APIManager.class)) | ||
| .rootUrl("http://foobar/api/v1/") | ||
| .defaultCatalog("foobar") | ||
| .build(); | ||
|
|
||
| private static final APIResponseParser responseParser = new GsonAPIResponseParser(apiContext); | ||
|
|
||
| @Test | ||
| public void singleDatasetInputFlowInResourcesParsesCorrectly() { | ||
| Map<String, Dataset> datasetMap = responseParser.parseDatasetResponse(singleDatasetInputFlowJson); | ||
| assertThat(datasetMap.size(), is(1)); | ||
|
|
||
| Dataset testDatasetResponse = datasetMap.get("SIF0001"); | ||
| assertThat(testDatasetResponse, is(equalTo(testDatasetInputFlow1))); | ||
| } | ||
|
|
||
| @Test | ||
| public void singleDatasetOutputFlowInResourcesParsesCorrectly() { | ||
| Map<String, Dataset> datasetMap = responseParser.parseDatasetResponse(singleDatasetOutputFlowJson); | ||
| assertThat(datasetMap.size(), is(1)); | ||
|
|
||
| Dataset testDatasetResponse = datasetMap.get("SOF0001"); | ||
| assertThat(testDatasetResponse, is(equalTo(testDatasetOutputFlow1))); | ||
| } | ||
|
|
||
| @Test | ||
| public void multipleCatalogsInResourcesParseCorrectly() { | ||
| Map<String, Dataset> datasetMap = responseParser.parseDatasetResponse(multipleDatasetJson); | ||
| assertThat(datasetMap.size(), is(3)); | ||
|
|
||
| Dataset testDatasetResponse = datasetMap.get("SIF0001"); | ||
| assertThat(testDatasetResponse, is(equalTo(testDatasetInputFlow1))); | ||
|
|
||
| Dataset testDatasetResponse2 = datasetMap.get("SOF0001"); | ||
| assertThat(testDatasetResponse2, is(equalTo(testDatasetOutputFlow1))); | ||
|
|
||
| Dataset testDatasetResponse3 = datasetMap.get("SIF0002"); | ||
| assertThat(testDatasetResponse3, is(equalTo(testDatasetInputFlow2))); | ||
| } | ||
|
|
||
| private static String loadTestResource(String resourceName) { | ||
| URL url = GsonAPIResponseParser.class.getResource(resourceName); | ||
| try { | ||
| Path path = Paths.get(url.toURI()); | ||
| return new String(Files.readAllBytes(path), StandardCharsets.UTF_8); | ||
| } catch (Exception e) { | ||
| throw new RuntimeException("Failed to load test data", e); | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.