7276350647

Committed 20 Dec 2023 01:21PM UTC coverage: 89.798% (-0.03%) from 89.823%

Build # 7276350647

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #906 from geo-engine/raster_result_describer

result descriptors for query processors

Run Details

1080 of 1240 new or added lines in 43 files covered. (87.1%)

11 existing lines in 3 files now uncovered.

115920 of 129090 relevant lines covered (89.8%)

58689.64 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

45.08

/operators/src/engine/query_processor.rs

use std::pin::Pin;
use std::task::{Context, Poll};

use super::query::QueryContext;
use super::{RasterResultDescriptor, ResultDescriptor, VectorResultDescriptor};
use crate::processing::RasterTypeConversionQueryProcessor;
use crate::util::Result;
use async_trait::async_trait;
use futures::stream::BoxStream;
use futures::Stream;
use geoengine_datatypes::collections::{
    DataCollection, MultiLineStringCollection, MultiPolygonCollection,
};
use geoengine_datatypes::plots::{PlotData, PlotOutputFormat};
use geoengine_datatypes::primitives::{
    AxisAlignedRectangle, BandSelection, BoundingBox2D, ColumnSelection, PlotQueryRectangle,
    QueryAttributeSelection, QueryRectangle, RasterQueryRectangle, SpatialPartition2D,
    VectorQueryRectangle,
};
use geoengine_datatypes::raster::{DynamicRasterDataType, Pixel};
use geoengine_datatypes::{collections::MultiPointCollection, raster::RasterTile2D};
use ouroboros::self_referencing;

/// An instantiation of an operator that produces a stream of results for a query
#[async_trait]
pub trait QueryProcessor: Send + Sync {
    type Output;
    type SpatialBounds: AxisAlignedRectangle + Send + Sync;
    type Selection: QueryAttributeSelection;
    type ResultDescription: ResultDescriptor<
        QueryRectangleSpatialBounds = Self::SpatialBounds,
        QueryRectangleAttributeSelection = Self::Selection,
    >;

    /// inner logic of the processor
    async fn _query<'a>(
        &'a self,
        query: QueryRectangle<Self::SpatialBounds, Self::Selection>, // TODO: query by reference
        ctx: &'a dyn QueryContext,
    ) -> Result<BoxStream<'a, Result<Self::Output>>>;

    async fn query<'a>(
        &'a self,
        query: QueryRectangle<Self::SpatialBounds, Self::Selection>, // TODO: query by reference
        ctx: &'a dyn QueryContext,
    ) -> Result<BoxStream<'a, Result<Self::Output>>> {
        self.result_descriptor().validate_query(&query)?;

        Ok(Box::pin(
            ctx.abort_registration()
                .wrap(self._query(query, ctx).await?),
        ))
    }

    fn result_descriptor(&self) -> &Self::ResultDescription;
}

/// Advanced methods for query processors
#[async_trait]
pub trait QueryProcessorExt: QueryProcessor {
    /// Query the processor and retrieve a stream of results.
    ///
    /// This stream owns the processor and the query context to provide a static lifetime.
    /// Thus, it can be stored in a struct.
    async fn query_into_owned_stream(
        self,
        query: QueryRectangle<Self::SpatialBounds, Self::Selection>, // TODO: query by reference
        ctx: Box<dyn QueryContext>,
    ) -> Result<OwnedQueryResultStream<Self>>
    where
        Self: Sized + 'static,
    {
        Ok(
            OwnedQueryResultStream::try_new_async_send(self, ctx, |processor, ctx| {
                processor.query(query, ctx.as_ref())
            })
            .await?,
        )
    }
}

impl<Q> QueryProcessorExt for Q where Q: QueryProcessor {}

/// An instantiation of a raster operator that produces a stream of raster results for a query
#[async_trait]
pub trait RasterQueryProcessor: Sync + Send {
    type RasterType: Pixel;

    async fn raster_query<'a>(
        &'a self,
        query: RasterQueryRectangle, // TODO: query by reference
        ctx: &'a dyn QueryContext,
    ) -> Result<BoxStream<'a, Result<RasterTile2D<Self::RasterType>>>>;

    fn boxed(self) -> Box<dyn RasterQueryProcessor<RasterType = Self::RasterType>>
    where
        Self: Sized + 'static,
    {
        Box::new(self)
    }

    fn raster_result_descriptor(&self) -> &RasterResultDescriptor;
}

