removed stew.sock

server.go

@@ -36,8 +36,6 @@ type server struct {
 	natsConn *nats.Conn
 	// net listener for communicating via the steward socket
 	StewardSocket net.Listener
-	// net listener for the communication with Stew
-	StewSocket net.Listener
 	// processes holds all the information about running processes
 	processes *processes
 	// The name of the node
@@ -122,13 +120,6 @@ func NewServer(c *Configuration, version string) (*server, error) {
 		}
 	}
 
-	// Open the stew socket file, and start the listener if enabled.
-	stewSocket, err := createSocket(c.SocketFolder, "stew.sock")
-	if err != nil {
-		cancel()
-		return nil, err
-	}
-
 	metrics := newMetrics(c.PromHostAndPort)
 
 	s := &server{
@@ -138,7 +129,6 @@ func NewServer(c *Configuration, version string) (*server, error) {
 		nodeName:      c.NodeName,
 		natsConn:      conn,
 		StewardSocket: stewardSocket,
-		StewSocket:    stewSocket,
 		processes:     newProcesses(ctx, metrics),
 		newMessagesCh: make(chan []subjectAndMessage),
 		metrics:       metrics,
@@ -289,17 +279,6 @@ func (s *server) Stop() {
 		}
 	}
 
-	// Delete the steward socket file when the program exits.
-	stewSocketFilepath := filepath.Join(s.configuration.SocketFolder, "stew.sock")
-
-	if _, err := os.Stat(stewSocketFilepath); !os.IsNotExist(err) {
-		err = os.Remove(stewSocketFilepath)
-		if err != nil {
-			er := fmt.Errorf("error: could not delete sock file: %v", err)
-			log.Printf("%v\n", er)
-		}
-	}
-
 }
 
 // sendErrorMessage will put the error message directly on the channel that is

stew/stew.go

@@ -10,7 +10,6 @@ import (
 )
 
 type Stew struct {
-	stewardSocket string
 }
 
 func NewStew() (*Stew, error) {
@@ -22,9 +21,7 @@ func NewStew() (*Stew, error) {
 		return nil, fmt.Errorf("error: specify the full path to the steward.sock file: %v", err)
 	}
 
-	s := Stew{
-		stewardSocket: *stewardSocket,
-	}
+	s := Stew{}
 	return &s, nil
 }