ledger/walk.cc

#include "walk.h"
#include "format.h"

namespace ledger {

void sort_transactions::flush()
{
  std::stable_sort(transactions.begin(), transactions.end(),
		   compare_items<transaction_t>(sort_order));

  for (transactions_deque::iterator i = transactions.begin();
       i != transactions.end();
       i++)
    (*handler)(**i);

  transactions.clear();

  item_handler<transaction_t>::flush();
}

void calc_transactions::operator()(transaction_t& xact)
{
  if (! xact.data)
    xact.data = new transaction_data_t;

  if (last_xact && last_xact->data) {
    XACT_DATA_(xact)->total += XACT_DATA(last_xact)->total;
    XACT_DATA_(xact)->index = XACT_DATA(last_xact)->index + 1;
  } else {
    XACT_DATA_(xact)->index = 0;
  }

  if (inverted) {
    xact.amount.negate();
    if (xact.cost)
      xact.cost->negate();
  }

  if (! (XACT_DATA_(xact)->dflags & TRANSACTION_NO_TOTAL))
    add_transaction_to(xact, XACT_DATA_(xact)->total);

  (*handler)(xact);

  if (inverted) {
    xact.amount.negate();
    if (xact.cost)
      xact.cost->negate();
  }

  last_xact = &xact;
}


static void handle_value(const value_t& value, account_t * account,
			 entry_t * entry, unsigned int flags,
			 transactions_list& temps,
			 item_handler<transaction_t> * handler)
{
  balance_t * bal = NULL;

  switch (value.type) {
  case value_t::BOOLEAN:
  case value_t::INTEGER:
  case value_t::AMOUNT: {
    transaction_t * xact = new transaction_t(account);
    temps.push_back(xact);

    xact->entry = entry;
    switch (value.type) {
    case value_t::BOOLEAN:
      xact->amount  = *((bool *) value.data);
      break;
    case value_t::INTEGER:
      xact->amount  = *((unsigned int *) value.data);
      break;
    case value_t::AMOUNT:
      xact->amount  = *((amount_t *) value.data);
      break;
    default:
      assert(0);
      break;
    }

    if (flags) {
      if (! xact->data)
	xact->data = new transaction_data_t;
      XACT_DATA(xact)->dflags |= flags;
    }

    (*handler)(*xact);
    break;
  }

  case value_t::BALANCE_PAIR:
    bal = &((balance_pair_t *) value.data)->quantity;
    // fall through...

  case value_t::BALANCE:
    if (! bal)
      bal = (balance_t *) value.data;

    for (amounts_map::const_iterator i = bal->amounts.begin();
	 i != bal->amounts.end();
	 i++) {
      transaction_t * xact = new transaction_t(account);
      temps.push_back(xact);

      xact->entry   = entry;
      xact->amount  = (*i).second;

      if (flags) {
	if (! xact->data)
	  xact->data = new transaction_data_t;
	XACT_DATA(xact)->dflags |= flags;
      }

      (*handler)(*xact);
    }
    break;

  default:
    assert(0);
    break;
  }
}

void collapse_transactions::report_cumulative_subtotal()
{
  if (count == 1) {
    (*handler)(*last_xact);
  } else {
    assert(count > 1);

    if (! totals_account->data)
      totals_account->data = new account_data_t;
    ACCT_DATA(totals_account)->total = subtotal;
    value_t result;
    format_t::compute_total(result, details_t(*totals_account));
    handle_value(result, totals_account, last_entry, 0, xact_temps, handler);
  }

  subtotal = 0;
  count    = 0;
}

void changed_value_transactions::output_diff(const std::time_t current)
{
  value_t     prev_bal;
  value_t     cur_bal;
  std::time_t prev_date = last_xact->entry->date;

  format_t::compute_total(prev_bal, details_t(*last_xact));

  last_xact->entry->date = current;
  format_t::compute_total(cur_bal,  details_t(*last_xact));
  last_xact->entry->date = prev_date;

  cur_bal -= prev_bal;
  if (cur_bal) {
    entry_t * entry = new entry_t;
    entry_temps.push_back(entry);

    entry->payee = "Commodities revalued";
    entry->date  = current;

    handle_value(cur_bal, NULL, entry, TRANSACTION_NO_TOTAL, xact_temps,
		 handler);
  }
}

void changed_value_transactions::operator()(transaction_t& xact)
{
  if (last_xact)
    output_diff(xact.entry->date);

  if (changed_values_only) {
    if (! xact.data)
      xact.data = new transaction_data_t;
    XACT_DATA_(xact)->dflags |= TRANSACTION_DISPLAYED;
  }

  (*handler)(xact);

  last_xact = &xact;
}

void subtotal_transactions::flush(const char * spec_fmt)
{
  char buf[256];

  if (! spec_fmt) {
    std::string fmt = "- ";
    fmt += format_t::date_format;

    // Make sure the end date is inclusive
    if (start != finish)
      finish -= 86400;

    std::strftime(buf, 255, fmt.c_str(), std::localtime(&finish));
  } else {
    std::strftime(buf, 255, spec_fmt, std::localtime(&finish));
  }

  entry_t * entry = new entry_t;
  entry_temps.push_back(entry);

  entry->payee = buf;

  value_t result;

  for (balances_map::iterator i = balances.begin();
       i != balances.end();
       i++) {
    entry->date = finish;
    {
      transaction_t temp((*i).first);
      temp.entry = entry;
      {
	std::auto_ptr<transaction_data_t> xact_data(new transaction_data_t);
	temp.data = xact_data.get();
	((transaction_data_t *) temp.data)->total = (*i).second;
	format_t::compute_total(result, details_t(temp));
      }
      temp.data = NULL;
    }
    entry->date = start;

    handle_value(result, (*i).first, entry, 0, xact_temps, handler);
  }

  balances.clear();

  item_handler<transaction_t>::flush();
}

void subtotal_transactions::operator()(transaction_t& xact)
{
  if (balances.size() == 0) {
    start = finish = xact.entry->date;
  } else {
    if (std::difftime(xact.entry->date, start) < 0)
      start = xact.entry->date;
    if (std::difftime(xact.entry->date, finish) > 0)
      finish = xact.entry->date;
  }

  balances_map::iterator i = balances.find(xact.account);
  if (i == balances.end()) {
    balance_pair_t temp;
    add_transaction_to(xact, temp);
    balances.insert(balances_pair(xact.account, temp));
  } else {
    add_transaction_to(xact, (*i).second);
  }
}

void interval_transactions::operator()(transaction_t& xact)
{
  std::time_t quant = interval.increment(begin);
  if (std::difftime(xact.entry->date, quant) > 0) {
    if (last_xact) {
      start  = begin;
      finish = quant;
      flush();
    }

    if (! interval.seconds) {
      struct std::tm * desc = std::localtime(&xact.entry->date);
      if (interval.years)
	desc->tm_mon = 0;
      desc->tm_mday = 1;
      desc->tm_hour = 0;
      desc->tm_min  = 0;
      desc->tm_sec  = 0;
      quant = std::mktime(desc);
    }

    std::time_t temp;
    while (std::difftime(xact.entry->date,
			 temp = interval.increment(quant)) > 0)
      quant = temp;
    begin = quant;
  }

  subtotal_transactions::operator()(xact);

  last_xact = &xact;
}

void dow_transactions::flush()
{
  for (int i = 0; i < 7; i++) {
    for (transactions_list::iterator d = days_of_the_week[i].begin();
	 d != days_of_the_week[i].end();
	 d++)
      subtotal_transactions::operator()(**d);
    subtotal_transactions::flush("%As");
    days_of_the_week[i].clear();
  }
}

} // namespace ledger

