ptr.pet
+27
-21
crates/jacquard-common/tests/streaming_integration.rs
+27
-21
crates/jacquard-common/tests/streaming_integration.rs
···
1
-
#![cfg(all(feature = "streaming", feature = "reqwest-client", not(target_arch = "wasm32")))]
1
+
#![cfg(all(
2
+
feature = "streaming",
3
+
feature = "reqwest-client",
4
+
not(target_arch = "wasm32")
5
+
))]
2
6
3
7
use jacquard_common::http_client::HttpClientExt;
4
8
use jacquard_common::stream::{StreamError, StreamErrorKind};
5
9
use n0_future::StreamExt;
6
-
use bytes::Bytes;
7
10
8
11
#[tokio::test]
9
12
async fn streaming_response_delivers_all_bytes() {
···
34
37
assert!(total > 0);
35
38
}
36
39
37
-
#[tokio::test]
38
-
async fn streaming_upload_sends_all_chunks() {
39
-
let client = reqwest::Client::new();
40
+
// #[tokio::test]
41
+
// async fn streaming_upload_sends_all_chunks() {
42
+
// let client = reqwest::Client::new();
40
43
41
-
let chunks = vec![
42
-
Bytes::from("chunk1"),
43
-
Bytes::from("chunk2"),
44
-
Bytes::from("chunk3"),
45
-
];
46
-
let body_stream = futures::stream::iter(chunks.clone());
44
+
// let chunks = vec![
45
+
// Bytes::from("chunk1"),
46
+
// Bytes::from("chunk2"),
47
+
// Bytes::from("chunk3"),
48
+
// ];
49
+
// let body_stream = futures::stream::iter(chunks.clone());
47
50
48
-
// Build a complete request and extract parts
49
-
let request: http::Request<Vec<u8>> = http::Request::builder()
50
-
.method(http::Method::POST)
51
-
.uri("https://httpbin.org/post")
52
-
.body(vec![])
53
-
.unwrap();
54
-
let (parts, _) = request.into_parts();
51
+
// // Build a complete request and extract parts
52
+
// let request: http::Request<Vec<u8>> = http::Request::builder()
53
+
// .method(http::Method::POST)
54
+
// .uri("https://httpbingo.org/post")
55
+
// .body(vec![])
56
+
// .unwrap();
57
+
// let (parts, _) = request.into_parts();
55
58
56
-
let response = client.send_http_bidirectional(parts, body_stream).await.unwrap();
57
-
assert!(response.status().is_success());
58
-
}
59
+
// let response = client
60
+
// .send_http_bidirectional(parts, body_stream)
61
+
// .await
62
+
// .unwrap();
63
+
// assert!(response.status().is_success());
64
+
// }
59
65
60
66
#[tokio::test]
61
67
async fn stream_error_preserves_source() {
+9
-4
crates/jacquard/src/client.rs
+9
-4
crates/jacquard/src/client.rs
···
1072
1072
/// ```no_run
1073
1073
/// # use jacquard::client::BasicClient;
1074
1074
/// # use jacquard::types::string::AtUri;
1075
-
/// # use jacquard_api::app_bsky::feed::post::Post;
1076
-
/// use crate::jacquard::client::{Agent, AgentSessionExt};
1075
+
/// # use jacquard::api::app_bsky::feed::post::Post;
1076
+
/// # use jacquard::types::string::Datetime;
1077
+
/// # use jacquard::CowStr;
1078
+
/// use jacquard::client::MemoryCredentialSession;
1079
+
/// use jacquard::client::{Agent, AgentSessionExt};
1077
1080
/// # #[tokio::main]
1078
1081
/// # async fn main() -> Result<(), Box<dyn std::error::Error>> {
1079
-
/// let (session, _) = MemoryCredentialSession::authenticated(identifier, password, None);
1082
+
/// # let (identifier, password, post_text): (CowStr<'_>, CowStr<'_>, CowStr<'_>) = todo!();
1083
+
/// let (session, _) = MemoryCredentialSession::authenticated(identifier, password, None).await?;
1080
1084
/// let agent = Agent::from(session);
1081
-
/// let output = agent.create_record::<Post>(post, None).await?;
1085
+
/// let post = Post::builder().text(post_text).created_at(Datetime::now()).build();
1086
+
/// let output = agent.create_record(post, None).await?;
1082
1087
/// # Ok(())
1083
1088
/// # }
1084
1089
/// ```
+4
-1
examples/app_password_create_post.rs
+4
-1
examples/app_password_create_post.rs
···
29
29
let agent: Agent<_> = Agent::from(session);
30
30
31
31
// Create a simple text post using the Agent convenience method
32
-
let post = Post::builder().text(args.text).build();
32
+
let post = Post::builder()
33
+
.text(args.text)
34
+
.created_at(Datetime::now())
35
+
.build();
33
36
let output = agent.create_record(post, None).await?;
34
37
println!("✓ Created post: {}", output.uri);
35
38