mirror of
https://github.com/henrygd/beszel.git
synced 2025-12-17 10:46:16 +01:00
402a1584d7
- Add version exchange between hub and agent. - Introduce ConnectionManager for managing WebSocket and SSH connections. - Implement fingerprint generation and storage in agent. - Create expiry map package to store universal tokens. - Update config.yml configuration to include tokens. - Enhance system management with new methods for handling system states and alerts. - Update front-end components to support token / fingerprint management features. - Introduce utility functions for token generation and hub URL retrieval. Co-authored-by: nhas <jordanatararimu@gmail.com>
103 lines
2.8 KiB
Go
103 lines
2.8 KiB
Go
//go:build testing
|
|
// +build testing
|
|
|
|
package systems
|
|
|
|
import (
|
|
entities "beszel/internal/entities/system"
|
|
"context"
|
|
"fmt"
|
|
)
|
|
|
|
// TESTING ONLY: GetSystemCount returns the number of systems in the store
|
|
func (sm *SystemManager) GetSystemCount() int {
|
|
return sm.systems.Length()
|
|
}
|
|
|
|
// TESTING ONLY: HasSystem checks if a system with the given ID exists in the store
|
|
func (sm *SystemManager) HasSystem(systemID string) bool {
|
|
return sm.systems.Has(systemID)
|
|
}
|
|
|
|
// TESTING ONLY: GetSystemStatusFromStore returns the status of a system with the given ID
|
|
// Returns an empty string if the system doesn't exist
|
|
func (sm *SystemManager) GetSystemStatusFromStore(systemID string) string {
|
|
sys, ok := sm.systems.GetOk(systemID)
|
|
if !ok {
|
|
return ""
|
|
}
|
|
return sys.Status
|
|
}
|
|
|
|
// TESTING ONLY: GetSystemContextFromStore returns the context and cancel function for a system
|
|
func (sm *SystemManager) GetSystemContextFromStore(systemID string) (context.Context, context.CancelFunc, error) {
|
|
sys, ok := sm.systems.GetOk(systemID)
|
|
if !ok {
|
|
return nil, nil, fmt.Errorf("no system")
|
|
}
|
|
return sys.ctx, sys.cancel, nil
|
|
}
|
|
|
|
// TESTING ONLY: GetSystemFromStore returns a store from the system
|
|
func (sm *SystemManager) GetSystemFromStore(systemID string) (*System, error) {
|
|
sys, ok := sm.systems.GetOk(systemID)
|
|
if !ok {
|
|
return nil, fmt.Errorf("no system")
|
|
}
|
|
return sys, nil
|
|
}
|
|
|
|
// TESTING ONLY: GetAllSystemIDs returns a slice of all system IDs in the store
|
|
func (sm *SystemManager) GetAllSystemIDs() []string {
|
|
data := sm.systems.GetAll()
|
|
ids := make([]string, 0, len(data))
|
|
for id := range data {
|
|
ids = append(ids, id)
|
|
}
|
|
return ids
|
|
}
|
|
|
|
// TESTING ONLY: GetSystemData returns the combined data for a system with the given ID
|
|
// Returns nil if the system doesn't exist
|
|
// This method is intended for testing
|
|
func (sm *SystemManager) GetSystemData(systemID string) *entities.CombinedData {
|
|
sys, ok := sm.systems.GetOk(systemID)
|
|
if !ok {
|
|
return nil
|
|
}
|
|
return sys.data
|
|
}
|
|
|
|
// TESTING ONLY: GetSystemHostPort returns the host and port for a system with the given ID
|
|
// Returns empty strings if the system doesn't exist
|
|
func (sm *SystemManager) GetSystemHostPort(systemID string) (string, string) {
|
|
sys, ok := sm.systems.GetOk(systemID)
|
|
if !ok {
|
|
return "", ""
|
|
}
|
|
return sys.Host, sys.Port
|
|
}
|
|
|
|
// TESTING ONLY: SetSystemStatusInDB sets the status of a system directly and updates the database record
|
|
// This is intended for testing
|
|
// Returns false if the system doesn't exist
|
|
func (sm *SystemManager) SetSystemStatusInDB(systemID string, status string) bool {
|
|
if !sm.HasSystem(systemID) {
|
|
return false
|
|
}
|
|
|
|
// Update the database record
|
|
record, err := sm.hub.FindRecordById("systems", systemID)
|
|
if err != nil {
|
|
return false
|
|
}
|
|
|
|
record.Set("status", status)
|
|
err = sm.hub.Save(record)
|
|
if err != nil {
|
|
return false
|
|
}
|
|
|
|
return true
|
|
}
|