Merge remote-tracking branch 'origin/main' into deploy-dmo-package

Author: zach-maddox

src/datacustomcode/cli.py

@@ -198,11 +198,7 @@ def zip(path: str, network: str):
     default=None,
     help="SF CLI org alias or username. Fetches credentials via `sf org display`.",
 )
-@click.option(
-    "--use-in-feature",
-    default="SearchIndexChunking",
-    help="Feature where this function will be used.",
-)
+@click.option("--use-in-feature", default=None, hidden=True, deprecated=True)
 def deploy(
     path: str,
     name: str,
@@ -248,17 +244,20 @@ def deploy(
     )
 
     if package_type == "function":
-        # Try to infer use_in_feature from function signature; fall back to
-        # the explicit flag value (defaults to SearchIndexChunking)
+        # Infer use_in_feature from function signature
         entrypoint_path = os.path.join(path, ENTRYPOINT_FILE)
-        inferred = infer_use_in_feature(entrypoint_path)
-        if inferred:
-            use_in_feature = inferred
+        use_in_feature = infer_use_in_feature(entrypoint_path)
+        if use_in_feature:
             logger.info(f"Inferred use_in_feature: {use_in_feature}")
         else:
-            logger.info(f"Using use_in_feature: {use_in_feature}")
+            click.secho(
+                "Error: Function signature does not match a supported type. "
+                "Use SearchIndexChunkingV1Request and "
+                "SearchIndexChunkingV1Response in function signature.",
+                fg="red",
+            )
+            raise click.Abort()
 
-        assert use_in_feature is not None
         # Map feature names to Connect API names
         mapped_feature = USE_IN_FEATURE_MAPPING_FOR_CONNECT_API.get(
             use_in_feature, use_in_feature

src/datacustomcode/token_provider.py

@@ -140,37 +140,44 @@ def _run_sf_command(args: list[str], description: str) -> dict:
                 )
             return dict(data)
 
-        # Get instanceUrl from sf org display
+        # Get org info from sf org display
         display_data = _run_sf_command(
             ["sf", "org", "display", "--target-org", self.sf_cli_org, "--json"],
             "sf org display",
         )
-        instance_url = display_data.get("result", {}).get("instanceUrl")
+        result_data = display_data.get("result", {})
+        instance_url = result_data.get("instanceUrl")
         if not instance_url:
             raise RuntimeError(
                 f"'sf org display' did not return an instance URL "
                 f"for org '{self.sf_cli_org}'"
             )
 
-        # Get access token via show-access-token (newer SF CLI versions
-        # redact the token in sf org display)
-        token_data = _run_sf_command(
-            [
-                "sf",
-                "org",
-                "auth",
-                "show-access-token",
-                "--target-org",
-                self.sf_cli_org,
-                "--json",
-            ],
-            "sf org auth show-access-token",
-        )
-        access_token = token_data.get("result", {}).get("accessToken")
+        # Try show-access-token first (SF CLI >= 2.136.6); fall back to the
+        # token from sf org display (older CLIs don't redact it).
+        access_token = None
+        try:
+            token_data = _run_sf_command(
+                [
+                    "sf",
+                    "org",
+                    "auth",
+                    "show-access-token",
+                    "--target-org",
+                    self.sf_cli_org,
+                    "--json",
+                ],
+                "sf org auth show-access-token",
+            )
+            access_token = token_data.get("result", {}).get("accessToken")
+        except RuntimeError:
+            # Command not available on older SF CLI versions
+            access_token = result_data.get("accessToken")
+
         if not access_token:
             raise RuntimeError(
-                f"'sf org auth show-access-token' did not return an access token "
-                f"for org '{self.sf_cli_org}'"
+                f"Could not obtain an access token for org '{self.sf_cli_org}'. "
+                f"Upgrade SF CLI to 2.136.6+ or ensure the org is authenticated."
             )
 
         return AccessTokenResponse(access_token=access_token, instance_url=instance_url)

tests/io/reader/test_sf_cli.py

@@ -175,7 +175,7 @@ def test_missing_access_token_raises_runtime_error(self, reader):
         token_result = MagicMock()
         token_result.stdout = json.dumps({"status": 0, "result": {}})
         with patch("subprocess.run", side_effect=[display_result, token_result]):
-            with pytest.raises(RuntimeError, match="did not return an access token"):
+            with pytest.raises(RuntimeError, match="Could not obtain an access token"):
                 reader._get_token()
 
     def test_missing_instance_url_raises_runtime_error(self, reader):

tests/test_sf_cli_contract.py

@@ -188,26 +188,6 @@ def test_accepts_network_flag(
         result = runner.invoke(deploy, [*self._BASE_ARGS, "--network", "custom"])
         assert result.exit_code != 2, result.output
 
-    @patch("datacustomcode.token_provider.SFCLITokenProvider")
-    @patch("datacustomcode.deploy.deploy_full")
-    @patch("datacustomcode.cli.find_base_directory")
-    @patch("datacustomcode.cli.get_package_type")
-    def test_accepts_use_in_feature_flag(
-        self, mock_pkg_type, mock_find_base, mock_deploy_full, mock_sf_cli_provider
-    ):
-        mock_find_base.return_value = "payload"
-        mock_pkg_type.return_value = "function"
-        mock_provider_instance = mock_sf_cli_provider.return_value
-        mock_provider_instance.get_token.return_value = AccessTokenResponse(
-            access_token="tok", instance_url="https://example.com"
-        )
-        runner = CliRunner()
-        result = runner.invoke(
-            deploy,
-            [*self._BASE_ARGS, "--use-in-feature", "SearchIndexChunking"],
-        )
-        assert result.exit_code != 2, result.output
-
 
 class TestRunArgContract:
     """

tests/test_token_provider.py

@@ -197,6 +197,40 @@ def test_successful_token_retrieval(self):
             assert "org" in display_call[0][0] and "display" in display_call[0][0]
             assert "show-access-token" in token_call[0][0]
 
+    def test_fallback_to_display_token_on_older_cli(self):
+        """Test fallback to sf org display token when show-access-token unavailable."""
+        import json
+        import subprocess
+
+        provider = SFCLITokenProvider("test_org")
+
+        display_output = json.dumps(
+            {
+                "status": 0,
+                "result": {
+                    "accessToken": "display_token",
+                    "instanceUrl": "https://cli.salesforce.com",
+                },
+            }
+        )
+
+        def side_effect(*args, **kwargs):
+            cmd = args[0]
+            if "show-access-token" in cmd:
+                raise subprocess.CalledProcessError(
+                    returncode=2, cmd="sf", stderr="not a sf command"
+                )
+            mock = MagicMock()
+            mock.stdout = display_output
+            return mock
+
+        with patch("subprocess.run", side_effect=side_effect):
+            result = provider.get_token()
+
+            assert isinstance(result, AccessTokenResponse)
+            assert result.access_token == "display_token"
+            assert result.instance_url == "https://cli.salesforce.com"
+
     def test_sf_command_not_found(self):
         """Test that FileNotFoundError is wrapped in RuntimeError."""
         provider = SFCLITokenProvider("test_org")