boxxkite-client 0.3.0

Rust client for a hosted boxxkite control-plane (sandboxes, exec, files, audit log, human takeover)
Documentation 
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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130

//! Agent-invokable language-server completions: `POST /v1/sandboxes/{id}/lsp/start`
//! and its `/{lsp_id}/open`, `/{lsp_id}/completion`, `/{lsp_id}/stop`
//! siblings. Mirrors `sdk-python`'s `lsp_start`/`lsp_open`/`lsp_completion`/
//! `lsp_stop` (`sdk-go` does not wrap these).

use reqwest::Method;
use serde::{Deserialize, Serialize};

use crate::client::Client;
use crate::error::BoxxkiteError;

/// `POST /v1/sandboxes/{id}/lsp/start`'s response. `lsp_id` is an opaque
/// handle to pass to the other LSP calls.
#[derive(Debug, Clone, Deserialize)]
pub struct LspStartResult {
    pub lsp_id: String,
}

/// `POST /v1/sandboxes/{id}/lsp/{lsp_id}/open`'s response.
#[derive(Debug, Clone, Deserialize)]
pub struct LspOpenResult {
    pub status: String,
}

/// `POST /v1/sandboxes/{id}/lsp/{lsp_id}/completion`'s response. Each item is
/// a raw LSP `CompletionItem` object -- left as raw JSON rather than an
/// over-fitted struct, since the shape is the language server's, not this
/// API's (matching how `ls`/`glob` leave their entries untyped).
#[derive(Debug, Clone, Deserialize)]
pub struct LspCompletionResult {
    #[serde(default)]
    pub items: Vec<serde_json::Value>,
}

/// `POST /v1/sandboxes/{id}/lsp/{lsp_id}/stop`'s response.
#[derive(Debug, Clone, Deserialize)]
pub struct LspStopResult {
    pub status: String,
}

impl Client {
    /// `POST /v1/sandboxes/{session_id}/lsp/start` -- start a persistent
    /// language server (`pyright` for `"python"`,
    /// `typescript-language-server` for `"typescript"`/`"javascript"`).
    /// Returns the opaque `lsp_id` handle for the other LSP calls.
    pub async fn lsp_start(
        &self,
        session_id: &str,
        language: &str,
    ) -> Result<LspStartResult, BoxxkiteError> {
        #[derive(Serialize)]
        struct Body<'a> {
            language: &'a str,
        }
        let builder = self
            .request(
                Method::POST,
                &format!("/v1/sandboxes/{session_id}/lsp/start"),
            )
            .json(&Body { language });
        self.send(builder).await
    }

    /// `POST /v1/sandboxes/{session_id}/lsp/{lsp_id}/open` -- open (or
    /// full-document-replace) a document on a running language server.
    pub async fn lsp_open(
        &self,
        session_id: &str,
        lsp_id: &str,
        path: &str,
        content: &str,
    ) -> Result<LspOpenResult, BoxxkiteError> {
        #[derive(Serialize)]
        struct Body<'a> {
            path: &'a str,
            content: &'a str,
        }
        let builder = self
            .request(
                Method::POST,
                &format!("/v1/sandboxes/{session_id}/lsp/{lsp_id}/open"),
            )
            .json(&Body { path, content });
        self.send(builder).await
    }

    /// `POST /v1/sandboxes/{session_id}/lsp/{lsp_id}/completion` -- request
    /// completions at a 0-indexed `(line, character)` position. `path` must
    /// already be open on this handle (see [`Client::lsp_open`]).
    pub async fn lsp_completion(
        &self,
        session_id: &str,
        lsp_id: &str,
        path: &str,
        line: u32,
        character: u32,
    ) -> Result<LspCompletionResult, BoxxkiteError> {
        #[derive(Serialize)]
        struct Body<'a> {
            path: &'a str,
            line: u32,
            character: u32,
        }
        let builder = self
            .request(
                Method::POST,
                &format!("/v1/sandboxes/{session_id}/lsp/{lsp_id}/completion"),
            )
            .json(&Body {
                path,
                line,
                character,
            });
        self.send(builder).await
    }

    /// `POST /v1/sandboxes/{session_id}/lsp/{lsp_id}/stop` -- gracefully shut
    /// down a running language server.
    pub async fn lsp_stop(
        &self,
        session_id: &str,
        lsp_id: &str,
    ) -> Result<LspStopResult, BoxxkiteError> {
        let builder = self.request(
            Method::POST,
            &format!("/v1/sandboxes/{session_id}/lsp/{lsp_id}/stop"),
        );
        self.send(builder).await
    }
}