From 6da9e99a221c814c50804783c598ec12f78e38d8 Mon Sep 17 00:00:00 2001
From: Runxi Yu <me@runxiyu.org>
Date: Sun, 17 Aug 2025 03:43:08 +0800
Subject: Add some stubs

---
 forged/internal/common/misc/net.go | 38 ++++++++++++++++++++++++++++++++++++++
 1 file changed, 38 insertions(+)
 create mode 100644 forged/internal/common/misc/net.go

(limited to 'forged/internal/common/misc/net.go')

diff --git a/forged/internal/common/misc/net.go b/forged/internal/common/misc/net.go
new file mode 100644
index 0000000..2c6b0a5
--- /dev/null
+++ b/forged/internal/common/misc/net.go
@@ -0,0 +1,38 @@
+package misc
+
+import (
+	"errors"
+	"fmt"
+	"net"
+	"syscall"
+)
+
+func ListenUnixSocket(path string) (listener net.Listener, replaced bool, err error) {
+	listener, err = net.Listen("unix", path)
+	if errors.Is(err, syscall.EADDRINUSE) {
+		replaced = true
+		if unlinkErr := syscall.Unlink(path); unlinkErr != nil {
+			return listener, false, fmt.Errorf("remove existing socket %q: %w", path, unlinkErr)
+		}
+		listener, err = net.Listen("unix", path)
+	}
+	if err != nil {
+		return listener, replaced, fmt.Errorf("listen on unix socket %q: %w", path, err)
+	}
+	return listener, replaced, nil
+}
+
+func Listen(net_, addr string) (listener net.Listener, err error) {
+	if net_ == "unix" {
+		listener, _, err = ListenUnixSocket(addr)
+		if err != nil {
+			return listener, fmt.Errorf("listen unix socket for web: %w", err)
+		}
+	} else {
+		listener, err = net.Listen(net_, addr)
+		if err != nil {
+			return listener, fmt.Errorf("listen %s for web: %w", net_, err)
+		}
+	}
+	return listener, nil
+}
-- 
cgit v1.2.3