add get_feature functionality

Author: stephenhillier

planet/cli/features.py

@@ -5,6 +5,7 @@
 
 from planet.cli.io import echo_json
 from planet.clients.features import FeaturesClient
+from planet.geojson import split_ref
 
 from .cmds import coro, translate_exceptions
 from .options import pretty, compact
@@ -122,6 +123,41 @@ async def items_list(ctx, collection_id, pretty):
         echo_json([f async for f in results], pretty)
 
 
+@features.command()  # type: ignore
+@click.pass_context
+@translate_exceptions
+@coro
+@click.argument("collection_id")
+@click.argument("feature_id", required=False)
+@pretty
+async def item_get(ctx, collection_id, feature_id, pretty):
+    """Get a feature in a collection.
+
+    You may supply either a collection ID and a feature ID, or
+    a feature reference.
+
+    Example:
+
+    planet features item-get my-collection-123 item123
+    planet features item-get pl:features/my/my-collection-123/item123"
+    """
+
+    # ensure that either collection_id and feature_id were supplied, or that
+    # a feature ref was supplied as a single value.
+    if not ((collection_id and feature_id) or
+            ("pl:features" in collection_id)):
+        raise ClickException(
+            "Must supply either collection_id and feature_id, or a valid feature reference."
+        )
+
+    if collection_id.startswith("pl:features"):
+        collection_id, feature_id = split_ref(collection_id)
+
+    async with features_client(ctx) as cl:
+        feature = await cl.get_feature(collection_id, feature_id)
+        echo_json(feature, pretty)
+
+
 @features.command()  # type: ignore
 @click.pass_context
 @translate_exceptions

planet/clients/features.py

@@ -116,7 +116,7 @@ async def get_collection(self, collection_id: str) -> dict:
 
     async def list_features(
         self,
-        collection_id,
+        collection_id: str,
         limit: int = 10,
     ) -> AsyncIterator[Feature]:
         """
@@ -164,6 +164,15 @@ def _next_link(self, page):
                                          limit=limit):
             yield Feature(**feat)
 
+    async def get_feature(self, collection_id: str,
+                          feature_id: str) -> Feature:
+        """
+        Return metadata for a single feature in a collection
+        """
+        url = f'{self._base_url}/collections/{collection_id}/items/{feature_id}'
+        response = await self._session.request(method='GET', url=url)
+        return Feature(**response.json())
+
     async def create_collection(self,
                                 title: str,
                                 description: Optional[str] = None) -> str:

planet/geojson.py

@@ -29,6 +29,17 @@
 LOGGER = logging.getLogger(__name__)
 
 
+def split_ref(ref: str) -> typing.Tuple[str, str]:
+    """split a feature ref into a tuple of the form (collection_id, feature_id)"""
+    validate_ref(ref)
+
+    # after validating the ref, return the collection_id and
+    # feature_id parts at the end.
+    parts = ref.split("/", 4)
+    path = parts[-2:]
+    return path[0], path[1]
+
+
 def as_geom_or_ref(data) -> dict:
     """Extract the geometry from GeoJSON and validate.
 

planet/sync/features.py

@@ -115,6 +115,13 @@ def list_features(self, collection_id: str) -> Iterator[Feature]:
         except StopAsyncIteration:
             pass
 
+    def get_feature(self, collection_id: str, feature_id: str) -> Feature:
+        """
+        Return metadata for a single feature in a collection
+        """
+        return self._client._call_sync(
+            self._client.get_feature(collection_id, feature_id))
+
     def add_features(self,
                      collection_id: str,
                      feature: Union[dict, GeoInterface],