remove v2 commands (#4478)

* remove v2 commands

* format

* remove v2

* remove v2

* little fixes friend

* add cloud

* relock poetry deps

* bump reflex-hosting-cli dep

* test_dynamic_routes: wait for token

attempt to avoid test flakiness

* relock deps

* test_dynamic_routes: increase polling timeout

---------

Co-authored-by: simon <simon@reflex.dev>
Co-authored-by: Masen Furer <m_github@0x26.net>
This commit is contained in:
Simon Young 2024-12-04 23:21:18 -08:00 committed by GitHub
parent e23d939781
commit 12771004cb
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
6 changed files with 30 additions and 197 deletions

16
poetry.lock generated
View File

@ -2206,13 +2206,13 @@ reflex = ">=0.6.0a"
[[package]] [[package]]
name = "reflex-hosting-cli" name = "reflex-hosting-cli"
version = "0.1.17" version = "0.1.28"
description = "Reflex Hosting CLI" description = "Reflex Hosting CLI"
optional = false optional = false
python-versions = "<4.0,>=3.8" python-versions = "<4.0,>=3.8"
files = [ files = [
{file = "reflex_hosting_cli-0.1.17-py3-none-any.whl", hash = "sha256:cf1accec70745557a40125ffa2a8929e6ef9834808afe78e4f4a01933ac0cb67"}, {file = "reflex_hosting_cli-0.1.28-py3-none-any.whl", hash = "sha256:68c60e8b2cb8856d0b8eac1f06410d8fe192944884f54bfad47adf5db62bd395"},
{file = "reflex_hosting_cli-0.1.17.tar.gz", hash = "sha256:263d8dc217eb24d4198ac0bcfd710980bd7795d9818a5e522027657f94752710"}, {file = "reflex_hosting_cli-0.1.28.tar.gz", hash = "sha256:9b4fb771396ffeba857ada0207fdfd78e2e40b8e35a5486b89cb07f1aa416867"},
] ]
[package.dependencies] [package.dependencies]
@ -2224,7 +2224,7 @@ pydantic = ">=1.10.2,<3.0"
python-dateutil = ">=2.8.1" python-dateutil = ">=2.8.1"
rich = ">=13.0.0,<14.0" rich = ">=13.0.0,<14.0"
tabulate = ">=0.9.0,<0.10.0" tabulate = ">=0.9.0,<0.10.0"
typer = ">=0.4.2,<1" typer = ">=0.15.0,<1"
websockets = ">=10.4" websockets = ">=10.4"
[[package]] [[package]]
@ -2722,13 +2722,13 @@ urllib3 = ">=1.26.0"
[[package]] [[package]]
name = "typer" name = "typer"
version = "0.13.1" version = "0.15.1"
description = "Typer, build great CLIs. Easy to code. Based on Python type hints." description = "Typer, build great CLIs. Easy to code. Based on Python type hints."
optional = false optional = false
python-versions = ">=3.7" python-versions = ">=3.7"
files = [ files = [
{file = "typer-0.13.1-py3-none-any.whl", hash = "sha256:5b59580fd925e89463a29d363e0a43245ec02765bde9fb77d39e5d0f29dd7157"}, {file = "typer-0.15.1-py3-none-any.whl", hash = "sha256:7994fb7b8155b64d3402518560648446072864beefd44aa2dc36972a5972e847"},
{file = "typer-0.13.1.tar.gz", hash = "sha256:9d444cb96cc268ce6f8b94e13b4335084cef4c079998a9f4851a90229a3bd25c"}, {file = "typer-0.15.1.tar.gz", hash = "sha256:a0588c0a7fa68a1978a069818657778f86abe6ff5ea6abf472f940a08bfe4f0a"},
] ]
[package.dependencies] [package.dependencies]
@ -3041,4 +3041,4 @@ type = ["pytest-mypy"]
[metadata] [metadata]
lock-version = "2.0" lock-version = "2.0"
python-versions = "^3.9" python-versions = "^3.9"
content-hash = "8000601d48cfc1b10d0ae18c6046cc59a50cb6c45e6d3ef4775a3203769f2154" content-hash = "8d908859a32731cfe8ec4d0d855f5643a2d8150f4a2a27b3dd8d4485877862ea"

View File

@ -49,7 +49,7 @@ wrapt = [
{version = ">=1.11.0,<2.0", python = "<3.11"}, {version = ">=1.11.0,<2.0", python = "<3.11"},
] ]
packaging = ">=23.1,<25.0" packaging = ">=23.1,<25.0"
reflex-hosting-cli = ">=0.1.17,<2.0" reflex-hosting-cli = ">=0.1.28,<2.0"
charset-normalizer = ">=3.3.2,<4.0" charset-normalizer = ">=3.3.2,<4.0"
wheel = ">=0.42.0,<1.0" wheel = ">=0.42.0,<1.0"
build = ">=1.0.3,<2.0" build = ">=1.0.3,<2.0"

