From d7bc0fd914f9f5b02919547cedbbd4adb8f0ebeb Mon Sep 17 00:00:00 2001 From: alemi Date: Fri, 9 Jun 2023 00:25:05 +0200 Subject: [PATCH] feat: some (wip) work to make a generic wrapper --- src/model.rs | 140 +++++++++++++++++++++++++++++++++------------------ 1 file changed, 92 insertions(+), 48 deletions(-) diff --git a/src/model.rs b/src/model.rs index ecca014..72d043a 100644 --- a/src/model.rs +++ b/src/model.rs @@ -1,60 +1,104 @@ -use std::str::FromStr; +use postman_collection::{PostmanCollection, v1_0_0, v2_0_0, v2_1_0}; -use reqwest::{Method, Result, Client, Response, Url}; +pub struct PostWomanCollection { + collection: PostmanCollection +} -impl Request { - pub async fn send(self) -> Result { - match self { - Self::Object { url, method, header, body, description: _ } => { - let method = Method::from_bytes( - method.as_bytes() // TODO lol? - ).unwrap_or(Method::GET); // TODO throw an error rather than replacing it silently +impl From for PostWomanCollection { + fn from(value: PostmanCollection) -> Self { + Self { collection: value } + } +} - let url = Url::from_str(&url.to_string()).unwrap(); - - let mut req = Client::new().request(method, url); - - if let Some(headers) = header { - for h in headers { - req = req.header(h.key.clone(), h.value.clone()) - } - } - - if let Some(body) = body { - req = req.body(body.to_string()); - } - - req.send().await +impl PostWomanCollection { + pub fn description(&self) -> Option<&String> { + match &self.collection { + PostmanCollection::V1_0_0(spec) => { + spec.description.as_ref() + }, + PostmanCollection::V2_0_0(spec) => { + match &spec.info.description { + Some(v2_0_0::DescriptionUnion::String(x)) => Some(x), + Some(v2_0_0::DescriptionUnion::Description(v2_0_0::Description { content, .. })) => content.as_ref(), + None => None, + } + }, + PostmanCollection::V2_1_0(spec) => { + match &spec.info.description { + Some(v2_1_0::DescriptionUnion::String(x)) => Some(x), + Some(v2_1_0::DescriptionUnion::Description(v2_1_0::Description { content, .. })) => content.as_ref(), + None => None, + } + }, + } + } + + pub fn requests(&self) -> Vec { + match self.collection { + PostmanCollection::V1_0_0(_) => todo!(), + PostmanCollection::V2_0_0(spec) => { + let mut out = Vec::new(); + for item in spec.item { + out.append(&mut collect_requests_2_0_0_r(&item)); + } + out + }, + PostmanCollection::V2_1_0(spec) => { + let mut out = Vec::new(); + for item in spec.item { + out.append(&mut collect_requests_2_1_0_r(&item)); + } + out }, - Self::String(url) => reqwest::get(url).await } } } -impl PostWomanCollection { // TODO repeated code from Item.collect() - pub fn collect(&self) -> Vec { - let mut out = Vec::new(); - for i in &self.item { - out.append(&mut i.collect()) - } - out +pub fn collect_requests_1_0_0_r(root: &v1_0_0::Spec) -> Vec { + todo!() +} + +pub trait IntoRequest { + fn make_request(&self) -> reqwest::Request; +} + +impl IntoRequest for v2_0_0::RequestClass { + fn make_request(&self) -> reqwest::Request { + todo!() } } -impl Item { - pub fn collect(&self) -> Vec { - let mut out = Vec::new(); // TODO very inefficient to always allocate - - if let Some(items) = &self.item { - for item in items { - out.append(&mut item.collect()); - } - } - - if let Some(req) = &self.request { - out.push(req.clone()); - } - - out - } +pub trait CollectRequests { + fn from_self(&self) -> &reqwest::Request; +} + +pub fn collect_requests_2_0_0_r(root: &v2_0_0::Items) -> Vec { + let mut requests = Vec::new(); + if let Some(r) = root.request { + let clazz = match r { + v2_0_0::RequestUnion::String(url) => v2_0_0::RequestClass { + auth: None, + body: None, + certificate: None, + description: None, + header: None, + method: None, + proxy: None, + url: Some(v2_0_0::Url::String(url)), + }, + v2_0_0::RequestUnion::RequestClass(r) => r, + }; + requests.push(clazz.make_request()); + } + if let Some(sub) = root.item { + for item in sub { + requests.append(&mut collect_requests_2_0_0_r(&item)); + } + + } + requests +} + +pub fn collect_requests_2_1_0_r(root: &v2_1_0::Items) -> Vec { + todo!() }