Sync up with ES main on PipelineConfiguration class changes. (#190)

* Sync up with ES main that PipelineConfiguration class getConfigAsMap() method renamed to getConfig().

* Request modifiable donfig when creating a pipeline.

Author: mashhurs

src/main/java/co/elastic/logstash/filters/elasticintegration/IngestPipelineFactory.java

@@ -46,7 +46,7 @@ public IngestPipelineFactory withProcessors(final Map<String, Processor.Factory>
 
     public Optional<IngestPipeline> create(final PipelineConfiguration pipelineConfiguration) {
         try {
-            final Pipeline pipeline = Pipeline.create(pipelineConfiguration.getId(), pipelineConfiguration.getConfigAsMap(), processorFactories, scriptService);
+            final Pipeline pipeline = Pipeline.create(pipelineConfiguration.getId(), pipelineConfiguration.getConfig(false), processorFactories, scriptService);
             final IngestPipeline ingestPipeline = new IngestPipeline(pipelineConfiguration, pipeline);
             LOGGER.debug(() -> String.format("successfully created ingest pipeline `%s` from pipeline configuration", pipelineConfiguration.getId()));
             return Optional.of(ingestPipeline);

src/test/java/co/elastic/logstash/filters/elasticintegration/ElasticsearchPipelineConfigurationResolverTest.java

@@ -59,7 +59,7 @@ void testLoadConfigurationExists() throws Exception {
             assertThat(resolvedPipelineConfiguration, isPresent());
             resolvedPipelineConfiguration.ifPresent(pipelineConfiguration -> {
                 assertThat(pipelineConfiguration.getId(), is(equalTo("my-pipeline-id")));
-                final Map<String, Object> configAsMap = pipelineConfiguration.getConfigAsMap();
+                final Map<String, Object> configAsMap = pipelineConfiguration.getConfig();
                 assertThat(configAsMap, is(equalTo(EXPECTED_MY_PIPELINE_ID_CONFIG_MAP)));
             });
         });
@@ -77,7 +77,7 @@ void testLoadConfigurationPipelineWithSpecialCharacters() throws Exception {
             assertThat(resolvedPipelineConfiguration, isPresent());
             resolvedPipelineConfiguration.ifPresent(pipelineConfiguration -> {
                 assertThat(pipelineConfiguration.getId(), is(equalTo("special char pipeline")));
-                final Map<String, Object> configAsMap = pipelineConfiguration.getConfigAsMap();
+                final Map<String, Object> configAsMap = pipelineConfiguration.getConfig();
                 assertThat(configAsMap, is(equalTo(EXPECTED_MY_PIPELINE_ID_CONFIG_MAP)));
             });
         });

src/test/java/co/elastic/logstash/filters/elasticintegration/PipelineConfigurationFactoryTest.java

@@ -44,7 +44,7 @@ public void testParseNamedObjectWithOnePipeline() throws Exception {
         final PipelineConfiguration loaded = PipelineConfigurationFactory.getInstance().parseNamedObject(json);
         assertThat(loaded, is(notNullValue()));
         assertThat(loaded.getId(), is(equalTo("pipeline-id-one")));
-        assertThat(loaded.getConfigAsMap(), is(equalTo(EXPECTED_PIPELINE_ID_ONE_CONFIG_MAP)));
+        assertThat(loaded.getConfig(), is(equalTo(EXPECTED_PIPELINE_ID_ONE_CONFIG_MAP)));
     }
 
     @Test
@@ -74,7 +74,7 @@ public void testParseNamedObjectsWithOnePipeline() throws Exception {
 
         assertThat(loaded.get(0), is(notNullValue()));
         assertThat(loaded.get(0).getId(), is(equalTo("pipeline-id-one")));
-        assertThat(loaded.get(0).getConfigAsMap(), is(equalTo(EXPECTED_PIPELINE_ID_ONE_CONFIG_MAP)));
+        assertThat(loaded.get(0).getConfig(), is(equalTo(EXPECTED_PIPELINE_ID_ONE_CONFIG_MAP)));
     }
 
     @Test
@@ -86,12 +86,12 @@ public void testParseNamedObjectWithTwoPipelines() throws Exception {
 
         assertThat(loaded.get(0), is(notNullValue()));
         assertThat(loaded.get(0).getId(), is(equalTo("pipeline-id-one")));
-        assertThat(loaded.get(0).getConfigAsMap(), is(equalTo(EXPECTED_PIPELINE_ID_ONE_CONFIG_MAP)));
+        assertThat(loaded.get(0).getConfig(), is(equalTo(EXPECTED_PIPELINE_ID_ONE_CONFIG_MAP)));
 
 
         assertThat(loaded.get(1), is(notNullValue()));
         assertThat(loaded.get(1).getId(), is(equalTo("pipeline-id-two")));
-        assertThat(loaded.get(1).getConfigAsMap(), is(equalTo(EXPECTED_PIPELINE_ID_TWO_CONFIG_MAP)));
+        assertThat(loaded.get(1).getConfig(), is(equalTo(EXPECTED_PIPELINE_ID_TWO_CONFIG_MAP)));
     }
 
     @Test
@@ -109,7 +109,7 @@ public void testParseConfigOnly() throws Exception {
         final PipelineConfiguration loaded = PipelineConfigurationFactory.getInstance().parseConfigOnly("bananas" , json);
         assertThat(loaded, is(notNullValue()));
         assertThat(loaded.getId(), is(equalTo("bananas")));
-        assertThat(loaded.getConfigAsMap(), is(equalTo(EXPECTED_PIPELINE_ID_ONE_CONFIG_MAP)));
+        assertThat(loaded.getConfig(), is(equalTo(EXPECTED_PIPELINE_ID_ONE_CONFIG_MAP)));
     }
 
     String elasticsearchApiFormattedJson(final String name) throws IOException {