local uv = require("uv")

local SOCK = "/tmp/echo.sock"

local server = uv.new_pipe(false)

local ret, err, code = server:bind(SOCK)
-- if file already exists, remove it first and try again
if not ret and code == "EADDRINUSE" then
  local fs = require("fs")
  fs.unlinkSync(SOCK)
  _, err, _ = server:bind(SOCK)
  assert(not err, err)
else
  assert(not err, err)
end

server:listen(128, function (err)
  assert(not err, err)
  local client = uv.new_pipe(false)
  server:accept(client)
  client:read_start(function (err, chunk)
    assert(not err, err)
    if chunk then
      print("Got: " .. chunk)
      client:write(chunk)
    else
      client:shutdown()
      client:close()
    end
  end)
end)

uv.run("default")