Files
team/server/channels/app/ai_bridge_test_helper.go
zeekay 8feb24ea1f One name for this fork, and it is ours
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.
2026-08-28 23:35:36 -07:00

68 lines
1.9 KiB
Go

// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
// See LICENSE.txt for license information.
package app
import (
"net/http"
"github.com/hanzoteam/server/server/public/model"
)
func (a *App) SetAIBridgeTestHelperConfig(config *model.AIBridgeTestHelperConfig) *model.AppError {
bridge, err := newE2EAgentsBridge(config)
if err != nil {
return model.NewAppError("SetAIBridgeTestHelperConfig", "app.ai_bridge_test_helper.invalid_config", nil, err.Error(), http.StatusBadRequest)
}
a.ch.SetAgentsBridge(bridge)
if config.FeatureFlags != nil {
if appErr := a.setAIBridgeTestHelperFeatureFlags(config.FeatureFlags); appErr != nil {
return appErr
}
}
return nil
}
func (a *App) GetAIBridgeTestHelperState() *model.AIBridgeTestHelperState {
var state *model.AIBridgeTestHelperState
if e2e, ok := a.ch.agentsBridge.(*e2eAgentsBridge); ok {
state = e2e.GetState()
} else {
state = &model.AIBridgeTestHelperState{
RecordedRequests: []model.AIBridgeTestHelperRecordedRequest{},
}
}
state.FeatureFlags = &model.AIBridgeTestHelperFeatureFlags{
EnableAIPluginBridge: new(a.Config().FeatureFlags.EnableAIPluginBridge),
EnableAIRecaps: new(a.Config().FeatureFlags.EnableAIRecaps),
}
return state
}
func (a *App) ResetAIBridgeTestHelper() {
a.ch.SetAgentsBridge(newLiveAgentsBridge(a.ch))
}
func (a *App) setAIBridgeTestHelperFeatureFlags(featureFlags *model.AIBridgeTestHelperFeatureFlags) *model.AppError {
configStore := a.Srv().Platform().GetConfigStore()
configStore.SetReadOnlyFF(false)
defer configStore.SetReadOnlyFF(true)
a.UpdateConfig(func(cfg *model.Config) {
if featureFlags.EnableAIPluginBridge != nil {
cfg.FeatureFlags.EnableAIPluginBridge = *featureFlags.EnableAIPluginBridge
}
if featureFlags.EnableAIRecaps != nil {
cfg.FeatureFlags.EnableAIRecaps = *featureFlags.EnableAIRecaps
}
})
return nil
}