mirror of
https://github.com/hanzoai/team.git
synced 2026-09-30 01:57:35 +00:00
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.
84 lines
2.8 KiB
Go
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)
|
|
}
|