send mq node delete update before deleting node

logic/nodes.go

@@ -476,12 +476,6 @@ func DeleteExpiredNodes(ctx context.Context, peerUpdate chan *models.Node) {
 			}
 			for _, node := range allnodes {
 				if time.Now().After(node.ExpirationDateTime) {
-					if err := DeleteNode(&node, true); err != nil {
-						slog.Error("error deleting expired node", "nodeid", node.ID.String(), "error", err.Error())
-						continue
-					}
-					node.Action = models.NODE_DELETE
-					node.PendingDelete = true
 					peerUpdate <- &node
 					slog.Info("deleting expired node", "nodeid", node.ID.String())
 				}

main.go

@@ -172,9 +172,14 @@ func runMessageQueue(wg *sync.WaitGroup, ctx context.Context) {
 				continue
 			}
 			node := nodeUpdate
+			node.Action = models.NODE_DELETE
+			node.PendingDelete = true
 			if err := mq.NodeUpdate(node); err != nil {
 				logger.Log(0, "failed to send peer update for deleted node: ", node.ID.String(), err.Error())
 			}
+			if err := logic.DeleteNode(node, true); err != nil {
+				slog.Error("error deleting expired node", "nodeid", node.ID.String(), "error", err.Error())
+			}
 			go mq.PublishDeletedNodePeerUpdate(node)
 		}
 	}()