gopeed/pkg/rest/invoke.go

package rest

import (
	"encoding/json"
	"net/url"

	goapi "github.com/GopeedLab/gopeed/pkg/api"
	"github.com/GopeedLab/gopeed/pkg/rest/model"
)

const (
	TaskEventDone  = uint64(goapi.TaskEventDone)
	TaskEventError = uint64(goapi.TaskEventError)
)

// Invoke dispatches a Core API request without using an HTTP listener. It is
// the shared entry point for Desktop FFI and gomobile bindings.
func Invoke(method, path, rawQuery, body string) string {
	service := APIService
	if service == nil {
		return marshalInvokeResult(model.NewErrorResult("service not started"))
	}
	query, err := url.ParseQuery(rawQuery)
	if err != nil {
		return marshalInvokeResult(model.NewErrorResult(err.Error()))
	}
	_, data := service.JSON(method, path, query, []byte(body), nil)
	return string(data)
}

func SubscribeTaskEvents(mask uint64, listener func(payload string)) {
	if APIService == nil {
		return
	}
	APIService.SubscribeTaskEvents(goapi.TaskEventMask(mask), listener)
}

func marshalInvokeResult(value any) string {
	data, err := json.Marshal(value)
	if err != nil {
		return `{"code":1000,"msg":"marshal response failed"}`
	}
	return string(data)
}