/*
 * Licensed to Elasticsearch under one or more contributor
 * license agreements. See the NOTICE file distributed with
 * this work for additional information regarding copyright
 * ownership. Elasticsearch 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 fr.pilato.elasticsearch.crawler.fs.client;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import java.util.Arrays;

public class BulkResponse {

    private static final Logger logger = LogManager.getLogger(ElasticsearchClient.class);

    private BulkItemResponse[] items;

    public boolean hasFailures() {
        for (BulkItemResponse item : items) {
            if (item.failed) {
                return true;
            }
        }
        return false;
    }

    public BulkItemResponse[] getItems() {
        return items;
    }

    public Throwable buildFailureMessage() {
        StringBuilder sbf = new StringBuilder();
        int failures = 0;
        for (BulkItemResponse item : items) {
            if (item.failed) {
                if (logger.isTraceEnabled()) {
                    sbf.append(item.getIndex()).append("/").append(item.getType()).append("/").append(item.getId());
                    sbf.append(":").append(item.getOpType()).append(":").append(item.getFailureMessage());
                }
                failures++;
            }
        }
        if (logger.isTraceEnabled()) {
            sbf.append("\n");
        }
        sbf.append(failures).append(" failures");
        return new RuntimeException(sbf.toString());
    }

    public static class BulkItemResponse {
        private boolean failed;
        private String index;
        private String type;
        private String id;
        private String opType;
        private String failureMessage;

        public boolean isFailed() {
            return failed;
        }

        public String getIndex() {
            return index;
        }

        public String getType() {
            return type;
        }

        public String getId() {
            return id;
        }

        public String getOpType() {
            return opType;
        }

        public String getFailureMessage() {
            return failureMessage;
        }

        public void setFailed(boolean failed) {
            this.failed = failed;
        }

        public void setIndex(String index) {
            this.index = index;
        }

        public void setType(String type) {
            this.type = type;
        }

        public void setId(String id) {
            this.id = id;
        }

        public void setOpType(String opType) {
            this.opType = opType;
        }

        public void setFailureMessage(String failureMessage) {
            this.failureMessage = failureMessage;
        }

        @Override
        public String toString() {
            final StringBuilder sb = new StringBuilder("BulkItemResponse{");
            sb.append("failed=").append(failed);
            sb.append(", index='").append(index).append('\'');
            sb.append(", type='").append(type).append('\'');
            sb.append(", id='").append(id).append('\'');
            sb.append(", opType=").append(opType);
            sb.append(", failureMessage='").append(failureMessage).append('\'');
            sb.append('}');
            return sb.toString();
        }
    }

    @Override
    public String toString() {
        final StringBuilder sb = new StringBuilder("BulkResponse{");
        sb.append("items=").append(items == null ? "null" : Arrays.asList(items).toString());
        sb.append('}');
        return sb.toString();
    }
}

@@ -11,29 +11,43 @@
 nsed to 
-Elasticsearch
+David Pilato (the %22Author%22)
  under o
@@ -48,16 +48,19 @@
 nder one
+%0A *
  or more
@@ -71,19 +71,16 @@
 tributor
-%0A *
  license
@@ -91,16 +91,17 @@
 eements.
+ 
  See the
@@ -112,16 +112,19 @@
 ICE file
+%0A *
  distrib
@@ -132,19 +132,16 @@
 ted with
-%0A *
  this wo
@@ -169,16 +169,19 @@
 ormation
+%0A *
  regardi
@@ -192,19 +192,16 @@
 opyright
-%0A *
  ownersh
@@ -204,29 +204,22 @@
 ership. 
-Elasticsearch
+Author
  license
@@ -220,24 +220,27 @@
 icenses this
+%0A *
  file to you
@@ -245,19 +245,16 @@
 ou under
-%0A *
  the Apa
@@ -282,16 +282,19 @@
 2.0 (the
+%0A *
  %22Licens
@@ -305,19 +305,16 @@
  you may
-%0A *
  not use
@@ -344,16 +344,19 @@
 mpliance
+%0A *
  with th
@@ -365,19 +365,17 @@
 License.
-%0A *
+ 
  You may

Fix License header