TinyGo SDK

brew tap tinygo-org/tools
brew install tinygo
tinygo version       # 0.41+ нужен для wasi-таргета с reactor mode

package main

import (
    "encoding/json"
    "lampac.cc/sdk/lampac"
)

func main() {} // обязателен для TinyGo wasi target

type item struct{ Name string `json:"name"` }
type movie struct {
    Type string `json:"type"`
    Data []item `json:"data"`
}

//export handle
func handle(ptr, length uint32) uint64 {
    inv := lampac.ReadInvocation(ptr, length)
    lampac.Info("got request, path=" + inv.Path)
    body, _ := json.Marshal(movie{
        Type: "movie",
        Data: []item{{Name: "Hello, " + inv.Query["q"]}},
    })
    return lampac.WriteResponse(body)
}

{
  "id": "hello",
  "name": "Hello plugin",
  "version": "0.1.0",
  "target": "server",
  "language": "tinygo",
  "abi_version": 1,
  "permissions": []
}

.PHONY: build
build:
	tinygo build -o plugin.wasm -target wasi -no-debug ./

make
curl 'http://localhost:9118/lite/hello?q=world'
# {"type":"movie","data":[{"name":"Hello, world"}]}

lampac.Debug("…")
lampac.Info("…")
lampac.Warn("…")
lampac.Error("…")

resp, err := lampac.HTTPGet(lampac.HTTPRequest{
    URL:     "https://api.example.com/v1/movies?id=123",
    Headers: map[string]string{"User-Agent": "lampac"},
})
// resp.Status, resp.Headers, resp.Body, resp.Err

resp, err := lampac.HTTPPost(lampac.HTTPRequest{
    URL:  "https://api.example.com/auth",
    Body: `{"login":"x","pass":"y"}`,
    Headers: map[string]string{"Content-Type": "application/json"},
})

url := lampac.ProxyURL("https://cdn.example.com/movie.m3u8", lampac.ProxyOpts{
    Plugin:  "hello",                              // опционально
    Headers: map[string]string{"Origin": "..."},   // headers для upstream
})
// url == "https://lampac-host/proxy/<aes-blob>"

lampac.CacheSet("user:42", []byte(`{"name":"alice"}`), 60) // ttl 60 сек
val, ok := lampac.CacheGet("user:42")                       // []byte, bool

inv := lampac.ReadInvocation(ptr, length)
// inv.Query, inv.Headers, inv.Host, inv.RequestIP,
// inv.Path, inv.Life, inv.Checksearch, inv.UserAgent, inv.Config

var cfg struct {
    APIHost string `json:"apiHost"`
    Token   string `json:"token"`
}
_ = json.Unmarshal(inv.Config, &cfg)

return lampac.WriteResponse(jsonBytes)         // плагин владеет lifecycle памяти

package main

import (
    "encoding/json"
    "fmt"

    "lampac.cc/sdk/lampac"
)

func main() {}

type cfg struct {
    APIHost string `json:"apiHost"`
}

//export handle
func handle(ptr, length uint32) uint64 {
    inv := lampac.ReadInvocation(ptr, length)

    var c cfg
    _ = json.Unmarshal(inv.Config, &c)

    id := inv.Query["id"]
    if id == "" {
        return lampac.WriteResponse([]byte(`{"data":[]}`))
    }

    cacheKey := "movie:" + id
    if v, ok := lampac.CacheGet(cacheKey); ok {
        return lampac.WriteResponse(v) // hit — отдаём без HTTP
    }

    resp, err := lampac.HTTPGet(lampac.HTTPRequest{
        URL: fmt.Sprintf("%s/api/movies/%s", c.APIHost, id),
    })
    if err != nil || resp.Status != 200 {
        return lampac.WriteResponse([]byte(`{"data":[],"rch":false}`))
    }

    lampac.CacheSet(cacheKey, resp.Body, 600)
    return lampac.WriteResponse(resp.Body)
}