diff --git a/pom.xml b/pom.xml
index 0abad3004..45e02f113 100644
--- a/pom.xml
+++ b/pom.xml
@@ -57,7 +57,7 @@
0.6.0F
- 1.0.11-SNAPSHOT
+ 1.0.11
2.3.0
diff --git a/src/main/java/org/codelibs/fess/ds/impl/GitBucketDataStoreImpl.java b/src/main/java/org/codelibs/fess/ds/impl/GitBucketDataStoreImpl.java
new file mode 100644
index 000000000..71e117b20
--- /dev/null
+++ b/src/main/java/org/codelibs/fess/ds/impl/GitBucketDataStoreImpl.java
@@ -0,0 +1,185 @@
+/*
+ * Copyright 2012-2016 CodeLibs Project and the Others.
+ *
+ * Licensed 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.codelibs.fess.ds.impl;
+
+import java.io.InputStream;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.commons.io.FilenameUtils;
+import org.codelibs.core.lang.StringUtil;
+import org.codelibs.elasticsearch.runner.net.Curl;
+import org.codelibs.elasticsearch.runner.net.CurlResponse;
+import org.codelibs.fess.ds.IndexUpdateCallback;
+import org.codelibs.fess.es.config.exentity.DataConfig;
+import org.elasticsearch.common.xcontent.json.JsonXContent;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * @author Keiichi Watanabe
+ */
+public class GitBucketDataStoreImpl extends AbstractDataStoreImpl {
+ private static final Logger logger = LoggerFactory.getLogger(CsvDataStoreImpl.class);
+
+ private static final int MAX_DEPTH = 20;
+
+ protected static final String TOKEN_PARAM = "token";
+ protected static final String GITBUCKET_URL_PARAM = "url";
+
+ @Override
+ protected void storeData(final DataConfig dataConfig, final IndexUpdateCallback callback, final Map paramMap,
+ final Map scriptMap, final Map defaultDataMap) {
+
+ final String rootURL = getRootURL(paramMap);
+ final String authToken = getAuthToken(paramMap);
+ final long readInterval = getReadInterval(paramMap);
+
+ if (rootURL.isEmpty() || authToken.isEmpty()) {
+ logger.warn("parameter \"" + TOKEN_PARAM + "\" and \"" + GITBUCKET_URL_PARAM + "\" are required");
+ return;
+ }
+
+ final List> repositoryList = getRepositoryList(rootURL, authToken);
+ if (repositoryList.isEmpty()) {
+ logger.warn("Token is invalid or no Repository");
+ return;
+ }
+
+ for (final Map repository : repositoryList) {
+ try {
+ final String name = (String) repository.get("name");
+ final String owner = (String) repository.get("owner");
+ final boolean isPrivate = (boolean) repository.get("is_private"); // TODO Use this info for roles
+
+ List pathList = collectFileNames(rootURL, authToken, owner, name, "", 0, readInterval);
+ for (String path : pathList) {
+ storeFileContent(rootURL, authToken, owner, name, path, dataConfig, callback, paramMap, scriptMap, defaultDataMap);
+ if (readInterval > 0) {
+ sleep(readInterval);
+ }
+ }
+ } catch (Exception e) {
+ logger.warn("Failed to access to " + repository, e);
+ }
+ }
+
+ }
+
+ protected String getRootURL(final Map paramMap) {
+ if (paramMap.containsKey(GITBUCKET_URL_PARAM)) {
+ String url = paramMap.get(GITBUCKET_URL_PARAM);
+ if (url.charAt(url.length() - 1) != '/') {
+ url += "/";
+ }
+ return url;
+ }
+ return StringUtil.EMPTY;
+ }
+
+ protected String getAuthToken(final Map paramMap) {
+ if (paramMap.containsKey(TOKEN_PARAM)) {
+ return paramMap.get(TOKEN_PARAM);
+ }
+ return StringUtil.EMPTY;
+ }
+
+ protected List> getRepositoryList(final String rootURL, final String authToken) {
+ final String url = rootURL + "api/v3/fess/repos";
+ try (CurlResponse curlResponse = Curl.get(url).header("Authorization", "token " + authToken).execute()) {
+ final String content = curlResponse.getContentAsString();
+ final Map map = curlResponse.getContentAsMap();
+ assert (map.containsKey("repositories"));
+ final List> repoList = (List>) map.get("repositories");
+ return repoList;
+ } catch (Exception e) {
+ logger.warn("Failed to access to " + rootURL, e);
+ return Collections.emptyList();
+ }
+ }
+
+ private List