firecgi/connection.h

#pragma once

#include <sys/uio.h>
#include <functional>
#include <unordered_map>
#include <unordered_set>

#include "firebuf/stream_buffer.h"

#include "request.h"

namespace firecgi {

class Connection {
 public:
  Connection(int sock, const sockaddr_in6& client_addr,
             const std::function<void(Request*)>& callback,
             int max_request_len);
  ~Connection();

  [[nodiscard]] int Read();
  [[nodiscard]] bool Write(const std::vector<iovec>& vecs);

  [[nodiscard]] uint64_t Requests() const;

 private:
  const int sock_;
  const std::function<void(Request*)>& callback_;
  firebuf::StreamBuffer buf_;
  Request request_;

  uint64_t requests_ = 0;
};

}  // namespace firecgi