package main
import "fmt"
import "net"
import "bufio"

func handleConnection(c net.Conn) () {
    fmt.Println("new connection")
    var client *bufio.ReadWriter;
    {
      client_r := bufio.NewReaderSize(c,14)
      client_w := bufio.NewWriterSize(c,14)
      client = bufio.NewReadWriter(client_r,client_w)
    }
    for {
          wasPrefix:=false
          var line string
          for isPrefix:=true;isPrefix; {
            var lineBuf []byte 
            var err error
            lineBuf,isPrefix,err = client.ReadLine()
            if err != nil {
                fmt.Printf("Readline Error: %s\n",err.Error())
                c.Close()
                return
            }
            if isPrefix {
              wasPrefix=true
            } else {
              line=string(lineBuf)
            }
          }
          if wasPrefix {
              fmt.Println("line too long")
              fmt.Fprintf(client,"line too long\n")
              client.Flush()
              continue
          }
          fmt.Printf("Received: %v\n", string(line))
//
//        data := buf[0:nr]
//        fmt.Printf("Received: %v", string(data))
//        _, err = c.Write(data)
//        if err != nil {
//            fmt.Println("Write: " + err.Error())
//            return
//        }
    }
}


func main() {
  ln, err := net.Listen("unix", "/tmp/test.sock")
  if err != nil {
    fmt.Printf("Error: %s\n",err.Error())
    return
  }
  fmt.Printf("Listener started\n")
  for {
    conn, err := ln.Accept()
    if err != nil {
      // handle error
      continue
    }
    go handleConnection(conn)
  }
}