diff options
| -rw-r--r-- | main.c3 | 30 | ||||
| -rw-r--r-- | radapi.c3 | 105 |
2 files changed, 114 insertions, 21 deletions
@@ -22,33 +22,17 @@ import std::io; import std::encoding::json; import std::collections::object; import curl; +import radapi; -char[10485760] response; -usz response_len; String url = "https://iris.radicle.network/api/v1"; -fn usz write_callback(char* buffer, usz size, usz nitems, void* outstream) -{ - response[response_len..response_len+nitems-1] = buffer[..nitems-1]; - response_len += nitems; - return nitems; -} - -fn void get(Curl* c, String endpoint) -{ - response_len = 0; - curl::easy_setopt(c, CurlOption.URL, url.tconcat(endpoint)); - curl::easy_setopt(c, CurlOption.WRITEFUNCTION, &write_callback); - CurlResult r = curl::easy_perform(c); -} - fn int main(String[] args) { - Curl* c = curl::easy_init(); - get(c, "/repos?show=all&perPage=16384&page=0"); - curl::easy_cleanup(c); + Client* c = radapi::new_client(url); + + c.request(Request.REPO_ROOT, "?show=all&perPage=16384&page=0"); - Object* j = json::tparse((String)response[..response_len], JsonFlavor.JSONC)!!; + Object* j = json::tparse(c.response())!!; int i = 0; while (i < j.array.len()) @@ -59,5 +43,9 @@ fn int main(String[] args) i++; } + c.request(Request.REPO, "", j.get_at(0).get_string("rid"))!!; + + io::printn((String)c.buffer.[..c.buffer_index]); + return 0; } diff --git a/radapi.c3 b/radapi.c3 new file mode 100644 index 0000000..f8c35eb --- /dev/null +++ b/radapi.c3 @@ -0,0 +1,105 @@ +/* +* +* Copyright (C) 2026 Andromeda +* +* This program is free software: you can redistribute it and/or modify +* it under the terms of the GNU General Public License as published by +* the Free Software Foundation, either version 3 of the License, or +* (at your option) any later version. +* +* This program is distributed in the hope that it will be useful, +* but WITHOUT ANY WARRANTY; without even the implied warranty of +* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +* GNU General Public License for more details. +* +* You should have received a copy of the GNU General Public License +* along with this program. If not, see <https://www.gnu.org/licenses/>. +* +*/ + +module radapi; +import std::io; +import std::core::string; +import curl; + +enum Request : int (String path, int args) +{ + DELEGATES_REPOS { "/delegates/$1/repos", 1 }, + NODE { "/node", 0 }, + NODE_POLICIES_REPOS { "/node/policies/repos", 0 }, + NODE_POLICIES_REPO { "/node/policies/repos/$1", 1 }, + NODES { "/nodes/$1", 1 }, + NODES_INVENTORY { "/nodes/$1/inventory", 1 }, + REPO_ROOT { "/repos", 0 }, + REPO_SEARCH { "/repos/search", 0 }, + REPO { "/repos/$1", 1 }, + HISTORY { "/repos/$1/commits", 1 }, + COMMIT { "/repos/$1/commits/$2", 2 }, + DIFF { "/repos/$1/diff/$2/$3", 3 }, + ACTIVITY { "/repos/$1/activity", 1 }, + TREE_ROOT { "/repos/$1/tree/$2/", 2 }, + TREE { "/repos/$1/tree/$2/$3", 3 }, + STATS_TREE { "/repos/$1/stats/tree/$2", 2 }, + REMOTES { "/repos/$1/remotes", 1 }, + REMOTE { "/repos/$1/remotes/$2", 2 }, + BLOB { "/repos/$1/blob/$2/$3", 3 }, + README { "/repos/$1/readme/$2", 2 }, + JOB { "/repos/$1/jobs/$2", 2 }, + ISSUES { "/repos/$1/issues", 1 }, + ISSUE { "/repos/$1/issues/$2", 2 }, + PATCHES { "/repos/$1/patches", 1 }, + PATCH { "/repos/$1/patches/$2", 2 }, + STATS { "/stats", 0 }, +} + +struct Client +{ + Curl* c; + char[10485760]* buffer; + String endpoint; + usz buffer_index; +} + +fn Client* new_client(String endpoint) +{ + Client* self = mem::alloc(Client); + self.c = curl::easy_init(); + self.endpoint = endpoint; + self.buffer = mem::alloc(char[10485760]); + curl::easy_setopt(self.c, CurlOption.WRITEFUNCTION, &cb); + curl::easy_setopt(self.c, CurlOption.WRITEDATA, self); + return self; +} + +fn CurlResult Client.request(Client* self, Request r, String params, String... args) +{ + self.buffer_index = 0; + CurlResult cr; + String s; + @pool() + { + s = self.endpoint.tconcat(r.path); + int i; + while (i < r.args) + { + s = s.treplace(string::tformat("$%d", i+1), args[i]); + i++; + } + s = s.tconcat(params); + curl::easy_setopt(self.c, CurlOption.URL, s); + cr = curl::easy_perform(self.c); + }; + return cr; +} + +fn String Client.response(Client* self) +{ + return (String)self.buffer.[..self.buffer_index]; +} + +fn usz cb(char* buffer, usz size, usz nitems, Client* client) +{ + client.buffer.[client.buffer_index..client.buffer_index+nitems-1] = buffer[..nitems-1]; + client.buffer_index += nitems; + return nitems; +}
\ No newline at end of file |