DeBros/orama
4
0
Fork 0
mirror of https://github.com/DeBrosOfficial/orama.git synced 2026-03-17 06:23:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: enhance WASM upload functionality with replication and error handling

Browse Source
This commit is contained in:
anonpenguin23 2026-02-20 09:44:13 +02:00
parent c499b2d76e
commit 8cabe48f7d
1 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
pkg/serverless/registry.go
View File

@ -428,13 +428,26 @@ func (r *Registry) GetLogs(ctx context.Context, namespace, name string, limit in
// Private helpers // Private helpers
// ----------------------------------------------------------------------------- // -----------------------------------------------------------------------------
// uploadWASM uploads WASM bytecode to IPFS and returns the CID. // defaultWASMReplicationFactor is the IPFS Cluster replication factor for WASM binaries.
const defaultWASMReplicationFactor = 3
// uploadWASM uploads WASM bytecode to IPFS and pins it for cluster-wide replication.
func (r *Registry) uploadWASM(ctx context.Context, wasmBytes []byte, name string) (string, error) { func (r *Registry) uploadWASM(ctx context.Context, wasmBytes []byte, name string) (string, error) {
reader := bytes.NewReader(wasmBytes) reader := bytes.NewReader(wasmBytes)
resp, err := r.ipfs.Add(ctx, reader, name+".wasm") resp, err := r.ipfs.Add(ctx, reader, name+".wasm")
if err != nil { if err != nil {
return "", fmt.Errorf("failed to upload WASM to IPFS: %w", err) return "", fmt.Errorf("failed to upload WASM to IPFS: %w", err)
} }
// Pin the CID across cluster peers so the binary survives node failures.
if _, err := r.ipfs.Pin(ctx, resp.Cid, name+".wasm", defaultWASMReplicationFactor); err != nil {
r.logger.Warn("Failed to pin WASM binary — content may not be replicated",
zap.String("cid", resp.Cid),
zap.String("function", name),
zap.Error(err),
)
}
return resp.Cid, nil return resp.Cid, nil
} }