summaryrefslogtreecommitdiff
path: root/src/qif.cc
diff options
context:
space:
mode:
Diffstat (limited to 'src/qif.cc')
-rw-r--r--src/qif.cc276
1 files changed, 276 insertions, 0 deletions
diff --git a/src/qif.cc b/src/qif.cc
new file mode 100644
index 00000000..1c0f01b7
--- /dev/null
+++ b/src/qif.cc
@@ -0,0 +1,276 @@
+/*
+ * Copyright (c) 2003-2008, John Wiegley. All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are
+ * met:
+ *
+ * - Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ *
+ * - Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ *
+ * - Neither the name of New Artisans LLC nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+#include "journal.h"
+#include "qif.h"
+#include "utils.h"
+
+namespace ledger {
+
+#define MAX_LINE 1024
+
+static char line[MAX_LINE + 1];
+static path pathname;
+static unsigned int src_idx;
+static unsigned int linenum;
+
+static inline char * get_line(std::istream& in) {
+ in.getline(line, MAX_LINE);
+ int len = std::strlen(line);
+ if (line[len - 1] == '\r')
+ line[len - 1] = '\0';
+ linenum++;
+ return line;
+}
+
+bool qif_parser_t::test(std::istream& in) const
+{
+ char magic[sizeof(unsigned int) + 1];
+ in.read(magic, sizeof(unsigned int));
+ magic[sizeof(unsigned int)] = '\0';
+ in.clear();
+ in.seekg(0, std::ios::beg);
+
+ return (std::strcmp(magic, "!Typ") == 0 ||
+ std::strcmp(magic, "\n!Ty") == 0 ||
+ std::strcmp(magic, "\r\n!T") == 0);
+}
+
+unsigned int qif_parser_t::parse(std::istream& in,
+ session_t& session,
+ journal_t& journal,
+ account_t * master,
+ const path * original_file)
+{
+ std::auto_ptr<entry_t> entry;
+ std::auto_ptr<amount_t> amount;
+
+ xact_t * xact;
+ unsigned int count = 0;
+ account_t * misc = NULL;
+ commodity_t * def_commodity = NULL;
+ bool saw_splits = false;
+ bool saw_category = false;
+ xact_t * total = NULL;
+
+ entry.reset(new entry_t);
+ xact = new xact_t(master);
+ entry->add_xact(xact);
+
+ pathname = journal.sources.back();
+ src_idx = journal.sources.size() - 1;
+ linenum = 1;
+
+ istream_pos_type beg_pos = 0;
+ unsigned long beg_line = 0;
+
+#define SET_BEG_POS_AND_LINE() \
+ if (! beg_line) { \
+ beg_pos = in.tellg(); \
+ beg_line = linenum; \
+ }
+
+ while (in.good() && ! in.eof()) {
+ char c;
+ in.get(c);
+ switch (c) {
+ case ' ':
+ case '\t':
+ if (peek_next_nonws(in) != '\n') {
+ get_line(in);
+ throw parse_error("Line begins with whitespace");
+ }
+ // fall through...
+
+ case '\n':
+ linenum++;
+ case '\r': // skip blank lines
+ break;
+
+ case '!':
+ get_line(in);
+
+ if (std::strcmp(line, "Type:Invst") == 0 ||
+ std::strcmp(line, "Account") == 0 ||
+ std::strcmp(line, "Type:Cat") == 0 ||
+ std::strcmp(line, "Type:Class") == 0 ||
+ std::strcmp(line, "Type:Memorized") == 0)
+ throw_(parse_error, "QIF files of type " << line << " are not supported.");
+ break;
+
+ case 'D':
+ SET_BEG_POS_AND_LINE();
+ get_line(in);
+ // jww (2008-08-01): Is this just a date?
+ entry->_date = parse_date(line);
+ break;
+
+ case 'T':
+ case '$': {
+ SET_BEG_POS_AND_LINE();
+ get_line(in);
+ xact->amount.parse(line);
+
+ unsigned char flags = xact->amount.commodity().flags();
+ unsigned char prec = xact->amount.commodity().precision();
+
+ if (! def_commodity) {
+ def_commodity = amount_t::current_pool->find_or_create("$");
+ assert(def_commodity);
+ }
+ xact->amount.set_commodity(*def_commodity);
+
+ def_commodity->add_flags(flags);
+ if (prec > def_commodity->precision())
+ def_commodity->set_precision(prec);
+
+ if (c == '$') {
+ saw_splits = true;
+ xact->amount.negate();
+ } else {
+ total = xact;
+ }
+ break;
+ }
+
+ case 'C':
+ SET_BEG_POS_AND_LINE();
+ c = in.peek();
+ if (c == '*' || c == 'X') {
+ in.get(c);
+ xact->state = xact_t::CLEARED;
+ }
+ break;
+
+ case 'N':
+ SET_BEG_POS_AND_LINE();
+ get_line(in);
+ entry->code = line;
+ break;
+
+ case 'P':
+ case 'M':
+ case 'L':
+ case 'S':
+ case 'E': {
+ SET_BEG_POS_AND_LINE();
+ get_line(in);
+
+ switch (c) {
+ case 'P':
+ entry->payee = line;
+ break;
+
+ case 'S':
+ xact = new xact_t(NULL);
+ entry->add_xact(xact);
+ // fall through...
+ case 'L': {
+ int len = std::strlen(line);
+ if (line[len - 1] == ']')
+ line[len - 1] = '\0';
+ xact->account = journal.find_account(line[0] == '[' ?
+ line + 1 : line);
+ if (c == 'L')
+ saw_category = true;
+ break;
+ }
+
+ case 'M':
+ case 'E':
+ xact->note = line;
+ break;
+ }
+ break;
+ }
+
+ case 'A':
+ SET_BEG_POS_AND_LINE();
+ // jww (2004-08-19): these are ignored right now
+ get_line(in);
+ break;
+
+ case '^': {
+ account_t * other;
+ if (xact->account == master) {
+ if (! misc)
+ misc = journal.find_account("Miscellaneous");
+ other = misc;
+ } else {
+ other = master;
+ }
+
+ if (total && saw_category) {
+ if (! saw_splits)
+ total->amount.negate(); // negate, to show correct flow
+ else
+ total->account = other;
+ }
+
+ if (! saw_splits) {
+ xact_t * nxact = new xact_t(other);
+ // The amount doesn't need to be set because the code below
+ // will balance this xact against the other.
+ entry->add_xact(nxact);
+ }
+
+ if (journal.add_entry(entry.get())) {
+ entry->src_idx = src_idx;
+ entry->beg_pos = beg_pos;
+ entry->beg_line = beg_line;
+ entry->end_pos = in.tellg();
+ entry->end_line = linenum;
+ entry.release();
+ count++;
+ }
+
+ // reset things for the next entry
+ entry.reset(new entry_t);
+ xact = new xact_t(master);
+ entry->add_xact(xact);
+
+ saw_splits = false;
+ saw_category = false;
+ total = NULL;
+ beg_line = 0;
+ break;
+ }
+
+ default:
+ get_line(in);
+ break;
+ }
+ }
+
+ return count;
+}
+
+} // namespace ledger
generated by cgit v1.2.3 (git 2.39.1) at 2025-01-22 20:00:42 +0000