X-Git-Url: https://plomlompom.com/repos/condition_titles?a=blobdiff_plain;ds=sidebyside;f=ledger.py;h=5610293becb20bcdff004447b7ba18b5a91ff277;hb=f659ede27c7fd6313e0bfaa8217a3359c00d5843;hp=334318ff301eb186efa6684809c9ebac1807d177;hpb=c3b5860ae1ca76c2a1dc3b61d3c1242d581424f0;p=misc diff --git a/ledger.py b/ledger.py index 334318f..5610293 100755 --- a/ledger.py +++ b/ledger.py @@ -1,5 +1,8 @@ from http.server import BaseHTTPRequestHandler, HTTPServer import sys +import os +import html +from urllib.parse import parse_qs, urlparse hostName = "localhost" serverPort = 8082 @@ -15,19 +18,140 @@ def handled_error_exit(msg): def apply_booking_to_account_balances(account_sums, account, currency, amount): if not account in account_sums: - account_sums[account] = {currency: amount} + account_sums[account] = {currency: amount} elif not currency in account_sums[account].keys(): account_sums[account][currency] = amount else: account_sums[account][currency] += amount +def parse_lines(lines): + import datetime + import decimal + inside_booking = False + date_string, description = None, None + booking_lines = [] + start_line = 0 + bookings = [] + comments = [] + lines += [''] # to ensure a booking-ending last line + for i, line in enumerate(lines): + prefix = f"line {i}" + # we start with the case of an utterly empty line + comments += [""] + stripped_line = line.rstrip() + if stripped_line == '': + if inside_booking: + # assume we finished a booking, finalize, and commit to DB + if len(booking_lines) < 2: + raise HandledException(f"{prefix} booking ends to early") + booking = Booking(date_string, description, booking_lines, start_line) + bookings += [booking] + # expect new booking to follow so re-zeroall booking data + inside_booking = False + date_string, description = None, None + booking_lines = [] + continue + # if non-empty line, first get comment if any, and commit to DB + split_by_comment = stripped_line.split(sep=";", maxsplit=1) + if len(split_by_comment) == 2: + comments[i] = split_by_comment[1] + # if pre-comment empty: if inside_booking, this must be a comment-only line so we keep it for later ledger-output to capture those comments; otherwise, no more to process for this line + non_comment = split_by_comment[0].rstrip() + if non_comment.rstrip() == '': + if inside_booking: + booking_lines += [''] + continue + # if we're starting a booking, parse by first-line pattern + if not inside_booking: + start_line = i + toks = non_comment.split(maxsplit=1) + date_string = toks[0] + try: + datetime.datetime.strptime(date_string, '%Y-%m-%d') + except ValueError: + raise HandledException(f"{prefix} bad date string: {date_string}") + try: + description = toks[1] + except IndexError: + raise HandledException(f"{prefix} bad description: {description}") + inside_booking = True + booking_lines += [non_comment] + continue + # otherwise, read as transfer data + toks = non_comment.split() # ignore specification's allowance of single spaces in names + if len(toks) > 3: + raise HandledException(f"{prefix} too many booking line tokens: {toks}") + amount, currency = None, None + account_name = toks[0] + if account_name[0] == '[' and account_name[-1] == ']': + # ignore specification's differentiation of "virtual" accounts + account_name = account_name[1:-1] + decimal_chars = ".-0123456789" + if len(toks) == 3: + i_currency = 1 + try: + amount = decimal.Decimal(toks[1]) + i_currency = 2 + except decimal.InvalidOperation: + try: + amount = decimal.Decimal(toks[2]) + except decimal.InvalidOperation: + raise HandledException(f"{prefix} no decimal number in: {toks[1:]}") + currency = toks[i_currency] + if currency[0] in decimal_chars: + raise HandledException(f"{prefix} currency starts with int, dot, or minus: {currency}") + elif len(toks) == 2: + value = toks[1] + inside_amount = False + inside_currency = False + amount_string = "" + currency = "" + dots_counted = 0 + for i, c in enumerate(value): + if i == 0: + if c in decimal_chars: + inside_amount = True + else: + inside_currency = True + if inside_currency: + if c in decimal_chars and len(amount_string) == 0: + inside_currency = False + inside_amount = True + else: + currency += c + continue + if inside_amount: + if c not in decimal_chars: + if len(currency) > 0: + raise HandledException(f"{prefix} amount has non-decimal chars: {value}") + inside_currency = True + inside_amount = False + currency += c + continue + if c == '-' and len(amount_string) > 1: + raise HandledException(f"{prefix} amount has non-start '-': {value}") + if c == '.': + if dots_counted > 1: + raise HandledException(f"{prefix} amount has multiple dots: {value}") + dots_counted += 1 + amount_string += c + if len(amount_string) == 0: + raise HandledException(f"{prefix} amount missing: {value}") + if len(currency) == 0: + raise HandledException(f"{prefix} currency missing: {value}") + amount = decimal.Decimal(amount_string) + booking_lines += [(account_name, amount, currency)] + if inside_booking: + raise HandledException(f"{prefix} last booking unfinished") + return bookings, comments + class Booking: def __init__(self, date_string, description, booking_lines, start_line): self.date_string = date_string - self.description = description - self.lines = booking_lines + self.description = description + self.lines = booking_lines self.start_line = start_line self.validate_booking_lines() self.account_changes = self.parse_booking_lines_to_account_changes() @@ -36,8 +160,8 @@ class Booking: prefix = f"booking at line {self.start_line}" sums = {} empty_values = 0 - for line in self.lines: - if line == '': + for line in self.lines[1:]: + if line == '': continue _, amount, currency = line if amount is None: @@ -56,7 +180,7 @@ class Booking: sinkable = False for k, v in sums.items(): if v != 0: - sinkable = True + sinkable = True if not sinkable: raise HandledException(f"{prefix} has empty value that cannot be filled") @@ -64,8 +188,8 @@ class Booking: account_changes = {} debt = {} sink_account = None - for line in self.lines: - if line == '': + for line in self.lines[1:]: + if line == '': continue account, amount, currency = line if amount is None: @@ -85,176 +209,155 @@ class Booking: class Database: - def __init__(self, load_from_file=True): - import os + def __init__(self): db_name = "_ledger" self.db_file = db_name + ".json" self.lock_file = db_name+ ".lock" self.bookings = [] self.comments = [] - if load_from_file and os.path.exists(self.db_file): + self.real_lines = [] + if os.path.exists(self.db_file): with open(self.db_file, "r") as f: - self.parse_lines(f.readlines()) + self.real_lines += f.readlines() + ret = parse_lines(self.real_lines) + self.bookings += ret[0] + self.comments += ret[1] - def parse_lines(self, lines): - import datetime - import decimal - inside_booking = False - date_string, description = None, None - booking_lines = [] - start_line = 0 - for i, line in enumerate(lines): - prefix = f"line {i}" - # we start with the case of an utterly empty line - self.comments += [""] - stripped_line = line.rstrip() - if stripped_line == '': - if inside_booking: - # assume we finished a booking, finalize, and commit to DB - if len(booking_lines) < 2: - raise HandledException(f"{prefix} booking ends to early") - booking = Booking(date_string, description, booking_lines, start_line) - self.bookings += [booking] - # expect new booking to follow so re-zeroall booking data - inside_booking = False - date_string, description = None, None - booking_lines = [] - continue - # if non-empty line, first get comment if any, and commit to DB - split_by_comment = stripped_line.split(sep=";", maxsplit=1) - if len(split_by_comment) == 2: - self.comments[i] = split_by_comment[1] - # if pre-comment empty: if inside_booking, this must be a comment-only line so we keep it for later ledger-output to capture those comments; otherwise, no more to process for this line - non_comment = split_by_comment[0].rstrip() - if non_comment.rstrip() == '': - if inside_booking: - booking_lines += [''] - continue - # if we're starting a booking, parse by first-line pattern - if not inside_booking: - start_line = i - toks = non_comment.split(maxsplit=1) - date_string = toks[0] - try: - datetime.datetime.strptime(date_string, '%Y-%m-%d') - except ValueError: - raise HandledException(f"{prefix} bad date string: {date_string}") - try: - description = toks[1] - except IndexError: - raise HandledException(f"{prefix} bad description: {description}") - inside_booking = True - continue - # otherwise, read as transfer data - toks = non_comment.split() # ignore specification's allowance of single spaces in names - if len(toks) > 3: - raise HandledException(f"{prefix} too many booking line tokens: {toks}") - amount, currency = None, None - account_name = toks[0] - if account_name[0] == '[' and account_name[-1] == ']': - # ignore specification's differentiation of "virtual" accounts - account_name = account_name[1:-1] - decimal_chars = ".-0123456789" - if len(toks) == 3: - i_currency = 1 - try: - amount = decimal.Decimal(toks[1]) - i_currency = 2 - except decimal.InvalidOperation: - try: - amount = decimal.Decimal(toks[2]) - except decimal.InvalidOperation: - raise HandledException(f"{prefix} no decimal number in: {toks[1:]}") - currency = toks[i_currency] - if currency[0] in decimal_chars: - raise HandledException(f"{prefix} currency starts with int, dot, or minus: {currency}") - elif len(toks) == 2: - value = toks[1] - inside_amount = False - inside_currency = False - amount_string = "" - currency = "" - dots_counted = 0 - for i, c in enumerate(value): - if i == 0: - if c in decimal_chars: - inside_amount = True - else: - inside_currency = True - if inside_currency: - if c in decimal_chars and len(amount_string) == 0: - inside_currency = False - inside_amount = True - else: - currency += c - continue - if inside_amount: - if c not in decimal_chars: - if len(currency) > 0: - raise HandledException(f"{prefix} amount has non-decimal chars: {value}") - inside_currency = True - inside_amount = False - currency += c - continue - if c == '-' and len(amount_string) > 1: - raise HandledException(f"{prefix} amount has non-start '-': {value}") - if c == '.': - if dots_counted > 1: - raise HandledException(f"{prefix} amount has multiple dots: {value}") - dots_counted += 1 - amount_string += c - if len(amount_string) == 0: - raise HandledException(f"{prefix} amount missing: {value}") - if len(currency) == 0: - raise HandledException(f"{prefix} currency missing: {value}") - amount = decimal.Decimal(amount_string) - booking_lines += [(account_name, amount, currency)] + def get_lines(self, start, end): + return db.real_lines[start:end] - def ledger_as_html(self): - lines = [] - for comment in self.comments: - lines += [f"; {comment}" if comment != '' else ''] - for booking in self.bookings: - i = booking.start_line - suffix = f" {lines[i]}" if len(lines[i]) > 0 else "" - lines[i] = f"{booking.date_string} {booking.description}{suffix}" - for booking_line in booking.lines: - i += 1 - if booking_line == '': + def replace(self, start, end, lines): + import shutil + if os.path.exists(self.lock_file): + raise HandledException('Sorry, lock file!') + if os.path.exists(self.db_file): + shutil.copy(self.db_file, self.db_file + ".bak") + f = open(self.lock_file, 'w+') + f.close() + text = ''.join(self.real_lines[:start]) + '\n'.join(lines) + ''.join(self.real_lines[end:]) + with open(self.db_file, 'w') as f: + f.write(text); + os.remove(self.lock_file) + + def append(self, lines): + import shutil + if os.path.exists(self.lock_file): + raise HandledException('Sorry, lock file!') + if os.path.exists(self.db_file): + shutil.copy(self.db_file, self.db_file + ".bak") + f = open(self.lock_file, 'w+') + f.close() + with open(self.db_file, 'a') as f: + f.write('\n' + '\n'.join(lines) + '\n'); + os.remove(self.lock_file) + + +class MyServer(BaseHTTPRequestHandler): + header = """ + +
+ledger +balance +add free +add structured +{content}" + new_line = new_main + if comment.rstrip() != '': + new_line += f' ; {comment}' + lines += [new_line] + elif '/add_free' == parsed_url.path: + lines = postvars['booking'][0].splitlines() + start = int(postvars['start'][0]) + end = int(postvars['end'][0]) + try: + _, _ = parse_lines(lines) + if start == end == 0: + db.append(lines) + else: + db.replace(start, end, lines) + self.send_response(301) + self.send_header('Location', '/') + self.end_headers() + except HandledException as e: + self.send_response(400) + self.end_headers() + page = f'{self.header}ERROR: {e}{self.footer}' + self.wfile.write(bytes(page, "utf-8")) - def balance_as_html(self): + def do_GET(self): + self.send_response(200) + self.send_header("Content-type", "text/html") + self.end_headers() + db = Database() + parsed_url = urlparse(self.path) + page = self.header + '' + params = parse_qs(parsed_url.query) + start = int(params.get('start', ['0'])[0]) + end = int(params.get('end', ['0'])[0]) + bonus_lines = int(params.get('bonus_lines', ['0'])[0]) + if parsed_url.path == '/balance': + page += self.balance_as_html(db) + elif parsed_url.path == '/add_free': + page += self.add_free(db, start, end) + elif parsed_url.path == '/add_structured': + page += self.add_structured(db, start, end) + elif parsed_url.path == '/copy_free': + page += self.add_free(db, start, end, copy=True) + elif parsed_url.path == '/copy_structured': + page += self.add_structured(db, start, end, copy=True) + else: + page += self.ledger_as_html(db) + page += self.footer + self.wfile.write(bytes(page, "utf-8")) + + def balance_as_html(self, db): account_sums = {} - for booking in self.bookings: + for booking in db.bookings: for account, changes in booking.account_changes.items(): for currency, amount in changes.items(): apply_booking_to_account_balances(account_sums, account, currency, amount) account_tree = {} def collect_branches(account_name, path): - node = account_tree + node = account_tree path_copy = path[:] while len(path_copy) > 0: step = path_copy.pop(0) - node = node[step] + node = node[step] toks = account_name.split(":", maxsplit=1) parent = toks[0] if parent in node.keys(): child = node[parent] else: child = {} - node[parent] = child + node[parent] = child if len(toks) == 2: k, v = collect_branches(toks[1], path + [parent]) if k not in child.keys(): child[k] = v else: child[k].update(v) - return parent, child + return parent, child for account_name in sorted(account_sums.keys()): k, v = collect_branches(account_name, []) if k not in account_tree.keys(): @@ -265,21 +368,21 @@ class Database: for k, v in tree_node.items(): child_path = parent_path + ":" + k for currency, amount in collect_totals(child_path, v).items(): - apply_booking_to_account_balances(account_sums, parent_path, currency, amount) + apply_booking_to_account_balances(account_sums, parent_path, currency, amount) return account_sums[parent_path] for account_name in account_tree.keys(): account_sums[account_name] = collect_totals(account_name, account_tree[account_name]) lines = [] def print_subtree(lines, indent, node, subtree, path): - line = f"{indent}{node}" + line = f"{indent}{node}" n_tabs = 5 - (len(line) // 8) - line += n_tabs * "\t" + line += n_tabs * "\t" if "â¬" in account_sums[path + node].keys(): amount = account_sums[path + node]["â¬"] line += f"{amount:9.2f} â¬\t" else: line += f"\t\t" - for currency, amount in account_sums[path + node].items(): + for currency, amount in account_sums[path + node].items(): if currency != 'â¬' and amount > 0: line += f"{amount:5.2f} {currency}\t" lines += [line] @@ -289,23 +392,104 @@ class Database: for k, v in sorted(account_tree.items()): print_subtree(lines, "", k, v, "") content = "\n".join(lines) - return f"
{content}" + return f"
{content}" + + def ledger_as_html(self, db): + lines = [] + line_sep = '
{booking.date_string} {booking.description}{suffix}' + for booking_line in booking.lines[1:]: + i += 1 + if booking_line == '': + continue + suffix = f' {lines[i]}' if len(lines[i]) > 0 else '' + value = f' {booking_line[1]} {booking_line[2]}' if booking_line[1] else '' + lines[i] = f'{booking_line[0]}{value}{suffix}' + lines[i] = lines[i][:-len(line_sep)] + f"""
+edit: +structured +/ free +| copy: +structured +/ free +