pub type BoxRasterQueryProcessor<P> = Box<dyn RasterQueryProcessor<RasterType = P>>;

#[async_trait]
impl<S, T> RasterQueryProcessor for S
where
    S: QueryProcessor<
            Output = RasterTile2D<T>,
            SpatialBounds = SpatialPartition2D,
            Selection = BandSelection,
            ResultDescription = RasterResultDescriptor,
        > + Sync
        + Send,
    T: Pixel,
{
    type RasterType = T;
    async fn raster_query<'a>(
        &'a self,
        query: RasterQueryRectangle, // TODO: query by reference
        ctx: &'a dyn QueryContext,
    ) -> Result<BoxStream<'a, Result<RasterTile2D<Self::RasterType>>>> {
        self.query(query, ctx).await
    }

    fn raster_result_descriptor(&self) -> &RasterResultDescriptor {
        self.result_descriptor()
    }
}

/// An instantiation of a vector operator that produces a stream of vector results for a query
#[async_trait]
pub trait VectorQueryProcessor: Sync + Send {
    type VectorType;
    async fn vector_query<'a>(
        &'a self,
        query: VectorQueryRectangle, // TODO: query by reference
        ctx: &'a dyn QueryContext,
    ) -> Result<BoxStream<'a, Result<Self::VectorType>>>;

    fn boxed(self) -> Box<dyn VectorQueryProcessor<VectorType = Self::VectorType>>
    where
        Self: Sized + 'static,
    {
        Box::new(self)
    }

    fn vector_result_descriptor(&self) -> &VectorResultDescriptor;
}

#[async_trait]
impl<S, VD> VectorQueryProcessor for S
where
    S: QueryProcessor<
            Output = VD,
            SpatialBounds = BoundingBox2D,
            Selection = ColumnSelection,
            ResultDescription = VectorResultDescriptor,
        > + Sync
        + Send,
{
    type VectorType = VD;

    async fn vector_query<'a>(
        &'a self,
        query: VectorQueryRectangle, // TODO: query by reference
        ctx: &'a dyn QueryContext,
    ) -> Result<BoxStream<'a, Result<Self::VectorType>>> {
        self.query(query, ctx).await
    }

    fn vector_result_descriptor(&self) -> &VectorResultDescriptor {
        self.result_descriptor()
    }
}

/// An instantiation of a plot operator that produces a stream of vector results for a query
#[async_trait]
pub trait PlotQueryProcessor: Sync + Send {
    type OutputFormat;

    fn plot_type(&self) -> &'static str;

    async fn plot_query<'a>(
        &'a self,
        query: PlotQueryRectangle, // TODO: query by reference
        ctx: &'a dyn QueryContext,
    ) -> Result<Self::OutputFormat>;

    fn boxed(self) -> Box<dyn PlotQueryProcessor<OutputFormat = Self::OutputFormat>>
    where
        Self: Sized + 'static,
    {
        Box::new(self)
    }
}

#[async_trait]
impl<T, S, U, R> QueryProcessor
    for Box<dyn QueryProcessor<Output = T, SpatialBounds = S, Selection = U, ResultDescription = R>>
where
    S: AxisAlignedRectangle + Send + Sync,
    U: QueryAttributeSelection,
    R: ResultDescriptor<QueryRectangleSpatialBounds = S, QueryRectangleAttributeSelection = U>,
{
    type Output = T;
    type SpatialBounds = S;
    type Selection = U;
    type ResultDescription = R;

    async fn _query<'a>(
        &'a self,
        query: QueryRectangle<S, U>, // TODO: query by reference
        ctx: &'a dyn QueryContext,
    ) -> Result<BoxStream<'a, Result<Self::Output>>> {
        self.as_ref().query(query, ctx).await
    }

    fn result_descriptor(&self) -> &Self::ResultDescription {
        self.as_ref().result_descriptor()
    }
}

#[async_trait]
impl<T> QueryProcessor for Box<dyn RasterQueryProcessor<RasterType = T>>
where
    T: Pixel,
{
    type Output = RasterTile2D<T>;
    type SpatialBounds = SpatialPartition2D;
    type Selection = BandSelection;
    type ResultDescription = RasterResultDescriptor;

    async fn _query<'a>(
        &'a self,
        query: RasterQueryRectangle, // TODO: query by reference
        ctx: &'a dyn QueryContext,
    ) -> Result<BoxStream<'a, Result<Self::Output>>> {
        self.as_ref().raster_query(query, ctx).await
    }

    fn result_descriptor(&self) -> &Self::ResultDescription {
        self.as_ref().raster_result_descriptor()
    }
}

