support for shinyapps.io

.gitignore

@@ -18,6 +18,7 @@
 /rsconnect/version.py
 htmlcov
 /tests/testdata/**/rsconnect-python/
+test-home/
 /docs/docs/index.md
 /docs/docs/changelog.md
 /rsconnect-build

requirements.txt

@@ -3,6 +3,7 @@ click>=7.0.0
 coverage
 flake8
 funcsigs
+httpretty==1.1.4
 importlib-metadata
 ipykernel
 ipython

rsconnect/actions.py

@@ -218,6 +218,15 @@ def test_server(connect_server):
     raise RSConnectException("\n".join(failures))
 
 
+def test_shinyapps_server(server: api.ShinyappsServer):
+    with api.ShinyappsClient(server) as client:
+        try:
+            result = client.get_current_user()
+            server.handle_bad_response(result)
+        except RSConnectException as exc:
+            raise RSConnectException("Failed to verify with shinyapps.io ({}).".format(exc))
+
+
 def test_api_key(connect_server):
     """
     Test that an API Key may be used to authenticate with the given RStudio Connect server.
@@ -313,7 +322,7 @@ def check_server_capabilities(connect_server, capability_functions, details_sour
             raise RSConnectException(message)
 
 
-def _make_deployment_name(connect_server, title, force_unique) -> str:
+def _make_deployment_name(remote_server: api.TargetableServer, title: str, force_unique: bool) -> str:
     """
     Produce a name for a deployment based on its title.  It is assumed that the
     title is already defaulted and validated as appropriate (meaning the title
@@ -324,7 +333,7 @@ def _make_deployment_name(connect_server, title, force_unique) -> str:
     that we collapse repeating underscores and, if the name is too short, it is
     padded to the left with underscores.
 
-    :param connect_server: the information needed to interact with the Connect server.
+    :param remote_server: the information needed to interact with the Connect server.
     :param title: the title to start with.
     :param force_unique: a flag noting whether the generated name must be forced to be
     unique.
@@ -338,7 +347,7 @@ def _make_deployment_name(connect_server, title, force_unique) -> str:
 
     # Now, make sure it's unique, if needed.
     if force_unique:
-        name = api.find_unique_name(connect_server, name)
+        name = api.find_unique_name(remote_server, name)
 
     return name
 
@@ -1447,7 +1456,7 @@ def _generate_gather_basic_deployment_info_for_python(app_mode: AppMode) -> typi
     """
 
     def gatherer(
-        connect_server: api.RSConnectServer,
+        remote_server: api.TargetableServer,
         app_store: AppStore,
         directory: str,
         entry_point: str,
@@ -1456,7 +1465,7 @@ def gatherer(
         title: str,
     ) -> typing.Tuple[str, int, str, str, bool, AppMode]:
         return _gather_basic_deployment_info_for_framework(
-            connect_server,
+            remote_server,
             app_store,
             directory,
             entry_point,
@@ -1477,7 +1486,7 @@ def gatherer(
 
 
 def _gather_basic_deployment_info_for_framework(
-    connect_server: api.RSConnectServer,
+    remote_server: api.TargetableServer,
     app_store: AppStore,
     directory: str,
     entry_point: str,
@@ -1489,7 +1498,7 @@ def _gather_basic_deployment_info_for_framework(
     """
     Helps to gather the necessary info for performing a deployment.
 
-    :param connect_server: the Connect server information.
+    :param remote_server: the server information.
     :param app_store: the store for the specified directory.
     :param directory: the primary file being deployed.
     :param entry_point: the entry point for the API in '<module>:<object> format.  if
@@ -1514,13 +1523,19 @@ def _gather_basic_deployment_info_for_framework(
         if app_id is None:
             # Possible redeployment - check for saved metadata.
             # Use the saved app information unless overridden by the user.
-            app_id, existing_app_mode = app_store.resolve(connect_server.url, app_id, app_mode)
+            app_id, existing_app_mode = app_store.resolve(remote_server.url, app_id, app_mode)
             logger.debug("Using app mode from app %s: %s" % (app_id, app_mode))
         elif app_id is not None:
             # Don't read app metadata if app-id is specified. Instead, we need
             # to get this from Connect.
-            app = api.get_app_info(connect_server, app_id)
-            existing_app_mode = AppModes.get_by_ordinal(app.get("app_mode", 0), True)
+            if isinstance(remote_server, api.RSConnectServer):
+                app = api.get_app_info(remote_server, app_id)
+                existing_app_mode = AppModes.get_by_ordinal(app.get("app_mode", 0), True)
+            elif isinstance(remote_server, api.ShinyappsServer):
+                app = api.get_shinyapp_info(remote_server, app_id)
+                existing_app_mode = AppModes.get_by_cloud_name(app.json_data["mode"])
+            else:
+                raise RSConnectException("Unable to infer Connect client.")
         if existing_app_mode and app_mode != existing_app_mode:
             msg = (
                 "Deploying with mode '%s',\n"
@@ -1538,7 +1553,7 @@ def _gather_basic_deployment_info_for_framework(
     return (
         entry_point,
         app_id,
-        _make_deployment_name(connect_server, title, app_id is None),
+        _make_deployment_name(remote_server, title, app_id is None),
         title,
         default_title,
         app_mode,
@@ -1697,7 +1712,7 @@ def create_quarto_deployment_bundle(
 
 
 def deploy_bundle(
-    connect_server: api.RSConnectServer,
+    remote_server: api.TargetableServer,
     app_id: int,
     name: str,
     title: str,
@@ -1708,7 +1723,7 @@ def deploy_bundle(
     """
     Deploys the specified bundle.
 
-    :param connect_server: the Connect server information.
+    :param remote_server: the server information.
     :param app_id: the ID of the app to deploy, if this is a redeploy.
     :param name: the name for the deploy.
     :param title: the title for the deploy.
@@ -1718,7 +1733,17 @@ def deploy_bundle(
     :return: application information about the deploy.  This includes the ID of the
     task that may be queried for deployment progress.
     """
-    return api.do_bundle_deploy(connect_server, app_id, name, title, title_is_default, bundle, env_vars)
+    ce = RSConnectExecutor(
+        server=remote_server,
+        app_id=app_id,
+        name=name,
+        title=title,
+        title_is_default=title_is_default,
+        bundle=bundle,
+        env_vars=env_vars,
+    )
+    ce.deploy_bundle()
+    return ce.state["deployed_info"]
 
 
 def spool_deployment_log(connect_server, app, log_callback):

rsconnect/actions_content.py

@@ -4,13 +4,11 @@
 import json
 import time
 import traceback
-
 from concurrent.futures import ThreadPoolExecutor, as_completed
 from datetime import datetime, timedelta
-
 import semver
 
-from .api import RSConnect, emit_task_log
+from .api import RSConnectClient, emit_task_log
 from .log import logger
 from .models import BuildStatus, ContentGuidWithBundle
 from .metadata import ContentBuildStore
@@ -37,7 +35,7 @@ def build_add_content(connect_server, content_guids_with_bundle):
             + "please wait for it to finish before adding new content."
         )
 
-    with RSConnect(connect_server, timeout=120) as client:
+    with RSConnectClient(connect_server, timeout=120) as client:
         if len(content_guids_with_bundle) == 1:
             all_content = [client.content_get(content_guids_with_bundle[0].guid)]
         else:
@@ -228,7 +226,7 @@ def _monitor_build(connect_server, content_items):
 
 def _build_content_item(connect_server, content, poll_wait):
     init_content_build_store(connect_server)
-    with RSConnect(connect_server) as client:
+    with RSConnectClient(connect_server) as client:
         # Pending futures will still try to execute when ThreadPoolExecutor.shutdown() is called
         # so just exit immediately if the current build has been aborted.
         # ThreadPoolExecutor.shutdown(cancel_futures=) isnt available until py3.9
@@ -292,7 +290,7 @@ def download_bundle(connect_server, guid_with_bundle):
     """
     :param guid_with_bundle: models.ContentGuidWithBundle
     """
-    with RSConnect(connect_server, timeout=120) as client:
+    with RSConnectClient(connect_server, timeout=120) as client:
         # bundle_id not provided so grab the latest
         if not guid_with_bundle.bundle_id:
             content = client.get_content(guid_with_bundle.guid)
@@ -311,7 +309,7 @@ def get_content(connect_server, guid):
     :param guid: a single guid as a string or list of guids.
     :return: a list of content items.
     """
-    with RSConnect(connect_server, timeout=120) as client:
+    with RSConnectClient(connect_server, timeout=120) as client:
         if isinstance(guid, str):
             result = [client.get_content(guid)]
         else:
@@ -322,7 +320,7 @@ def get_content(connect_server, guid):
 def search_content(
     connect_server, published, unpublished, content_type, r_version, py_version, title_contains, order_by
 ):
-    with RSConnect(connect_server, timeout=120) as client:
+    with RSConnectClient(connect_server, timeout=120) as client:
         result = client.search_content()
         result = _apply_content_filters(
             result, published, unpublished, content_type, r_version, py_version, title_contains