#ifndef _VALEXPR_H
#define _VALEXPR_H

#include "value.h"
#include "utils.h"
#include "mask.h"

#include <memory>

namespace ledger {

class entry_t;
class transaction_t;
class account_t;

struct details_t
{
  const entry_t *	entry;
  const transaction_t * xact;
  const account_t *     account;

  details_t() : entry(NULL), xact(NULL), account(NULL) {}
  details_t(const entry_t& _entry)
    : entry(&_entry), xact(NULL), account(NULL) {
    DEBUG("ledger.memory.ctors", "ctor details_t");
  }
  details_t(const transaction_t& _xact);
  details_t(const account_t& _account)
    : entry(NULL), xact(NULL), account(&_account) {
    DEBUG("ledger.memory.ctors", "ctor details_t");
  }
#ifdef DEBUG_ENABLED
  ~details_t() {
    DEBUG("ledger.memory.dtors", "dtor details_t");
  }
#endif
};

struct value_expr_t
{
  enum kind_t {
    // Constants
    CONSTANT,
    ARG_INDEX,

    CONSTANTS,

    // Item details
    AMOUNT,
    COST,
    PRICE,
    DATE,
    ACT_DATE,
    EFF_DATE,
    CLEARED,
    PENDING,
    REAL,
    ACTUAL,
    INDEX,
    DEPTH,

    // Item totals
    COUNT,
    TOTAL,
    COST_TOTAL,
    PRICE_TOTAL,

    // Relating to format_t
    VALUE_EXPR,
    TOTAL_EXPR,

    // Functions
    F_NOW,
    F_ARITH_MEAN,
    F_QUANTITY,
    F_COMMODITY,
    F_SET_COMMODITY,
    F_VALUE,
    F_ABS,
    F_ROUND,
    F_PRICE,
    F_DATE,
    F_DATECMP,
    F_YEAR,
    F_MONTH,
    F_DAY,
    F_CODE_MASK,
    F_PAYEE_MASK,
    F_NOTE_MASK,
    F_ACCOUNT_MASK,
    F_SHORT_ACCOUNT_MASK,
    F_COMMODITY_MASK,

    TERMINALS,

    F_PARENT,

    // Binary operators
    O_NEG,
    O_ADD,
    O_SUB,
    O_MUL,
    O_DIV,
    O_PERC,
    O_NEQ,
    O_EQ,
    O_LT,
    O_LTE,
    O_GT,
    O_GTE,
    O_NOT,
    O_AND,
    O_OR,
    O_QUES,
    O_COL,
    O_COM,
    O_DEF,
    O_REF,
    O_ARG,

    LAST
  };

  kind_t	 kind;
  mutable short  refc;
  value_expr_t * left;

  union {
    value_t *	   value;
    mask_t *	   mask;
    unsigned int   arg_index;	// used by ARG_INDEX and O_ARG
    value_expr_t * right;
  };

  value_expr_t(const kind_t _kind)
    : kind(_kind), refc(0), left(NULL), right(NULL) {
    DEBUG("ledger.memory.ctors", "ctor value_expr_t " << this);
  }
  ~value_expr_t();

  void release() const {
    DEBUG("ledger.valexpr.memory",
		"Releasing " << this << ", refc now " << refc - 1);
    assert(refc > 0);
    if (--refc == 0)
      delete this;
  }
  value_expr_t * acquire() {
    DEBUG("ledger.valexpr.memory",
		"Acquiring " << this << ", refc now " << refc + 1);
    assert(refc >= 0);
    refc++;
    return this;
  }
  const value_expr_t * acquire() const {
    DEBUG("ledger.valexpr.memory",
		"Acquiring " << this << ", refc now " << refc + 1);
    refc++;
    return this;
  }

  void set_left(value_expr_t * expr) {
    assert(kind > TERMINALS);
    if (left)
      left->release();
    left = expr ? expr->acquire() : NULL;
  }

  void set_right(value_expr_t * expr) {
    assert(kind > TERMINALS);
    if (right)
      right->release();
    right = expr ? expr->acquire() : NULL;
  }

  void compute(value_t& result,
	       const details_t& details = details_t(),
	       value_expr_t *   context = NULL) const;

  value_t compute(const details_t& details = details_t(),
		  value_expr_t *   context = NULL) const {
    value_t temp;
    compute(temp, details, context);
    return temp;
  }

 private:
  value_expr_t(const value_expr_t&) {
    DEBUG("ledger.memory.ctors", "ctor value_expr_t (copy) " << this);
  }
};

class valexpr_context : public error_context {
 public:
  const ledger::value_expr_t * expr;
  const ledger::value_expr_t * error_node;

