checkpoint

farcaster/client.py

@@ -68,6 +68,8 @@ def __init__(
             self.create_new_auth_token(expires_in=self.rotation_duration)
 
     def get_base_path(self):
+        if self.config.neynar_api_key:
+            return self.config.neynar_base_path
         return self.config.base_path
 
     def get_base_options(self):

farcaster/config.py

@@ -3,13 +3,16 @@
 from farcaster.models import *
 
 FARCASTER_API_BASE_URL = "https://api.warpcast.com/v2/"
+NEYNAR_API_BASE_URL = "https://api.neynar.io/v2/farcaster/"
 
 
 class ConfigurationParams(BaseModel):
     username: Optional[str] = None
     password: Optional[str] = None
     base_path: str = FARCASTER_API_BASE_URL
     base_options: Optional[Dict[Any, Any]] = None
+    neynar_api_key: Optional[str] = None
+    neynar_base_path: str = NEYNAR_API_BASE_URL
 
 
 class Configuration(BaseModel):

tests/integration_tests.py

@@ -99,4 +99,19 @@ def test_stream_notifications() -> None:
             print(notification.model_dump())
 
 
-# test_stream_casts()
+def client_from_neynar() -> None:
+    load_dotenv()
+    NEYNAR_API_KEY = os.getenv("NEYNAR_API_KEY")
+    assert NEYNAR_API_KEY, "PKEY env var not set"
+    client = Warpcast(neynar_api_key=NEYNAR_API_KEY)
+    # expiry = (int(time.time()) + (10 * 60)) * 1000
+    # assert client.wallet
+    assert client.get_user_by_username("mason").username == "mason"
+    # assert client.access_token
+    # assert client.rotation_duration == 10
+    # print(client.expires_at)
+    # print(client.access_token)
+    # assert client.expires_at == expiry
+
+
+client_from_neynar()