diff options
author | n-peugnet <n.peugnet@free.fr> | 2021-10-18 16:00:08 +0200 |
---|---|---|
committer | n-peugnet <n.peugnet@free.fr> | 2021-10-18 16:00:08 +0200 |
commit | 04563efa9c0dc1f6a36094dfd884ae432cf46b29 (patch) | |
tree | be5a78647bec2a6d5812fb8b61b4ac4fcd3744b7 /repo/export.go | |
parent | 5539220a8839519becd45b63be65ed86fa9286a4 (diff) | |
download | dna-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.go | 58 |
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 + } +} |