#[async_trait]
impl<V> QueryProcessor for Box<dyn VectorQueryProcessor<VectorType = V>>
where
    V: 'static,
{
    type Output = V;
    type SpatialBounds = BoundingBox2D;
    type Selection = ColumnSelection;
    type ResultDescription = VectorResultDescriptor;

    async fn _query<'a>(
        &'a self,
        query: VectorQueryRectangle, // TODO: query by reference
        ctx: &'a dyn QueryContext,
    ) -> Result<BoxStream<'a, Result<Self::Output>>> {
        self.as_ref().vector_query(query, ctx).await
    }

    fn result_descriptor(&self) -> &Self::ResultDescription {
        self.as_ref().vector_result_descriptor()
    }
}

/// An enum to differentiate between outputs of raster processors
pub enum TypedRasterQueryProcessor {
    U8(Box<dyn RasterQueryProcessor<RasterType = u8>>),
    U16(Box<dyn RasterQueryProcessor<RasterType = u16>>),
    U32(Box<dyn RasterQueryProcessor<RasterType = u32>>),
    U64(Box<dyn RasterQueryProcessor<RasterType = u64>>),
    I8(Box<dyn RasterQueryProcessor<RasterType = i8>>),
    I16(Box<dyn RasterQueryProcessor<RasterType = i16>>),
    I32(Box<dyn RasterQueryProcessor<RasterType = i32>>),
    I64(Box<dyn RasterQueryProcessor<RasterType = i64>>),
    F32(Box<dyn RasterQueryProcessor<RasterType = f32>>),
    F64(Box<dyn RasterQueryProcessor<RasterType = f64>>),
}

impl DynamicRasterDataType for TypedRasterQueryProcessor {
    fn raster_data_type(&self) -> geoengine_datatypes::raster::RasterDataType {
        match self {
            Self::U8(_) => geoengine_datatypes::raster::RasterDataType::U8,
            Self::U16(_) => geoengine_datatypes::raster::RasterDataType::U16,
            Self::U32(_) => geoengine_datatypes::raster::RasterDataType::U32,
            Self::U64(_) => geoengine_datatypes::raster::RasterDataType::U64,
            Self::I8(_) => geoengine_datatypes::raster::RasterDataType::I8,
            Self::I16(_) => geoengine_datatypes::raster::RasterDataType::I16,
            Self::I32(_) => geoengine_datatypes::raster::RasterDataType::I32,
            Self::I64(_) => geoengine_datatypes::raster::RasterDataType::I64,
            Self::F32(_) => geoengine_datatypes::raster::RasterDataType::F32,
            Self::F64(_) => geoengine_datatypes::raster::RasterDataType::F64,
        }
    }
}

impl std::fmt::Debug for TypedRasterQueryProcessor {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        let interals = "RasterQueryProcessor"; // TODO: implement debug for children
        match self {
            Self::U8(_) => f.debug_tuple("U8").field(&interals).finish(),
            Self::U16(_) => f.debug_tuple("U16").field(&interals).finish(),
            Self::U32(_) => f.debug_tuple("U32").field(&interals).finish(),
            Self::U64(_) => f.debug_tuple("U64").field(&interals).finish(),
            Self::I8(_) => f.debug_tuple("I8").field(&interals).finish(),
            Self::I16(_) => f.debug_tuple("I16").field(&interals).finish(),
            Self::I32(_) => f.debug_tuple("I32").field(&interals).finish(),
            Self::I64(_) => f.debug_tuple("I64").field(&interals).finish(),
            Self::F32(_) => f.debug_tuple("F32").field(&interals).finish(),
            Self::F64(_) => f.debug_tuple("F64").field(&interals).finish(),
        }
    }
}

