GitRoot

 1// SPDX-FileCopyrightText: 2025 Romain Maneschi <romain@gitroot.dev>
 2//
 3// SPDX-License-Identifier: EUPL-1.2
 4
 5package plugin
 6
 7import (
 8	"context"
 9	"encoding/json"
10	"fmt"
11
12	"github.com/samber/oops"
13	"github.com/tetratelabs/wazero/api"
14	pluginLib "gitroot.dev/libs/golang/plugin/model"
15	"gitroot.dev/server/logger"
16)
17
18func (r *runtime) conf(ctx context.Context, plugin Plugin) (*pluginLib.ConfPlugin, error) {
19	r.repo = nil
20	r.repoWriter = nil
21	r.plugin = plugin
22	r.command = nil
23	timerStop := r.logger.Time(fmt.Sprintf("Timer %s", plugin.Log()))
24	defer timerStop()
25
26	r.logger.Debug("start plugin conf", logger.NewLoggerPair("name", plugin.Log()))
27
28	m, _, err := r.loadModule(ctx, plugin) //no fs for conf
29	if err != nil {
30		r.logger.Error("loadModule for conf error", err, logger.NewLoggerPair("name", plugin.Log()))
31		return nil, err
32	}
33	defer r.garbage()
34
35	conf, err := r.callPluginForConf(ctx, m, r.logger.NewSubLogger(plugin.Log()))
36	if err != nil {
37		r.logger.Error("finish plugin conf with error", err, logger.NewLoggerPair("name", plugin.Log()))
38	}
39
40	r.logger.Debug("finish plugin conf", logger.NewLoggerPair("name", plugin.Log()))
41	return conf, err
42}
43
44func (r *runtime) callPluginForConf(ctx context.Context, module api.Module, log *logger.Logger) (*pluginLib.ConfPlugin, error) {
45	defaultConf := &pluginLib.ConfPlugin{}
46
47	if pluginConf := module.ExportedFunction("pluginConf"); pluginConf != nil {
48		ptrSizeArr, err := pluginConf.Call(ctx)
49		if err != nil {
50			return nil, oops.Wrapf(err, "pluginConf call")
51		}
52		pluginConfPtr := uint32(ptrSizeArr[0] >> 32)
53		pluginConfSize := uint32(ptrSizeArr[0])
54		if pluginConfPtr != 0 {
55			defer func() {
56				r.free(module, []ptrSize{{ptr: uint64(pluginConfPtr), size: uint64(pluginConfSize)}})
57			}()
58		}
59		res, err := r.readString(module, "read memory conf", pluginConfPtr, pluginConfSize)
60		if err != nil {
61			return nil, oops.Wrapf(err, "can't read memory")
62		}
63		if res != "" {
64			if err = json.Unmarshal([]byte(res), &defaultConf); err != nil {
65				conf, err := r.readASString(module, "read conf", uint32(ptrSizeArr[0]))
66				if err != nil {
67					return nil, oops.Wrapf(err, "can't readASString Configuration")
68				}
69				if err = json.Unmarshal([]byte(conf), &defaultConf); err != nil {
70					return nil, oops.Wrapf(err, "can't unmarshal Configuration")
71				}
72			}
73		}
74	} else {
75		log.Info("plugin has no pluginConf exported function")
76	}
77	for name := range module.ExportedFunctionDefinitions() {
78		log.Info(fmt.Sprintf("plugin has %s function", name))
79	}
80	return defaultConf, nil
81}