From 024dddf5a87aec69d08402d36f7210a699e458d7 Mon Sep 17 00:00:00 2001
From: vadym <vadym.vikulin@gmail.com>
Date: Mon, 12 Dec 2022 20:26:07 +0200
Subject: [PATCH] fixed removepeers command

---
 src/core/api.go | 17 ++++++++++++-----
 1 file changed, 12 insertions(+), 5 deletions(-)

diff --git a/src/core/api.go b/src/core/api.go
index b1742523..059e46a0 100644
--- a/src/core/api.go
+++ b/src/core/api.go
@@ -234,11 +234,18 @@ func (c *Core) RemovePeer(uri string, sourceInterface string) error {
 }
 
 func (c *Core) RemovePeers() error {
-	c.config._peers = map[Peer]*linkInfo{}
-	//for k := range c.config.InterfacePeers {
-	//	delete(c.config.InterfacePeers, k)
-	//}
-
+	phony.Block(c, func() {
+		for peer, linkInfo := range c.config._peers {
+			if linkInfo != nil {
+				c.links.Act(nil, func() {
+					if link := c.links._links[*linkInfo]; link != nil {
+						_ = link.close()
+					}
+				})
+			}
+			delete(c.config._peers, peer)
+		}
+	})
 	return nil
 }