Files
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

84 lines
2.8 KiB
Go

// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
// See LICENSE.txt for license information.
package sqlstore
import (
"database/sql"
"testing"
"time"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"github.com/hanzoteam/server/server/public/model"
"github.com/hanzoteam/server/server/public/shared/request"
"github.com/hanzoteam/server/server/v8/channels/store"
)
func TestGetDiagnostics(t *testing.T) {
StoreTest(t, func(t *testing.T, rctx request.CTX, ss store.Store) {
sqlStore := ss.(*SqlStore)
diagnostics, err := sqlStore.GetDiagnostics(rctx)
require.NoError(t, err)
require.NotNil(t, diagnostics)
// Pool stats are populated for every supported driver.
assert.GreaterOrEqual(t, diagnostics.MasterConnectionsInUse, 0)
assert.GreaterOrEqual(t, diagnostics.MasterConnectionsIdle, 0)
if sqlStore.DriverName() != model.DatabaseDriverPostgres {
assert.Nil(t, diagnostics.CacheHitRatio)
return
}
require.NotNil(t, diagnostics.CacheHitRatio)
assert.GreaterOrEqual(t, *diagnostics.CacheHitRatio, 0.0)
assert.LessOrEqual(t, *diagnostics.CacheHitRatio, 1.0)
require.NotNil(t, diagnostics.Deadlocks)
require.NotNil(t, diagnostics.TempFiles)
require.NotNil(t, diagnostics.TempBytesMB)
require.NotNil(t, diagnostics.Rollbacks)
require.NotNil(t, diagnostics.IdleInTransactionCount)
require.NotNil(t, diagnostics.LongestQueryDurationSeconds)
require.NotNil(t, diagnostics.WaitingForLockCount)
})
}
func TestApplyDBPoolStats(t *testing.T) {
diagnostics := &store.DatabaseDiagnostics{}
applyDBPoolStats(
diagnostics,
sql.DBStats{
InUse: 3,
Idle: 7,
WaitCount: 11,
WaitDuration: 2*time.Second + 25*time.Millisecond,
MaxIdleClosed: 13,
MaxLifetimeClosed: 17,
},
sql.DBStats{
InUse: 5,
Idle: 9,
WaitCount: 19,
WaitDuration: 4*time.Second + 90*time.Millisecond,
MaxIdleClosed: 23,
MaxLifetimeClosed: 29,
},
)
assert.Equal(t, 3, diagnostics.MasterConnectionsInUse)
assert.Equal(t, 7, diagnostics.MasterConnectionsIdle)
assert.Equal(t, int64(11), diagnostics.MasterPoolWaitCount)
assert.Equal(t, int64(2025), diagnostics.MasterPoolWaitDurationMs)
assert.Equal(t, int64(13), diagnostics.MasterConnectionsClosedMaxIdle)
assert.Equal(t, int64(17), diagnostics.MasterConnectionsClosedMaxLifetime)
assert.Equal(t, 5, diagnostics.ReplicaConnectionsInUse)
assert.Equal(t, 9, diagnostics.ReplicaConnectionsIdle)
assert.Equal(t, int64(19), diagnostics.ReplicaPoolWaitCount)
assert.Equal(t, int64(4090), diagnostics.ReplicaPoolWaitDurationMs)
assert.Equal(t, int64(23), diagnostics.ReplicaConnectionsClosedMaxIdle)
assert.Equal(t, int64(29), diagnostics.ReplicaConnectionsClosedMaxLifetime)
}