Skip to content

Commit 35efa59

Browse files
committed
Requested changes.
1 parent cc967e9 commit 35efa59

File tree

1 file changed

+19
-10
lines changed

1 file changed

+19
-10
lines changed

core/commands/swarm.go

Lines changed: 19 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,7 @@ var swarmPeeringAddCmd = &cmds.Command{
143143
save, _ := req.Options[swarmSaveOptionName].(bool)
144144
if save {
145145
update := func(cfg *config.Config) {
146-
cfg.Peering.Peers = node.Peering.ListPeers()
146+
cfg.Peering.Peers = append(cfg.Peering.Peers, addInfos...)
147147
}
148148
err := updateAndPersistConfig(env, update)
149149
if err != nil {
@@ -231,16 +231,25 @@ var swarmPeeringRmCmd = &cmds.Command{
231231
if err = res.Emit(peeringResult{id, "success"}); err != nil {
232232
return err
233233
}
234-
}
235234

236-
save, _ := req.Options[swarmSaveOptionName].(bool)
237-
if save {
238-
update := func(cfg *config.Config) {
239-
cfg.Peering.Peers = node.Peering.ListPeers()
240-
}
241-
err := updateAndPersistConfig(env, update)
242-
if err != nil {
243-
return fmt.Errorf("unable to update and persist config change: %w", err)
235+
save, _ := req.Options[swarmSaveOptionName].(bool)
236+
if save {
237+
update := func(cfg *config.Config) {
238+
var cfgOut []peer.AddrInfo
239+
for _, p := range cfg.Peering.Peers {
240+
if p.ID == id {
241+
continue
242+
}
243+
cfgOut = append(cfgOut, p)
244+
}
245+
246+
cfg.Peering.Peers = cfgOut
247+
}
248+
249+
err := updateAndPersistConfig(env, update)
250+
if err != nil {
251+
return fmt.Errorf("unable to update and persist config change: %w", err)
252+
}
244253
}
245254
}
246255

0 commit comments

Comments
 (0)