waveterm/backup
0
0
Fork 0
mirror of https://github.com/wavetermdev/backup.git synced 2026-08-05 13:57:07 -07:00
Code Issues Packages Projects Releases Wiki Activity

add x-blockfileinfo and last-modified to blockfile handler

Browse Source
This commit is contained in:
sawka
2024-05-28 22:54:49 -07:00
parent bff46d9822
commit 30ef011338
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
main.go
+8
View File
@@ -8,6 +8,8 @@ package main
import ( import (
"context" "context"
"embed" "embed"
"encoding/base64"
"encoding/json"
"fmt" "fmt"
"io/fs" "io/fs"
"log" "log"
@@ -121,8 +123,14 @@ func serveBlockFile(w http.ResponseWriter, r *http.Request) {
http.Error(w, fmt.Sprintf("error getting file info: %v", err), http.StatusInternalServerError) http.Error(w, fmt.Sprintf("error getting file info: %v", err), http.StatusInternalServerError)
return return
} }
jsonFileBArr, err := json.Marshal(file)
if err != nil {
http.Error(w, fmt.Sprintf("error serializing file info: %v", err), http.StatusInternalServerError)
}
w.Header().Set("Content-Type", "application/octet-stream") w.Header().Set("Content-Type", "application/octet-stream")
w.Header().Set("Content-Length", fmt.Sprintf("%d", file.Size)) w.Header().Set("Content-Length", fmt.Sprintf("%d", file.Size))
w.Header().Set("X-BlockFileInfo", base64.StdEncoding.EncodeToString(jsonFileBArr))
w.Header().Set("Last-Modified", time.UnixMilli(file.ModTs).UTC().Format(http.TimeFormat))
for offset := file.DataStartIdx(); offset < file.Size; offset += blockstore.DefaultPartDataSize { for offset := file.DataStartIdx(); offset < file.Size; offset += blockstore.DefaultPartDataSize {
_, data, err := blockstore.GBS.ReadAt(r.Context(), blockId, name, offset, blockstore.DefaultPartDataSize) _, data, err := blockstore.GBS.ReadAt(r.Context(), blockId, name, offset, blockstore.DefaultPartDataSize)
if err != nil { if err != nil {