local helpers = require "spec.helpers"
local stream_api = require "kong.tools.stream_api"

describe("Stream module API endpoint", function()

  local socket_path

  lazy_setup(function()
    helpers.get_db_utils(nil, {}) -- runs migrations
    assert(helpers.start_kong {
      stream_listen = "127.0.0.1:8008",
      plugins = "stream-api-echo",
    })

    socket_path = "unix:" .. helpers.get_running_conf().prefix .. "/stream_rpc.sock"
  end)

  lazy_teardown(function()
    helpers.stop_kong()
  end)

  describe("creates listener", function()
    it("error response for unknown path", function()
      local res, err = stream_api.request("not-this", "nope", socket_path)
      assert.is.falsy(res)
      assert.equal("stream-api errmsg: no handler", err)
    end)

    it("calls an echo handler", function ()
      local res, err = stream_api.request("stream-api-echo", "ping!", socket_path)
      assert.equal("back: ping!", res)
      assert.is_nil(err)
    end)

  end)
end)