github-copilot-sdk 1.0.24-preview.0

Rust SDK for programmatic control of the GitHub Copilot CLI via JSON-RPC.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

use std::sync::Arc;
use std::time::Duration;

use github_copilot_sdk::handler::ApproveAllHandler;
use github_copilot_sdk::{Client, SessionConfig};

use super::support::{DEFAULT_TEST_TOKEN, with_e2e_context_no_snapshot};

#[tokio::test]
async fn should_forward_github_telemetry_on_session_create() {
    // TODO(cli-1.0.81-2): CLI 1.0.81-2 does not forward GitHub telemetry notifications over
    // the in-process (FFI) host, mirroring the existing telemetry-configuration limitation.
    if super::support::skip_inprocess("GitHub telemetry forwarding is not honored in-process") {
        return;
    }
    with_e2e_context_no_snapshot(|ctx| {
        Box::pin(async move {
            ctx.set_default_copilot_user();

            let (collected, mut notifications) = tokio::sync::mpsc::unbounded_channel();
            let client = Client::start(ctx.client_options().with_on_github_telemetry(move |n| {
                let _ = collected.send(n);
            }))
            .await
            .expect("start client");
            let session = client
                .create_session(
                    SessionConfig::default()
                        .with_github_token(DEFAULT_TEST_TOKEN)
                        .with_permission_handler(Arc::new(ApproveAllHandler)),
                )
                .await
                .expect("create session");

            let first = tokio::time::timeout(Duration::from_secs(30), notifications.recv())
                .await
                .expect("timed out waiting for github telemetry notification")
                .expect("github telemetry notification");
            assert!(
                first
                    .session_id
                    .as_deref()
                    .is_some_and(|session_id| !session_id.is_empty())
            );
            let _: bool = first.restricted;
            assert!(!first.event.kind.is_empty());
            session.disconnect().await.expect("disconnect session");
            client.stop().await.expect("stop client");
        })
    })
    .await;
}