fix: update 05_queries.py to new query api

Author: matthiaszimmermann

pyproject.toml

@@ -5,7 +5,7 @@ description = "Starter template for Arkiv Python SDK"
 readme = "README.md"
 requires-python = ">=3.10"
 dependencies = [
-    "arkiv-sdk[dev]>=1.0.0a10",
+    "arkiv-sdk[dev]>=1.0.0b1",
 ]
 
 [build-system]

src/arkiv_starter/03_clients.py

@@ -18,7 +18,7 @@
 from arkiv.provider import ProviderBuilder
 from urllib.parse import urlparse
 
-EXTERNAL_RPC_URL: str = "https://mendoza.hoodi.arkiv.network/rpc"
+EXTERNAL_RPC_URL: str = "https://rosario.hoodi.arkiv.network/rpc"
 
 def is_rpc_reachable(rpc_url: str, timeout: float = 2.0) -> bool:
     """Check if RPC endpoint is reachable using a simple socket connection."""

src/arkiv_starter/05_queries.py

@@ -1,19 +1,17 @@
 """
-Example 3: Querying Entities with Filters
+Example 5: Querying Entities with Filters
 
 This example demonstrates:
 - Creating multiple entities
-- Querying with filters (owner, content type)
+- Querying with the fluent query builder
+- Filtering with typed attributes
 - Sorting results
-- Pagination
 
-Run this example: uv run python -m arkiv_starter.03_queries
+Run this example: uv run python -m arkiv_starter.05_queries
 """
 
-from arkiv.provider import ProviderBuilder
-from arkiv import Arkiv, NamedAccount
-from arkiv.node import ArkivNode
-from arkiv.types import OrderByAttribute, QueryOptions, INT, DESC, Attributes
+from arkiv import Arkiv, IntAttr, IntSort, StrAttr
+from arkiv.types import DESC, Attributes
 
 # Setup: Start node and create client
 print("🚀 Starting local Arkiv node and client ...")
@@ -50,20 +48,30 @@
     entities.append(entity_key)
     print(f"   Created JSON entity: {entity_key}")
 
+# Query 1: Retrieve all entities with details
+# Define typed attributes
+owner = StrAttr("$owner")
+idx = IntAttr("idx")
+
 print(f"\n🔍 Query 1: Retrieving all entities with details...")
-all_with_details = list(client.arkiv.query_entities(f'$owner = "{account}"'))
+all_with_details = list(client.arkiv.select().where(owner == account).fetch())
 print(f"✅ Found {len(all_with_details)} entities:")
 for entity in all_with_details:
     if entity.payload:
         content = entity.payload.decode('utf-8')
         print(f"   Type: {entity.content_type:20} | {content:30} | {entity.attributes}")
 
+# Query 2: Retrieve entities filtered by idx and sorted by idx descending
+idx_desc = IntSort("idx", DESC)
+
 print("\n🔍 Query 2: Retrieving filtered (idx > 1 and idx < 5) and sorted (idx desc) entities")
-sort = OrderByAttribute("idx", INT, DESC)
-options = QueryOptions(order_by=[sort])
-filtered_and_sorted = list(client.arkiv.query_entities(f"idx > 1 and idx < 5", options=options))
+filtered_and_sorted = list(client.arkiv.select().where((idx > 1) & (idx < 5)).order_by(idx_desc).fetch())
 print(f"✅ Found {len(filtered_and_sorted)} entities:")
 for entity in filtered_and_sorted:
     if entity.payload:
         content = entity.payload.decode('utf-8')
         print(f"   Type: {entity.content_type:20} | {content:30} | {entity.attributes}")
+
+# Cleanup
+client.node.stop()
+print("\n✅ Node stopped.")