mirror of
https://github.com/OpenBB-finance/OpenBB.git
synced 2026-11-06 09:22:26 +00:00
* start papermill rollback * move reports to templates folder * comment some stuff * refactor reports controller * change var names * clean ctrl class vars * small refactoring on metadata search * relocate some func * breaking changes * revert some changes * destroying changes * change menu appearance * change menu appeaerance again * update choices * change some assets locations * remove unused vars * change some docstrings * rename vars * its working * forgot one dash * omg its working * clean some code and doc * change func name * fix a bug and add some comments * fix economy report startup * add custom reports * allow custom reports * forgot to delete this * unused import * make somestuff more explicit, 5 min rule * add helper func * supress errors--no-verify * add some type checks * fix check ipynb func * check inputs in run * rewrite some integration tests * remove unused import * add some docs to website * add auto completion * warn if no forecast * add to do * add arg name if 1 arg * add papermill pointing to github main * add notebooks * fix terminal spec * relocated choices files * merge main * relocate website docs for reports * limit user choices * fix portfolio auto completion * limit choices fix * clean som edocstrings * limit user choices in run command * improve run parser * fix msg * add reports controller tests * relax crypto choices limit * contain commands * pass pre commit * flake8 * flake8 * ignore mypy * pylint * website * move docs to jupyter tab * add installer dep * remove etf * remove reports * update reports to main * handle events erros * rever reports to previous commits before main merge * add papermill installer strategies * add flags to terminal * avoid sdk crash * execute notebook in thread * remove unused sys * execute report in a child process * fix some notebook stuff * fix portfolio report * fix reports controller volatility * change api to sdk * move images * remove som unucessary installer imports * remove debugger warning * move ipykernel launcher * supress notebook crash * remove portfolio decorator * fix run command * forgot to change this * add images * fix portfolio report * fix crypto report * linting and tests * add run integration test * pylint * hide reports module args * try at supressing args * try at supreccing warning * solve some os issues * handle pm errors * fix warning unrecognized arguments * change comment * avoid crash when parameters not found * fix etf commands * minor cleanup * update forecasting check * fix some linting * fix futures test * pylint * limit user choices to prompt * limit user choices to prompt * supress warnings * revert poetry lock back to main * papermill pointing to main * flake8 * forgot requirements * Update helper_funcs.py * Update reports_model.py * choices Co-authored-by: hjoaquim <h.joaquim@campus.fct.unl.pt> Co-authored-by: James Simmons <53658028+simmonsj330@users.noreply.github.com>
265 lines
9.2 KiB
Python
265 lines
9.2 KiB
Python
"""Reports Controller Module."""
|
|
__docformat__ = "numpy"
|
|
|
|
import argparse
|
|
import logging
|
|
import os
|
|
|
|
# pylint: disable=R1732, R0912
|
|
from typing import Any, Dict, List
|
|
|
|
from openbb_terminal import feature_flags as obbff
|
|
from openbb_terminal.core.config.paths import (
|
|
USER_CUSTOM_REPORTS_DIRECTORY,
|
|
)
|
|
from openbb_terminal.helper_funcs import parse_simple_args
|
|
from openbb_terminal.reports import reports_model
|
|
from openbb_terminal.custom_prompt_toolkit import NestedCompleter
|
|
from openbb_terminal.decorators import log_start_end
|
|
from openbb_terminal.menu import session
|
|
from openbb_terminal.parent_classes import BaseController
|
|
from openbb_terminal.rich_config import console, MenuText
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class ReportController(BaseController):
|
|
"""Report Controller class."""
|
|
|
|
CHOICES_COMMANDS: List[str] = [
|
|
"crypto",
|
|
"economy",
|
|
"equity",
|
|
"etf",
|
|
"forecast",
|
|
"forex",
|
|
"portfolio",
|
|
"run",
|
|
"load",
|
|
]
|
|
PATH = "/reports/"
|
|
|
|
REPORTS: List[str] = reports_model.get_reports_available()
|
|
REPORTS = sorted(list(set(CHOICES_COMMANDS).intersection(REPORTS)))
|
|
PARAMETERS_DICT: Dict[str, Any] = {}
|
|
|
|
def __init__(self, queue: List[str] = None):
|
|
"""Constructor"""
|
|
|
|
super().__init__(queue)
|
|
self.update_choices()
|
|
|
|
def update_choices(self):
|
|
"""Update controller choices with reports available under templates folder."""
|
|
|
|
for report_name in self.REPORTS:
|
|
# Extract report parameters do display on menu
|
|
self.PARAMETERS_DICT[report_name] = reports_model.extract_parameters(
|
|
str(reports_model.REPORTS_FOLDER / report_name)
|
|
)
|
|
|
|
if session and obbff.USE_PROMPT_TOOLKIT:
|
|
|
|
self.choices: dict = {c: {} for c in self.controller_choices}
|
|
self.choices["run"] = {
|
|
"--file": {c: None for c in reports_model.USER_REPORTS},
|
|
"-f": "--file",
|
|
"--parameters": {},
|
|
"-p": "--parameters",
|
|
}
|
|
for report_name in self.REPORTS:
|
|
|
|
# Completer with limited user choices to avoid unforeseen problems
|
|
self.choices[report_name] = {}
|
|
for arg in self.PARAMETERS_DICT[report_name]:
|
|
if report_name in reports_model.REPORT_CHOICES:
|
|
self.choices[report_name][
|
|
"--" + arg
|
|
] = reports_model.REPORT_CHOICES[report_name]["--" + arg]
|
|
|
|
self.choices["support"] = self.SUPPORT_CHOICES
|
|
self.choices["about"] = self.ABOUT_CHOICES
|
|
|
|
self.completer = NestedCompleter.from_nested_dict(self.choices)
|
|
|
|
def print_help(self):
|
|
"""Print help."""
|
|
|
|
self.REPORTS = reports_model.get_reports_available()
|
|
self.REPORTS = sorted(
|
|
list(set(self.CHOICES_COMMANDS).intersection(self.REPORTS))
|
|
)
|
|
self.update_choices()
|
|
|
|
mt = MenuText("reports/")
|
|
mt.add_info("_reports_")
|
|
mt.add_raw("\n")
|
|
mt.add_info("_OpenBB_reports_")
|
|
MAX_LEN_NAME = max(len(name) for name in self.REPORTS) + 2
|
|
templates_string = ""
|
|
for report_name in self.REPORTS:
|
|
|
|
parameters_names = list(self.PARAMETERS_DICT[report_name].keys())
|
|
|
|
if len(parameters_names) > 1 or not parameters_names:
|
|
args = f"<{'> <'.join(parameters_names)}>"
|
|
else:
|
|
args = f"<{parameters_names[0]}>"
|
|
|
|
templates_string += (
|
|
f" [cmds]{report_name}[/cmds]"
|
|
+ f"{(MAX_LEN_NAME-len(report_name))*' '} "
|
|
+ f"[param]{args if args != '<>' else ''}[/param]\n"
|
|
)
|
|
mt.add_raw(f"{templates_string}")
|
|
mt.add_raw("\n")
|
|
mt.add_info("_Custom_reports_")
|
|
mt.add_cmd("run")
|
|
console.print(text=mt.menu_text, menu="Reports - WORK IN PROGRESS")
|
|
|
|
@log_start_end(log=logger)
|
|
def call_etf(self, other_args: List[str]):
|
|
self.run_report("etf", other_args)
|
|
|
|
@log_start_end(log=logger)
|
|
def call_forex(self, other_args: List[str]):
|
|
self.run_report("forex", other_args)
|
|
|
|
@log_start_end(log=logger)
|
|
def call_portfolio(self, other_args: List[str]):
|
|
self.run_report("portfolio", other_args)
|
|
|
|
@log_start_end(log=logger)
|
|
def call_economy(self, other_args: List[str]):
|
|
self.run_report("economy", other_args)
|
|
|
|
@log_start_end(log=logger)
|
|
def call_equity(self, other_args: List[str]):
|
|
self.run_report("equity", other_args)
|
|
|
|
@log_start_end(log=logger)
|
|
def call_crypto(self, other_args: List[str]):
|
|
self.run_report("crypto", other_args)
|
|
|
|
@log_start_end(log=logger)
|
|
def call_forecast(self, other_args: List[str]):
|
|
try:
|
|
import darts # pyright: reportMissingImports=false # noqa: F401, E501 #pylint: disable=import-outside-toplevel, unused-import
|
|
from darts import ( # pyright: reportMissingImports=false # noqa: F401, E501 #pylint: disable=import-outside-toplevel, unused-import
|
|
utils,
|
|
)
|
|
|
|
forecast = True
|
|
except ImportError:
|
|
forecast = False
|
|
console.print(
|
|
"\n'forecast' menu dependencies are not installed."
|
|
" This part of the SDK will not be usable.\n\n"
|
|
"For more information see the official documentation at: "
|
|
"[blue]https://openbb-finance.github.io/OpenBBTerminal/sdk/[/blue]\n"
|
|
)
|
|
if forecast:
|
|
self.run_report("forecast", other_args)
|
|
|
|
@log_start_end(log=logger)
|
|
def run_report(self, report_name: str, other_args: List[str]):
|
|
parser = argparse.ArgumentParser(
|
|
add_help=False,
|
|
formatter_class=argparse.ArgumentDefaultsHelpFormatter,
|
|
prog=report_name,
|
|
description=f"Run {report_name} report.",
|
|
)
|
|
|
|
if report_name in self.PARAMETERS_DICT:
|
|
|
|
# Assign respective parameters as arguments
|
|
for arg_name, arg_default in self.PARAMETERS_DICT[report_name].items():
|
|
|
|
choices = reports_model.get_arg_choices(report_name, arg_name)
|
|
|
|
getattr(parser, "add_argument")(
|
|
"--" + arg_name,
|
|
type=str,
|
|
default=arg_default,
|
|
choices=choices,
|
|
dest=arg_name,
|
|
help=arg_name,
|
|
)
|
|
|
|
if (
|
|
other_args
|
|
and "-" not in other_args[0][0]
|
|
and len(self.PARAMETERS_DICT[report_name]) == 1
|
|
):
|
|
other_args.insert(
|
|
0, "--" + list(self.PARAMETERS_DICT[report_name].keys())[0]
|
|
)
|
|
ns_parser = parse_simple_args(parser, other_args)
|
|
|
|
if ns_parser:
|
|
parameters = vars(ns_parser)
|
|
parameters.pop("help")
|
|
reports_model.render_report(
|
|
input_path=str(reports_model.REPORTS_FOLDER / report_name),
|
|
args_dict=parameters,
|
|
)
|
|
|
|
else:
|
|
console.print("[red]Notebook not found![/red]\n")
|
|
|
|
@log_start_end(log=logger)
|
|
def call_run(self, other_args: List[str]):
|
|
"""Process run command"""
|
|
parser = argparse.ArgumentParser(
|
|
add_help=False,
|
|
formatter_class=argparse.ArgumentDefaultsHelpFormatter,
|
|
prog="run",
|
|
description=f"Run a notebook from this folder: '{str(USER_CUSTOM_REPORTS_DIRECTORY)}'.",
|
|
)
|
|
parser.add_argument(
|
|
"-f",
|
|
"--file",
|
|
dest="file",
|
|
choices=reports_model.USER_REPORTS,
|
|
required="-h" not in other_args,
|
|
help="The file to be loaded",
|
|
)
|
|
parser.add_argument(
|
|
"-p",
|
|
"--parameters",
|
|
nargs="+",
|
|
dest="parameters",
|
|
help="Report parameters with format 'name:value'.",
|
|
)
|
|
|
|
ns_parser = self.parse_known_args_and_warn(parser, other_args)
|
|
|
|
if ns_parser:
|
|
# Validate parameter inputs
|
|
parameters_dict = {}
|
|
if ns_parser.parameters:
|
|
for p in ns_parser.parameters:
|
|
if ":" in p:
|
|
item = p.split(":")
|
|
if item[1]:
|
|
parameters_dict[item[0]] = item[1]
|
|
else:
|
|
console.print(
|
|
f"[red]Bad format '{p}': empty value.[/red]\nExecuting with defaults.\n"
|
|
)
|
|
else:
|
|
console.print(
|
|
f"[red]Bad format '{p}': use format 'name:value'.[/red]\nExecuting with defaults.\n"
|
|
)
|
|
|
|
if ns_parser.file:
|
|
complete_file_path = str(USER_CUSTOM_REPORTS_DIRECTORY / ns_parser.file)
|
|
if os.path.exists(complete_file_path):
|
|
reports_model.render_report(
|
|
input_path=complete_file_path, args_dict=parameters_dict
|
|
)
|
|
else:
|
|
console.print(
|
|
f"[red]Notebook '{ns_parser.file}' not found![/red]\n"
|
|
)
|