Nemcio/SCM-Manager
1
0
Fork 0
mirror of https://github.com/scm-manager/scm-manager.git synced 2026-03-05 03:40:56 +01:00
Code Issues Packages Projects Releases Activity

Wrap event

Browse Source
This commit is contained in:
René Pfeuffer
2021-02-26 12:30:08 +01:00
parent 5b9a445cb3
commit 4ceb9c1b8c
1 changed files with 16 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
scm-webapp/src/main/java/sonia/scm/importexport/FromBundleImporter.java
View File

@@ -30,8 +30,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import sonia.scm.Type;
import sonia.scm.event.ScmEventBus;
import sonia.scm.repository.ImportRepositoryHookEvent;
import sonia.scm.repository.InternalRepositoryException;
import sonia.scm.repository.Repository;
import sonia.scm.repository.RepositoryHookEvent;
import sonia.scm.repository.RepositoryImportEvent;
import sonia.scm.repository.RepositoryManager;
import sonia.scm.repository.RepositoryPermission;
@@ -46,6 +48,7 @@ import javax.inject.Inject;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.util.concurrent.atomic.AtomicReference;
import java.util.function.Consumer;
import static java.util.Collections.singletonList;
@@ -106,7 +109,7 @@ public class FromBundleImporter {
long length = Files.asByteSink(file).writeFrom(inputStream);
LOG.info("copied {} bytes to temp, start bundle import", length);
logger.step("importing repository data from dump file");
service.getUnbundleCommand().setCompressed(compressed).unbundle(file);
runUnbundleCommand(compressed, service, file);
logger.finished();
} catch (IOException e) {
logger.failed(e);
@@ -120,4 +123,16 @@ public class FromBundleImporter {
}
};
}
private void runUnbundleCommand(boolean compressed, RepositoryService service, File file) throws IOException {
AtomicReference<RepositoryHookEvent> eventSink = new AtomicReference<>();
service.getUnbundleCommand()
.setCompressed(compressed)
.setPostEventSink(eventSink::set)
.unbundle(file);
RepositoryHookEvent repositoryHookEvent = eventSink.get();
if (repositoryHookEvent != null) {
eventBus.post(new ImportRepositoryHookEvent(repositoryHookEvent));
}
}
}