feat: Switch PDS API endpoint dynamically (#88)

* Add SessionStore trait, which AtpAgent uses

* Restructure agent inner wrappers

* Move agent::tests

* Implement Store::update_endpoint

* Update docs

atrium-api/Cargo.toml

@@ -27,7 +27,7 @@ agent = ["tokio/sync"]
 atrium-xrpc-client = "0.2.0"
 futures = "0.3.28"
 serde_json = "1.0.107"
-tokio = { version = "1.33.0", features = ["test-util", "macros"] }
+tokio = { version = "1.33.0", features = ["macros", "rt-multi-thread"] }
 
 [package.metadata.docs.rs]
 all-features = true

atrium-api/README.md

@@ -17,7 +17,7 @@ use atrium_api::client::AtpServiceClient;
 use atrium_api::com::atproto::server::create_session::Input;
 use atrium_xrpc_client::reqwest::ReqwestClient;
 
-#[tokio::main(flavor = "current_thread")]
+#[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let client = AtpServiceClient::new(ReqwestClient::new("https://bsky.social"));
     let result = client
@@ -34,3 +34,32 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     Ok(())
 }
 ```
+
+### `AtpAgent`
+
+While `AtpServiceClient` can be used for simple XRPC calls, it is better to use `AtpAgent`, which has practical features such as session management.
+
+```rust,no_run
+use atrium_api::agent::{store::MemorySessionStore, AtpAgent};
+use atrium_xrpc_client::reqwest::ReqwestClient;
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error>> {
+    let agent = AtpAgent::new(
+        ReqwestClient::new("https://bsky.social"),
+        MemorySessionStore::default(),
+    );
+    agent.login("[email protected]", "hunter2").await?;
+    let result = agent
+        .api
+        .app
+        .bsky
+        .actor
+        .get_profile(atrium_api::app::bsky::actor::get_profile::Parameters {
+            actor: "bsky.app".into(),
+        })
+        .await?;
+    println!("{:?}", result);
+    Ok(())
+}
+```