aboutsummaryrefslogtreecommitdiff
path: root/repo/export.go
diff options
context:
space:
mode:
authorn-peugnet <n.peugnet@free.fr>2021-10-18 16:00:08 +0200
committern-peugnet <n.peugnet@free.fr>2021-10-18 16:00:08 +0200
commit04563efa9c0dc1f6a36094dfd884ae432cf46b29 (patch)
treebe5a78647bec2a6d5812fb8b61b4ac4fcd3744b7 /repo/export.go
parent5539220a8839519becd45b63be65ed86fa9286a4 (diff)
downloaddna-backup-04563efa9c0dc1f6a36094dfd884ae432cf46b29.tar.gz
dna-backup-04563efa9c0dc1f6a36094dfd884ae432cf46b29.zip
add intermediate export package no to make repo dependant on dna
Diffstat (limited to 'repo/export.go')
-rw-r--r--repo/export.go58
1 files changed, 58 insertions, 0 deletions
diff --git a/repo/export.go b/repo/export.go
new file mode 100644
index 0000000..dd12077
--- /dev/null
+++ b/repo/export.go
@@ -0,0 +1,58 @@
+/* Copyright (C) 2021 Nicolas Peugnet <n.peugnet@free.fr>
+
+ This file is part of dna-backup.
+
+ dna-backup is free software: you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation, either version 3 of the License, or
+ (at your option) any later version.
+
+ dna-backup is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ GNU General Public License for more details.
+
+ You should have received a copy of the GNU General Public License
+ along with dna-backup. If not, see <https://www.gnu.org/licenses/>. */
+
+package repo
+
+import (
+ "io"
+
+ "github.com/n-peugnet/dna-backup/export"
+ "github.com/n-peugnet/dna-backup/logger"
+)
+
+func (r *Repo) Export(exporter export.Exporter) {
+ r.Init()
+ chunks := r.loadChunks(r.versions)
+ for i := range r.versions {
+ var err error
+ input, end := exporter.ExportVersion()
+ if len(chunks[i]) > 0 {
+ for _, c := range chunks[i] {
+ _, err := io.Copy(input.Chunks, c.Reader())
+ if err != nil {
+ logger.Error(err)
+ }
+ }
+ input.Chunks.Close()
+ }
+ readDelta(r.versions[i], recipeName, r.chunkReadWrapper, func(rc io.ReadCloser) {
+ _, err = io.Copy(input.Recipe, rc)
+ if err != nil {
+ logger.Error("load recipe ", err)
+ }
+ input.Recipe.Close()
+ })
+ readDelta(r.versions[i], filesName, r.chunkReadWrapper, func(rc io.ReadCloser) {
+ _, err = io.Copy(input.Files, rc)
+ if err != nil {
+ logger.Error("load files ", err)
+ }
+ input.Files.Close()
+ })
+ <-end
+ }
+}