| 42 | ) |
| 43 | |
| 44 | func publishPeerUpdate(ctx context.Context, ps pubsub.Pubsub, logger slog.Logger, peerID uuid.UUID) { |
| 45 | if err := ps.Publish(eventPeerUpdate, []byte(peerID.String())); err != nil { |
| 46 | logger.Warn(ctx, "failed to publish peer update", slog.F("peer_id", peerID), slog.Error(err)) |
| 47 | } |
| 48 | } |
| 49 | |
| 50 | func publishTunnelUpdate(ctx context.Context, ps pubsub.Pubsub, logger slog.Logger, srcID, dstID uuid.UUID) { |
| 51 | if err := ps.Publish(eventTunnelUpdate, []byte(srcID.String()+","+dstID.String())); err != nil { |