commit 3ddc62a15396be4db74c47695be5e3c24cfdb136
author Saša Živkov <sasa.zivkov@sap.com> Thu Mar 05 16:38:30 2015 +0100
committer Saša Živkov <sasa.zivkov@sap.com> Fri Mar 06 14:47:22 2015 +0100
tree 893dd52cf4b88ce506f56d3889c29114f34888ab
parent 46a15de18b0821837fd8479eecb3189c0eac5aa8

Persist the project import parameters for each imported project

The data is persisted into the data/<plugin-name>/<project-name> file.
The persisted parameters will be used to repeat/continue an import.

Change-Id: I3083131f890de661a37f079da700edc0e6b0b1c3

src/main/java/com/googlesource/gerrit/plugins/importer/ImportProjectTask.java

diff --git a/src/main/java/com/googlesource/gerrit/plugins/importer/ImportProjectTask.java b/src/main/java/com/googlesource/gerrit/plugins/importer/ImportProjectTask.java
index f2059d0..c108ca0 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/importer/ImportProjectTask.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/importer/ImportProjectTask.java
@@ -16,11 +16,13 @@
 
 import static java.lang.String.format;
 
+import com.google.common.base.Charsets;
 import com.google.gerrit.common.errors.NoSuchAccountException;
 import com.google.gerrit.extensions.annotations.PluginData;
 import com.google.gerrit.extensions.restapi.ResourceConflictException;
 import com.google.gerrit.extensions.restapi.RestApiException;
 import com.google.gerrit.reviewdb.client.Project;
+import com.google.gerrit.server.OutputFormat;
 import com.google.gerrit.server.project.NoSuchChangeException;
 import com.google.gerrit.server.validators.ValidationException;
 import com.google.gwtorm.server.OrmException;
@@ -36,6 +38,7 @@
 
 import java.io.File;
 import java.io.IOException;
+import java.io.OutputStream;
 
 class ImportProjectTask implements Runnable {
 
@@ -62,6 +65,8 @@
   private final String password;
   private final StringBuffer messages;
 
+  private LockFile lockFile;
+
   @Inject
   ImportProjectTask(OpenRepositoryStep openRepoStep,
       ConfigureRepositoryStep configRepoStep,
@@ -88,8 +93,8 @@
 
   @Override
   public void run() {
-    LockFile importing = lockForImport(name);
-    if (importing == null) {
+    lockFile = lockForImport(name);
+    if (lockFile == null) {
       return;
     }
 
@@ -100,6 +105,7 @@
       }
 
       try {
+        persistParams();
         configRepoStep.configure(repo, name, fromGerrit);
         gitFetchStep.fetch(user, password, repo, name, messages);
         replayChangesFactory.create(fromGerrit, user, password, repo, name)
@@ -114,8 +120,30 @@
     } catch (ResourceConflictException e) {
       handleError(e);
     } finally {
-      importing.unlock();
-      importing.commit();
+      try {
+        lockFile.commit();
+      } finally {
+        lockFile.unlock();
+      }
+    }
+  }
+
+  static class Params {
+    String from;
+    String user;
+    String project;
+  }
+
+  private void persistParams() throws IOException {
+    Params p = new Params();
+    p.from = fromGerrit;
+    p.user = user;
+    p.project = name.get();
+
+    String s = OutputFormat.JSON_COMPACT.newGson().toJson(p);
+    try (OutputStream out = lockFile.getOutputStream()) {
+      out.write(s.getBytes(Charsets.UTF_8));
+      out.write('\n');
     }
   }