use pds for fetching post

firehose_classifier.py

···
 
         try:
             post_view = await self._get_post(evt.did, op.rkey)
+
+            if post_view.labels is not None:
+                for label in post_view.labels:
+                    if label.val in ["sexual", "nudity", "porn"]:
+                        logger.info("skipping bsky labeled post")
+                        return
         except Exception as e:
             logger.error(f"Failed to get post {e}")
-            raise
-
-        if post_view.labels is not None:
-            for label in post_view.labels:
-                if label.val in ["sexual", "nudity", "porn"]:
-                    logger.info("skipping bsky labeled post")
-                    return
 
         final_label = ""
         final_pred = 0.0
···
         self, did: str, rkey: str
     ) -> atproto.models.AppBskyFeedDefs.PostView:
         at_uri = f"at://{did}/app.bsky.feed.post/{rkey}"
-        url = f"https://public.api.bsky.app/xrpc/app.bsky.feed.getPosts?uris={at_uri}"
+        url = f"{CONFIG.ozone_pds_url}/xrpc/app.bsky.feed.getPosts?uris={at_uri}"
+
+        headers = await self.ozone_client.get_auth_headers()
 
         try:
-            resp = await self.http_client.get(url)
+            resp = await self.http_client.get(url, headers=headers)
             resp.raise_for_status()
         except Exception as e:
             logger.error(f"Failed to fetch post from API: {e}")

ozone_client.py

···
         ):
             await self._refresh_session()
 
-    async def _get_auth_headers(self) -> Dict[str, str]:
+    async def get_auth_headers(self) -> Dict[str, str]:
         await self._ensure_valid_session()
 
         return {