objectiveai-api 2.0.5

ObjectiveAI API Server
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

//! Wrapper around [`objectiveai_sdk::HttpClient`] that injects per-request
//! authorization headers from the request context.

use crate::ctx;
use std::sync::Arc;

/// ObjectiveAI HTTP client that injects per-request authorization from context.
///
/// Stores the same configuration as [`objectiveai_sdk::HttpClient`]. The per-request
/// authorization fields are populated via [`with_authorization`](Self::with_authorization).
#[derive(Debug, Clone)]
pub struct Client {
    pub http_client: reqwest::Client,
    pub address: String,
    pub authorization: Option<String>,
    pub user_agent: String,
    pub x_title: String,
    pub http_referer: String,
    pub x_github_authorization: Option<Arc<String>>,
    pub x_openrouter_authorization: Option<Arc<String>>,
    pub x_mcp_authorization: Option<Arc<std::collections::HashMap<String, String>>>,
    pub x_viewer_signature: Option<Arc<String>>,
    pub x_viewer_address: Option<Arc<String>>,
    pub x_commit_author_name: Option<Arc<String>>,
    pub x_commit_author_email: Option<Arc<String>>,
}

impl Client {
    pub fn new(
        http_client: reqwest::Client,
        address: String,
        authorization: Option<String>,
        user_agent: String,
        x_title: String,
        http_referer: String,
        x_github_authorization: Option<Arc<String>>,
        x_openrouter_authorization: Option<Arc<String>>,
        x_mcp_authorization: Option<Arc<std::collections::HashMap<String, String>>>,
        x_viewer_signature: Option<Arc<String>>,
        x_viewer_address: Option<Arc<String>>,
        x_commit_author_name: Option<Arc<String>>,
        x_commit_author_email: Option<Arc<String>>,
    ) -> Self {
        Self {
            http_client,
            address,
            authorization,
            user_agent,
            x_title,
            http_referer,
            x_github_authorization,
            x_openrouter_authorization,
            x_mcp_authorization,
            x_viewer_signature,
            x_viewer_address,
            x_commit_author_name,
            x_commit_author_email,
        }
    }

    /// Creates an [`objectiveai_sdk::HttpClient`] with authorization headers
    /// populated from the request context.
    pub async fn with_authorization<CTXEXT: ctx::ContextExt>(
        &self,
        ctx: &ctx::Context<CTXEXT, impl crate::ctx::persistent_cache::PersistentCacheClient>,
    ) -> objectiveai_sdk::HttpClient {
        let (
            ctx_github_authorization,
            ctx_openrouter_authorization,
            ctx_mcp_authorization,
            ctx_viewer_signature,
            ctx_viewer_address,
            ctx_commit_author_name,
            ctx_commit_author_email,
        ) = tokio::join!(
            ctx.github_authorization(),
            ctx.upstream_authorization(objectiveai_sdk::agent::Upstream::Openrouter),
            ctx.mcp_authorization(),
            ctx.viewer_signature(),
            ctx.viewer_address(),
            ctx.commit_author_name(),
            ctx.commit_author_email(),
        );

        let authorization = match ctx.objectiveai_authorization() {
            Some(token) => Some(token.clone()),
            None => self.authorization.as_ref().map(|k| Arc::new(k.clone())),
        };

        objectiveai_sdk::HttpClient {
            http_client: self.http_client.clone(),
            address: self.address.clone(),
            authorization,
            user_agent: Some(self.user_agent.clone()),
            x_title: Some(self.x_title.clone()),
            http_referer: Some(self.http_referer.clone()),
            x_github_authorization: ctx_github_authorization
                .or_else(|| self.x_github_authorization.clone()),
            x_openrouter_authorization: ctx_openrouter_authorization
                .or_else(|| self.x_openrouter_authorization.clone()),
            x_mcp_authorization: ctx_mcp_authorization
                .or_else(|| self.x_mcp_authorization.clone()),
            x_viewer_signature: ctx_viewer_signature
                .or_else(|| self.x_viewer_signature.clone()),
            x_viewer_address: ctx_viewer_address
                .or_else(|| self.x_viewer_address.clone()),
            x_commit_author_name: ctx_commit_author_name
                .or_else(|| self.x_commit_author_name.clone()),
            x_commit_author_email: ctx_commit_author_email
                .or_else(|| self.x_commit_author_email.clone()),
        }
    }
}