fix(removeQueue): add panic recovery and double-check for outbound removal (#80)

* fix(removeQueue): add panic recovery and double-check for outbound removal

* remove tag from pending if already removed

Author: garmr-ulfr

adapter/groups/manager.go

@@ -306,13 +306,24 @@ func (rq *removalQueue) checkPending() {
 	}
 
 	if len(toRemove) > 0 {
+		defer func() {
+			if err := recover(); err != nil {
+				rq.logger.Error("panic during outbound/endpoint removal", "error", err)
+			}
+		}()
 		rq.mu.Lock()
 		defer rq.mu.Unlock()
 		for _, tag := range toRemove {
 			item, exists := rq.pending[tag]
 			if !exists {
 				continue
 			}
+			// double check if outbound/endpoint still exists
+			if _, exists = rq.outMgr.Outbound(tag); !exists {
+				rq.logger.Trace("outbound already removed", "tag", tag)
+				delete(rq.pending, tag)
+				continue
+			}
 			rq.logger.Debug("removing outbound", "tag", tag)
 			if item.isEndpoint {
 				rq.epMgr.Remove(tag)