#ifdef USE_BOOST_PYTHON

#include <boost/python.hpp>

using namespace boost::python;
using namespace ledger;

template <typename T>
struct item_handler_wrap : public item_handler<T>
{
  PyObject* self;

  item_handler_wrap(PyObject * self_) : self(self_) {}
  item_handler_wrap(PyObject * self_, const item_handler<T>& handler)
    : item_handler<T>(const_cast<item_handler<T> *>(&handler)), self(self_) {}

  virtual void flush() {
    call_method<void>(self, "flush");
  }
  void default_flush() {
    item_handler<T>::flush();
  }

  virtual void operator()(T& item) {
    call_method<void>(self, "__call__", item);
  }
  void default_call(T& item) {
    item_handler<T>::operator()(item);
  }
};

void (subtotal_transactions::*subtotal_transactions_flush)() =
  &subtotal_transactions::flush;

void py_walk_entries(journal_t& journal, item_handler<transaction_t>& handler)
{
  walk_entries(journal.entries, handler);
}

void py_walk_transactions(entry_t& entry, item_handler<transaction_t>& handler)
{
  walk_transactions(entry.transactions, handler);
}

void export_walk()
{
  class_< item_handler<transaction_t>,
	  item_handler_wrap<transaction_t> > ("TransactionHandler")
    .def(init<item_handler<transaction_t> *>())

    .def("flush", &item_handler<transaction_t>::flush,
	 &item_handler_wrap<transaction_t>::default_flush)
    .def("__call__", &item_handler<transaction_t>::operator(),
	 &item_handler_wrap<transaction_t>::default_call)
    ;

  class_< ignore_transactions > ("IgnoreTransactions")
    .def("flush", &item_handler<transaction_t>::flush)
    .def("__call__", &ignore_transactions::operator());
    ;

  class_< clear_transaction_data > ("ClearTransactionData")
    .def("flush", &item_handler<transaction_t>::flush)
    .def("__call__", &clear_transaction_data::operator());
    ;

  class_< set_account_value >
    ("SetAccountValue", init<item_handler<transaction_t> *>()
     [with_custodian_and_ward<1, 2>()])
    .def("flush", &item_handler<transaction_t>::flush)
    .def("__call__", &set_account_value::operator());
    ;

#if 0
  class_< sort_transactions >
    ("SortTransactions", init<item_handler<transaction_t> *>()
     [with_custodian_and_ward<1, 2>()])
    .def("flush", &sort_transactions::flush)
    .def("__call__", &sort_transactions::operator());
    ;
#endif

  class_< filter_transactions >
    ("FilterTransactions", init<item_handler<transaction_t> *, std::string>()
     [with_custodian_and_ward<1, 2>()])
    .def("flush", &item_handler<transaction_t>::flush)
    .def("__call__", &filter_transactions::operator());
    ;

  class_< calc_transactions >
    ("CalcTransactions", init<item_handler<transaction_t> *, optional<bool> >()
     [with_custodian_and_ward<1, 2>()])
    .def("flush", &item_handler<transaction_t>::flush)
    .def("__call__", &calc_transactions::operator());
    ;

  class_< collapse_transactions >
    ("CollapseTransactions", init<item_handler<transaction_t> *>()
     [with_custodian_and_ward<1, 2>()])
    .def("flush", &collapse_transactions::flush)
    .def("__call__", &collapse_transactions::operator());
    ;

  class_< changed_value_transactions >
    ("ChangeValueTransactions", init<item_handler<transaction_t> *, bool>()
     [with_custodian_and_ward<1, 2>()])
    .def("flush", &changed_value_transactions::flush)
    .def("__call__", &changed_value_transactions::operator());
    ;

  class_< subtotal_transactions >
    ("SubtotalTransactions", init<item_handler<transaction_t> *>()
     [with_custodian_and_ward<1, 2>()])
    .def("flush", subtotal_transactions_flush)
    .def("__call__", &subtotal_transactions::operator());
    ;

#if 0
  class_< interval_transactions >
    ("IntervalTransactions", init<item_handler<transaction_t> *>()
     [with_custodian_and_ward<1, 2>()])
    .def("flush", &item_handler<transaction_t>::flush)
    .def("__call__", &interval_transactions::operator());
    ;
#endif

  class_< dow_transactions >
    ("DowTransactions", init<item_handler<transaction_t> *>()
     [with_custodian_and_ward<1, 2>()])
    .def("flush", &dow_transactions::flush)
    .def("__call__", &dow_transactions::operator());
    ;

  class_< related_transactions >
    ("RelatedTransactions",
     init<item_handler<transaction_t> *, optional<bool> >()
     [with_custodian_and_ward<1, 2>()])
    .def("flush", &item_handler<transaction_t>::flush)
    .def("__call__", &related_transactions::operator());
    ;

  def("walk_entries", py_walk_entries);
  def("walk_transactions", py_walk_transactions);
}

#endif // USE_BOOST_PYTHON