mirror of
https://github.com/h44z/wg-portal.git
synced 2025-08-12 16:22:23 +00:00
do not delete disabled mikrotik peers on app restart
This commit is contained in:
parent
a9f5190ab4
commit
5dee6d051d
@ -11,6 +11,7 @@ import (
|
|||||||
|
|
||||||
"github.com/h44z/wg-portal/internal/app"
|
"github.com/h44z/wg-portal/internal/app"
|
||||||
"github.com/h44z/wg-portal/internal/app/audit"
|
"github.com/h44z/wg-portal/internal/app/audit"
|
||||||
|
"github.com/h44z/wg-portal/internal/config"
|
||||||
"github.com/h44z/wg-portal/internal/domain"
|
"github.com/h44z/wg-portal/internal/domain"
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -267,18 +268,12 @@ func (m Manager) RestoreInterfaceState(
|
|||||||
// restore peers
|
// restore peers
|
||||||
for _, peer := range peers {
|
for _, peer := range peers {
|
||||||
switch {
|
switch {
|
||||||
case iface.IsDisabled(): // if interface is disabled, delete all peers
|
case iface.IsDisabled() && iface.Backend == config.LocalBackendName: // if interface is disabled, delete all peers
|
||||||
if err := m.wg.GetController(iface).DeletePeer(ctx, iface.Identifier,
|
if err := m.wg.GetController(iface).DeletePeer(ctx, iface.Identifier,
|
||||||
peer.Identifier); err != nil {
|
peer.Identifier); err != nil {
|
||||||
return fmt.Errorf("failed to remove peer %s for disabled interface %s: %w",
|
return fmt.Errorf("failed to remove peer %s for disabled interface %s: %w",
|
||||||
peer.Identifier, iface.Identifier, err)
|
peer.Identifier, iface.Identifier, err)
|
||||||
}
|
}
|
||||||
case peer.IsDisabled(): // if peer is disabled, delete it
|
|
||||||
if err := m.wg.GetController(iface).DeletePeer(ctx, iface.Identifier,
|
|
||||||
peer.Identifier); err != nil {
|
|
||||||
return fmt.Errorf("failed to remove disbaled peer %s from interface %s: %w",
|
|
||||||
peer.Identifier, iface.Identifier, err)
|
|
||||||
}
|
|
||||||
default: // update peer
|
default: // update peer
|
||||||
err := m.wg.GetController(iface).SavePeer(ctx, iface.Identifier, peer.Identifier,
|
err := m.wg.GetController(iface).SavePeer(ctx, iface.Identifier, peer.Identifier,
|
||||||
func(pp *domain.PhysicalPeer) (*domain.PhysicalPeer, error) {
|
func(pp *domain.PhysicalPeer) (*domain.PhysicalPeer, error) {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user