navidrome/plugins/host/scrobbleretriever_gen.go

// Code generated by ndpgen. DO NOT EDIT.

package host

import (
	"context"
	"encoding/json"

	extism "github.com/extism/go-sdk"
)

// ScrobbleRetrieverGetFirstTimestampRequest is the request type for ScrobbleRetriever.GetFirstTimestamp.
type ScrobbleRetrieverGetFirstTimestampRequest struct {
	Username string `json:"username"`
}

// ScrobbleRetrieverGetFirstTimestampResponse is the response type for ScrobbleRetriever.GetFirstTimestamp.
type ScrobbleRetrieverGetFirstTimestampResponse struct {
	Result *int64 `json:"result,omitempty"`
	Error  string `json:"error,omitempty"`
}

// ScrobbleRetrieverGetLastTimestampRequest is the request type for ScrobbleRetriever.GetLastTimestamp.
type ScrobbleRetrieverGetLastTimestampRequest struct {
	Username string `json:"username"`
}

// ScrobbleRetrieverGetLastTimestampResponse is the response type for ScrobbleRetriever.GetLastTimestamp.
type ScrobbleRetrieverGetLastTimestampResponse struct {
	Result *int64 `json:"result,omitempty"`
	Error  string `json:"error,omitempty"`
}

// ScrobbleRetrieverGetScrobblesRequest is the request type for ScrobbleRetriever.GetScrobbles.
type ScrobbleRetrieverGetScrobblesRequest struct {
	Username string          `json:"username"`
	Options  ScrobbleOptions `json:"options"`
}

// ScrobbleRetrieverGetScrobblesResponse is the response type for ScrobbleRetriever.GetScrobbles.
type ScrobbleRetrieverGetScrobblesResponse struct {
	Scrobbles []ScrobbleRef    `json:"scrobbles,omitempty"`
	Next      *ScrobbleOptions `json:"next,omitempty"`
	Error     string           `json:"error,omitempty"`
}

// ScrobbleRetrieverGetScrobbleCountRequest is the request type for ScrobbleRetriever.GetScrobbleCount.
type ScrobbleRetrieverGetScrobbleCountRequest struct {
	Username string               `json:"username"`
	Options  ScrobbleCountOptions `json:"options"`
}

// ScrobbleRetrieverGetScrobbleCountResponse is the response type for ScrobbleRetriever.GetScrobbleCount.
type ScrobbleRetrieverGetScrobbleCountResponse struct {
	Result int64  `json:"result,omitempty"`
	Error  string `json:"error,omitempty"`
}

// RegisterScrobbleRetrieverHostFunctions registers ScrobbleRetriever service host functions.
// The returned host functions should be added to the plugin's configuration.
func RegisterScrobbleRetrieverHostFunctions(service ScrobbleRetrieverService) []extism.HostFunction {
	return []extism.HostFunction{
		newScrobbleRetrieverGetFirstTimestampHostFunction(service),
		newScrobbleRetrieverGetLastTimestampHostFunction(service),
		newScrobbleRetrieverGetScrobblesHostFunction(service),
		newScrobbleRetrieverGetScrobbleCountHostFunction(service),
	}
}

func newScrobbleRetrieverGetFirstTimestampHostFunction(service ScrobbleRetrieverService) extism.HostFunction {
	return extism.NewHostFunctionWithStack(
		"scrobbleretriever_getfirsttimestamp",
		func(ctx context.Context, p *extism.CurrentPlugin, stack []uint64) {
			// Read JSON request from plugin memory
			reqBytes, err := p.ReadBytes(stack[0])
			if err != nil {
				scrobbleretrieverWriteError(p, stack, err)
				return
			}
			var req ScrobbleRetrieverGetFirstTimestampRequest
			if err := json.Unmarshal(reqBytes, &req); err != nil {
				scrobbleretrieverWriteError(p, stack, err)
				return
			}

			// Call the service method
			result, svcErr := service.GetFirstTimestamp(ctx, req.Username)
			if svcErr != nil {
				scrobbleretrieverWriteError(p, stack, svcErr)
				return
			}

			// Write JSON response to plugin memory
			resp := ScrobbleRetrieverGetFirstTimestampResponse{
				Result: result,
			}
			scrobbleretrieverWriteResponse(p, stack, resp)
		},
		[]extism.ValueType{extism.ValueTypePTR},
		[]extism.ValueType{extism.ValueTypePTR},
	)
}

