Revert "feat: add project_id to authorize in auth0_client"

This reverts commit cf0d691.

lean/commands/backtest.py

@@ -17,7 +17,7 @@
 
 from lean.click import LeanCommand, PathParameter
 from lean.constants import DEFAULT_ENGINE_IMAGE, LEAN_ROOT_PATH
-from lean.container import container, Logger, get_project_id
+from lean.container import container, Logger
 from lean.models.utils import DebuggingMethod
 from lean.models.cli import cli_data_downloaders, cli_addon_modules
 from lean.components.util.json_modules_handler import build_and_configure_modules, non_interactive_config_build_for_name
@@ -362,11 +362,9 @@ def backtest(project: Path,
     engine_image, container_module_version, project_config = container.manage_docker_image(image, update, no_update,
                                                                                            algorithm_file.parent)
 
-    project_id = get_project_id(project_config)
-
     if data_provider_historical is not None:
         data_provider = non_interactive_config_build_for_name(lean_config, data_provider_historical,
-                                                              cli_data_downloaders, kwargs, logger, project_id, environment_name)
+                                                              cli_data_downloaders, kwargs, logger, environment_name)
         data_provider.ensure_module_installed(organization_id, container_module_version)
         container.lean_config_manager.set_properties(data_provider.get_settings())
         paths_to_mount = data_provider.get_paths_to_mount()
@@ -396,7 +394,7 @@ def backtest(project: Path,
 
     # Configure addon modules
     build_and_configure_modules(addon_module, cli_addon_modules, organization_id, lean_config,
-                                kwargs, logger, environment_name, container_module_version, project_id)
+                                kwargs, logger, environment_name, container_module_version)
 
     lean_runner = container.lean_runner
     lean_runner.run_lean(lean_config,

lean/commands/cloud/live/deploy.py

@@ -245,7 +245,7 @@ def deploy(project: str,
         ensure_options(["brokerage", "node", "auto_restart", "notify_order_events", "notify_insights"])
 
         brokerage_instance = non_interactive_config_build_for_name(lean_config, brokerage, cloud_brokerages,
-                                                                   kwargs, logger, cloud_project.projectId)
+                                                                   kwargs, logger)
         notify_methods = []
         if notify_emails is not None:
             for config in notify_emails.split(","):
@@ -287,13 +287,11 @@ def deploy(project: str,
     else:
         # let the user choose the brokerage
         brokerage_instance = interactive_config_build(lean_config, cloud_brokerages, logger, kwargs, show_secrets,
-                                                      "Select a brokerage", multiple=False,
-                                                      project_id=cloud_project.projectId)
+                                                      "Select a brokerage", multiple=False)
 
         notify_order_events, notify_insights, notify_methods = _configure_notifications(logger)
         auto_restart = _configure_auto_restart(logger)
-        cash_balance_option, holdings_option, last_cash, last_holdings = (
-            get_last_portfolio_cash_holdings(api_client, brokerage_instance, cloud_project.projectId, project))
+        cash_balance_option, holdings_option, last_cash, last_holdings = get_last_portfolio_cash_holdings(api_client, brokerage_instance, cloud_project.projectId, project)
         if cash_balance_option != LiveInitialStateInput.NotSupported:
             live_cash_balance = _configure_initial_cash_interactively(logger, cash_balance_option, last_cash)
         if holdings_option != LiveInitialStateInput.NotSupported:
@@ -305,15 +303,13 @@ def deploy(project: str,
         # the user sent the live data provider to use
         for data_provider in data_provider_live:
             data_provider_instance = non_interactive_config_build_for_name(lean_config, data_provider,
-                                                                           cloud_data_queue_handlers, kwargs, logger,
-                                                                           cloud_project.projectId)
+                                                                           cloud_data_queue_handlers, kwargs, logger)
 
             live_data_provider_settings.update({data_provider_instance.get_id(): data_provider_instance.get_settings()})
     else:
         # let's ask the user which live data providers to use
         data_feed_instances = interactive_config_build(lean_config, cloud_data_queue_handlers, logger, kwargs,
-                                                       show_secrets, "Select a live data feed",
-                                                       multiple=True, project_id=cloud_project.projectId)
+                                                       show_secrets, "Select a live data feed", multiple=True)
         for data_feed in data_feed_instances:
             settings = data_feed.get_settings()
 

lean/commands/data/download.py

@@ -19,7 +19,7 @@
 from lean.click import LeanCommand, ensure_options
 from lean.components.util.json_modules_handler import config_build_for_name
 from lean.constants import DEFAULT_ENGINE_IMAGE
-from lean.container import container, get_project_id
+from lean.container import container
 from lean.models.api import QCDataInformation, QCDataVendor, QCFullOrganization, QCDatasetDelivery, QCResolution, QCSecurityType, QCDataType
 from lean.models.click_options import get_configs_for_options, options_from_json
 from lean.models.data import Dataset, DataFile, DatasetDateOption, DatasetTextOption, DatasetTextOptionTransform,OptionResult, Product
