Sender / Receiver through socket

orchestrator.go

package main

import (
	"fmt"
	"net"
	"os"
	"sync"
	"time"
)

const SOCKET_PATH = "/tmp/ipc_socket"

func handleConn(clients *[]net.Conn, mutex *sync.Mutex) {
	ipc, _ := net.Listen("unix", SOCKET_PATH)
	defer ipc.Close()
	fmt.Println("Waiting for connections...")

	for {
		client, _ := ipc.Accept()
		mutex.Lock()
		*clients = append(*clients, client)
		mutex.Unlock()
		fmt.Println("Client connected")
	}
}

func sendMessage(clients *[]net.Conn, mutex *sync.Mutex, message string, callback func(string)) {
	mutex.Lock()
	defer mutex.Unlock()

	for i, client := range *clients {
		client.Write([]byte(message))
		buffer := make([]byte, 1024)
		n, err := client.Read(buffer)

		if err != nil {
			fmt.Println("Client disconnected")
			client.Close()
			*clients = append((*clients)[:i], (*clients)[i+1:]...)
			continue
		}
		callback(string(buffer[:n]))
	}
}

func main() {
	if _, err := os.Stat(SOCKET_PATH); err == nil {
		os.Remove(SOCKET_PATH)
	}

	var clients []net.Conn
	var mutex sync.Mutex

	go handleConn(&clients, &mutex)

	for {
		message := "Henrique Soares"
		sendMessage(&clients, &mutex, message, func(response string) {
			fmt.Printf("\"%s\" -> \"%s\"\n", message, response)
		})
		time.Sleep(1 * time.Second)
	}
}