plugin v2 preview

.github/workflows/test.yml

@@ -0,0 +1,33 @@
+name: Test
+
+on:
+  push:
+    branches:
+      - main
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - name: Set up Go
+        uses: actions/setup-go@v4
+        with:
+          go-version: 1.24.6
+      - name: Install dependencies
+        run: go mod download
+      - name: Test
+        run: cd v2 && go test -v ./...
+
+  test-windows:
+    runs-on: windows-latest
+    steps:
+      - uses: actions/checkout@v4
+      - name: Set up Go
+        uses: actions/setup-go@v4
+        with:
+          go-version: 1.24.6
+      - name: Install dependencies
+        run: go mod download
+      - name: Test
+        run: cd v2 && go test -v ./...

v2/cli_flags.go

@@ -0,0 +1,75 @@
+package plugin
+
+import (
+	"flag"
+	"os"
+	"strconv"
+	"strings"
+)
+
+type PluginCliFlags struct {
+	flagSet     *flag.FlagSet
+	KexReqFile  *os.File
+	KexRespFile *os.File
+	Debug       bool
+}
+
+func ParsePluginCLIFlags(args []string) (*PluginCliFlags, error) {
+	flagSet := flag.NewFlagSet(os.Args[0], flag.ContinueOnError)
+	var kexReqFileName string
+	var kexRespFileName string
+	var debug bool
+	flagSet.StringVar(&kexReqFileName, "kex-req-file", "", "File name for the key exchange for Transport Auth. /proc/self/fd/* can be used to open a file descriptor cross platform.")
+	flagSet.StringVar(&kexRespFileName, "kex-resp-file", "", "File name for the key exchange for Transport Auth. /proc/self/fd/* can be used to open a file descriptor cross platform.")
+	flagSet.BoolVar(&debug, "debug", false, "Enable debug mode.")
+	flagSet.Parse(args)
+
+	var kexReqFile *os.File
+	var kexRespFile *os.File
+	var err error
+
+	if fdNumber, found := strings.CutPrefix(kexReqFileName, "/proc/self/fd/"); found {
+		fdNumber, err := strconv.ParseUint(fdNumber, 10, 64)
+		kexReqFile = os.NewFile(uintptr(fdNumber), kexReqFileName)
+		if err != nil {
+			return nil, err
+		}
+	} else {
+		kexReqFile, err = os.OpenFile(kexReqFileName, os.O_WRONLY, 0)
+		if err != nil {
+			return nil, err
+		}
+	}
+	if fdNumber, found := strings.CutPrefix(kexRespFileName, "/proc/self/fd/"); found {
+		fdNumber, err := strconv.ParseUint(fdNumber, 10, 64)
+		kexRespFile = os.NewFile(uintptr(fdNumber), kexRespFileName)
+		if err != nil {
+			return nil, err
+		}
+	} else {
+		kexRespFile, err = os.OpenFile(kexRespFileName, os.O_RDONLY, 0)
+		if err != nil {
+			return nil, err
+		}
+	}
+
+	if err != nil {
+		return nil, err
+	}
+	return &PluginCliFlags{
+		flagSet:     flagSet,
+		KexReqFile:  kexReqFile,
+		KexRespFile: kexRespFile,
+		Debug:       debug,
+	}, nil
+}
+
+func (f *PluginCliFlags) Close() error {
+	if err := f.KexReqFile.Close(); err != nil {
+		return err
+	}
+	if err := f.KexRespFile.Close(); err != nil {
+		return err
+	}
+	return nil
+}

v2/examples_v1/echo/echo.go

@@ -0,0 +1,120 @@
+package main
+
+import (
+	"encoding/json"
+	"fmt"
+	"log"
+	"net/url"
+
+	"github.com/gin-gonic/gin"
+	"github.com/gotify/plugin-api"
+)
+
+// GetGotifyPluginInfo returns gotify plugin info.
+func GetGotifyPluginInfo() plugin.Info {
+	return plugin.Info{
+		ModulePath: "github.com/gotify/server/v2/plugin/example/echo",
+		Name:       "test plugin",
+	}
+}
+
+// EchoPlugin is the gotify plugin instance.
+type EchoPlugin struct {
+	msgHandler     plugin.MessageHandler
+	storageHandler plugin.StorageHandler
+	config         *Config
+	basePath       string
+}
+
+// SetStorageHandler implements plugin.Storager
+func (c *EchoPlugin) SetStorageHandler(h plugin.StorageHandler) {
+	c.storageHandler = h
+}
+
+// SetMessageHandler implements plugin.Messenger.
+func (c *EchoPlugin) SetMessageHandler(h plugin.MessageHandler) {
+	c.msgHandler = h
+}
+
+// Storage defines the plugin storage scheme
+type Storage struct {
+	CalledTimes int `json:"called_times"`
+}
+
+// Config defines the plugin config scheme
+type Config struct {
+	MagicString string `yaml:"magic_string"`
+}
+
+// DefaultConfig implements plugin.Configurer
+func (c *EchoPlugin) DefaultConfig() interface{} {
+	return &Config{
+		MagicString: "hello world",
+	}
+}
+
+// ValidateAndSetConfig implements plugin.Configurer
+func (c *EchoPlugin) ValidateAndSetConfig(config interface{}) error {
+	c.config = config.(*Config)
+	return nil
+}
+
+// Enable enables the plugin.
+func (c *EchoPlugin) Enable() error {
+	log.Println("echo plugin enabled")
+	return nil
+}
+
+// Disable disables the plugin.
+func (c *EchoPlugin) Disable() error {
+	log.Println("echo plugin disbled")
+	return nil
+}
+
+// RegisterWebhook implements plugin.Webhooker.
+func (c *EchoPlugin) RegisterWebhook(baseURL string, g *gin.RouterGroup) {
+	c.basePath = baseURL
+	g.GET("/echo", func(ctx *gin.Context) {
+
+		storage, _ := c.storageHandler.Load()
+		conf := new(Storage)
+		json.Unmarshal(storage, conf)
+		conf.CalledTimes++
+		newStorage, _ := json.Marshal(conf)
+		c.storageHandler.Save(newStorage)
+
+		c.msgHandler.SendMessage(plugin.Message{
+			Title:    "Hello received",
+			Message:  fmt.Sprintf("echo server received a hello message %d times", conf.CalledTimes),
+			Priority: 2,
+			Extras: map[string]any{
+				"plugin::name": "echo",
+			},
+		})
+		ctx.Writer.WriteString(fmt.Sprintf("Magic string is: %s\r\nEcho server running at %secho", c.config.MagicString, c.basePath))
+	})
+}
+
+// GetDisplay implements plugin.Displayer.
+func (c *EchoPlugin) GetDisplay(location *url.URL) string {
+	loc := &url.URL{
+		Path: c.basePath,
+	}
+	if location != nil {
+		loc.Scheme = location.Scheme
+		loc.Host = location.Host
+	}
+	loc = loc.ResolveReference(&url.URL{
+		Path: "echo",
+	})
+	return "Echo plugin running at: " + loc.String()
+}
+
+// NewGotifyPluginInstance creates a plugin instance for a user context.
+func NewGotifyPluginInstance(ctx plugin.UserContext) plugin.Plugin {
+	return &EchoPlugin{}
+}
+
+func main() {
+	panic("this should be built as go plugin")
+}