  valexpr_context(const ledger::value_expr_t * _expr,
		  const string& desc = "") throw();
  virtual ~valexpr_context() throw();

  virtual void describe(std::ostream& out) const throw();
};

class compute_error : public error {
 public:
  compute_error(const string& reason, error_context * ctxt = NULL) throw()
    : error(reason, ctxt) {}
  virtual ~compute_error() throw() {}
};

class value_expr_error : public error {
 public:
  value_expr_error(const string& reason,
		   error_context * ctxt = NULL) throw()
    : error(reason, ctxt) {}
  virtual ~value_expr_error() throw() {}
};

struct scope_t
{
  scope_t * parent;

  typedef std::map<const string, value_expr_t *>  symbol_map;
  typedef std::pair<const string, value_expr_t *> symbol_pair;

  symbol_map symbols;

  scope_t(scope_t * _parent = NULL) : parent(_parent) {
    DEBUG("ledger.memory.ctors", "ctor scope_t");
  }
  ~scope_t() {
    DEBUG("ledger.memory.dtors", "dtor scope_t");
    for (symbol_map::iterator i = symbols.begin();
	 i != symbols.end();
	 i++)
      (*i).second->release();
  }

  void define(const string& name, value_expr_t * def) {
    DEBUG("ledger.valexpr.syms",
		"Defining '" << name << "' = " << def);
    std::pair<symbol_map::iterator, bool> result
      = symbols.insert(symbol_pair(name, def));
    if (! result.second) {
      symbols.erase(name);
      std::pair<symbol_map::iterator, bool> result
	= symbols.insert(symbol_pair(name, def));
      if (! result.second) {
	def->release();
	throw new compute_error(string("Redefinition of '") +
				name + "' in same scope");
      }
    }
    def->acquire();
  }
  value_expr_t * lookup(const string& name) {
    symbol_map::const_iterator i = symbols.find(name);
    if (i != symbols.end())
      return (*i).second;
    else if (parent)
      return parent->lookup(name);
    return NULL;
  }
};

extern std::auto_ptr<scope_t> global_scope;

extern datetime_t terminus;
extern bool	  initialized;

void init_value_expr();

bool compute_amount(value_expr_t * expr, amount_t& amt,
		    const transaction_t * xact,
		    value_expr_t * context = NULL);

#define PARSE_VALEXPR_NORMAL	 0x00
#define PARSE_VALEXPR_PARTIAL	 0x01
#define PARSE_VALEXPR_RELAXED	 0x02
#define PARSE_VALEXPR_NO_MIGRATE 0x04
#define PARSE_VALEXPR_NO_REDUCE  0x08

value_expr_t * parse_value_expr(std::istream& in,
				scope_t * scope = NULL,
				const short flags = PARSE_VALEXPR_RELAXED);

inline value_expr_t *
parse_value_expr(const string& str,
		 scope_t *     scope	  = NULL,
		 const short   flags = PARSE_VALEXPR_RELAXED) {
  std::istringstream stream(str);
  try {
    return parse_value_expr(stream, scope, flags);
  }
  catch (error * err) {
    err->context.push_back
      (new line_context(str, (long)stream.tellg() - 1,
			"While parsing value expression:"));
    throw err;
  }
}

inline value_expr_t *
parse_value_expr(const char * p,
		 scope_t *    scope = NULL,
		 const short  flags  = PARSE_VALEXPR_RELAXED) {
  return parse_value_expr(string(p), scope, flags);
}

void dump_value_expr(std::ostream& out, const value_expr_t * node,
		     const int depth = 0);

bool print_value_expr(std::ostream&	   out,
		      const value_expr_t * node,
		      const bool           relaxed      = true,
		      const value_expr_t * node_to_find = NULL,
		      unsigned long *	   start_pos    = NULL,
		      unsigned long *	   end_pos      = NULL);

//////////////////////////////////////////////////////////////////////

inline void guarded_compute(const value_expr_t * expr,
			    value_t&		 result,
			    const details_t&	 details = details_t(),
			    value_expr_t *       context = NULL) {
  try {
    expr->compute(result, details);
  }
  catch (error * err) {
    if (err->context.empty() ||
	! dynamic_cast<valexpr_context *>(err->context.back()))
      err->context.push_back(new valexpr_context(expr));
    error_context * last = err->context.back();
    if (valexpr_context * ctxt = dynamic_cast<valexpr_context *>(last)) {
      ctxt->expr = expr->acquire();
      ctxt->desc = "While computing value expression:";
    }
    throw err;
  }
}

inline value_t guarded_compute(const value_expr_t * expr,
			       const details_t&	    details = details_t(),
			       value_expr_t *       context = NULL) {
  value_t temp;
  guarded_compute(expr, temp, details, context);
  return temp;
}

//////////////////////////////////////////////////////////////////////

class value_expr
{
  value_expr_t * ptr;
public:
  string expr;

