self.prior_range = ranges.DateRange(

                cliutil.diff_year(start_date, -year_diff),

                start_date,

            )

            self.period_desc = f"Year{'s' if year_diff > 1 else ''}"

        self.middle_range = ranges.DateRange(self.prior_range.stop, start_date)

        self.period_range = ranges.DateRange(start_date, stop_date)

        self.balances: Mapping[BalanceKey, core.MutableBalance] \

            = collections.defaultdict(core.MutableBalance)

        for post in postings:

            post_date = post.meta.date

            if post_date >= stop_date:

                continue

            elif post_date in self.period_range:

                period = Period.PERIOD

            elif post_date in self.middle_range:

                period = Period.MIDDLE

            elif post_date in self.prior_range:

                period = Period.PRIOR

            else:

                period = Period.OPENING

            if post.meta.get(fund_key) == unrestricted_fund_value:

                fund = Fund.UNRESTRICTED

            else:

                fund = Fund.RESTRICTED

            try:

                classification_s = post.account.meta['classification']

                if isinstance(classification_s, str):

                    classification = data.Account(classification_s)

                else:

                    raise TypeError()

            except (KeyError, TypeError):

                classification = post.account

            if post.account.root_part() == 'Expenses':

                post_type = post.meta.get('expense-type')

            else:

                post_type = None

            key = BalanceKey(post.account, classification, period, fund, post_type)

            self.balances[key] += post.at_cost()

    def total(self,

              account: Union[None, str, Collection[str]]=None,

              classification: Optional[str]=None,

              period: int=Period.ANY,

              fund: int=Fund.ANY,

              post_type: Optional[str]=None,

    ) -> core.Balance:

        if isinstance(account, str):

            account = (account,)

        retval = core.MutableBalance()

        for key, balance in self.balances.items():

            if not (account is None or key.account.is_under(*account)):

                pass

            elif not (classification is None

                      or key.classification.is_under(classification)):

                pass

            elif not period & key.period:

                pass

            elif not fund & key.fund:

                pass

            elif not (post_type is None or post_type == key.post_type):

                pass

            else:

                retval += balance

        return retval

    def classifications(self,

                        account: str,

                        sort_period: Optional[int]=None,

    ) -> Sequence[data.Account]:

        if sort_period is None:

            if account in EQUITY_ACCOUNTS:

                sort_period = Period.PERIOD

            else:

                sort_period = Period.ANY

        class_bals: Mapping[data.Account, core.MutableBalance] \

            = collections.defaultdict(core.MutableBalance)

        for key, balance in self.balances.items():

            if not key.account.is_under(account):

                pass

            elif key.period & sort_period:

                class_bals[key.classification] += balance

            else:

                # Ensure the balance exists in the mapping

                class_bals[key.classification]

        norm_func = core.normalize_amount_func(f'{account}:RootsOK')

        def sortkey(acct: data.Account) -> Hashable:

            prefix, _, _ = acct.rpartition(':')

            balance = norm_func(class_bals[acct])

            try:

                max_bal = max(amount.number for amount in balance.values())

            except ValueError:

                max_bal = Decimal(0)

            return prefix, -max_bal

        return sorted(class_bals, key=sortkey)

        start_date = self.period_range.start

        stop_date = self.period_range.stop

        return sorted(

            account

            for account in data.Account.iter_accounts(root)

            if account.meta.open_date < stop_date

            and (account.meta.close_date is None

                 or account.meta.close_date > start_date)

        )

