logos-storage/logos-storage-nim
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim.git synced 2026-01-03 22:13:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add storage delete (block or dataset delete)

Browse Source
This commit is contained in:
Arnaud 2025-10-01 09:54:15 +02:00
parent 84b9e676f0
commit 9c8879d8bb
No known key found for this signature in database
GPG Key ID: B8FBC178F10CA7AE
2 changed files with 43 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
examples/golang/codex.go
View File

@ -156,6 +156,10 @@ package main
return codex_storage_space(codexCtx, (CodexCallback) callback, resp);
}
static int cGoCodexStorageDelete(void* codexCtx, char* cid, void* resp) {
return codex_storage_delete(codexCtx, cid, (CodexCallback) callback, resp);
}
static int cGoCodexStart(void* codexCtx, void* resp) {
return codex_start(codexCtx, (CodexCallback) callback, resp);
}
@ -1027,6 +1031,21 @@ func (self CodexNode) CodexStorageSpace() (CodexSpace, error) {
return space, err
}
func (self CodexNode) CodexStorageDelete(cid string) error {
bridge := newBridgeCtx()
defer bridge.free()
var cCid = C.CString(cid)
defer C.free(unsafe.Pointer(cCid))
if C.cGoCodexStorageDelete(self.ctx, cCid, bridge.resp) != C.RET_OK {
return bridge.CallError("cGoCodexStorageDelete")
}
_, err := bridge.wait()
return err
}
func (self CodexNode) CodexStart() error {
bridge := newBridgeCtx()
defer bridge.free()
@ -1286,6 +1305,12 @@ func main() {
}
log.Println("Storage Space content:", space)
if err := node.CodexStorageDelete(cid); err != nil {
log.Fatal("Error happened:", err.Error())
}
log.Println("Storage Delete finished.")
// }
// err = node.CodexConnect(peerId, []string{})

21
library/codex_thread_requests/requests/node_storage_request.nim
View File

@ -18,7 +18,8 @@ import ../../../codex/manifest
import ../../../codex/stores/repostore
from ../../../codex/codex import CodexServer, node, repoStore
from ../../../codex/node import iterateManifests, fetchManifest, fetchDatasetAsyncTask
from ../../../codex/node import
iterateManifests, fetchManifest, fetchDatasetAsyncTask, delete
from libp2p import Cid, init, `$`
logScope:
@ -75,9 +76,23 @@ proc list(
return ok(serde.toJson(manifests))
proc delete(
codex: ptr CodexServer, cid: cstring
codex: ptr CodexServer, cCid: cstring
): Future[Result[string, string]] {.async: (raises: []).} =
return err("DELETE operation not implemented yet.")
let cid = Cid.init($cCid)
if cid.isErr:
return err("Failed to delete the data: cannot parse cid: " & $cCid)
let node = codex[].node
try:
let res = await node.delete(cid.get())
if res.isErr:
return err("Failed to delete the data: " & res.error.msg)
except CancelledError:
return err("Failed to delete the data: cancelled operation.")
except CatchableError as err:
return err("Failed to delete the data: " & err.msg)
return ok("")
proc fetch(
codex: ptr CodexServer, cCid: cstring