  value_expr() : ptr(NULL) {}

  value_expr(const string& _expr) : expr(_expr) {
    DEBUG("ledger.memory.ctors", "ctor value_expr");
    if (! _expr.empty())
      ptr = parse_value_expr(expr)->acquire();
    else
      ptr = NULL;
  }
  value_expr(value_expr_t * _ptr)
    : ptr(_ptr ? _ptr->acquire(): NULL) {
    DEBUG("ledger.memory.ctors", "ctor value_expr");
  }
  value_expr(const value_expr& other)
    : ptr(other.ptr ? other.ptr->acquire() : NULL),
      expr(other.expr) {
    DEBUG("ledger.memory.ctors", "ctor value_expr");
  }
  virtual ~value_expr() {
    DEBUG("ledger.memory.dtors", "dtor value_expr");
    if (ptr)
      ptr->release();
  }

  value_expr& operator=(const string& _expr) {
    expr = _expr;
    reset(parse_value_expr(expr));
    return *this;
  }
  value_expr& operator=(value_expr_t * _expr) {
    expr = "";
    reset(_expr);
    return *this;
  }
  value_expr& operator=(const value_expr& _expr) {
    expr = _expr.expr;
    reset(_expr.get());
    return *this;
  }

  operator bool() const throw() {
    return ptr != NULL;
  }
  operator string() const throw() {
    return expr;
  }
  operator value_expr_t *() const throw() {
    return ptr;
  }

  value_expr_t& operator*() const throw() {
    return *ptr;
  }
  value_expr_t * operator->() const throw() {
    return ptr;
  }

  value_expr_t * get() const throw() { return ptr; }
  value_expr_t * release() throw() {
    value_expr_t * tmp = ptr;
    ptr = 0;
    return tmp;
  }
  void reset(value_expr_t * p = 0) throw() {
    if (p != ptr) {
      if (ptr)
	ptr->release();
      ptr = p ? p->acquire() : NULL;
    }
  }

  virtual void compute(value_t& result,
		       const details_t& details = details_t(),
		       value_expr_t *   context = NULL) {
    guarded_compute(ptr, result, details, context);
  }
  virtual value_t compute(const details_t& details = details_t(),
			  value_expr_t *   context = NULL) {
    value_t temp;
    guarded_compute(ptr, temp, details, context);
    return temp;
  }

  friend bool print_value_expr(std::ostream&	    out,
			       const value_expr_t * node,
			       const value_expr_t * node_to_find,
			       unsigned long *	    start_pos,
			       unsigned long *	    end_pos);
};

extern value_expr amount_expr;
extern value_expr total_expr;

inline void compute_amount(value_t& result,
			   const details_t& details = details_t()) {
  if (amount_expr)
    amount_expr->compute(result, details);
}

inline value_t compute_amount(const details_t& details = details_t()) {
  if (amount_expr)
    return amount_expr->compute(details);
}

inline void compute_total(value_t& result,
			  const details_t& details = details_t()) {
  if (total_expr)
    total_expr->compute(result, details);
}

inline value_t compute_total(const details_t& details = details_t()) {
  if (total_expr)
    return total_expr->compute(details);
}

value_expr_t * parse_boolean_expr(std::istream& in, scope_t * scope,
				  const short flags);

inline void parse_value_definition(const string& str,
				   scope_t * scope = NULL) {
  std::istringstream def(str);
  value_expr expr
    (parse_boolean_expr(def, scope ? scope : global_scope.get(),
			PARSE_VALEXPR_RELAXED));
}

//////////////////////////////////////////////////////////////////////

template <typename T>
class item_predicate
{
 public:
  const value_expr_t * predicate;

  item_predicate(const string& _predicate) : predicate(NULL) {
    DEBUG("ledger.memory.ctors", "ctor item_predicate<T>");
    if (! _predicate.empty())
      predicate = parse_value_expr(_predicate)->acquire();
  }
  item_predicate(const value_expr_t * _predicate = NULL)
    : predicate(_predicate->acquire()) {
    DEBUG("ledger.memory.ctors", "ctor item_predicate<T>");
  }

  ~item_predicate() {
    DEBUG("ledger.memory.dtors", "dtor item_predicate<T>");
    if (predicate)
      predicate->release();
  }

  bool operator()(const T& item) const {
    return (! predicate ||
	    predicate->compute(details_t(item)).strip_annotations());
  }
};

} // namespace ledger

#endif // _VALEXPR_H