func newScrobbleRetrieverGetLastTimestampHostFunction(service ScrobbleRetrieverService) extism.HostFunction {
	return extism.NewHostFunctionWithStack(
		"scrobbleretriever_getlasttimestamp",
		func(ctx context.Context, p *extism.CurrentPlugin, stack []uint64) {
			// Read JSON request from plugin memory
			reqBytes, err := p.ReadBytes(stack[0])
			if err != nil {
				scrobbleretrieverWriteError(p, stack, err)
				return
			}
			var req ScrobbleRetrieverGetLastTimestampRequest
			if err := json.Unmarshal(reqBytes, &req); err != nil {
				scrobbleretrieverWriteError(p, stack, err)
				return
			}

			// Call the service method
			result, svcErr := service.GetLastTimestamp(ctx, req.Username)
			if svcErr != nil {
				scrobbleretrieverWriteError(p, stack, svcErr)
				return
			}

			// Write JSON response to plugin memory
			resp := ScrobbleRetrieverGetLastTimestampResponse{
				Result: result,
			}
			scrobbleretrieverWriteResponse(p, stack, resp)
		},
		[]extism.ValueType{extism.ValueTypePTR},
		[]extism.ValueType{extism.ValueTypePTR},
	)
}

func newScrobbleRetrieverGetScrobblesHostFunction(service ScrobbleRetrieverService) extism.HostFunction {
	return extism.NewHostFunctionWithStack(
		"scrobbleretriever_getscrobbles",
		func(ctx context.Context, p *extism.CurrentPlugin, stack []uint64) {
			// Read JSON request from plugin memory
			reqBytes, err := p.ReadBytes(stack[0])
			if err != nil {
				scrobbleretrieverWriteError(p, stack, err)
				return
			}
			var req ScrobbleRetrieverGetScrobblesRequest
			if err := json.Unmarshal(reqBytes, &req); err != nil {
				scrobbleretrieverWriteError(p, stack, err)
				return
			}

			// Call the service method
			scrobbles, next, svcErr := service.GetScrobbles(ctx, req.Username, req.Options)
			if svcErr != nil {
				scrobbleretrieverWriteError(p, stack, svcErr)
				return
			}

			// Write JSON response to plugin memory
			resp := ScrobbleRetrieverGetScrobblesResponse{
				Scrobbles: scrobbles,
				Next:      next,
			}
			scrobbleretrieverWriteResponse(p, stack, resp)
		},
		[]extism.ValueType{extism.ValueTypePTR},
		[]extism.ValueType{extism.ValueTypePTR},
	)
}

func newScrobbleRetrieverGetScrobbleCountHostFunction(service ScrobbleRetrieverService) extism.HostFunction {
	return extism.NewHostFunctionWithStack(
		"scrobbleretriever_getscrobblecount",
		func(ctx context.Context, p *extism.CurrentPlugin, stack []uint64) {
			// Read JSON request from plugin memory
			reqBytes, err := p.ReadBytes(stack[0])
			if err != nil {
				scrobbleretrieverWriteError(p, stack, err)
				return
			}
			var req ScrobbleRetrieverGetScrobbleCountRequest
			if err := json.Unmarshal(reqBytes, &req); err != nil {
				scrobbleretrieverWriteError(p, stack, err)
				return
			}

			// Call the service method
			result, svcErr := service.GetScrobbleCount(ctx, req.Username, req.Options)
			if svcErr != nil {
				scrobbleretrieverWriteError(p, stack, svcErr)
				return
			}

			// Write JSON response to plugin memory
			resp := ScrobbleRetrieverGetScrobbleCountResponse{
				Result: result,
			}
			scrobbleretrieverWriteResponse(p, stack, resp)
		},
		[]extism.ValueType{extism.ValueTypePTR},
		[]extism.ValueType{extism.ValueTypePTR},
	)
}

// scrobbleretrieverWriteResponse writes a JSON response to plugin memory.
func scrobbleretrieverWriteResponse(p *extism.CurrentPlugin, stack []uint64, resp any) {
	respBytes, err := json.Marshal(resp)
	if err != nil {
		scrobbleretrieverWriteError(p, stack, err)
		return
	}
	respPtr, err := p.WriteBytes(respBytes)
	if err != nil {
		stack[0] = 0
		return
	}
	stack[0] = respPtr
}

// scrobbleretrieverWriteError writes an error response to plugin memory.
func scrobbleretrieverWriteError(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
}