@@ -677,11 +677,8 @@ def download(ctx: Context,
 
         engine_image, container_module_version, project_config = container.manage_docker_image(image, update, no_update)
 
-        project_id = get_project_id(project_config)
-
         data_downloader_provider = config_build_for_name(lean_config, data_downloader_provider.get_name(),
-                                                         cli_data_downloaders, kwargs, logger, interactive=True,
-                                                         project_id=project_id)
+                                                         cli_data_downloaders, kwargs, logger, interactive=True)
         data_downloader_provider.ensure_module_installed(organization.id, container_module_version)
         container.lean_config_manager.set_properties(data_downloader_provider.get_settings())
         # mounting additional data_downloader config files

lean/commands/live/deploy.py

@@ -17,7 +17,7 @@
 from lean.click import LeanCommand, PathParameter
 from lean.components.util.name_rename import rename_internal_config_to_user_friendly_format
 from lean.constants import DEFAULT_ENGINE_IMAGE
-from lean.container import container, get_project_id
+from lean.container import container
 from lean.models.cli import (cli_brokerages, cli_data_queue_handlers, cli_data_downloaders,
                              cli_addon_modules, cli_history_provider)
 from lean.models.errors import MoreInfoError
@@ -194,11 +194,6 @@ def deploy(project: Path,
     project_manager = container.project_manager
     algorithm_file = project_manager.find_algorithm_file(Path(project))
 
-    engine_image, container_module_version, project_config = container.manage_docker_image(image, update, no_update,
-                                                                                           algorithm_file.parent)
-
-    project_id = get_project_id(project_config)
-
     if output is None:
         output = algorithm_file.parent / "live" / datetime.now().strftime("%Y-%m-%d_%H-%M-%S")
 
@@ -243,39 +238,41 @@ def deploy(project: Path,
     if brokerage:
         # user provided brokerage, check all arguments were provided
         brokerage_instance = non_interactive_config_build_for_name(lean_config, brokerage, cli_brokerages, kwargs,
-                                                                   logger, project_id, environment_name)
+                                                                   logger, environment_name)
     else:
         # let the user choose the brokerage
         brokerage_instance = interactive_config_build(lean_config, cli_brokerages, logger, kwargs, show_secrets,
                                                       "Select a brokerage", multiple=False,
-                                                      project_id=project_id, environment_name=environment_name)
+                                                      environment_name=environment_name)
 
     if data_provider_live and len(data_provider_live) > 0:
         for data_feed_name in data_provider_live:
             data_feed = non_interactive_config_build_for_name(lean_config, data_feed_name, cli_data_queue_handlers,
-                                                              kwargs, logger, project_id, environment_name)
+                                                              kwargs, logger, environment_name)
             data_provider_live_instances.append(data_feed)
     else:
         data_provider_live_instances = interactive_config_build(lean_config, cli_data_queue_handlers, logger, kwargs,
-                                                                show_secrets, "Select a live data feed",
-                                                                multiple=True, project_id=project_id,
+                                                                show_secrets, "Select a live data feed", multiple=True,
                                                                 environment_name=environment_name)
 
     # based on the live data providers we set up the history providers
     data_provider_live = [provider.get_name() for provider in data_provider_live_instances]
     if data_provider_historical is None:
         data_provider_historical = "Local"
     data_downloader_instances = non_interactive_config_build_for_name(lean_config, data_provider_historical,
-                                                                      cli_data_downloaders, kwargs, logger, project_id,
+                                                                      cli_data_downloaders, kwargs, logger,
                                                                       environment_name)
     if history_providers is None or len(history_providers) == 0:
         history_providers = _get_history_provider_name(data_provider_live)
     for history_provider in history_providers:
         if history_provider in ["BrokerageHistoryProvider", "SubscriptionDataReaderHistoryProvider"]:
             continue
         history_providers_instances.append(config_build_for_name(lean_config, history_provider, cli_history_provider,
-                                                                 kwargs, logger, True, project_id,
-                                                                 environment_name))
+                                                                 kwargs, logger, interactive=True,
+                                                                 environment_name=environment_name))
+
+    engine_image, container_module_version, project_config = container.manage_docker_image(image, update, no_update,
+                                                                                           algorithm_file.parent)
 
     organization_id = container.organization_manager.try_get_working_organization_id()
     paths_to_mount = {}
@@ -344,7 +341,7 @@ def deploy(project: Path,
 
     # Configure addon modules
     build_and_configure_modules(addon_module, cli_addon_modules, organization_id, lean_config,
-                                kwargs, logger, environment_name, container_module_version, project_id)
+                                kwargs, logger, environment_name, container_module_version)
 
     if container.platform_manager.is_host_arm():
         if "InteractiveBrokersBrokerage" in lean_config["environments"][environment_name]["live-mode-brokerage"] \

lean/commands/optimize.py

@@ -20,7 +20,7 @@
 from lean.click import LeanCommand, PathParameter, ensure_options
 from lean.components.docker.lean_runner import LeanRunner
 from lean.constants import DEFAULT_ENGINE_IMAGE
