clear unix addr before sever startup

Author: Reasno

example/main.php

@@ -9,6 +9,7 @@
  * @contact  [email protected]
  * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
  */
+
 use Hyperf\GoTask\GoTask;
 use Hyperf\GoTask\IPC\SocketIPCSender;
 use Swoole\Process;

pkg/gotask/server.go

@@ -70,10 +70,14 @@ func Run() error {
 
 	if *address != "" {
 		network, addr := parseAddr(*address)
+		if err := clearAddr(network, addr); err != nil {
+			return errors.Wrap(err, "Cannot remove existing unix socket")
+		}
 		ln, err := net.Listen(network, addr)
 		if err != nil {
 			return errors.Wrap(err, "Unable to listen")
 		}
+
 		g.Add(func() error {
 			for {
 				conn, err := ln.Accept()
@@ -121,6 +125,16 @@ func Run() error {
 	return g.Run()
 }
 
+func clearAddr(network string, addr string) error {
+	if network != "unix" {
+		return nil
+	}
+	if _, err := os.Stat(addr); os.IsNotExist(err) {
+		return nil
+	}
+	return os.Remove(addr)
+}
+
 // Add an actor (function) to the group. Each actor must be pre-emptable by an
 // interrupt function. That is, if interrupt is invoked, execute should return.
 // Also, it must be safe to call interrupt even after execute has returned.

pkg/gotask/server_test.go

@@ -0,0 +1,28 @@
+package gotask
+
+import (
+	"log"
+	"os"
+	"testing"
+)
+
+func TestClearAddr(t *testing.T) {
+	if err := clearAddr("unix", "/tmp/non-exist.sock"); err != nil {
+		t.Errorf("clearAddr should not return error for non-exist files")
+	}
+	if err := clearAddr("tcp", "127.0.0.1:6000"); err != nil {
+		t.Errorf("clearAddr should not return error for tcp ports")
+	}
+	file, err := os.Create("/tmp/temp.sock")
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer file.Close()
+	if err := clearAddr("unix", "/tmp/temp.sock"); err != nil {
+		t.Errorf("clearAddr should be able to clear unix socket")
+	}
+	_, err = os.Stat("/tmp/temp.sock")
+	if !os.IsNotExist(err) {
+		t.Errorf("unix socket are not cleared, %v", err)
+	}
+}