From cfe758bce9d563e03690b2461d3c6c2bb1d4a9fb Mon Sep 17 00:00:00 2001
From: Runxi Yu <me@runxiyu.org>
Date: Sun, 17 Aug 2025 14:04:18 +0800
Subject: [PATCH] Fix incoming's calls to misc.Listen*

---
 forged/internal/incoming/hooks/hooks.go | 2 +-
 forged/internal/incoming/lmtp/lmtp.go   | 2 +-
 forged/internal/incoming/ssh/ssh.go     | 2 +-
 forged/internal/incoming/web/web.go     | 2 +-

diff --git a/forged/internal/incoming/hooks/hooks.go b/forged/internal/incoming/hooks/hooks.go
index 65277d4ca2f070ab8ab64c9ce0c014bf74593f99..4400b617b452f50225858ace8a055f71dd7f4f7f 100644
--- a/forged/internal/incoming/hooks/hooks.go
+++ b/forged/internal/incoming/hooks/hooks.go
@@ -45,7 +45,7 @@ 	}
 }
 
 func (server *Server) Run(ctx context.Context) error {
-	listener, _, err := misc.ListenUnixSocket(server.socketPath)
+	listener, _, err := misc.ListenUnixSocket(ctx, server.socketPath)
 	if err != nil {
 		return fmt.Errorf("listen unix socket for hooks: %w", err)
 	}
diff --git a/forged/internal/incoming/lmtp/lmtp.go b/forged/internal/incoming/lmtp/lmtp.go
index cf5618cbc2052486248cc0d36f13919edacedc93..429ff20be4c2b8af26583902558e77c4cc46824d 100644
--- a/forged/internal/incoming/lmtp/lmtp.go
+++ b/forged/internal/incoming/lmtp/lmtp.go
@@ -37,7 +37,7 @@ 	}
 }
 
 func (server *Server) Run(ctx context.Context) error {
-	listener, _, err := misc.ListenUnixSocket(server.socket)
+	listener, _, err := misc.ListenUnixSocket(ctx, server.socket)
 	if err != nil {
 		return fmt.Errorf("listen unix socket for LMTP: %w", err)
 	}
diff --git a/forged/internal/incoming/ssh/ssh.go b/forged/internal/incoming/ssh/ssh.go
index e55186300de6c098a63eadc0ee4501b27d6824e4..a0cce5ed66f5bb5f0e5302cddb2ddc9ca85de11c 100644
--- a/forged/internal/incoming/ssh/ssh.go
+++ b/forged/internal/incoming/ssh/ssh.go
@@ -65,7 +65,7 @@ 	return server, nil
 }
 
 func (server *Server) Run(ctx context.Context) (err error) {
-	listener, err := misc.Listen(server.net, server.addr)
+	listener, err := misc.Listen(ctx, server.net, server.addr)
 	if err != nil {
 		return fmt.Errorf("listen for SSH: %w", err)
 	}
diff --git a/forged/internal/incoming/web/web.go b/forged/internal/incoming/web/web.go
index fb5bedc48d735b2063f36b9a6068fc9538668176..5c9501303d74c6927d820541ccf45f40e230c967 100644
--- a/forged/internal/incoming/web/web.go
+++ b/forged/internal/incoming/web/web.go
@@ -57,7 +57,7 @@
 func (server *Server) Run(ctx context.Context) (err error) {
 	server.httpServer.BaseContext = func(_ net.Listener) context.Context { return ctx }
 
-	listener, err := misc.Listen(server.net, server.addr)
+	listener, err := misc.Listen(ctx, server.net, server.addr)
 	if err != nil {
 		return fmt.Errorf("listen for web: %w", err)
 	}

-- 
2.48.1