View File

@ -652,9 +652,9 @@ class Config(Base):
frontend_packages: List[str] = [] frontend_packages: List[str] = []
# The hosting service backend URL. # The hosting service backend URL.
cp_backend_url: str = Hosting.CP_BACKEND_URL cp_backend_url: str = Hosting.HOSTING_SERVICE
# The hosting service frontend URL. # The hosting service frontend URL.
cp_web_url: str = Hosting.CP_WEB_URL cp_web_url: str = Hosting.HOSTING_SERVICE_UI
# The worker class used in production mode # The worker class used in production mode
gunicorn_worker_class: str = "uvicorn.workers.UvicornH11Worker" gunicorn_worker_class: str = "uvicorn.workers.UvicornH11Worker"

View File

@ -827,11 +827,11 @@ def _collect_details_for_gallery():
Raises: Raises:
Exit: If pyproject.toml file is ill-formed or the request to the backend services fails. Exit: If pyproject.toml file is ill-formed or the request to the backend services fails.
""" """
from reflex.reflex import _login from reflex_cli.utils import hosting
console.rule("[bold]Authentication with Reflex Services") console.rule("[bold]Authentication with Reflex Services")
console.print("First let's log in to Reflex backend services.") console.print("First let's log in to Reflex backend services.")
access_token = _login() access_token, _ = hosting.authenticated_token()
console.rule("[bold]Custom Component Information") console.rule("[bold]Custom Component Information")
params = {} params = {}

View File

