roder-core 0.1.14

Agentic software development tools and SDKs for Roder.
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

//! Minimal in-memory [`VcsProvider`] so review tests can exercise target
//! resolution without a real repository on disk.

use std::path::Path;

use roder_api::version_control::{
    VcsBase, VcsCapabilities, VcsChangedContentPage, VcsChangedFile, VcsDetectionClaim, VcsError,
    VcsListChangesRequest, VcsProvider, VcsProviderId, VcsProviderIdentity,
    VcsReadChangedContentRequest, VcsStatus, VcsStatusRequest, VcsWorkspace,
};

pub(crate) struct StubVcs {
    base: Option<VcsBase>,
    head: Option<String>,
}

impl StubVcs {
    pub(crate) fn new(ref_name: Option<&str>, sha: Option<&str>) -> Self {
        Self {
            base: Some(VcsBase {
                ref_name: ref_name.map(str::to_string),
                sha: sha.map(str::to_string),
            }),
            head: Some("headsha".to_string()),
        }
    }
}

#[async_trait::async_trait]
impl VcsProvider for StubVcs {
    fn id(&self) -> VcsProviderId {
        "stub".to_string()
    }

    fn display_name(&self) -> String {
        "Stub".to_string()
    }

    /// Always claims the workspace; `RegistryVcsProviderResolver` picks the
    /// provider from this.
    async fn detect(&self, workspace_root: &Path) -> Result<Option<VcsDetectionClaim>, VcsError> {
        Ok(Some(VcsDetectionClaim {
            workspace: VcsWorkspace {
                root: workspace_root.to_path_buf(),
                id: None,
            },
            priority: 1,
            metadata: serde_json::Value::Null,
        }))
    }

    async fn status(&self, request: VcsStatusRequest) -> Result<VcsStatus, VcsError> {
        Ok(VcsStatus {
            provider: VcsProviderIdentity {
                id: self.id(),
                display_name: self.display_name(),
            },
            workspace: VcsWorkspace {
                root: request.workspace_root,
                id: self.head.clone(),
            },
            active_line: None,
            base: self.base.clone(),
            capabilities: VcsCapabilities::default(),
            changed_file_count: 0,
        })
    }

    async fn list_changes(
        &self,
        _request: VcsListChangesRequest,
    ) -> Result<Vec<VcsChangedFile>, VcsError> {
        Ok(Vec::new())
    }

    async fn read_changed_content(
        &self,
        request: VcsReadChangedContentRequest,
    ) -> Result<VcsChangedContentPage, VcsError> {
        Ok(VcsChangedContentPage {
            path: request.path,
            content: None,
            offset: 0,
            total_lines: 0,
            next_offset: None,
            binary: false,
        })
    }
}