diff --git a/tus/tus.go b/tus/tus.go index d800308..68183e8 100644 --- a/tus/tus.go +++ b/tus/tus.go @@ -166,7 +166,7 @@ func tusWorker(upload *tusd.Upload) error { return err } - _, err = files.Upload(file.(io.ReadSeeker), info.Size, hashBytes) + newUpload, err := files.Upload(file.(io.ReadSeeker), info.Size, hashBytes) tErr := terminateUpload(*upload) if tErr != nil { @@ -177,6 +177,11 @@ func tusWorker(upload *tusd.Upload) error { return err } + err = files.Pin(newUpload.Hash, newUpload.AccountID) + if err != nil { + return err + } + return nil }