Sync up with upstream ES main: apply project ID resolver to ScriptService. (#357)

* Sync up with upstream ES main: apply null project ID resolver as applied in logstash-bridge ScriptServiceBridge.

Author: mashhurs

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

@@ -17,6 +17,7 @@
 import co.elastic.logstash.filters.elasticintegration.resolver.ResolverCache;
 import co.elastic.logstash.filters.elasticintegration.util.Exceptions;
 import co.elastic.logstash.filters.elasticintegration.util.PluginContext;
+import co.elastic.logstash.filters.elasticintegration.util.PluginProjectResolver;
 import com.google.common.util.concurrent.Service;
 import com.google.common.util.concurrent.ServiceManager;
 import org.elasticsearch.client.RestClient;
@@ -33,7 +34,6 @@
 import org.elasticsearch.painless.PainlessPlugin;
 import org.elasticsearch.painless.PainlessScriptEngine;
 import org.elasticsearch.painless.spi.PainlessExtension;
-import org.elasticsearch.painless.spi.Whitelist;
 import org.elasticsearch.plugins.ExtensiblePlugin;
 import org.elasticsearch.plugins.IngestPlugin;
 import org.elasticsearch.script.IngestConditionalScript;
@@ -318,7 +318,13 @@ private static ScriptService initScriptService(final Settings settings, final Th
         Map<String, ScriptEngine> engines = new HashMap<>();
         engines.put(PainlessScriptEngine.NAME, getPainlessScriptEngine(settings));
         engines.put(MustacheScriptEngine.NAME, new MustacheScriptEngine(settings));
-        return new ScriptService(settings, engines, ScriptModule.CORE_CONTEXTS, threadPool::absoluteTimeInMillis);
+
+        return new ScriptService(
+                settings,
+                engines,
+                ScriptModule.CORE_CONTEXTS,
+                threadPool::absoluteTimeInMillis,
+                new PluginProjectResolver());
     }
 
     /**

src/main/java/co/elastic/logstash/filters/elasticintegration/util/PluginProjectResolver.java

@@ -0,0 +1,21 @@
+package co.elastic.logstash.filters.elasticintegration.util;
+
+import org.elasticsearch.cluster.metadata.ProjectId;
+import org.elasticsearch.cluster.project.ProjectResolver;
+import org.elasticsearch.core.CheckedRunnable;
+
+public class PluginProjectResolver implements ProjectResolver {
+    @Override
+    public ProjectId getProjectId() {
+        return null;
+    }
+
+    @Override
+    public <E extends Exception> void executeOnProject(ProjectId projectId, CheckedRunnable<E> checkedRunnable) throws E {
+        if (projectId.equals(ProjectId.DEFAULT)) {
+            checkedRunnable.run();
+        } else {
+            throw new IllegalArgumentException("Cannot execute on a project other than [" + ProjectId.DEFAULT + "]");
+        }
+    }
+}