Use directives in graphql client

CHANGELOG.md

@@ -5,6 +5,8 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 ## [Unreleased]
+### Changed
+  - [#438](https://github.com/thoth-pub/thoth/issues/438) - Allow specifying query parameters based on the requested specification
 
 ## [[0.8.9]](https://github.com/thoth-pub/thoth/releases/tag/v0.8.9) - 2022-09-21
 ### Added

thoth-app/src/component/mod.rs

@@ -1,3 +1,5 @@
+#![allow(clippy::let_unit_value)]
+
 #[macro_export]
 macro_rules! pagination_helpers {
     ($component:ident, $pagination_text:ident, $search_text:ident) => {

thoth-client/assets/queries.graphql

@@ -36,7 +36,7 @@ fragment Work on Work {
             publisherUrl
         }
     }
-    issues {
+    issues(limit: $issuesLimit) {
         issueOrdinal
         series {
             seriesType
@@ -67,12 +67,12 @@ fragment Work on Work {
             }
         }
     }
-    languages {
+    languages(limit: $languagesLimit) {
         languageCode
         languageRelation
         mainLanguage
     }
-    publications {
+    publications(limit: $publicationsLimit) {
         publicationId
         publicationType
         isbn
@@ -98,12 +98,12 @@ fragment Work on Work {
             canonical
         }
     }
-    subjects {
+    subjects(limit: $subjectsLimit) {
         subjectCode
         subjectType
         subjectOrdinal
     }
-    fundings {
+    fundings(limit: $fundingsLimit) {
         program
         projectName
         projectShortname
@@ -116,7 +116,7 @@ fragment Work on Work {
             countryCode
         }
     }
-    relations {
+    relations(limit: $relationsLimit) {
         relationType
         relationOrdinal
         relatedWork {
@@ -157,13 +157,29 @@ fragment Work on Work {
     }
 }
 
-query WorkQuery($workId: Uuid!) {
+query WorkQuery(
+    $workId: Uuid!,
+    $issuesLimit: Int!,
+    $languagesLimit: Int!,
+    $publicationsLimit: Int!,
+    $subjectsLimit: Int!,
+    $fundingsLimit: Int!,
+    $relationsLimit: Int!
+) {
     work(workId: $workId) {
         ...Work
     }
 }
-query WorksQuery($publishers: [Uuid!]) {
+query WorksQuery(
+    $publishers: [Uuid!],
+    $issuesLimit: Int!,
+    $languagesLimit: Int!,
+    $publicationsLimit: Int!,
+    $subjectsLimit: Int!,
+    $fundingsLimit: Int!,
+    $relationsLimit: Int!
+) {
     works(limit: 99999, publishers: $publishers) {
         ...Work
     }
-}
+}

thoth-client/src/lib.rs

@@ -1,3 +1,4 @@
+mod parameters;
 // GraphQLQuery derive macro breaks this linting rule - ignore while awaiting fix
 #[allow(clippy::derive_partial_eq_without_eq)]
 mod queries;
@@ -9,6 +10,8 @@ use std::future::Future;
 use thoth_errors::{ThothError, ThothResult};
 use uuid::Uuid;
 
+pub use crate::parameters::QueryParameters;
+use crate::parameters::{WorkQueryVariables, WorksQueryVariables};
 pub use crate::queries::work_query::*;
 use crate::queries::{work_query, works_query, WorkQuery, WorksQuery};
 
@@ -50,18 +53,19 @@ impl ThothClient {
     ///
     /// ```no_run
     /// # use thoth_errors::ThothResult;
-    /// # use thoth_client::{ThothClient, Work};
+    /// # use thoth_client::{QueryParameters, ThothClient, Work};
     /// # use uuid::Uuid;
     ///
     /// # async fn run() -> ThothResult<Work> {
     /// let thoth_client = ThothClient::new("https://api.thoth.pub/graphql".to_string());
     /// let work_id = Uuid::parse_str("00000000-0000-0000-AAAA-000000000001")?;
-    /// let work = thoth_client.get_work(work_id).await?;
+    /// let work = thoth_client.get_work(work_id, QueryParameters::new()).await?;
     /// # Ok(work)
     /// # }
     /// ```
-    pub async fn get_work(&self, work_id: Uuid) -> ThothResult<Work> {
-        let request_body = WorkQuery::build_query(work_query::Variables { work_id });
+    pub async fn get_work(&self, work_id: Uuid, parameters: QueryParameters) -> ThothResult<Work> {
+        let variables: work_query::Variables = WorkQueryVariables::new(work_id, parameters).into();
+        let request_body = WorkQuery::build_query(variables);
         let res = self.post_request(&request_body).await.await?;
         let response_body: Response<work_query::ResponseData> = res.json().await?;
         match response_body.data {
@@ -80,18 +84,24 @@ impl ThothClient {
     ///
     /// ```no_run
     /// # use thoth_errors::ThothResult;
-    /// # use thoth_client::{ThothClient, Work};
+    /// # use thoth_client::{QueryParameters, ThothClient, Work};
     /// # use uuid::Uuid;
     ///
     /// # async fn run() -> ThothResult<Vec<Work>> {
     /// let thoth_client = ThothClient::new("https://api.thoth.pub/graphql".to_string());
     /// let publisher_id = Uuid::parse_str("00000000-0000-0000-AAAA-000000000001")?;
-    /// let works = thoth_client.get_works(Some(vec![publisher_id])).await?;
+    /// let works = thoth_client.get_works(Some(vec![publisher_id]), QueryParameters::new()).await?;
     /// # Ok(works)
     /// # }
     /// ```
-    pub async fn get_works(&self, publishers: Option<Vec<Uuid>>) -> ThothResult<Vec<Work>> {
-        let request_body = WorksQuery::build_query(works_query::Variables { publishers });
+    pub async fn get_works(
+        &self,
+        publishers: Option<Vec<Uuid>>,
+        parameters: QueryParameters,
+    ) -> ThothResult<Vec<Work>> {
+        let variables: works_query::Variables =
+            WorksQueryVariables::new(publishers, parameters).into();
+        let request_body = WorksQuery::build_query(variables);
         let res = self.post_request(&request_body).await.await?;
         let response_body: Response<works_query::ResponseData> = res.json().await?;
         match response_body.data {