@ -9,8 +9,6 @@ from typing import List, Optional
import typer import typer
import typer.core import typer.core
from reflex_cli.deployments import deployments_cli
from reflex_cli.utils import dependency
from reflex_cli.v2.deployments import check_version, hosting_cli from reflex_cli.v2.deployments import check_version, hosting_cli
from reflex import constants from reflex import constants
@ -330,41 +328,8 @@ def export(
) )
def _login() -> str:
"""Helper function to authenticate with Reflex hosting service."""
from reflex_cli.utils import hosting
access_token, invitation_code = hosting.authenticated_token()
if access_token:
console.print("You already logged in.")
return access_token
# If not already logged in, open a browser window/tab to the login page.
access_token = hosting.authenticate_on_browser(invitation_code)
if not access_token:
console.error("Unable to authenticate. Please try again or contact support.")
raise typer.Exit(1)
console.print("Successfully logged in.")
return access_token
@cli.command() @cli.command()
def login( def login(loglevel: constants.LogLevel = typer.Option(config.loglevel)):
loglevel: constants.LogLevel = typer.Option(
config.loglevel, help="The log level to use."
),
):
"""Authenticate with Reflex hosting service."""
# Set the log level.
console.set_log_level(loglevel)
_login()
@cli.command()
def loginv2(loglevel: constants.LogLevel = typer.Option(config.loglevel)):
"""Authenicate with experimental Reflex hosting service.""" """Authenicate with experimental Reflex hosting service."""
from reflex_cli.v2 import cli as hosting_cli from reflex_cli.v2 import cli as hosting_cli
@ -382,26 +347,11 @@ def logout(
), ),
): ):
"""Log out of access to Reflex hosting service.""" """Log out of access to Reflex hosting service."""
from reflex_cli.utils import hosting from reflex_cli.v2.cli import logout
console.set_log_level(loglevel)
hosting.log_out_on_browser()
console.debug("Deleting access token from config locally")
hosting.delete_token_from_config(include_invitation_code=True)
@cli.command()
def logoutv2(
loglevel: constants.LogLevel = typer.Option(
config.loglevel, help="The log level to use."
),
):
"""Log out of access to Reflex hosting service."""
from reflex_cli.v2 import cli
check_version() check_version()
cli.logout()
logout(loglevel) # type: ignore
db_cli = typer.Typer() db_cli = typer.Typer()
@ -486,126 +436,6 @@ def makemigrations(
@cli.command() @cli.command()
def deploy( def deploy(
key: Optional[str] = typer.Option(
None,
"-k",
"--deployment-key",
help="The name of the deployment. Domain name safe characters only.",
),
app_name: str = typer.Option(
config.app_name,
"--app-name",
help="The name of the App to deploy under.",
hidden=True,
),
regions: List[str] = typer.Option(
list(),
"-r",
"--region",
help="The regions to deploy to.",
),
envs: List[str] = typer.Option(
list(),
"--env",
help="The environment variables to set: <key>=<value>. For multiple envs, repeat this option, e.g. --env k1=v2 --env k2=v2.",
),
cpus: Optional[int] = typer.Option(
None, help="The number of CPUs to allocate.", hidden=True
),
memory_mb: Optional[int] = typer.Option(
None, help="The amount of memory to allocate.", hidden=True
),
auto_start: Optional[bool] = typer.Option(
None,
help="Whether to auto start the instance.",
hidden=True,
),
auto_stop: Optional[bool] = typer.Option(
None,
help="Whether to auto stop the instance.",
hidden=True,
),
frontend_hostname: Optional[str] = typer.Option(
None,
"--frontend-hostname",
help="The hostname of the frontend.",
hidden=True,
),
interactive: bool = typer.Option(
True,
help="Whether to list configuration options and ask for confirmation.",
),
with_metrics: Optional[str] = typer.Option(
None,
help="Setting for metrics scraping for the deployment. Setup required in user code.",
hidden=True,
),
with_tracing: Optional[str] = typer.Option(
None,
help="Setting to export tracing for the deployment. Setup required in user code.",
hidden=True,
),
upload_db_file: bool = typer.Option(
False,
help="Whether to include local sqlite db files when uploading to hosting service.",
hidden=True,
),
loglevel: constants.LogLevel = typer.Option(
config.loglevel, help="The log level to use."
),
):
"""Deploy the app to the Reflex hosting service."""
from reflex_cli import cli as hosting_cli
from reflex.utils import export as export_utils
from reflex.utils import prerequisites
# Set the log level.
console.set_log_level(loglevel)
# Only check requirements if interactive. There is user interaction for requirements update.
if interactive:
dependency.check_requirements()
# Check if we are set up.
if prerequisites.needs_reinit(frontend=True):
_init(name=config.app_name, loglevel=loglevel)
prerequisites.check_latest_package_version(constants.ReflexHostingCLI.MODULE_NAME)
hosting_cli.deploy(
app_name=app_name,
export_fn=lambda zip_dest_dir,
api_url,
deploy_url,
frontend,
backend,
zipping: export_utils.export(
zip_dest_dir=zip_dest_dir,
api_url=api_url,
deploy_url=deploy_url,
frontend=frontend,
backend=backend,
zipping=zipping,
loglevel=loglevel.subprocess_level(),
upload_db_file=upload_db_file,
),
key=key,
regions=regions,
envs=envs,
cpus=cpus,
memory_mb=memory_mb,
auto_start=auto_start,
auto_stop=auto_stop,
frontend_hostname=frontend_hostname,
interactive=interactive,
with_metrics=with_metrics,
with_tracing=with_tracing,
loglevel=loglevel.subprocess_level(),
)
@cli.command()
def deployv2(
app_name: str = typer.Option( app_name: str = typer.Option(
config.app_name, config.app_name,
"--app-name", "--app-name",
@ -657,8 +487,8 @@ def deployv2(
), ),
): ):
"""Deploy the app to the Reflex hosting service.""" """Deploy the app to the Reflex hosting service."""
from reflex_cli.utils import dependency
from reflex_cli.v2 import cli as hosting_cli from reflex_cli.v2 import cli as hosting_cli
from reflex_cli.v2.utils import dependency
from reflex.utils import export as export_utils from reflex.utils import export as export_utils
from reflex.utils import prerequisites from reflex.utils import prerequisites
@ -702,7 +532,7 @@ def deployv2(
envfile=envfile, envfile=envfile,
hostname=hostname, hostname=hostname,
interactive=interactive, interactive=interactive,
loglevel=loglevel.subprocess_level(), loglevel=type(loglevel).INFO, # type: ignore
token=token, token=token,
project=project, project=project,
) )
@ -710,15 +540,10 @@ def deployv2(
cli.add_typer(db_cli, name="db", help="Subcommands for managing the database schema.") cli.add_typer(db_cli, name="db", help="Subcommands for managing the database schema.")
cli.add_typer(script_cli, name="script", help="Subcommands running helper scripts.") cli.add_typer(script_cli, name="script", help="Subcommands running helper scripts.")
cli.add_typer(
deployments_cli,
name="deployments",
help="Subcommands for managing the Deployments.",
)
cli.add_typer( cli.add_typer(
hosting_cli, hosting_cli,
name="apps", name="cloud",
help="Subcommands for managing the Deployments.", help="Subcommands for managing the reflex cloud.",
) )
cli.add_typer( cli.add_typer(
custom_components_cli, custom_components_cli,

View File

@ -89,6 +89,11 @@ def DynamicRoute():
@rx.page(route="/arg/[arg_str]") @rx.page(route="/arg/[arg_str]")
def arg() -> rx.Component: def arg() -> rx.Component:
return rx.vstack( return rx.vstack(
rx.input(
value=DynamicState.router.session.client_token,
read_only=True,
id="token",
),
rx.data_list.root( rx.data_list.root(
rx.data_list.item( rx.data_list.item(
rx.data_list.label("rx.State.arg_str (dynamic)"), rx.data_list.label("rx.State.arg_str (dynamic)"),
@ -373,12 +378,14 @@ async def test_on_load_navigate_non_dynamic(
async def test_render_dynamic_arg( async def test_render_dynamic_arg(
dynamic_route: AppHarness, dynamic_route: AppHarness,
driver: WebDriver, driver: WebDriver,
token: str,
): ):
"""Assert that dynamic arg var is rendered correctly in different contexts. """Assert that dynamic arg var is rendered correctly in different contexts.
Args: Args:
dynamic_route: harness for DynamicRoute app. dynamic_route: harness for DynamicRoute app.
driver: WebDriver instance. driver: WebDriver instance.
token: The token visible in the driver browser.
""" """
assert dynamic_route.app_instance is not None assert dynamic_route.app_instance is not None
with poll_for_navigation(driver): with poll_for_navigation(driver):
@ -398,7 +405,8 @@ async def test_render_dynamic_arg(
el = driver.find_element(By.ID, id) el = driver.find_element(By.ID, id)
assert el assert el
assert ( assert (
dynamic_route.poll_for_content(el, exp_not_equal=expect_not) == expected dynamic_route.poll_for_content(el, timeout=30, exp_not_equal=expect_not)
== expected
) )
assert_content("0", "") assert_content("0", "")