Struct GraphQlService 

pub struct GraphQlService { /* private fields */ }

ScrapingService adapter for GraphQL APIs.

Implement any spec-compliant GraphQL endpoint by constructing a GraphQlService with a config and an optional plugin registry. Target specifics (endpoint, version headers, auth) are supplied either via ServiceInput.params directly or through a registered GraphQlTargetPlugin.

Example

use stygian_graph::adapters::graphql::{GraphQlService, GraphQlConfig};
use stygian_graph::ports::{ScrapingService, ServiceInput};
use serde_json::json;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let service = GraphQlService::new(GraphQlConfig::default(), None);
    let input = ServiceInput {
        url: "https://countries.trevorblades.com/".to_string(),
        params: json!({
            "query": "{ countries { code name } }"
        }),
    };
    let output = service.execute(input).await?;
    println!("{}", output.data);
    Ok(())
}

Implementations

impl GraphQlService

pub fn new( config: GraphQlConfig, plugins: Option<Arc<GraphQlPluginRegistry>>, ) -> Self

Create a new GraphQlService.

plugins may be None for raw-params mode (no plugin resolution).

Example

use stygian_graph::adapters::graphql::{GraphQlService, GraphQlConfig};
use stygian_graph::ports::ScrapingService;

let service = GraphQlService::new(GraphQlConfig::default(), None);
assert_eq!(service.name(), "graphql");

pub fn with_auth_port(self, port: Arc<dyn ErasedAuthPort>) -> Self

Attach a runtime auth port.

When set, the port’s erased_resolve_token() will be called to obtain a bearer token whenever params.auth is absent and the plugin supplies no default_auth.

Example

use std::sync::Arc;
use stygian_graph::adapters::graphql::{GraphQlService, GraphQlConfig};
use stygian_graph::ports::auth::{EnvAuthPort, ErasedAuthPort};

let auth: Arc<dyn ErasedAuthPort> = Arc::new(EnvAuthPort::new("API_TOKEN"));
let service = GraphQlService::new(GraphQlConfig::default(), None)
    .with_auth_port(auth);

Trait Implementations

impl ScrapingService for GraphQlService

fn execute<'life0, 'async_trait>( &'life0 self, input: ServiceInput, ) -> Pin<Box<dyn Future<Output = Result<ServiceOutput>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute a GraphQL query.

Reads ServiceInput.params for:

• query (required) — the GraphQL query string
• variables — optional JSON object
• operation_name — optional string
• auth — optional {"kind": "bearer"|"api_key"|"header"|"none", "token": "..."}
• headers — optional extra headers object
• plugin — optional plugin name to resolve from the registry
• pagination — optional {"strategy": "cursor", "page_info_path": "...", "edges_path": "...", "page_size": 50}

Errors

Returns Err for HTTP ≥ 400, invalid JSON, GraphQL errors[], missing data key, throttle detection, or pagination runaway.

fn name(&self) -> &'static str

Service name for identification in logs and metrics