-from lean.container import container, get_project_id
+from lean.container import container
 from lean.models.api import QCParameter, QCBacktest
 from lean.models.click_options import options_from_json, get_configs_for_options
 from lean.models.cli import cli_data_downloaders, cli_addon_modules
@@ -298,12 +298,9 @@ def optimize(project: Path,
 
     paths_to_mount = None
 
-    project_id = get_project_id(project_config)
-
     if data_provider_historical is not None:
         data_provider = non_interactive_config_build_for_name(lean_config, data_provider_historical,
-                                                              cli_data_downloaders, kwargs, logger, project_id,
-                                                              environment_name)
+                                                              cli_data_downloaders, kwargs, logger, environment_name)
         data_provider.ensure_module_installed(organization_id, container_module_version)
         container.lean_config_manager.set_properties(data_provider.get_settings())
         paths_to_mount = data_provider.get_paths_to_mount()
@@ -331,7 +328,7 @@ def optimize(project: Path,
 
     # Configure addon modules
     build_and_configure_modules(addon_module, cli_addon_modules, organization_id, lean_config,
-                                kwargs, logger, environment_name, container_module_version, project_id)
+                                kwargs, logger, environment_name, container_module_version)
 
     run_options = lean_runner.get_basic_docker_config(lean_config, algorithm_file, output, None, release, should_detach,
                                                       engine_image, paths_to_mount)

lean/commands/research.py

@@ -17,7 +17,7 @@
 from lean.click import LeanCommand, PathParameter
 from lean.components.docker.lean_runner import LeanRunner
 from lean.constants import DEFAULT_RESEARCH_IMAGE, LEAN_ROOT_PATH
-from lean.container import container, get_project_id
+from lean.container import container
 from lean.models.cli import cli_data_downloaders
 from lean.components.util.name_extraction import convert_to_class_name
 from lean.components.util.json_modules_handler import non_interactive_config_build_for_name
@@ -121,14 +121,13 @@ def research(project: Path,
     research_image, container_module_version, project_config = container.manage_docker_image(image, update, no_update,
                                                                                              algorithm_file.parent,
                                                                                              False)
-    project_id = get_project_id(project_config)
+
     paths_to_mount = None
 
     if data_provider_historical is not None:
         organization_id = container.organization_manager.try_get_working_organization_id()
         data_provider = non_interactive_config_build_for_name(lean_config, data_provider_historical,
-                                                              cli_data_downloaders, kwargs, logger, project_id,
-                                                              environment_name)
+                                                              cli_data_downloaders, kwargs, logger, environment_name)
         data_provider.ensure_module_installed(organization_id, container_module_version)
         container.lean_config_manager.set_properties(data_provider.get_settings())
         paths_to_mount = data_provider.get_paths_to_mount()

lean/components/api/auth0_client.py

@@ -52,16 +52,15 @@ def read(self, brokerage_id: str) -> QCAuth0Authorization:
             return QCAuth0Authorization(authorization=None)
 
     @staticmethod
-    def authorize(brokerage_id: str, project_id: str, logger: Logger) -> None:
+    def authorize(brokerage_id: str, logger: Logger) -> None:
         """Starts the authorization process for a brokerage.
 
         :param brokerage_id: the id of the brokerage to start the authorization process for
-        :param project_id: The local or cloud project_id
         :param logger: the logger instance to use
         """
         from webbrowser import open
 
-        full_url = f"{API_BASE_URL}live/auth0/authorize?brokerage={brokerage_id}&projectId={project_id}"
+        full_url = f"{API_BASE_URL}live/auth0/authorize?brokerage={brokerage_id}"
         logger.info(f"Please open the following URL in your browser to authorize the LEAN CLI.")
         logger.info(full_url)
         open(full_url)

lean/components/util/auth0_helper.py

@@ -16,12 +16,11 @@
 from lean.components.util.logger import Logger
 
 
-def get_authorization(auth0_client: Auth0Client, brokerage_id: str, project_id: str, logger: Logger) -> QCAuth0Authorization:
+def get_authorization(auth0_client: Auth0Client, brokerage_id: str, logger: Logger) -> QCAuth0Authorization:
     """Gets the authorization data for a brokerage, authorizing if necessary.
 
     :param auth0_client: An instance of Auth0Client, containing methods to interact with live/auth0/* API endpoints.
     :param brokerage_id: The ID of the brokerage to get the authorization data for.
-    :param project_id: The local or cloud project_id.
     :param logger: An instance of Logger, handling all output printing.
     :return: The authorization data for the specified brokerage.
     """
@@ -32,7 +31,7 @@ def get_authorization(auth0_client: Auth0Client, brokerage_id: str, project_id:
         return data
 
     start_time = time()
-    auth0_client.authorize(brokerage_id, project_id, logger)
+    auth0_client.authorize(brokerage_id, logger)
 
     # keep checking for new data every 5 seconds for 7 minutes
     while time() - start_time < 420: