logos-storage/logos-storage-nim
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim.git synced 2026-01-08 16:33:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add async version for file upload

Browse Source
This commit is contained in:
Arnaud 2025-09-22 15:55:44 +02:00 committed by Eric
parent 2ce5c37c58
commit 54f71890c7
No known key found for this signature in database
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
examples/golang/codex.go
View File

@ -706,13 +706,11 @@ func (self *CodexNode) CodexUploadFile(options CodexUploadOptions) (string, erro
return cid, err
}
// TODO provide an async version of CodexUploadFile
// that starts a gorountine to upload the file
// and take:
// a callback to be called when done
// another callback to cancel the upload
func (self *CodexNode) CodexUploadFileAsync(filepath string, chunkSize int, cb func(error)) (string, error) {
return "", nil
func (self *CodexNode) CodexUploadFileAsync(options CodexUploadOptions, onDone func(cid string, err error)) {
go func() {
cid, err := self.CodexUploadFile(options)
onDone(cid, err)
}()
}
func (self *CodexNode) CodexStart() error {
@ -889,8 +887,8 @@ func main() {
}
// Choose a big file to see the progress logs
// filepath := path.Join(current, "examples", "golang", "hello.txt")
filepath := path.Join(current, "examples", "golang", "discord-0.0.109.deb")
filepath := path.Join(current, "examples", "golang", "hello.txt")
// filepath := path.Join(current, "examples", "golang", "discord-0.0.109.deb")
options := CodexUploadOptions{filepath: filepath, onProgress: func(read, total int, percent float64) {
log.Printf("Uploaded %d bytes, total %d bytes (%.2f%%)\n", read, total, percent)
}}