package host
import (
"context"
"encoding/json"
extism "github.com/extism/go-sdk"
)
type UsersGetUsersResponse struct {
Result []User `json:"result,omitempty"`
Error string `json:"error,omitempty"`
}
type UsersGetAdminsResponse struct {
Result []User `json:"result,omitempty"`
Error string `json:"error,omitempty"`
}
func RegisterUsersHostFunctions(service UsersService) []extism.HostFunction {
return []extism.HostFunction{
newUsersGetUsersHostFunction(service),
newUsersGetAdminsHostFunction(service),
}
}
func newUsersGetUsersHostFunction(service UsersService) extism.HostFunction {
return extism.NewHostFunctionWithStack(
"users_getusers",
func(ctx context.Context, p *extism.CurrentPlugin, stack []uint64) {
result, svcErr := service.GetUsers(ctx)
if svcErr != nil {
usersWriteError(p, stack, svcErr)
return
}
resp := UsersGetUsersResponse{
Result: result,
}
usersWriteResponse(p, stack, resp)
},
[]extism.ValueType{extism.ValueTypePTR},
[]extism.ValueType{extism.ValueTypePTR},
)
}
func newUsersGetAdminsHostFunction(service UsersService) extism.HostFunction {
return extism.NewHostFunctionWithStack(
"users_getadmins",
func(ctx context.Context, p *extism.CurrentPlugin, stack []uint64) {
result, svcErr := service.GetAdmins(ctx)
if svcErr != nil {
usersWriteError(p, stack, svcErr)
return
}
resp := UsersGetAdminsResponse{
Result: result,
}
usersWriteResponse(p, stack, resp)
},
[]extism.ValueType{extism.ValueTypePTR},
[]extism.ValueType{extism.ValueTypePTR},
)
}
func usersWriteResponse(p *extism.CurrentPlugin, stack []uint64, resp any) {
respBytes, err := json.Marshal(resp)
if err != nil {
usersWriteError(p, stack, err)
return
}
respPtr, err := p.WriteBytes(respBytes)
if err != nil {
stack[0] = 0
return
}
stack[0] = respPtr
}
func usersWriteError(p *extism.CurrentPlugin, stack []uint64, err error) {
errResp := struct {
Error string `json:"error"`
}{Error: err.Error()}
respBytes, _ := json.Marshal(errResp)
respPtr, _ := p.WriteBytes(respBytes)
stack[0] = respPtr
}