class Report(core.BaseODS[Sequence[None], None]):

    C_CASH = 'Cash'

    NO_BALANCE = core.Balance()

    SPACE = ' ' * 4

    def __init__(self,

                 balances: Balances,

                 *,

                 date_fmt: str='%B %d, %Y',

    ) -> None:

        super().__init__()

        self.balances = balances

        self.period_desc = balances.period_desc

        self.date_fmt = date_fmt

        one_day = datetime.timedelta(days=1)

        date = balances.period_range.stop - one_day

        self.period_name = date.strftime(date_fmt)

        date = balances.prior_range.stop - one_day

        self.opening_name = date.strftime(date_fmt)

        self.last_totals_row = odf.table.TableRow()

    def section_key(self, row: Sequence[None]) -> None:

        raise NotImplementedError("balance_sheet.Report.section_key")

    def init_styles(self) -> None:

        super().init_styles()

        self.style_header = self.merge_styles(self.style_bold, self.style_centertext)

        self.style_huline = self.merge_styles(

            self.style_header,

            self.border_style(core.Border.BOTTOM, '1pt'),

        )

    def write_all(self) -> None:

        self.write_financial_position()

        self.write_activities()

        self.write_functional_expenses()

        self.write_cash_flows()

        self.write_trial_balances()

    def walk_classifications(self, cseq: Iterable[data.Account]) \

        -> Iterator[Tuple[str, Optional[data.Account]]]:

        last_prefix: Sequence[str] = []

        for classification in cseq:

            parts = classification.split(':')

            tail = parts.pop()

            space = self.SPACE * len(parts)

            if parts != last_prefix:

                yield f'{space[len(self.SPACE):]}{parts[-1]}', None

                last_prefix = parts

            yield f'{space}{tail}', classification

    def walk_classifications_by_account(

            self,

            account: str,

            sort_period: Optional[int]=None,

    ) -> Iterator[Tuple[str, Optional[data.Account]]]:

        return self.walk_classifications(self.balances.classifications(

            account, sort_period,

        ))

    def start_sheet(self,

                    sheet_name: str,

                    *headers: Iterable[str],

                    totals_prefix: Sequence[str]=(),

                    first_width: Union[float, str]=3,

                    width: Union[float, str]=1.5,

                    title_fmt: str="DRAFT Statement of {sheet_name}",

    ) -> None:

        header_cells: Sequence[odf.table.TableCell] = [

            odf.table.TableCell(),

            *(self.multiline_cell(header_lines, stylename=self.style_huline)

              for header_lines in headers),

            *(self.multiline_cell([*totals_prefix, date_s], stylename=self.style_huline)

              for date_s in [self.period_name, self.opening_name]),

        ]

        self.col_count = len(header_cells)

        self.use_sheet(sheet_name)

        for index in range(self.col_count):

            col_style = self.column_style(width if index else first_width)

            self.sheet.addElement(odf.table.TableColumn(stylename=col_style))

        start_date = self.balances.period_range.start.strftime(self.date_fmt)

        self.add_row(

            self.multiline_cell([

                title_fmt.format(sheet_name=sheet_name),

                f"{start_date}—{self.period_name}",

        other_totals[2] -= period_bal

        other_totals[3] -= prior_bal

        self.write_totals_row("Change in Net Assets", income_totals, other_totals)

        for kwargs in bal_kwargs:

            if kwargs['period'] is Period.PERIOD:

                kwargs['period'] = Period.THRU_MIDDLE

            else:

                kwargs['period'] = Period.OPENING

        equity_totals = [

            -self.balances.total(account=EQUITY_ACCOUNTS, **kwargs)

            for kwargs in bal_kwargs

        ]

        self.write_totals_row("Beginning Net Assets", equity_totals)

        self.write_totals_row(

            "Ending Net Assets",

            income_totals, other_totals, equity_totals,

            stylename=self.style_bottomline,

        )

    def write_functional_expenses(self) -> None:

        self.start_sheet(

            "Functional Expenses",

            ["Program", "Services"],

            ["Management and", "Administrative"],

            ["Fundraising"],

            totals_prefix=[f"Total {self.period_desc} Ended"],

        )

        totals = self.write_classifications_by_account('Expenses', [

            {'period': Period.PERIOD, 'post_type': 'program'},

            {'period': Period.PERIOD, 'post_type': 'management'},

            {'period': Period.PERIOD, 'post_type': 'fundraising'},

            {'period': Period.PERIOD},

            {'period': Period.PRIOR},

        ])

        self.write_totals_row(

            "Total Expenses",

            totals,

            stylename=self.style_bottomline,

        )

    def write_cash_flows(self) -> None:

        self.start_sheet("Cash Flows")

        bal_kwargs: Sequence[Dict[str, Any]] = [

            {'period': Period.PERIOD},

            {'period': Period.PRIOR},

        ]

        norm_func = operator.neg

        self.add_row(self.string_cell(

            "Cash Flows from Operating Activities",

            stylename=self.style_bold,

        ))

        equity_totals = [

            -self.balances.total(account=EQUITY_ACCOUNTS, **kwargs)

            for kwargs in bal_kwargs

        ]

        self.write_totals_row("Change in Net Assets", equity_totals, leading_rows=1)

        self.add_row(self.string_cell(

            "(Increase) decrease in operating assets:",

        ))

        asset_totals = self.write_classifications_by_account(

            'Assets', bal_kwargs, (self.C_CASH,), self.SPACE, norm_func,

        )

        self.add_row(self.string_cell(

            "Increase (decrease) in operating liabilities:",

        ))

        liabilities = self.write_classifications_by_account(

            'Liabilities', bal_kwargs, (), self.SPACE, norm_func,

        )

        period_totals = [

            sum(bals, core.MutableBalance())

            for bals in zip(equity_totals, asset_totals, liabilities)

        ]

        self.write_totals_row(

            "Net cash provided by operating activities",

            period_totals,

            stylename=self.style_endtotal,

        )

        self.write_totals_row("Net Increase in Cash", period_totals)

        begin_totals = [

            self.balances.total(classification=self.C_CASH, period=period)

            for period in [Period.THRU_MIDDLE, Period.OPENING]

        ]

        self.write_totals_row("Beginning Cash", begin_totals)

        self.write_totals_row(

            "Ending Cash",

            period_totals, begin_totals,

            stylename=self.style_bottomline,

        )

    def write_trial_balances(self) -> None:

        self.start_sheet(

            "Trial Balances",

            ["Account Name"],

            ["Classification"],

            ["Balance Beginning", self.balances.period_range.start.strftime(self.date_fmt)],

            totals_prefix=["Change During", f"{self.period_desc} Ending"],

            title_fmt="Chart of Accounts with DRAFT {sheet_name}",

        )

        # Widen text columns

        col_style = self.column_style(3.5)

        for col in self.sheet.childNodes[:2]:

            col.setAttribute('stylename', col_style)

        # Patch up header row text

        header_row = self.sheet.lastChild

        header_row.removeChild(header_row.firstChild)

        header_row.insertBefore(self.multiline_cell(

            ["Balance Ending", self.period_name],

            stylename=header_row.lastChild.getAttribute('stylename'),

        ), header_row.lastChild)

        for acct_root in ['Assets', 'Liabilities', 'Income', 'Expenses', 'Equity']:

            norm_func = core.normalize_amount_func(f'{acct_root}:Dummy')

            want_balance = acct_root not in EQUITY_ACCOUNTS

            self.add_row()

            for account in self.balances.iter_accounts(acct_root):

                period_bal = self.balances.total(account=account, period=Period.PERIOD)

                prior_bal = self.balances.total(account=account, period=Period.PRIOR)

                if want_balance:

                    close_bal = self.balances.total(account=account)

                    close_cell = self.balance_cell(norm_func(close_bal))

                    open_cell = self.balance_cell(norm_func(close_bal - period_bal))

                else:

                    close_cell = odf.table.TableCell()

                    open_cell = odf.table.TableCell()

                self.add_row(

                    self.string_cell(account),

                    self.string_cell(account.meta.get('classification', '')),

                    open_cell,

                    self.balance_cell(norm_func(period_bal)),

                    close_cell,

                    self.balance_cell(norm_func(prior_bal)),

                )

def parse_arguments(arglist: Optional[Sequence[str]]=None) -> argparse.Namespace:

    parser = argparse.ArgumentParser(prog=PROGNAME)

    cliutil.add_version_argument(parser)

    parser.add_argument(

        '--begin', '--start', '-b',

        dest='start_date',

        metavar='DATE',

        type=cliutil.date_arg,

        help="""Date to start reporting entries, inclusive, in YYYY-MM-DD format.

The default is one year ago.

""")

    parser.add_argument(

        '--end', '--stop', '-e',

        dest='stop_date',

        metavar='DATE',

        type=cliutil.date_arg,

        help="""Date to stop reporting entries, exclusive, in YYYY-MM-DD format.

The default is a year after the start date.

""")

    cliutil.add_rewrite_rules_argument(parser)

    parser.add_argument(

        '--fund-metadata-key', '-m',

        metavar='KEY',

        default='project',

        help="""Name of the fund metadata key. Default %(default)s.

""")

    parser.add_argument(

        '--unrestricted-fund', '-u',

        metavar='PROJECT',

        default='Conservancy',

        help="""Name of the unrestricted fund. Default %(default)s.

""")

    parser.add_argument(

        '--output-file', '-O',

        metavar='PATH',

        type=Path,

        help="""Write the report to this file, or stdout when PATH is `-`.

""")

    cliutil.add_loglevel_argument(parser)

    return parser.parse_args(arglist)

def main(arglist: Optional[Sequence[str]]=None,

         stdout: TextIO=sys.stdout,

         stderr: TextIO=sys.stderr,

         config: Optional[configmod.Config]=None,

) -> int:

    args = parse_arguments(arglist)

    cliutil.set_loglevel(logger, args.loglevel)

    if config is None:

        config = configmod.Config()

        config.load_file()

    if args.stop_date is None:

        if args.start_date is None:

            args.stop_date = datetime.date.today()

        else:

            args.stop_date = cliutil.diff_year(args.start_date, 1)

    if args.start_date is None:

        args.start_date = cliutil.diff_year(args.stop_date, -1)

    returncode = 0

    books_loader = config.books_loader()

    if books_loader is None:

        entries, load_errors, options_map = books.Loader.load_none(config.config_file_path())

        returncode = cliutil.ExitCode.NoConfiguration

    else:

        start_fy = config.fiscal_year_begin().for_date(args.start_date) - 1

        entries, load_errors, options_map = books_loader.load_fy_range(start_fy, args.stop_date)

        if load_errors:

            returncode = cliutil.ExitCode.BeancountErrors

        elif not entries:

            returncode = cliutil.ExitCode.NoDataLoaded

    for error in load_errors:

        bc_printer.print_error(error, file=stderr)

    data.Account.load_from_books(entries, options_map)

    postings = data.Posting.from_entries(entries)

    for rewrite_path in args.rewrite_rules:

        try:

            ruleset = rewrite.RewriteRuleset.from_yaml(rewrite_path)

        except ValueError as error:

            logger.critical("failed loading rewrite rules from %s: %s",

                            rewrite_path, error.args[0])

            return cliutil.ExitCode.RewriteRulesError

        postings = ruleset.rewrite(postings)

    balances = Balances(

        postings,

        args.start_date,

#!/usr/bin/env python3

from setuptools import setup

setup(

    name='conservancy_beancount',

    description="Plugin, library, and reports for reading Conservancy's books",

    author='Software Freedom Conservancy',

    author_email='info@sfconservancy.org',

    license='GNU AGPLv3+',

    install_requires=[

        'babel>=2.6',  # Debian:python3-babel

        'beancount>=2.2',  # Debian:beancount

        'GitPython>=2.0',  # Debian:python3-git

        # 1.4.1 crashes when trying to save some documents.

        'odfpy>=1.4.0,!=1.4.1',  # Debian:python3-odf

        'PyYAML>=3.0',  # Debian:python3-yaml

        'regex',  # Debian:python3-regex

        'rt>=2.0',

    ],

    setup_requires=[

        'pytest-mypy',

        'pytest-runner',  # Debian:python3-pytest-runner

    ],

    tests_require=[

        'mypy>=0.770',  # Debian:python3-mypy

        'pytest',  # Debian:python3-pytest

    ],

    packages=[

        'conservancy_beancount',

        'conservancy_beancount.plugin',

        'conservancy_beancount.reports',

        'conservancy_beancount.tools',

    ],

    entry_points={

        'console_scripts': [

            'accrual-report = conservancy_beancount.reports.accrual:entry_point',

            'assemble-audit-reports = conservancy_beancount.tools.audit_report:entry_point',

            'balance-sheet-report = conservancy_beancount.reports.balance_sheet:entry_point',

            'extract-odf-links = conservancy_beancount.tools.extract_odf_links:entry_point',

            'fund-report = conservancy_beancount.reports.fund:entry_point',

            'ledger-report = conservancy_beancount.reports.ledger:entry_point',

            'opening-balances = conservancy_beancount.tools.opening_balances:entry_point',

        ],

    },

)