ogc-cql2 0.5.2

OGC CQL2 Text + JSON Encoding parser and interpreter in Rust
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

// SPDX-License-Identifier: Apache-2.0

#![warn(missing_docs)]

//! Groups artifacts providing Features and Resources from known types used in
//! the geospatial ecosystem such as GeoPackage files.
//!

mod csv;
mod gpkg;
mod pg;
mod sql;
mod types;

pub use csv::*;
pub use gpkg::*;
pub use pg::*;
pub use types::*;

use crate::{Expression, Q};
use async_trait::async_trait;
use futures::stream::BoxStream;
use std::collections::HashMap;

/// A dictionary of queryable property names (strings) to [`Queryable`][Q] values.
pub type Resource = HashMap<String, Q>;

/// Trait for a type that can act as a data source provider of _Features_
/// and [`Resource`]s, including a _Geometry_ attribute, in the context of
/// processing CQL2 filter expressions.
///
/// A CSV file, and a GeoPackage autonomous database file are examples of this.
pub trait DataSource {
    /// Return SRID of this if it was known at construction; `None` otherwise.
    fn srid(&self) -> Option<u32>;
}

/// Capability of a [`DataSource`] to provide an iterator over a collection of
/// _Features_ or [Resources][Resource].
pub trait IterableDS {
    /// Type representing a Feature which must be convertible to a [Resource].
    type Item: TryInto<Resource, Error = Self::Err>;
    /// Error raised by this.
    type Err;

    /// Return an iterator over this data source _Features_.
    fn iter(&self) -> Result<impl Iterator<Item = Result<Self::Item, Self::Err>>, Self::Err>;
}

/// Capability of a [`DataSource`] to asynchronously stream _Features_ or
/// [Resources][Resource].
#[async_trait]
pub trait StreamableDS {
    /// Type representing a _Feature_ which must be convertible to a [`Resource`].
    type Item: TryInto<Resource, Error = Self::Err>;
    /// Error raised by this.
    type Err;

    /// Return an unfiltered stream of all data source _Features_.
    async fn fetch(&self) -> Result<BoxStream<'_, Result<Self::Item, Self::Err>>, Self::Err>;

    /// Return an unfiltered stream of all data source _Resources_.
    async fn stream(&self) -> Result<BoxStream<'_, Result<Resource, Self::Err>>, Self::Err>;

    /// Return a filtered stream of _Features_ satisfying a CQL2 filter [Expression].
    async fn fetch_where(
        &self,
        exp: &Expression,
    ) -> Result<BoxStream<'_, Result<Self::Item, Self::Err>>, Self::Err>;

    /// Return a filtered stream of _Resources_ satisfying a CQL2 filter [Expression].
    async fn stream_where(
        &self,
        exp: &Expression,
    ) -> Result<BoxStream<'_, Result<Resource, Self::Err>>, Self::Err>;
}