📦 updates HDK for v0.0.5

Author: k33g

Taskfile.yml

@@ -23,8 +23,8 @@ tasks:
       #TAG: "v0.0.1"
       #TAG: "v0.0.2" 
       #TAG: "v0.0.3" 
-      TAG: "v0.0.4" # current release
-      #TAG: "v0.0.5" # it will be the next release
+      #TAG: "v0.0.4" # current release
+      TAG: "v0.0.5"
     cmds:
       - echo "📦 Generating release..."
       - git add .

capsule.dk.go

@@ -6,7 +6,7 @@ import (
 	"errors"
 	"log"
 
-	"github.com/tetratelabs/wazero"
+	//"github.com/tetratelabs/wazero"
 	"github.com/tetratelabs/wazero/api"
 )
 
@@ -71,12 +71,7 @@ func GetHandleHTTP(mod api.Module) api.Function {
 }
 
 // CallOnStart calls the OnStart function (if it exists) from the given module.
-func CallOnStart(ctx context.Context, runtime wazero.Runtime, wasmFile []byte) {
-
-	mod, err := runtime.Instantiate(ctx, wasmFile)
-	if err != nil {
-		log.Println("❌ [OnStart] Error with the module instance", err)
-	}
+func CallOnStart(ctx context.Context, mod api.Module , wasmFile []byte) {
 
 	onStart := mod.ExportedFunction("OnStart")
 	if onStart != nil {
@@ -89,11 +84,7 @@ func CallOnStart(ctx context.Context, runtime wazero.Runtime, wasmFile []byte) {
 }
 
 // CallOnStop calls the OnStop function (if it exists) from the given module.
-func CallOnStop(ctx context.Context, runtime wazero.Runtime, wasmFile []byte) {
-	mod, err := runtime.Instantiate(ctx, wasmFile)
-	if err != nil {
-		log.Println("❌ [OnStop] Error with the module instance", err)
-	}
+func CallOnStop(ctx context.Context, mod api.Module, wasmFile []byte) {
 
 	onStop := mod.ExportedFunction("OnStop")
 	if onStop != nil {

docs/index.md

@@ -1,6 +1,7 @@
 # Capsule Host SDK
 
 !!! info "What's new?"
+    - `v0.0.5`: ✨ Helpers updated: `CallOnStart` and `CallOnStop` (they are executed from the same wasm module instance)
     - `v0.0.4`: ✨ Helpers added: `CallOnStart` and `CallOnStop`
     - `v0.0.3`: ✨ Wazero update 1.2.0
     - `v0.0.2`: ✨ Redis support

hostfunc.memorycache.go

@@ -23,6 +23,9 @@ import (
 
 var memCache sync.Map
 
+//var memoryCache = make(map[string][]byte)
+//var mutex = &sync.RWMutex{}
+
 // DefineHostFuncCacheSet defines a new Go module function for setting values in
 // the cache. It takes in 6 parameters:
 //   - key position (int32)
@@ -73,6 +76,13 @@ var cacheSet = api.GoModuleFunc(func(ctx context.Context, module api.Module, par
 
 	// start the host work
 	memCache.Store(string(bufferKey), bufferStringValue)
+
+	/*
+	mutex.Lock()
+	defer mutex.Unlock()
+	memoryCache[string(bufferKey)] = bufferStringValue
+	*/
+	
 	resultFromHost = success(bufferKey)
 	//! we cannot know if there is an error or not
 	// end of the host work
@@ -88,6 +98,7 @@ var cacheSet = api.GoModuleFunc(func(ctx context.Context, module api.Module, par
 
 	params[0] = 0
 
+
 })
 
 
@@ -125,14 +136,28 @@ var cacheGet = api.GoModuleFunc(func(ctx context.Context, module api.Module, par
 	// Execute the host function with the arguments and return a value
 	var resultFromHost []byte
 
+	/*
+	mutex.RLock()
+	defer mutex.RUnlock()
+	result := memoryCache[string(bufferKey)]
+	if result == nil {
+		resultFromHost = failure([]byte("key not found"))
+	} else {
+		resultFromHost = success(result)
+	}
+	*/
+	
+
 	// start the host work
+	
 	result, ok := memCache.Load(string(bufferKey))
 
 	if ok {
 		resultFromHost = success(result.([]byte))
 	} else {
 		resultFromHost = failure([]byte("key not found"))
 	}
+	
 	// end of the host work
 
 	// return the result value (using the return buffer)

samples/simple-talk/go.mod

@@ -11,6 +11,6 @@ require (
 	golang.org/x/net v0.0.0-20211029224645-99673261e6eb // indirect
 )
 
-require github.com/bots-garden/capsule-host-sdk v0.0.2
+require github.com/bots-garden/capsule-host-sdk v0.0.4
 
 replace github.com/bots-garden/capsule-host-sdk => ../..