fix: improve pagination for asm search

censys/asm/inventory.py

@@ -18,6 +18,7 @@ def search(
         cursor: Optional[str] = None,
         sort: Optional[List[str]] = None,
         fields: Optional[List[str]] = None,
+        pages: Optional[int] = None,
     ) -> dict:
         """Search inventory data.
 
@@ -28,6 +29,7 @@ def search(
             cursor (str, optional): Cursor to start search from.
             sort (List[str], optional): List of fields to sort by.
             fields (List[str], optional): List of fields to return.
+            pages (int, optional): Number of pages of results to return (when set to -1 returns all pages available).
 
         Returns:
             dict: Inventory search results.
@@ -43,6 +45,9 @@ def search(
         if page_size is None:
             page_size = 50
 
+        if pages is None:
+            pages = 1
+
         args = {
             "workspaces": workspaces,
             "pageSize": page_size,
@@ -57,7 +62,24 @@ def search(
         if fields:
             args["fields"] = fields
 
-        return self._get(self.base_path, args=args)
+        page = 0
+        next_cursor = None
+        hits = []
+        resp = self._get(self.base_path, args=args)
+        next_cursor = resp.get("nextCursor")
+        hits.extend(resp.get("hits", []))
+        while next_cursor and (page == 0 or pages == -1 or page < pages):
+            args["cursor"] = next_cursor
+            resp = self._get(self.base_path, args=args)
+            if "nextCursor" in resp:
+                next_cursor = resp.get("nextCursor")
+            else:
+                next_cursor = None
+            hits.extend(resp.get("hits", []))
+            page += 1
+
+        resp["hits"] = hits
+        return resp
 
     def aggregate(
         self,

censys/cli/commands/asm.py

@@ -557,7 +557,9 @@ def cli_execute_saved_query_by_name(args: argparse.Namespace):
     query = results[0]["query"]
 
     try:
-        res = s.search(None, query, args.page_size, None, args.sort, args.fields)
+        res = s.search(
+            None, query, args.page_size, None, args.sort, args.fields, args.pages
+        )
         console.print_json(json.dumps(res))
     except CensysAsmException:
         console.print("Failed to execute saved query.")
@@ -579,7 +581,9 @@ def cli_execute_saved_query_by_id(args: argparse.Namespace):
         console.print("No saved query found with that ID.")
         sys.exit(1)
     try:
-        res = s.search(None, query, args.page_size, None, args.sort, args.fields)
+        res = s.search(
+            None, query, args.page_size, None, args.sort, args.fields, args.pages
+        )
         console.print_json(json.dumps(res))
     except CensysAsmException:
         console.print("Failed to execute saved query.")
@@ -602,6 +606,7 @@ def cli_search(args: argparse.Namespace):
             args.cursor,
             args.sort,
             args.fields,
+            args.pages,
         )
         console.print_json(json.dumps(res))
     except CensysAsmException:
@@ -885,6 +890,12 @@ def add_verbose(parser):
         type=List[str],
         default=[],
     )
+    execute_saved_query_by_name_parser.add_argument(
+        "--pages",
+        help="Number of pages to return. Defaults to 1.",
+        type=int,
+        default=1,
+    )
     add_verbose(execute_saved_query_by_name_parser)
     execute_saved_query_by_name_parser.set_defaults(
         func=cli_execute_saved_query_by_name
@@ -920,6 +931,12 @@ def add_verbose(parser):
         type=List[str],
         default=[],
     )
+    execute_saved_query_by_id_parser.add_argument(
+        "--pages",
+        help="Number of pages to return. Defaults to 1.",
+        type=int,
+        default=1,
+    )
     add_verbose(execute_saved_query_by_id_parser)
     execute_saved_query_by_id_parser.set_defaults(func=cli_execute_saved_query_by_id)
 
@@ -965,5 +982,11 @@ def add_verbose(parser):
         type=str,
         required=False,
     )
+    search_parser.add_argument(
+        "--pages",
+        help="Number of pages to return. Defaults to 1.",
+        type=int,
+        default=1,
+    )
     add_verbose(search_parser)
     search_parser.set_defaults(func=cli_search)

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "censys"
-version = "2.2.13"
+version = "2.2.14"
 description = "An easy-to-use and lightweight API wrapper for Censys APIs (censys.io)."
 authors = ["Censys, Inc. <support@censys.io>"]
 license = "Apache-2.0"

tests/asm/test_inventory.py

@@ -12,7 +12,7 @@
 
 TEST_INVENTORY_SEARCH_JSON = {
     "totalHits": 0,
-    "nextCursor": "string",
+    "nextCursor": "",
     "previousCursor": "string",
     "queryDurationMillis": 0,
     "hits": [{}],