nntpchan/contrib/backends/nntpchan-daemon/src/line.cpp

#include "line.hpp"
#include <iostream>

namespace nntpchan {

  LineReader::LineReader(size_t limit) : m_close(false), lineLimit(limit) {}

  void LineReader::Data(const char * d, ssize_t l)
  {
    if(l <= 0) return;
    // process leftovers
    std::string current = m_leftovers + std::string(d, l);
    if(current.size() > lineLimit) {
      m_close = true;
      return;
    }
    std::size_t idx = 0;
    ssize_t begin = l;
    const char * data = current.c_str();
    while(l-- > 0) {
      char c = data[idx++];
      if(c == '\n') {
        OnLine(data, idx-1);
        data += idx;
      } else if (c == '\r' && data[idx] == '\n') {
        OnLine(data, idx-1);
        data += idx + 1;
      }
    }
    if (idx < begin)
    {
      // leftovers
      m_leftovers = std::string(data, begin-idx);
    }
    else
      m_leftovers = "";
  }

  void LineReader::OnLine(const char *d, const size_t l)
  {
    std::string line(d, l);
    HandleLine(line);
  }

  bool LineReader::ShouldClose()
  {
    return m_close;
  }
}