start work on the groovy plugin

Author: kimchy

.idea/dictionaries/kimchy.xml

@@ -18,6 +18,12 @@ explodedDistLibDir = new File(explodedDistDir, 'lib')
 explodedDistBinDir = new File(explodedDistDir, 'bin')
 explodedDistConfigDir = new File(explodedDistDir, 'config')
 
+//mavenRepoUrl = "file://localhost/" + projectDir.absolutePath + "/build/maven/repository"
+//mavenSnapshotRepoUrl = "file://localhost/" + projectDir.absolutePath + "/build/maven/snapshotRepository"
+mavenRepoUrl = "http://oss.sonatype.org/service/local/staging/deploy/maven2/"
+mavenSnapshotRepoUrl = "http://oss.sonatype.org/content/repositories/snapshots"
+mavenRepoUser = "kimchy"
+mavenRepoPass = System.getenv("REPO_PASS")
 
 allprojects {
     group = 'org.elasticsearch'

.idea/modules.xml

@@ -97,15 +97,12 @@ artifacts {
 
 uploadArchives {
     repositories.mavenDeployer {
-//        repository(url: "file://localhost/" + rootProject.projectDir.absolutePath + "/build/maven/repository")
-//        snapshotRepository(url: "file://localhost/" + rootProject.projectDir.absolutePath + "/build/maven/snapshotRepository")
-
         configuration = configurations.deployerJars
-        repository(url: "http://oss.sonatype.org/service/local/staging/deploy/maven2/") {
-            authentication(userName: "kimchy", password: System.getenv("REPO_PASS"))
+        repository(url: rootProject.mavenRepoUrl) {
+            authentication(userName: rootProject.mavenRepoUser, password: rootProject.mavenRepoPass)
         }
-        snapshotRepository(url: "http://oss.sonatype.org/content/repositories/snapshots") {
-            authentication(userName: "kimchy", password: System.getenv("REPO_PASS"))
+        snapshotRepository(url: rootProject.mavenSnapshotRepoUrl) {
+            authentication(userName: rootProject.mavenRepoUser, password: rootProject.mavenRepoPass)
         }
 
         pom.project {

.idea/modules/plugin-groovy.iml

@@ -20,11 +20,19 @@
 package org.elasticsearch.action;
 
 /**
- * @author kimchy (Shay Banon)
+ * A listener for action responses or failures.
+ *
+ * @author kimchy (shay.banon)
  */
 public interface ActionListener<Response> {
 
+    /**
+     * A response handler.
+     */
     void onResponse(Response response);
 
+    /**
+     * A failure handler.
+     */
     void onFailure(Throwable e);
 }

build.gradle

@@ -22,7 +22,7 @@
 import org.elasticsearch.util.io.stream.Streamable;
 
 /**
- * @author kimchy (Shay Banon)
+ * @author kimchy (shay.banon)
  */
 public interface ActionRequest extends Streamable {
 

modules/elasticsearch/build.gradle

@@ -22,7 +22,7 @@
 import org.elasticsearch.util.io.stream.Streamable;
 
 /**
- * @author kimchy (Shay Banon)
+ * @author kimchy (shay.banon)
  */
 public interface ActionResponse extends Streamable {
 }

modules/elasticsearch/src/main/java/org/elasticsearch/action/ActionListener.java

@@ -0,0 +1,38 @@
+/*
+ * Licensed to Elastic Search and Shay Banon under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. Elastic Search licenses this
+ * file to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.elasticsearch.action;
+
+/**
+ * An {@link ActionFuture} that listeners can be added to.
+ *
+ * @author kimchy (shay.banon)
+ */
+public interface ListenableActionFuture<T> extends ActionFuture<T> {
+
+    /**
+     * Add an action listener to be invoked when a response has received.
+     */
+    void addListener(final ActionListener<T> listener);
+
+    /**
+     * Add an action listener (runnable) to be invoked when a response has received.
+     */
+    void addListener(final Runnable listener);
+}

modules/elasticsearch/src/main/java/org/elasticsearch/action/ActionRequest.java

@@ -58,20 +58,41 @@ public String index() {
         return this.index;
     }
 
+    /**
+     * The index the document was deleted from.
+     */
+    public String getIndex() {
+        return index;
+    }
+
     /**
      * The type of the document deleted.
      */
     public String type() {
         return this.type;
     }
 
+    /**
+     * The type of the document deleted.
+     */
+    public String getType() {
+        return type;
+    }
+
     /**
      * The id of the document deleted.
      */
     public String id() {
         return this.id;
     }
 
+    /**
+     * The id of the document deleted.
+     */
+    public String getId() {
+        return id;
+    }
+
     @Override public void readFrom(StreamInput in) throws IOException {
         index = in.readUTF();
         id = in.readUTF();

modules/elasticsearch/src/main/java/org/elasticsearch/action/ActionResponse.java

@@ -50,10 +50,18 @@ public String name() {
         return name;
     }
 
+    public String getName() {
+        return name;
+    }
+
     public List<Object> values() {
         return values;
     }
 
+    public List<Object> getValues() {
+        return values;
+    }
+
     @Override public Iterator<Object> iterator() {
         return values.iterator();
     }

modules/elasticsearch/src/main/java/org/elasticsearch/action/ListenableActionFuture.java

@@ -55,6 +55,8 @@ public class GetResponse implements ActionResponse, Streamable, Iterable<GetFiel
 
     private Map<String, GetField> fields;
 
+    private Map<String, Object> sourceAsMap;
+
     private byte[] source;
 
     GetResponse() {
@@ -79,27 +81,55 @@ public boolean exists() {
         return exists;
     }
 
+    /**
+     * Does the document exists.
+     */
+    public boolean isExists() {
+        return exists;
+    }
+
     /**
      * The index the document was fetched from.
      */
     public String index() {
         return this.index;
     }
 
+    /**
+     * The index the document was fetched from.
+     */
+    public String getIndex() {
+        return index;
+    }
+
     /**
      * The type of the document.
      */
     public String type() {
         return type;
     }
 
+    /**
+     * The type of the document.
+     */
+    public String getType() {
+        return type;
+    }
+
     /**
      * The id of the document.
      */
     public String id() {
         return id;
     }
 
+    /**
+     * The id of the document.
+     */
+    public String getId() {
+        return id;
+    }
+
     /**
      * The source of the document if exists.
      */
@@ -125,17 +155,29 @@ public Map<String, Object> sourceAsMap() throws ElasticSearchParseException {
         if (source == null) {
             return null;
         }
+        if (sourceAsMap != null) {
+            return sourceAsMap;
+        }
         try {
-            return defaultObjectMapper().readValue(source, 0, source.length, Map.class);
+            sourceAsMap = defaultObjectMapper().readValue(source, 0, source.length, Map.class);
+            return sourceAsMap;
         } catch (Exception e) {
             throw new ElasticSearchParseException("Failed to parse source to map", e);
         }
     }
 
+    public Map<String, Object> getSource() {
+        return sourceAsMap();
+    }
+
     public Map<String, GetField> fields() {
         return this.fields;
     }
 
+    public Map<String, GetField> getFields() {
+        return fields;
+    }
+
     public GetField field(String name) {
         return fields.get(name);
     }

modules/elasticsearch/src/main/java/org/elasticsearch/action/delete/DeleteResponse.java

@@ -104,6 +104,9 @@ public static OpType fromId(byte id) {
     private byte[] source;
     private OpType opType = OpType.INDEX;
 
+    public IndexRequest() {
+    }
+
     /**
      * Constructs a new index request against the specific index. The {@link #type(String)},
      * {@link #id(String)} and {@link #source(byte[])} must be set.
@@ -127,9 +130,6 @@ public IndexRequest(String index, String type, String id, byte[] source) {
         this.source = source;
     }
 
-    IndexRequest() {
-    }
-
     @Override public ActionRequestValidationException validate() {
         ActionRequestValidationException validationException = super.validate();
         if (type == null) {

modules/elasticsearch/src/main/java/org/elasticsearch/action/get/GetField.java

@@ -58,20 +58,41 @@ public String index() {
         return this.index;
     }
 
+    /**
+     * The index the document was indexed into.
+     */
+    public String getIndex() {
+        return index;
+    }
+
     /**
      * The type of the document indexed.
      */
     public String type() {
         return this.type;
     }
 
+    /**
+     * The type of the document indexed.
+     */
+    public String getType() {
+        return type;
+    }
+
     /**
      * The id of the document indexed.
      */
     public String id() {
         return this.id;
     }
 
+    /**
+     * The id of the document indexed.
+     */
+    public String getId() {
+        return id;
+    }
+
     @Override public void readFrom(StreamInput in) throws IOException {
         index = in.readUTF();
         id = in.readUTF();