paddle-rust-sdk 0.17.0

//! # Helpers for working with paginated requests.

use crate::{Error, Paddle, SuccessResponse};
use reqwest::{Method, Url};
use serde::{de::DeserializeOwned, Serialize};
use serde_json::{Map, Value};
use std::marker::PhantomData;

pub struct Paginated<'a, T> {
    client: &'a Paddle,
    path: String,
    query: Option<Value>,
    _type: PhantomData<T>,
    error: Option<Error>,
}

impl<'a, T> Paginated<'a, T> {
    pub fn new<Q>(client: &'a Paddle, path: &str, query: Q) -> Self
    where
        Q: Serialize,
    {
        let (query, error) = match serde_json::to_value(query) {
            Ok(query) => (Some(query), None),
            Err(err) => (None, Some(Error::from(err))),
        };
        Self {
            client,
            path: path.to_string(),
            query,
            _type: PhantomData,
            error,
        }
    }
}

impl<'a, T> Paginated<'a, T>
where
    T: DeserializeOwned,
{
    pub async fn next(&mut self) -> Result<Option<SuccessResponse<T>>, Error> {
        if let Some(err) = self.error.take() {
            return Err(err);
        }
        if let Some(query) = self.query.take() {
            let response = self.client.send(query, Method::GET, &self.path).await?;
            if let Some(pagination) = &response.meta.pagination {
                if pagination.has_more {
                    let url = Url::parse(&pagination.next)?;
                    self.path = url.path().to_string();
                    let query: Map<String, Value> = url
                        .query()
                        .map(serde_qs::from_str)
                        .transpose()?
                        .unwrap_or_default();
                    self.query = Some(Value::Object(query));
                }
            }
            Ok(Some(response))
        } else {
            Ok(None)
        }
    }
}

impl<'a, I> Paginated<'a, Vec<I>>
where
    I: DeserializeOwned,
{
    pub async fn all(&mut self) -> Result<Vec<I>, Error> {
        let mut collected = Vec::new();
        while let Some(response) = self.next().await? {
            collected.extend(response.data.into_iter());
        }
        Ok(collected)
    }
}