mirror of
https://github.com/hanzoai/team.git
synced 2026-09-30 01:57:35 +00:00
zeekay
8feb24ea1f
The server module named github.com/hanzoai/team/server/v8 — a path that resolves to the retired workspace's repository, not this one — while server/public still published github.com/mattermost/mattermost/server/public. Both are github.com/hanzoteam/server/... now, which is where this code actually lives. That second half is what made the binary unbootable. Upstream's public path stayed claimed by upstream, mattermost-plugin-ai imported it, and the build linked public/model twice; public/plugin's gob.Register then ran twice under one name and panicked at init, before main. Reverting the rename traded the brand for a working binary. Rebranding the plugin alongside it needs no such trade: the agents fork is github.com/hanzoteam/agents/v2 against our public module, so no module named mattermost/mattermost is in the graph at all. Measured: `go list -deps ./cmd/mattermost` names exactly one public/model, and it is ours.
86 lines
2.4 KiB
Go
86 lines
2.4 KiB
Go
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
package plugintest_test
|
|
|
|
import (
|
|
"context"
|
|
"os"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
|
|
goPlugin "github.com/hashicorp/go-plugin"
|
|
"github.com/hanzoteam/server/server/public/model"
|
|
"github.com/hanzoteam/server/server/public/plugin"
|
|
)
|
|
|
|
type UnitTestedPlugin struct {
|
|
plugin.MattermostPlugin
|
|
}
|
|
|
|
// This example demonstrates a plugin that's launched during a unit test and reattached to an
|
|
// existing server instance to obtain a real PluginAPI.
|
|
func Example_unitTestingPlugins() {
|
|
t := &testing.T{}
|
|
|
|
// The manifest is usually generated dynamically.
|
|
manifest := &model.Manifest{
|
|
Id: "reattach-plugin-test",
|
|
}
|
|
|
|
// ctx, and specifically cancel, gives us control over the plugin lifecycle
|
|
ctx, cancel := context.WithCancel(context.Background())
|
|
|
|
// reattachConfigCh is the means by which we get the Unix socket information to relay back
|
|
// to the server and finish the reattachment.
|
|
reattachConfigCh := make(chan *goPlugin.ReattachConfig)
|
|
|
|
// closeCh tells us when the plugin exits and allows for cleanup.
|
|
closeCh := make(chan struct{})
|
|
|
|
// plugin.ClientMain with options allows for reattachment.
|
|
go plugin.ClientMain(
|
|
&UnitTestedPlugin{},
|
|
plugin.WithTestContext(ctx),
|
|
plugin.WithTestReattachConfigCh(reattachConfigCh),
|
|
plugin.WithTestCloseCh(closeCh),
|
|
)
|
|
|
|
// Make sure the plugin shuts down normally with the test
|
|
t.Cleanup(func() {
|
|
cancel()
|
|
|
|
select {
|
|
case <-closeCh:
|
|
case <-time.After(5 * time.Second):
|
|
panic("plugin failed to close after 5 seconds")
|
|
}
|
|
})
|
|
|
|
// Wait for the plugin to start and then reattach to the server.
|
|
var reattachConfig *goPlugin.ReattachConfig
|
|
select {
|
|
case reattachConfig = <-reattachConfigCh:
|
|
case <-time.After(5 * time.Second):
|
|
t.Fatal("failed to get reattach config")
|
|
}
|
|
|
|
// Reattaching requires a local mode client.
|
|
socketPath := os.Getenv("MM_LOCALSOCKETPATH")
|
|
if socketPath == "" {
|
|
socketPath = model.LocalModeSocketPath
|
|
}
|
|
|
|
clientLocal := model.NewAPIv4SocketClient(socketPath)
|
|
_, err := clientLocal.ReattachPlugin(ctx, &model.PluginReattachRequest{
|
|
Manifest: manifest,
|
|
PluginReattachConfig: model.NewPluginReattachConfig(reattachConfig),
|
|
})
|
|
require.NoError(t, err)
|
|
|
|
// At this point, the plugin is ready for unit testing and will be cleaned up automatically
|
|
// with the testing.T instance.
|
|
}
|