jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(backend): 2 files back compatible format

Browse source
This commit is contained in:
Alex Kaminskii 2022-05-04 20:33:52 +02:00
parent a4278aec23
commit 6314fcbbef
1 changed files with 3 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
backend/services/storage/main.go
View file

@ -8,7 +8,6 @@ import (
"bytes"
"io"
//"io/ioutil"
"os/signal"
"syscall"
@ -47,28 +46,21 @@ func main() {
}
defer file.Close()
fileR2 := new(bytes.Buffer)
fileR1 := io.TeeReader(file, fileR2)
startBytes := make([]byte, SESSION_FILE_SPLIT_SIZE)
nRead, err := fileR1.Read(startBytes)
nRead, err := file.Read(startBytes)
if err != nil {
log.Printf("File read error: %f", err)
return
}
startReader := bytes.NewBuffer(startBytes)
if err := storage.Upload(gzipFile(startReader), key+"-s", "application/octet-stream", true); err != nil {
if err := storage.Upload(gzipFile(startReader), key, "application/octet-stream", true); err != nil {
log.Fatalf("Storage: start upload failed. %v\n", err)
}
if nRead == SESSION_FILE_SPLIT_SIZE {
if err := storage.Upload(gzipFile(fileR1), key+"-e", "application/octet-stream", true); err != nil {
if err := storage.Upload(gzipFile(file), key + "e", "application/octet-stream", true); err != nil {
log.Fatalf("Storage: end upload failed. %v\n", err)
}
}
if err := storage.Upload(gzipFile(fileR2), key, "application/octet-stream", true); err != nil {
log.Fatalf("Storage: upload failed. %v\n", err)
}
}
consumer := queue.NewMessageConsumer(