viaprog/Sylve
1
0
Fork 0
mirror of https://github.com/AlchemillaHQ/Sylve.git synced 2026-06-15 00:56:36 +03:00
Code Issues Packages Projects Releases Wiki Activity

jail: refactor JailAction to use emitWithFreshState for state refresh

Browse Source
This commit is contained in:
hayzamjs
2026-03-13 15:55:17 +01:00
parent 5cd127f822
commit 3fca631d5a
1 changed files with 16 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/services/jail/action.go
+16 -3
View File
@@ -17,6 +17,7 @@ import (
"github.com/alchemillahq/sylve/internal/config"
clusterModels "github.com/alchemillahq/sylve/internal/db/models/cluster"
jailModels "github.com/alchemillahq/sylve/internal/db/models/jail"
"github.com/alchemillahq/sylve/internal/logger"
clusterService "github.com/alchemillahq/sylve/internal/services/cluster"
"github.com/alchemillahq/sylve/pkg/utils"
)
@@ -63,6 +64,18 @@ func (s *Service) JailAction(ctId int, action string) error {
return nil
}
emitWithFreshState := func(reason string) {
if _, refreshErr := s.refreshLiveStates(); refreshErr != nil {
logger.L.Warn().
Err(refreshErr).
Int("ct_id", ctId).
Str("action", action).
Msg("failed_to_refresh_jail_live_states_after_action")
}
s.emitLeftPanelRefresh(reason)
}
switch action {
case "start":
allowed, leaseErr := s.canMutateProtectedJail(uint(ctId))
@@ -94,7 +107,7 @@ func (s *Service) JailAction(ctId int, action string) error {
if err := s.DB.Save(&jail).Error; err != nil {
return fmt.Errorf("failed to update jail status: %w", err)
}
s.emitLeftPanelRefresh(fmt.Sprintf("jail_start_%d", ctId))
emitWithFreshState(fmt.Sprintf("jail_start_%d", ctId))
return nil
case "stop":
@@ -107,7 +120,7 @@ func (s *Service) JailAction(ctId int, action string) error {
if err := s.DB.Save(&jail).Error; err != nil {
return fmt.Errorf("failed to update jail status: %w", err)
}
s.emitLeftPanelRefresh(fmt.Sprintf("jail_stop_%d", ctId))
emitWithFreshState(fmt.Sprintf("jail_stop_%d", ctId))
return nil
case "restart":
@@ -137,7 +150,7 @@ func (s *Service) JailAction(ctId int, action string) error {
if err := s.DB.Save(&jail).Error; err != nil {
return fmt.Errorf("failed to update jail status: %w", err)
}
s.emitLeftPanelRefresh(fmt.Sprintf("jail_restart_%d", ctId))
emitWithFreshState(fmt.Sprintf("jail_restart_%d", ctId))
return nil
}