impl TypedRasterQueryProcessor {
    pub fn get_u8(self) -> Option<Box<dyn RasterQueryProcessor<RasterType = u8>>> {
        match self {
            Self::U8(r) => Some(r),
            _ => None,
        }
    }
    pub fn get_u16(self) -> Option<Box<dyn RasterQueryProcessor<RasterType = u16>>> {
        match self {
            Self::U16(r) => Some(r),
            _ => None,
        }
    }
    pub fn get_u32(self) -> Option<Box<dyn RasterQueryProcessor<RasterType = u32>>> {
        match self {
            Self::U32(r) => Some(r),
            _ => None,
        }
    }
    pub fn get_u64(self) -> Option<Box<dyn RasterQueryProcessor<RasterType = u64>>> {
        match self {
            Self::U64(r) => Some(r),
            _ => None,
        }
    }
    pub fn get_i8(self) -> Option<Box<dyn RasterQueryProcessor<RasterType = i8>>> {
        match self {
            Self::I8(r) => Some(r),
            _ => None,
        }
    }
    pub fn get_i16(self) -> Option<Box<dyn RasterQueryProcessor<RasterType = i16>>> {
        match self {
            Self::I16(r) => Some(r),
            _ => None,
        }
    }
    pub fn get_i32(self) -> Option<Box<dyn RasterQueryProcessor<RasterType = i32>>> {
        match self {
            Self::I32(r) => Some(r),
            _ => None,
        }
    }
    pub fn get_i64(self) -> Option<Box<dyn RasterQueryProcessor<RasterType = i64>>> {
        match self {
            Self::I64(r) => Some(r),
            _ => None,
        }
    }
    pub fn get_f32(self) -> Option<Box<dyn RasterQueryProcessor<RasterType = f32>>> {
        match self {
            Self::F32(r) => Some(r),
            _ => None,
        }
    }
    pub fn get_f64(self) -> Option<Box<dyn RasterQueryProcessor<RasterType = f64>>> {
        match self {
            Self::F64(r) => Some(r),
            _ => None,
        }
    }

    pub fn into_u8(self) -> BoxRasterQueryProcessor<u8> {
        match self {
            Self::U8(r) => r,
            Self::U16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
        }
    }

    pub fn into_u16(self) -> BoxRasterQueryProcessor<u16> {
        match self {
            Self::U8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U16(r) => r,
            Self::U32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
        }
    }

    pub fn into_u32(self) -> BoxRasterQueryProcessor<u32> {
        match self {
            Self::U8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U32(r) => r,
            Self::U64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
        }
    }

    pub fn into_u64(self) -> BoxRasterQueryProcessor<u64> {
        match self {
            Self::U8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U64(r) => r,
            Self::I8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
        }
    }

    pub fn into_f32(self) -> BoxRasterQueryProcessor<f32> {
        match self {
            Self::U8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F32(r) => r,
            Self::F64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
        }
    }

    pub fn into_i8(self) -> BoxRasterQueryProcessor<i8> {
        match self {
            Self::U8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I8(r) => r,
            Self::I16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
        }
    }

    pub fn into_i16(self) -> BoxRasterQueryProcessor<i16> {
        match self {
            Self::U8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I16(r) => r,
            Self::I32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
        }
    }

    pub fn into_i32(self) -> BoxRasterQueryProcessor<i32> {
        match self {
            Self::U8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I32(r) => r,
            Self::I64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
        }
    }

    pub fn into_i64(self) -> BoxRasterQueryProcessor<i64> {
        match self {
            Self::U8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I64(r) => r,
            Self::F32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
        }
    }

