Struct OsmAdapter 

pub struct OsmAdapter {
    pub id: &'static str,
    pub overpass_endpoint: String,
    pub tile_endpoint: String,
}

Stub adapter for OpenStreetMap Overpass API and MVT vector tile endpoints.

Fields

id: &'static str

overpass_endpoint: String

tile_endpoint: String

Implementations

impl OsmAdapter

pub fn new( id: &'static str, overpass_endpoint: &str, tile_endpoint: &str, ) -> Self

impl OsmAdapter

pub fn adapter_id(&self) -> &'static str

pub fn build_fetch_request( &self, bbox: (f64, f64, f64, f64), time_range: (u64, u64), registry: &NetworkDisclosureRegistry, ) -> Result<AdapterHttpRequest, String>

pub fn fetch_region( &self, bbox: (f64, f64, f64, f64), time_range: (u64, u64), registry: &NetworkDisclosureRegistry, ) -> Result<(), String>

pub fn parse_features(&self, body: &str) -> Result<Vec<NQuin>, String>

Parse an OpenStreetMap Overpass API JSON response body into provenance NQuins.

Each element of the top-level elements array (a node, way, or relation) is mapped to a set of Dublin Core / RDF / WGS84 provenance quins, using generate_60bit_token for IRI/literal hashing so the emitted data is queryable by the SPARQL layer (which hashes IRIs the same way). If elements is absent an empty Vec is returned. Only invalid JSON yields an Err.

Trait Implementations

impl DataAdapter for OsmAdapter

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

Returns the unique identifier for this adapter (e.g., “dem_adapter”)

fn build_fetch_request( &self, bbox: (f64, f64, f64, f64), time_range: (u64, u64), registry: &NetworkDisclosureRegistry, ) -> Result<AdapterHttpRequest, String>

Build the outbound request for a spatial bounding box [x1, y1, x2, y2] and temporal range [t0, t1]. Implementations must check NetworkDisclosureRegistry before returning an actual network request.

fn primary_endpoint(&self) -> &str

Primary egress endpoint for disclosure checks and fetch reports.

fn estimate_tile_count(&self, bbox: (f64, f64, f64, f64)) -> u32

Honest estimate of how many tile/API units would be requested (no fake payloads).

fn fetch_region( &self, bbox: (f64, f64, f64, f64), time_range: (u64, u64), registry: &NetworkDisclosureRegistry, ) -> Result<(), String>

Initiate fetching through the native blocking transport. Browser WASM cannot legally block on network I/O, so wasm callers use fetch_region_async.

fn needs_fetch_body(&self) -> bool

Whether the adapter consumes the response body instead of only checking that the endpoint accepted the request.

fn handle_fetch_body(&self, _body: &str) -> Result<(), String>

Parse or enqueue the fetched body. Most adapters currently only verify access; CKAN consumes JSON discovery results here.

fn parse_response(&self, _body: &str) -> Result<Vec<NQuin>, String>

Parse a fetched response body into provenance NQuins (title / license / created / source / lat / long, hashed with the same generate_60bit_token the SPARQL layer uses, so the results are queryable). Adapters that can interpret their response format override this — GBIF, OSM/Overpass, STAC, OGC 3D Tiles and SPARQL-results do — and the default yields none. This is how a fetched response becomes graph data rather than being discarded.

fn fetch_region_features( &self, bbox: (f64, f64, f64, f64), time_range: (u64, u64), registry: &NetworkDisclosureRegistry, ) -> Result<Vec<NQuin>, String>

Native fetch that returns the parsed provenance NQuins: build the consent-gated request, execute it, and run parse_response on the body. A caller can then route the quins into the graph. (WASM callers fetch via fetch_region_async and call parse_response on the returned body.)