// Copyright 2017 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "src/lib/fsl/socket/blocking_drain.h"

#include <lib/zx/socket.h>

#include <vector>

#include <gtest/gtest.h>

#include "src/lib/fsl/socket/strings.h"

namespace fsl {
namespace {

TEST(BlockingDrain, BlockingDrainFrom) {
  zx::socket socket = WriteStringToSocket("Hello");
  std::vector<char> buffer;

  EXPECT_TRUE(BlockingDrainFrom(std::move(socket), [&](const void* data, uint32_t len) {
    const char* begin = static_cast<const char*>(data);
    buffer.insert(buffer.end(), begin, begin + len);
    return len;
  }));

  std::string message(buffer.data(), buffer.size());
  EXPECT_EQ("Hello", message);
}

// TODO(abarth): Add more tests that cover more of the codepaths. The
// BlockingDrainFrom test above only exercises the optimistic case when blocking
// isn't required.

}  // namespace
}  // namespace fsl