    pub fn into_f64(self) -> BoxRasterQueryProcessor<f64> {
        match self {
            Self::U8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::U64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I8(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I16(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::I64(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F32(r) => RasterTypeConversionQueryProcessor::new(r).boxed(),
            Self::F64(r) => r,
        }
    }
}

impl From<Box<dyn RasterQueryProcessor<RasterType = u8>>> for TypedRasterQueryProcessor {
    fn from(value: Box<dyn RasterQueryProcessor<RasterType = u8>>) -> Self {
        TypedRasterQueryProcessor::U8(value)
    }
}

impl From<Box<dyn RasterQueryProcessor<RasterType = i8>>> for TypedRasterQueryProcessor {
    fn from(value: Box<dyn RasterQueryProcessor<RasterType = i8>>) -> Self {
        TypedRasterQueryProcessor::I8(value)
    }
}

impl From<Box<dyn RasterQueryProcessor<RasterType = u16>>> for TypedRasterQueryProcessor {
    fn from(value: Box<dyn RasterQueryProcessor<RasterType = u16>>) -> Self {
        TypedRasterQueryProcessor::U16(value)
    }
}

impl From<Box<dyn RasterQueryProcessor<RasterType = i16>>> for TypedRasterQueryProcessor {
    fn from(value: Box<dyn RasterQueryProcessor<RasterType = i16>>) -> Self {
        TypedRasterQueryProcessor::I16(value)
    }
}

impl From<Box<dyn RasterQueryProcessor<RasterType = u32>>> for TypedRasterQueryProcessor {
    fn from(value: Box<dyn RasterQueryProcessor<RasterType = u32>>) -> Self {
        TypedRasterQueryProcessor::U32(value)
    }
}

impl From<Box<dyn RasterQueryProcessor<RasterType = i32>>> for TypedRasterQueryProcessor {
    fn from(value: Box<dyn RasterQueryProcessor<RasterType = i32>>) -> Self {
        TypedRasterQueryProcessor::I32(value)
    }
}

impl From<Box<dyn RasterQueryProcessor<RasterType = u64>>> for TypedRasterQueryProcessor {
    fn from(value: Box<dyn RasterQueryProcessor<RasterType = u64>>) -> Self {
        TypedRasterQueryProcessor::U64(value)
    }
}
impl From<Box<dyn RasterQueryProcessor<RasterType = i64>>> for TypedRasterQueryProcessor {
    fn from(value: Box<dyn RasterQueryProcessor<RasterType = i64>>) -> Self {
        TypedRasterQueryProcessor::I64(value)
    }
}
impl From<Box<dyn RasterQueryProcessor<RasterType = f32>>> for TypedRasterQueryProcessor {
    fn from(value: Box<dyn RasterQueryProcessor<RasterType = f32>>) -> Self {
        TypedRasterQueryProcessor::F32(value)
    }
}
impl From<Box<dyn RasterQueryProcessor<RasterType = f64>>> for TypedRasterQueryProcessor {
    fn from(value: Box<dyn RasterQueryProcessor<RasterType = f64>>) -> Self {
        TypedRasterQueryProcessor::F64(value)
    }
}

/// An enum that contains all possible query processor variants
pub enum TypedVectorQueryProcessor {
    Data(Box<dyn VectorQueryProcessor<VectorType = DataCollection>>),
    MultiPoint(Box<dyn VectorQueryProcessor<VectorType = MultiPointCollection>>),
    MultiLineString(Box<dyn VectorQueryProcessor<VectorType = MultiLineStringCollection>>),
    MultiPolygon(Box<dyn VectorQueryProcessor<VectorType = MultiPolygonCollection>>),
}

impl TypedVectorQueryProcessor {
    pub fn data(self) -> Option<Box<dyn VectorQueryProcessor<VectorType = DataCollection>>> {
        if let TypedVectorQueryProcessor::Data(p) = self {
            Some(p)
        } else {
            None
        }
    }

    pub fn multi_point(
        self,
    ) -> Option<Box<dyn VectorQueryProcessor<VectorType = MultiPointCollection>>> {
        if let TypedVectorQueryProcessor::MultiPoint(p) = self {
            Some(p)
        } else {
            None
        }
    }

    pub fn multi_line_string(
        self,
    ) -> Option<Box<dyn VectorQueryProcessor<VectorType = MultiLineStringCollection>>> {
        if let TypedVectorQueryProcessor::MultiLineString(p) = self {
            Some(p)
        } else {
            None
        }
    }

    pub fn multi_polygon(
        self,
    ) -> Option<Box<dyn VectorQueryProcessor<VectorType = MultiPolygonCollection>>> {
        if let TypedVectorQueryProcessor::MultiPolygon(p) = self {
            Some(p)
        } else {
            None
        }
    }
}

impl From<Box<dyn VectorQueryProcessor<VectorType = DataCollection>>>
    for TypedVectorQueryProcessor
{
    fn from(value: Box<dyn VectorQueryProcessor<VectorType = DataCollection>>) -> Self {
        TypedVectorQueryProcessor::Data(value)
    }
}

impl From<Box<dyn VectorQueryProcessor<VectorType = MultiPointCollection>>>
    for TypedVectorQueryProcessor
{
    fn from(value: Box<dyn VectorQueryProcessor<VectorType = MultiPointCollection>>) -> Self {
        TypedVectorQueryProcessor::MultiPoint(value)
    }
}

impl From<Box<dyn VectorQueryProcessor<VectorType = MultiLineStringCollection>>>
    for TypedVectorQueryProcessor
{
    fn from(value: Box<dyn VectorQueryProcessor<VectorType = MultiLineStringCollection>>) -> Self {
        TypedVectorQueryProcessor::MultiLineString(value)
    }
}

impl From<Box<dyn VectorQueryProcessor<VectorType = MultiPolygonCollection>>>
    for TypedVectorQueryProcessor
{
    fn from(value: Box<dyn VectorQueryProcessor<VectorType = MultiPolygonCollection>>) -> Self {
        TypedVectorQueryProcessor::MultiPolygon(value)
    }
}

/// An enum that contains all possible query processor variants
pub enum TypedPlotQueryProcessor {
    JsonPlain(Box<dyn PlotQueryProcessor<OutputFormat = serde_json::Value>>),
    JsonVega(Box<dyn PlotQueryProcessor<OutputFormat = PlotData>>),
    ImagePng(Box<dyn PlotQueryProcessor<OutputFormat = Vec<u8>>>),
}

impl From<&TypedPlotQueryProcessor> for PlotOutputFormat {
    fn from(typed_processor: &TypedPlotQueryProcessor) -> Self {
        match typed_processor {
            TypedPlotQueryProcessor::JsonPlain(_) => PlotOutputFormat::JsonPlain,
            TypedPlotQueryProcessor::JsonVega(_) => PlotOutputFormat::JsonVega,
            TypedPlotQueryProcessor::ImagePng(_) => PlotOutputFormat::ImagePng,
        }
    }
}

impl TypedPlotQueryProcessor {
    pub fn plot_type(&self) -> &'static str {
        match self {
            TypedPlotQueryProcessor::JsonPlain(p) => p.plot_type(),
            TypedPlotQueryProcessor::JsonVega(p) => p.plot_type(),
            TypedPlotQueryProcessor::ImagePng(p) => p.plot_type(),
        }
    }

    pub fn json_plain(
        self,
    ) -> Option<Box<dyn PlotQueryProcessor<OutputFormat = serde_json::Value>>> {
        if let TypedPlotQueryProcessor::JsonPlain(p) = self {
            Some(p)
        } else {
            None
        }
    }

    pub fn json_vega(self) -> Option<Box<dyn PlotQueryProcessor<OutputFormat = PlotData>>> {
        if let TypedPlotQueryProcessor::JsonVega(p) = self {
            Some(p)
        } else {
            None
        }
    }

    pub fn image_png(self) -> Option<Box<dyn PlotQueryProcessor<OutputFormat = Vec<u8>>>> {
        if let TypedPlotQueryProcessor::ImagePng(p) = self {
            Some(p)
        } else {
            None
        }
    }
}

/// Maps a `TypedVectorQueryProcessor` to another `TypedVectorQueryProcessor` by calling a function on its variant.
/// Call via `map_typed_query_processor!(input, processor => function)`.
#[macro_export]
macro_rules! map_typed_query_processor {
    ($input:expr, $processor:ident => $function_call:expr) => {
        map_typed_query_processor!(
            @variants $input, $processor => $function_call,
            Data, MultiPoint, MultiLineString, MultiPolygon
        )
    };

    (@variants $input:expr, $processor:ident => $function_call:expr, $($variant:tt),+) => {
        match $input {
            $(
                $crate::engine::TypedVectorQueryProcessor::$variant($processor) => {
                    $crate::engine::TypedVectorQueryProcessor::$variant($function_call)
                }
            )+
        }
    };
}

/// In the case that it is required to store a query stream in a struct with a static lifetime,
///  one can use this struct.
/// This struct owns the query processor and the query context and thus ensures that the query
/// has the lifetime dependencies it needs.
#[self_referencing]
pub struct OwnedQueryResultStream<Q>
where
    Q: QueryProcessor + 'static,
{
    processor: Q,
    ctx: Box<dyn QueryContext>,
    #[borrows(processor, ctx)]
    #[covariant]
    stream: BoxStream<'this, Result<Q::Output>>,
}

impl<Q> OwnedQueryResultStream<Q>
where
    Q: QueryProcessor + 'static,
{
    /// Stop/drop the current stream and return the query processor.
    pub fn into_query_processor(self) -> Q {
        self.into_heads().processor
    }
}

impl<Q> Stream for OwnedQueryResultStream<Q>
where
    Q: QueryProcessor + 'static,
{
    type Item = Result<Q::Output>;

    fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
        self.with_stream_mut(|stream| Pin::new(stream).poll_next(cx))
    }
}

geo-engine / geoengine / 7276350647

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous