// Copyright (C) 2016-2017 Sebastian Dröge <sebastian@centricular.com>
//
// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
// option. This file may not be copied, modified, or distributed
// except according to those terms.

use gst_sys;
use structure::*;
use GenericFormattedValue;

use std::ffi::CStr;
use std::fmt;
use std::mem;
use std::ops::{Deref, DerefMut};
use std::ptr;

use glib;
use glib::translate::*;
use glib_sys;

gst_define_mini_object_wrapper!(Query, QueryRef, gst_sys::GstQuery, || {
    gst_sys::gst_query_get_type()
});

impl Query {
    /// Constructs a new query stream position query object. Use `Query::unref`
    /// when done with it. A position query is used to query the current position
    /// of playback in the streams, in some format.
    ///
    /// Free-function: `Query::unref`
    /// ## `format`
    /// the default `Format` for the new query
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Position::new` instead")]
    pub fn new_position(fmt: ::Format) -> Position<Self> {
        assert_initialized_main_thread!();
        unsafe {
            Position::<Self>(from_glib_full(gst_sys::gst_query_new_position(
                fmt.to_glib(),
            )))
        }
    }

    /// Constructs a new stream duration query object to query in the given format.
    /// Use `Query::unref` when done with it. A duration query will give the
    /// total length of the stream.
    ///
    /// Free-function: `Query::unref`
    /// ## `format`
    /// the `Format` for this duration query
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Duration::new` instead")]
    pub fn new_duration(fmt: ::Format) -> Duration<Self> {
        assert_initialized_main_thread!();
        unsafe {
            Duration::<Self>(from_glib_full(gst_sys::gst_query_new_duration(
                fmt.to_glib(),
            )))
        }
    }

    /// Constructs a new latency query object.
    /// Use `Query::unref` when done with it. A latency query is usually performed
    /// by sinks to compensate for additional latency introduced by elements in the
    /// pipeline.
    ///
    /// Free-function: `Query::unref`
    ///
    /// # Returns
    ///
    /// a `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Latency::new` instead")]
    pub fn new_latency() -> Latency<Self> {
        assert_initialized_main_thread!();
        unsafe { Latency::<Self>(from_glib_full(gst_sys::gst_query_new_latency())) }
    }

    /// Constructs a new query object for querying seeking properties of
    /// the stream.
    ///
    /// Free-function: `Query::unref`
    /// ## `format`
    /// the default `Format` for the new query
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Seeking::new` instead")]
    pub fn new_seeking(fmt: ::Format) -> Seeking<Self> {
        assert_initialized_main_thread!();
        unsafe {
            Seeking::<Self>(from_glib_full(gst_sys::gst_query_new_seeking(
                fmt.to_glib(),
            )))
        }
    }

    /// Constructs a new segment query object. Use `Query::unref`
    /// when done with it. A segment query is used to discover information about the
    /// currently configured segment for playback.
    ///
    /// Free-function: `Query::unref`
    /// ## `format`
    /// the `Format` for the new query
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Segment::new` instead")]
    pub fn new_segment(fmt: ::Format) -> Segment<Self> {
        assert_initialized_main_thread!();
        unsafe {
            Segment::<Self>(from_glib_full(gst_sys::gst_query_new_segment(
                fmt.to_glib(),
            )))
        }
    }

    /// Constructs a new convert query object. Use `Query::unref`
    /// when done with it. A convert query is used to ask for a conversion between
    /// one format and another.
    ///
    /// Free-function: `Query::unref`
    /// ## `src_format`
    /// the source `Format` for the new query
    /// ## `value`
    /// the value to convert
    /// ## `dest_format`
    /// the target `Format`
    ///
    /// # Returns
    ///
    /// a `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Convert::new` instead")]
    pub fn new_convert<V: Into<GenericFormattedValue>>(
        value: V,
        dest_fmt: ::Format,
    ) -> Convert<Self> {
        assert_initialized_main_thread!();
        let value = value.into();
        unsafe {
            Convert::<Self>(from_glib_full(gst_sys::gst_query_new_convert(
                value.get_format().to_glib(),
                value.get_value(),
                dest_fmt.to_glib(),
            )))
        }
    }

    /// Constructs a new query object for querying formats of
    /// the stream.
    ///
    /// Free-function: `Query::unref`
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Formats::new` instead")]
    pub fn new_formats() -> Formats<Self> {
        assert_initialized_main_thread!();
        unsafe { Formats::<Self>(from_glib_full(gst_sys::gst_query_new_formats())) }
    }

    /// Constructs a new query object for querying the buffering status of
    /// a stream.
    ///
    /// Free-function: `Query::unref`
    /// ## `format`
    /// the default `Format` for the new query
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Buffering::new` instead")]
    pub fn new_buffering(fmt: ::Format) -> Buffering<Self> {
        assert_initialized_main_thread!();
        unsafe {
            Buffering::<Self>(from_glib_full(gst_sys::gst_query_new_buffering(
                fmt.to_glib(),
            )))
        }
    }

    /// Constructs a new custom query object. Use `Query::unref`
    /// when done with it.
    ///
    /// Free-function: `Query::unref`
    /// ## `type_`
    /// the query type
    /// ## `structure`
    /// a structure for the query
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Custom::new` instead")]
    pub fn new_custom(structure: ::Structure) -> Custom<Self> {
        assert_initialized_main_thread!();
        unsafe {
            Custom::<Self>(from_glib_full(gst_sys::gst_query_new_custom(
                gst_sys::GST_QUERY_CUSTOM,
                structure.into_ptr(),
            )))
        }
    }

    /// Constructs a new query URI query object. Use `Query::unref`
    /// when done with it. An URI query is used to query the current URI
    /// that is used by the source or sink.
    ///
    /// Free-function: `Query::unref`
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Uri::new` instead")]
    pub fn new_uri() -> Uri<Self> {
        assert_initialized_main_thread!();
        unsafe { Uri::<Self>(from_glib_full(gst_sys::gst_query_new_uri())) }
    }

    /// Constructs a new query object for querying the allocation properties.
    ///
    /// Free-function: `Query::unref`
    /// ## `caps`
    /// the negotiated caps
    /// ## `need_pool`
    /// return a pool
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Allocation::new` instead")]
    pub fn new_allocation(caps: &::Caps, need_pool: bool) -> Allocation<Self> {
        assert_initialized_main_thread!();
        unsafe {
            Allocation::<Self>(from_glib_full(gst_sys::gst_query_new_allocation(
                caps.as_mut_ptr(),
                need_pool.to_glib(),
            )))
        }
    }

    /// Constructs a new query object for querying the scheduling properties.
    ///
    /// Free-function: `Query::unref`
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Scheduling::new` instead")]
    pub fn new_scheduling() -> Scheduling<Self> {
        assert_initialized_main_thread!();
        unsafe { Scheduling::<Self>(from_glib_full(gst_sys::gst_query_new_scheduling())) }
    }

    /// Constructs a new query object for querying if `caps` are accepted.
    ///
    /// Free-function: `Query::unref`
    /// ## `caps`
    /// a fixed `Caps`
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[deprecated(since = "0.16.0", note = "use `query::AcceptCaps::new` instead")]
    pub fn new_accept_caps(caps: &::Caps) -> AcceptCaps<Self> {
        assert_initialized_main_thread!();
        unsafe {
            AcceptCaps::<Self>(from_glib_full(gst_sys::gst_query_new_accept_caps(
                caps.as_mut_ptr(),
            )))
        }
    }

    /// Constructs a new query object for querying the caps.
    ///
    /// The CAPS query should return the allowable caps for a pad in the context
    /// of the element's state, its link to other elements, and the devices or files
    /// it has opened. These caps must be a subset of the pad template caps. In the
    /// NULL state with no links, the CAPS query should ideally return the same caps
    /// as the pad template. In rare circumstances, an object property can affect
    /// the caps returned by the CAPS query, but this is discouraged.
    ///
    /// For most filters, the caps returned by CAPS query is directly affected by the
    /// allowed caps on other pads. For demuxers and decoders, the caps returned by
    /// the srcpad's getcaps function is directly related to the stream data. Again,
    /// the CAPS query should return the most specific caps it reasonably can, since this
    /// helps with autoplugging.
    ///
    /// The `filter` is used to restrict the result caps, only the caps matching
    /// `filter` should be returned from the CAPS query. Specifying a filter might
    /// greatly reduce the amount of processing an element needs to do.
    ///
    /// Free-function: `Query::unref`
    /// ## `filter`
    /// a filter
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Caps::new` instead")]
    pub fn new_caps(filter: Option<&::Caps>) -> Caps<Self> {
        assert_initialized_main_thread!();
        unsafe {
            Caps::<Self>(from_glib_full(gst_sys::gst_query_new_caps(
                filter.to_glib_none().0,
            )))
        }
    }

    /// Constructs a new query object for querying the drain state.
    ///
    /// Free-function: `Query::unref`
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Drain::new` instead")]
    pub fn new_drain() -> Drain<Self> {
        assert_initialized_main_thread!();
        unsafe { Drain::<Self>(from_glib_full(gst_sys::gst_query_new_drain())) }
    }

    /// Constructs a new query object for querying the pipeline-local context.
    ///
    /// Free-function: `Query::unref`
    /// ## `context_type`
    /// Context type to query
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[deprecated(since = "0.16.0", note = "use `query::Context::new` instead")]
    pub fn new_context(context_type: &str) -> Context<Self> {
        assert_initialized_main_thread!();
        unsafe {
            Context::<Self>(from_glib_full(gst_sys::gst_query_new_context(
                context_type.to_glib_none().0,
            )))
        }
    }

    /// Constructs a new query object for querying the bitrate.
    ///
    /// Free-function: `Query::unref`
    ///
    /// Feature: `v1_16`
    ///
    ///
    /// # Returns
    ///
    /// a new `Query`
    #[cfg(any(feature = "v1_16", feature = "dox"))]
    #[deprecated(since = "0.16.0", note = "use `query::Bitrate::new` instead")]
    pub fn new_bitrate() -> Bitrate<Self> {
        assert_initialized_main_thread!();
        unsafe { Bitrate::<Self>(from_glib_full(gst_sys::gst_query_new_bitrate())) }
    }
}

impl QueryRef {
    pub fn get_structure(&self) -> Option<&StructureRef> {
        unsafe {
            let structure = gst_sys::gst_query_get_structure(self.as_mut_ptr());
            if structure.is_null() {
                None
            } else {
                Some(StructureRef::from_glib_borrow(structure))
            }
        }
    }

    pub fn get_mut_structure(&mut self) -> &mut StructureRef {
        unsafe {
            let structure = gst_sys::gst_query_writable_structure(self.as_mut_ptr());
            StructureRef::from_glib_borrow_mut(structure)
        }
    }

    pub fn is_downstream(&self) -> bool {
        unsafe { ((*self.as_ptr()).type_ as u32) & gst_sys::GST_QUERY_TYPE_DOWNSTREAM != 0 }
    }

    pub fn is_upstream(&self) -> bool {
        unsafe { ((*self.as_ptr()).type_ as u32) & gst_sys::GST_QUERY_TYPE_UPSTREAM != 0 }
    }

    pub fn is_serialized(&self) -> bool {
        unsafe { ((*self.as_ptr()).type_ as u32) & gst_sys::GST_QUERY_TYPE_SERIALIZED != 0 }
    }

    pub fn view(&self) -> QueryView<&Self> {
        let type_ = unsafe { (*self.as_ptr()).type_ };

        match type_ {
            gst_sys::GST_QUERY_POSITION => QueryView::Position(Position(self)),
            gst_sys::GST_QUERY_DURATION => QueryView::Duration(Duration(self)),
            gst_sys::GST_QUERY_LATENCY => QueryView::Latency(Latency(self)),
            gst_sys::GST_QUERY_SEEKING => QueryView::Seeking(Seeking(self)),
            gst_sys::GST_QUERY_SEGMENT => QueryView::Segment(Segment(self)),
            gst_sys::GST_QUERY_CONVERT => QueryView::Convert(Convert(self)),
            gst_sys::GST_QUERY_FORMATS => QueryView::Formats(Formats(self)),
            gst_sys::GST_QUERY_BUFFERING => QueryView::Buffering(Buffering(self)),
            gst_sys::GST_QUERY_CUSTOM => QueryView::Custom(Custom(self)),
            gst_sys::GST_QUERY_URI => QueryView::Uri(Uri(self)),
            gst_sys::GST_QUERY_ALLOCATION => QueryView::Allocation(Allocation(self)),
            gst_sys::GST_QUERY_SCHEDULING => QueryView::Scheduling(Scheduling(self)),
            gst_sys::GST_QUERY_ACCEPT_CAPS => QueryView::AcceptCaps(AcceptCaps(self)),
            gst_sys::GST_QUERY_CAPS => QueryView::Caps(Caps(self)),
            gst_sys::GST_QUERY_DRAIN => QueryView::Drain(Drain(self)),
            gst_sys::GST_QUERY_CONTEXT => QueryView::Context(Context(self)),
            gst_sys::GST_QUERY_BITRATE => QueryView::Bitrate(Bitrate(self)),
            _ => QueryView::Other(Other(self)),
        }
    }

    pub fn view_mut(&mut self) -> QueryView<&mut Self> {
        unsafe { mem::transmute(self.view()) }
    }
}

impl fmt::Debug for Query {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        QueryRef::fmt(self, f)
    }
}

impl fmt::Debug for QueryRef {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        f.debug_struct("Query")
            .field("ptr", unsafe { &self.as_ptr() })
            .field("type", &unsafe {
                let type_ = gst_sys::gst_query_type_get_name((*self.as_ptr()).type_);
                CStr::from_ptr(type_).to_str().unwrap()
            })
            .field("structure", &self.get_structure())
            .finish()
    }
}

pub unsafe trait AsPtr {
    unsafe fn as_ptr(&self) -> *mut gst_sys::GstQuery;
}

pub unsafe trait AsMutPtr: AsPtr {
    unsafe fn as_mut_ptr(&self) -> *mut gst_sys::GstQuery;
}

unsafe impl AsPtr for Query {
    unsafe fn as_ptr(&self) -> *mut gst_sys::GstQuery {
        QueryRef::as_ptr(self) as *mut gst_sys::GstQuery
    }
}

unsafe impl AsMutPtr for Query {
    unsafe fn as_mut_ptr(&self) -> *mut gst_sys::GstQuery {
        QueryRef::as_ptr(self) as *mut gst_sys::GstQuery
    }
}

unsafe impl<'a> AsPtr for &'a QueryRef {
    unsafe fn as_ptr(&self) -> *mut gst_sys::GstQuery {
        QueryRef::as_ptr(self) as *mut gst_sys::GstQuery
    }
}

unsafe impl<'a> AsPtr for &'a mut QueryRef {
    unsafe fn as_ptr(&self) -> *mut gst_sys::GstQuery {
        QueryRef::as_ptr(self) as *mut gst_sys::GstQuery
    }
}

unsafe impl<'a> AsMutPtr for &'a mut QueryRef {
    unsafe fn as_mut_ptr(&self) -> *mut gst_sys::GstQuery {
        QueryRef::as_ptr(self) as *mut gst_sys::GstQuery
    }
}

#[derive(Debug)]
pub enum QueryView<T> {
    Position(Position<T>),
    Duration(Duration<T>),
    Latency(Latency<T>),
    Seeking(Seeking<T>),
    Segment(Segment<T>),
    Convert(Convert<T>),
    Formats(Formats<T>),
    Buffering(Buffering<T>),
    Custom(Custom<T>),
    Uri(Uri<T>),
    Allocation(Allocation<T>),
    Scheduling(Scheduling<T>),
    AcceptCaps(AcceptCaps<T>),
    Caps(Caps<T>),
    Drain(Drain<T>),
    Context(Context<T>),
    Bitrate(Bitrate<T>),
    Other(Other<T>),
    __NonExhaustive,
}

macro_rules! declare_concrete_query(
    ($name:ident, $param:ident) => {
        #[derive(Debug)]
        pub struct $name<$param>($param);

        impl<'a> $name<&'a QueryRef> {
            pub fn get_query(&self) -> &QueryRef {
                self.0
            }
        }

        impl<'a> Deref for $name<&'a QueryRef> {
            type Target = QueryRef;

            fn deref(&self) -> &Self::Target {
                self.0
            }
        }

        impl<'a> Deref for $name<&'a mut QueryRef> {
            type Target = $name<&'a QueryRef>;

            fn deref(&self) -> &Self::Target {
                unsafe {
                    &*(self as *const $name<&'a mut QueryRef> as *const $name<&'a QueryRef>)
                }
            }
        }

        impl<'a> $name<&'a mut QueryRef> {
            pub fn get_mut_query(&mut self) -> &mut QueryRef {
                self.0
            }
        }

        impl Deref for $name<Query> {
            type Target = QueryRef;

            fn deref(&self) -> &Self::Target {
                &self.0
            }
        }

        impl DerefMut for $name<Query> {
            fn deref_mut(&mut self) -> &mut Self::Target {
                self.0.get_mut().unwrap()
            }
        }

        impl From<$name<Query>> for Query {
            fn from(concrete: $name<Query>) -> Self {
                skip_assert_initialized!();
                unsafe { from_glib_none(concrete.0.as_mut_ptr()) }
            }
        }
    }
);

declare_concrete_query!(Position, T);
impl Position<Query> {
    pub fn new(fmt: ::Format) -> Self {
        assert_initialized_main_thread!();
        unsafe {
            Self(from_glib_full(gst_sys::gst_query_new_position(
                fmt.to_glib(),
            )))
        }
    }
}

impl<T: AsPtr> Position<T> {
    pub fn get_result(&self) -> GenericFormattedValue {
        unsafe {
            let mut fmt = mem::MaybeUninit::uninit();
            let mut pos = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_position(self.0.as_ptr(), fmt.as_mut_ptr(), pos.as_mut_ptr());

            GenericFormattedValue::new(from_glib(fmt.assume_init()), pos.assume_init())
        }
    }

    pub fn get_format(&self) -> ::Format {
        unsafe {
            let mut fmt = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_position(self.0.as_ptr(), fmt.as_mut_ptr(), ptr::null_mut());

            from_glib(fmt.assume_init())
        }
    }
}

impl<T: AsMutPtr> Position<T> {
    pub fn set<V: Into<GenericFormattedValue>>(&mut self, pos: V) {
        let pos = pos.into();
        assert_eq!(pos.get_format(), self.get_format());
        unsafe {
            gst_sys::gst_query_set_position(
                self.0.as_mut_ptr(),
                pos.get_format().to_glib(),
                pos.get_value(),
            );
        }
    }
}

declare_concrete_query!(Duration, T);
impl Duration<Query> {
    pub fn new(fmt: ::Format) -> Self {
        assert_initialized_main_thread!();
        unsafe {
            Self(from_glib_full(gst_sys::gst_query_new_duration(
                fmt.to_glib(),
            )))
        }
    }
}

impl<T: AsPtr> Duration<T> {
    pub fn get_result(&self) -> GenericFormattedValue {
        unsafe {
            let mut fmt = mem::MaybeUninit::uninit();
            let mut pos = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_duration(self.0.as_ptr(), fmt.as_mut_ptr(), pos.as_mut_ptr());

            GenericFormattedValue::new(from_glib(fmt.assume_init()), pos.assume_init())
        }
    }

    pub fn get_format(&self) -> ::Format {
        unsafe {
            let mut fmt = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_duration(self.0.as_ptr(), fmt.as_mut_ptr(), ptr::null_mut());

            from_glib(fmt.assume_init())
        }
    }
}

impl<T: AsMutPtr> Duration<T> {
    pub fn set<V: Into<GenericFormattedValue>>(&mut self, dur: V) {
        let dur = dur.into();
        assert_eq!(dur.get_format(), self.get_format());
        unsafe {
            gst_sys::gst_query_set_duration(
                self.0.as_mut_ptr(),
                dur.get_format().to_glib(),
                dur.get_value(),
            );
        }
    }
}

declare_concrete_query!(Latency, T);
impl Latency<Query> {
    pub fn new() -> Self {
        assert_initialized_main_thread!();
        unsafe { Self(from_glib_full(gst_sys::gst_query_new_latency())) }
    }
}

impl Default for Latency<Query> {
    fn default() -> Self {
        Self::new()
    }
}

impl<T: AsPtr> Latency<T> {
    pub fn get_result(&self) -> (bool, ::ClockTime, ::ClockTime) {
        unsafe {
            let mut live = mem::MaybeUninit::uninit();
            let mut min = mem::MaybeUninit::uninit();
            let mut max = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_latency(
                self.0.as_ptr(),
                live.as_mut_ptr(),
                min.as_mut_ptr(),
                max.as_mut_ptr(),
            );

            (
                from_glib(live.assume_init()),
                from_glib(min.assume_init()),
                from_glib(max.assume_init()),
            )
        }
    }
}

impl<T: AsMutPtr> Latency<T> {
    pub fn set(&mut self, live: bool, min: ::ClockTime, max: ::ClockTime) {
        unsafe {
            gst_sys::gst_query_set_latency(
                self.0.as_mut_ptr(),
                live.to_glib(),
                min.to_glib(),
                max.to_glib(),
            );
        }
    }
}

declare_concrete_query!(Seeking, T);
impl Seeking<Query> {
    pub fn new(fmt: ::Format) -> Self {
        assert_initialized_main_thread!();
        unsafe {
            Self(from_glib_full(gst_sys::gst_query_new_seeking(
                fmt.to_glib(),
            )))
        }
    }
}

impl<T: AsPtr> Seeking<T> {
    pub fn get_result(&self) -> (bool, GenericFormattedValue, GenericFormattedValue) {
        unsafe {
            let mut fmt = mem::MaybeUninit::uninit();
            let mut seekable = mem::MaybeUninit::uninit();
            let mut start = mem::MaybeUninit::uninit();
            let mut end = mem::MaybeUninit::uninit();
            gst_sys::gst_query_parse_seeking(
                self.0.as_ptr(),
                fmt.as_mut_ptr(),
                seekable.as_mut_ptr(),
                start.as_mut_ptr(),
                end.as_mut_ptr(),
            );

            (
                from_glib(seekable.assume_init()),
                GenericFormattedValue::new(from_glib(fmt.assume_init()), start.assume_init()),
                GenericFormattedValue::new(from_glib(fmt.assume_init()), end.assume_init()),
            )
        }
    }

    pub fn get_format(&self) -> ::Format {
        unsafe {
            let mut fmt = mem::MaybeUninit::uninit();
            gst_sys::gst_query_parse_seeking(
                self.0.as_ptr(),
                fmt.as_mut_ptr(),
                ptr::null_mut(),
                ptr::null_mut(),
                ptr::null_mut(),
            );

            from_glib(fmt.assume_init())
        }
    }
}

impl<T: AsMutPtr> Seeking<T> {
    pub fn set<V: Into<GenericFormattedValue>>(&mut self, seekable: bool, start: V, end: V) {
        let start = start.into();
        let end = end.into();

        assert_eq!(self.get_format(), start.get_format());
        assert_eq!(start.get_format(), end.get_format());

        unsafe {
            gst_sys::gst_query_set_seeking(
                self.0.as_mut_ptr(),
                start.get_format().to_glib(),
                seekable.to_glib(),
                start.get_value(),
                end.get_value(),
            );
        }
    }
}

declare_concrete_query!(Segment, T);
impl Segment<Query> {
    pub fn new(fmt: ::Format) -> Self {
        assert_initialized_main_thread!();
        unsafe {
            Self(from_glib_full(gst_sys::gst_query_new_segment(
                fmt.to_glib(),
            )))
        }
    }
}

impl<T: AsPtr> Segment<T> {
    pub fn get_result(&self) -> (f64, GenericFormattedValue, GenericFormattedValue) {
        unsafe {
            let mut rate = mem::MaybeUninit::uninit();
            let mut fmt = mem::MaybeUninit::uninit();
            let mut start = mem::MaybeUninit::uninit();
            let mut stop = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_segment(
                self.0.as_ptr(),
                rate.as_mut_ptr(),
                fmt.as_mut_ptr(),
                start.as_mut_ptr(),
                stop.as_mut_ptr(),
            );
            (
                rate.assume_init(),
                GenericFormattedValue::new(from_glib(fmt.assume_init()), start.assume_init()),
                GenericFormattedValue::new(from_glib(fmt.assume_init()), stop.assume_init()),
            )
        }
    }

    pub fn get_format(&self) -> ::Format {
        unsafe {
            let mut fmt = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_segment(
                self.0.as_ptr(),
                ptr::null_mut(),
                fmt.as_mut_ptr(),
                ptr::null_mut(),
                ptr::null_mut(),
            );
            from_glib(fmt.assume_init())
        }
    }
}

impl<T: AsMutPtr> Segment<T> {
    pub fn set<V: Into<GenericFormattedValue>>(&mut self, rate: f64, start: V, stop: V) {
        let start = start.into();
        let stop = stop.into();

        assert_eq!(start.get_format(), stop.get_format());

        unsafe {
            gst_sys::gst_query_set_segment(
                self.0.as_mut_ptr(),
                rate,
                start.get_format().to_glib(),
                start.get_value(),
                stop.get_value(),
            );
        }
    }
}

declare_concrete_query!(Convert, T);
impl Convert<Query> {
    pub fn new<V: Into<GenericFormattedValue>>(value: V, dest_fmt: ::Format) -> Self {
        assert_initialized_main_thread!();
        let value = value.into();
        unsafe {
            Self(from_glib_full(gst_sys::gst_query_new_convert(
                value.get_format().to_glib(),
                value.get_value(),
                dest_fmt.to_glib(),
            )))
        }
    }
}

impl<T: AsPtr> Convert<T> {
    pub fn get_result(&self) -> (GenericFormattedValue, GenericFormattedValue) {
        unsafe {
            let mut src_fmt = mem::MaybeUninit::uninit();
            let mut src = mem::MaybeUninit::uninit();
            let mut dest_fmt = mem::MaybeUninit::uninit();
            let mut dest = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_convert(
                self.0.as_ptr(),
                src_fmt.as_mut_ptr(),
                src.as_mut_ptr(),
                dest_fmt.as_mut_ptr(),
                dest.as_mut_ptr(),
            );
            (
                GenericFormattedValue::new(from_glib(src_fmt.assume_init()), src.assume_init()),
                GenericFormattedValue::new(from_glib(dest_fmt.assume_init()), dest.assume_init()),
            )
        }
    }

    pub fn get(&self) -> (GenericFormattedValue, ::Format) {
        unsafe {
            let mut src_fmt = mem::MaybeUninit::uninit();
            let mut src = mem::MaybeUninit::uninit();
            let mut dest_fmt = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_convert(
                self.0.as_ptr(),
                src_fmt.as_mut_ptr(),
                src.as_mut_ptr(),
                dest_fmt.as_mut_ptr(),
                ptr::null_mut(),
            );
            (
                GenericFormattedValue::new(from_glib(src_fmt.assume_init()), src.assume_init()),
                from_glib(dest_fmt.assume_init()),
            )
        }
    }
}

impl<T: AsMutPtr> Convert<T> {
    pub fn set<V: Into<GenericFormattedValue>>(&mut self, src: V, dest: V) {
        let src = src.into();
        let dest = dest.into();

        unsafe {
            gst_sys::gst_query_set_convert(
                self.0.as_mut_ptr(),
                src.get_format().to_glib(),
                src.get_value(),
                dest.get_format().to_glib(),
                dest.get_value(),
            );
        }
    }
}

declare_concrete_query!(Formats, T);
impl Formats<Query> {
    pub fn new() -> Self {
        assert_initialized_main_thread!();
        unsafe { Self(from_glib_full(gst_sys::gst_query_new_formats())) }
    }
}

impl Default for Formats<Query> {
    fn default() -> Self {
        Self::new()
    }
}

impl<T: AsPtr> Formats<T> {
    pub fn get_result(&self) -> Vec<::Format> {
        unsafe {
            let mut n = mem::MaybeUninit::uninit();
            gst_sys::gst_query_parse_n_formats(self.0.as_ptr(), n.as_mut_ptr());
            let n = n.assume_init();
            let mut res = Vec::with_capacity(n as usize);

            for i in 0..n {
                let mut fmt = mem::MaybeUninit::uninit();
                gst_sys::gst_query_parse_nth_format(self.0.as_ptr(), i, fmt.as_mut_ptr());
                res.push(from_glib(fmt.assume_init()));
            }

            res
        }
    }
}

impl<T: AsMutPtr> Formats<T> {
    pub fn set(&mut self, formats: &[::Format]) {
        unsafe {
            let v: Vec<_> = formats.iter().map(|f| f.to_glib()).collect();
            gst_sys::gst_query_set_formatsv(
                self.0.as_mut_ptr(),
                v.len() as i32,
                v.as_ptr() as *mut _,
            );
        }
    }
}

declare_concrete_query!(Buffering, T);
impl Buffering<Query> {
    pub fn new(fmt: ::Format) -> Self {
        assert_initialized_main_thread!();
        unsafe {
            Self(from_glib_full(gst_sys::gst_query_new_buffering(
                fmt.to_glib(),
            )))
        }
    }
}

impl<T: AsPtr> Buffering<T> {
    pub fn get_format(&self) -> ::Format {
        unsafe {
            let mut fmt = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_buffering_range(
                self.0.as_ptr(),
                fmt.as_mut_ptr(),
                ptr::null_mut(),
                ptr::null_mut(),
                ptr::null_mut(),
            );

            from_glib(fmt.assume_init())
        }
    }

    pub fn get_percent(&self) -> (bool, i32) {
        unsafe {
            let mut busy = mem::MaybeUninit::uninit();
            let mut percent = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_buffering_percent(
                self.0.as_ptr(),
                busy.as_mut_ptr(),
                percent.as_mut_ptr(),
            );

            (from_glib(busy.assume_init()), percent.assume_init())
        }
    }

    pub fn get_range(&self) -> (GenericFormattedValue, GenericFormattedValue, i64) {
        unsafe {
            let mut fmt = mem::MaybeUninit::uninit();
            let mut start = mem::MaybeUninit::uninit();
            let mut stop = mem::MaybeUninit::uninit();
            let mut estimated_total = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_buffering_range(
                self.0.as_ptr(),
                fmt.as_mut_ptr(),
                start.as_mut_ptr(),
                stop.as_mut_ptr(),
                estimated_total.as_mut_ptr(),
            );
            (
                GenericFormattedValue::new(from_glib(fmt.assume_init()), start.assume_init()),
                GenericFormattedValue::new(from_glib(fmt.assume_init()), stop.assume_init()),
                estimated_total.assume_init(),
            )
        }
    }

    pub fn get_stats(&self) -> (::BufferingMode, i32, i32, i64) {
        unsafe {
            let mut mode = mem::MaybeUninit::uninit();
            let mut avg_in = mem::MaybeUninit::uninit();
            let mut avg_out = mem::MaybeUninit::uninit();
            let mut buffering_left = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_buffering_stats(
                self.0.as_ptr(),
                mode.as_mut_ptr(),
                avg_in.as_mut_ptr(),
                avg_out.as_mut_ptr(),
                buffering_left.as_mut_ptr(),
            );

            (
                from_glib(mode.assume_init()),
                avg_in.assume_init(),
                avg_out.assume_init(),
                buffering_left.assume_init(),
            )
        }
    }

    pub fn get_ranges(&self) -> Vec<(GenericFormattedValue, GenericFormattedValue)> {
        unsafe {
            let mut fmt = mem::MaybeUninit::uninit();
            gst_sys::gst_query_parse_buffering_range(
                self.0.as_ptr(),
                fmt.as_mut_ptr(),
                ptr::null_mut(),
                ptr::null_mut(),
                ptr::null_mut(),
            );
            let fmt = from_glib(fmt.assume_init());

            let n = gst_sys::gst_query_get_n_buffering_ranges(self.0.as_ptr());
            let mut res = Vec::with_capacity(n as usize);
            for i in 0..n {
                let mut start = mem::MaybeUninit::uninit();
                let mut stop = mem::MaybeUninit::uninit();
                let s: bool = from_glib(gst_sys::gst_query_parse_nth_buffering_range(
                    self.0.as_ptr(),
                    i,
                    start.as_mut_ptr(),
                    stop.as_mut_ptr(),
                ));
                if s {
                    res.push((
                        GenericFormattedValue::new(fmt, start.assume_init()),
                        GenericFormattedValue::new(fmt, stop.assume_init()),
                    ));
                }
            }

            res
        }
    }
}

impl<T: AsMutPtr> Buffering<T> {
    pub fn set_percent(&mut self, busy: bool, percent: i32) {
        unsafe {
            gst_sys::gst_query_set_buffering_percent(self.0.as_mut_ptr(), busy.to_glib(), percent);
        }
    }

    pub fn set_range<V: Into<GenericFormattedValue>>(
        &mut self,
        start: V,
        stop: V,
        estimated_total: i64,
    ) {
        let start = start.into();
        let stop = stop.into();

        assert_eq!(self.get_format(), start.get_format());
        assert_eq!(start.get_format(), stop.get_format());

        unsafe {
            gst_sys::gst_query_set_buffering_range(
                self.0.as_mut_ptr(),
                start.get_format().to_glib(),
                start.get_value(),
                stop.get_value(),
                estimated_total,
            );
        }
    }

    pub fn set_stats(
        &mut self,
        mode: ::BufferingMode,
        avg_in: i32,
        avg_out: i32,
        buffering_left: i64,
    ) {
        skip_assert_initialized!();
        unsafe {
            gst_sys::gst_query_set_buffering_stats(
                self.0.as_mut_ptr(),
                mode.to_glib(),
                avg_in,
                avg_out,
                buffering_left,
            );
        }
    }

    pub fn add_buffering_ranges<V: Into<GenericFormattedValue> + Copy>(
        &mut self,
        ranges: &[(V, V)],
    ) {
        unsafe {
            let fmt = self.get_format();

            for &(start, stop) in ranges {
                let start = start.into();
                let stop = stop.into();
                assert_eq!(start.get_format(), fmt);
                assert_eq!(stop.get_format(), fmt);
                gst_sys::gst_query_add_buffering_range(
                    self.0.as_mut_ptr(),
                    start.get_value(),
                    stop.get_value(),
                );
            }
        }
    }
}

declare_concrete_query!(Custom, T);
impl Custom<Query> {
    pub fn new(structure: ::Structure) -> Self {
        assert_initialized_main_thread!();
        unsafe {
            Self(from_glib_full(gst_sys::gst_query_new_custom(
                gst_sys::GST_QUERY_CUSTOM,
                structure.into_ptr(),
            )))
        }
    }
}

declare_concrete_query!(Uri, T);
impl Uri<Query> {
    pub fn new() -> Self {
        assert_initialized_main_thread!();
        unsafe { Self(from_glib_full(gst_sys::gst_query_new_uri())) }
    }
}

impl Default for Uri<Query> {
    fn default() -> Self {
        Self::new()
    }
}

impl<T: AsPtr> Uri<T> {
    pub fn get_uri(&self) -> Option<String> {
        unsafe {
            let mut uri = ptr::null_mut();
            gst_sys::gst_query_parse_uri(self.0.as_ptr(), &mut uri);
            from_glib_full(uri)
        }
    }

    pub fn get_redirection(&self) -> (Option<String>, bool) {
        unsafe {
            let mut uri = ptr::null_mut();
            gst_sys::gst_query_parse_uri_redirection(self.0.as_ptr(), &mut uri);
            let mut permanent = mem::MaybeUninit::uninit();
            gst_sys::gst_query_parse_uri_redirection_permanent(
                self.0.as_ptr(),
                permanent.as_mut_ptr(),
            );

            (from_glib_full(uri), from_glib(permanent.assume_init()))
        }
    }
}

impl<T: AsMutPtr> Uri<T> {
    pub fn set_uri<'b, U: Into<&'b str>>(&mut self, uri: U) {
        let uri = uri.into();
        unsafe {
            gst_sys::gst_query_set_uri(self.0.as_mut_ptr(), uri.to_glib_none().0);
        }
    }

    pub fn set_redirection<'b, U: Into<&'b str>>(&mut self, uri: U, permanent: bool) {
        let uri = uri.into();
        unsafe {
            gst_sys::gst_query_set_uri_redirection(self.0.as_mut_ptr(), uri.to_glib_none().0);
            gst_sys::gst_query_set_uri_redirection_permanent(
                self.0.as_mut_ptr(),
                permanent.to_glib(),
            );
        }
    }
}

declare_concrete_query!(Allocation, T);
impl Allocation<Query> {
    pub fn new(caps: &::Caps, need_pool: bool) -> Self {
        assert_initialized_main_thread!();
        unsafe {
            Self(from_glib_full(gst_sys::gst_query_new_allocation(
                caps.as_mut_ptr(),
                need_pool.to_glib(),
            )))
        }
    }
}

impl<T: AsPtr> Allocation<T> {
    pub fn get(&self) -> (&::CapsRef, bool) {
        unsafe {
            let mut caps = ptr::null_mut();
            let mut need_pool = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_allocation(self.0.as_ptr(), &mut caps, need_pool.as_mut_ptr());
            (
                ::CapsRef::from_ptr(caps),
                from_glib(need_pool.assume_init()),
            )
        }
    }

    pub fn get_owned(&self) -> (::Caps, bool) {
        unsafe {
            let (caps, need_pool) = self.get();
            (from_glib_none(caps.as_ptr()), need_pool)
        }
    }

    pub fn get_allocation_pools(&self) -> Vec<(Option<::BufferPool>, u32, u32, u32)> {
        unsafe {
            let n = gst_sys::gst_query_get_n_allocation_pools(self.0.as_ptr());
            let mut pools = Vec::with_capacity(n as usize);
            for i in 0..n {
                let mut pool = ptr::null_mut();
                let mut size = mem::MaybeUninit::uninit();
                let mut min_buffers = mem::MaybeUninit::uninit();
                let mut max_buffers = mem::MaybeUninit::uninit();

                gst_sys::gst_query_parse_nth_allocation_pool(
                    self.0.as_ptr(),
                    i,
                    &mut pool,
                    size.as_mut_ptr(),
                    min_buffers.as_mut_ptr(),
                    max_buffers.as_mut_ptr(),
                );
                pools.push((
                    from_glib_full(pool),
                    size.assume_init(),
                    min_buffers.assume_init(),
                    max_buffers.assume_init(),
                ));
            }

            pools
        }
    }

    pub fn get_allocation_metas(&self) -> Vec<(glib::Type, Option<&::StructureRef>)> {
        unsafe {
            let n = gst_sys::gst_query_get_n_allocation_metas(self.0.as_ptr());
            let mut metas = Vec::with_capacity(n as usize);
            for i in 0..n {
                let mut structure = ptr::null();

                let api = gst_sys::gst_query_parse_nth_allocation_meta(
                    self.0.as_ptr(),
                    i,
                    &mut structure,
                );
                metas.push((
                    from_glib(api),
                    if structure.is_null() {
                        None
                    } else {
                        Some(::StructureRef::from_glib_borrow(structure))
                    },
                ));
            }

            metas
        }
    }

    pub fn find_allocation_meta<U: ::MetaAPI>(&self) -> Option<u32> {
        unsafe {
            let mut idx = mem::MaybeUninit::uninit();
            if gst_sys::gst_query_find_allocation_meta(
                self.0.as_ptr(),
                U::get_meta_api().to_glib(),
                idx.as_mut_ptr(),
            ) != glib_sys::GFALSE
            {
                Some(idx.assume_init())
            } else {
                None
            }
        }
    }
}

impl<T: AsMutPtr> Allocation<T> {
    pub fn add_allocation_pool(
        &mut self,
        pool: Option<&::BufferPool>,
        size: u32,
        min_buffers: u32,
        max_buffers: u32,
    ) {
        unsafe {
            gst_sys::gst_query_add_allocation_pool(
                self.0.as_mut_ptr(),
                pool.to_glib_none().0,
                size,
                min_buffers,
                max_buffers,
            );
        }
    }

    pub fn set_nth_allocation_pool(
        &mut self,
        idx: u32,
        pool: Option<&::BufferPool>,
        size: u32,
        min_buffers: u32,
        max_buffers: u32,
    ) {
        unsafe {
            gst_sys::gst_query_set_nth_allocation_pool(
                self.0.as_mut_ptr(),
                idx,
                pool.to_glib_none().0,
                size,
                min_buffers,
                max_buffers,
            );
        }
    }

    pub fn remove_nth_allocation_pool(&mut self, idx: u32) {
        unsafe {
            gst_sys::gst_query_remove_nth_allocation_pool(self.0.as_mut_ptr(), idx);
        }
    }

    pub fn add_allocation_meta<U: ::MetaAPI>(&mut self, structure: Option<&::StructureRef>) {
        unsafe {
            gst_sys::gst_query_add_allocation_meta(
                self.0.as_mut_ptr(),
                U::get_meta_api().to_glib(),
                if let Some(structure) = structure {
                    structure.as_ptr()
                } else {
                    ptr::null()
                },
            );
        }
    }

    pub fn remove_nth_allocation_meta(&mut self, idx: u32) {
        unsafe {
            gst_sys::gst_query_remove_nth_allocation_meta(self.0.as_mut_ptr(), idx);
        }
    }
}

declare_concrete_query!(Scheduling, T);
impl Scheduling<Query> {
    pub fn new() -> Self {
        assert_initialized_main_thread!();
        unsafe { Self(from_glib_full(gst_sys::gst_query_new_scheduling())) }
    }
}

impl Default for Scheduling<Query> {
    fn default() -> Self {
        Self::new()
    }
}

impl<T: AsPtr> Scheduling<T> {
    pub fn has_scheduling_mode(&self, mode: ::PadMode) -> bool {
        unsafe {
            from_glib(gst_sys::gst_query_has_scheduling_mode(
                self.0.as_ptr(),
                mode.to_glib(),
            ))
        }
    }

    pub fn has_scheduling_mode_with_flags(
        &self,
        mode: ::PadMode,
        flags: ::SchedulingFlags,
    ) -> bool {
        skip_assert_initialized!();
        unsafe {
            from_glib(gst_sys::gst_query_has_scheduling_mode_with_flags(
                self.0.as_ptr(),
                mode.to_glib(),
                flags.to_glib(),
            ))
        }
    }

    pub fn get_scheduling_modes(&self) -> Vec<::PadMode> {
        unsafe {
            let n = gst_sys::gst_query_get_n_scheduling_modes(self.0.as_ptr());
            let mut res = Vec::with_capacity(n as usize);
            for i in 0..n {
                res.push(from_glib(gst_sys::gst_query_parse_nth_scheduling_mode(
                    self.0.as_ptr(),
                    i,
                )));
            }

            res
        }
    }

    pub fn get_result(&self) -> (::SchedulingFlags, i32, i32, i32) {
        unsafe {
            let mut flags = mem::MaybeUninit::uninit();
            let mut minsize = mem::MaybeUninit::uninit();
            let mut maxsize = mem::MaybeUninit::uninit();
            let mut align = mem::MaybeUninit::uninit();

            gst_sys::gst_query_parse_scheduling(
                self.0.as_ptr(),
                flags.as_mut_ptr(),
                minsize.as_mut_ptr(),
                maxsize.as_mut_ptr(),
                align.as_mut_ptr(),
            );

            (
                from_glib(flags.assume_init()),
                minsize.assume_init(),
                maxsize.assume_init(),
                align.assume_init(),
            )
        }
    }
}

impl<T: AsMutPtr> Scheduling<T> {
    pub fn add_scheduling_modes(&mut self, modes: &[::PadMode]) {
        unsafe {
            for mode in modes {
                gst_sys::gst_query_add_scheduling_mode(self.0.as_mut_ptr(), mode.to_glib());
            }
        }
    }

    pub fn set(&mut self, flags: ::SchedulingFlags, minsize: i32, maxsize: i32, align: i32) {
        unsafe {
            gst_sys::gst_query_set_scheduling(
                self.0.as_mut_ptr(),
                flags.to_glib(),
                minsize,
                maxsize,
                align,
            );
        }
    }
}

declare_concrete_query!(AcceptCaps, T);
impl AcceptCaps<Query> {
    pub fn new(caps: &::Caps) -> Self {
        assert_initialized_main_thread!();
        unsafe {
            Self(from_glib_full(gst_sys::gst_query_new_accept_caps(
                caps.as_mut_ptr(),
            )))
        }
    }
}

impl<T: AsPtr> AcceptCaps<T> {
    pub fn get_caps(&self) -> &::CapsRef {
        unsafe {
            let mut caps = ptr::null_mut();
            gst_sys::gst_query_parse_accept_caps(self.0.as_ptr(), &mut caps);
            ::CapsRef::from_ptr(caps)
        }
    }

    pub fn get_caps_owned(&self) -> ::Caps {
        unsafe { from_glib_none(self.get_caps().as_ptr()) }
    }

    pub fn get_result(&self) -> bool {
        unsafe {
            let mut accepted = mem::MaybeUninit::uninit();
            gst_sys::gst_query_parse_accept_caps_result(self.0.as_ptr(), accepted.as_mut_ptr());
            from_glib(accepted.assume_init())
        }
    }
}

impl<T: AsMutPtr> AcceptCaps<T> {
    pub fn set_result(&mut self, accepted: bool) {
        unsafe {
            gst_sys::gst_query_set_accept_caps_result(self.0.as_mut_ptr(), accepted.to_glib());
        }
    }
}

declare_concrete_query!(Caps, T);
impl Caps<Query> {
    pub fn new(filter: Option<&::Caps>) -> Self {
        assert_initialized_main_thread!();
        unsafe {
            Self(from_glib_full(gst_sys::gst_query_new_caps(
                filter.to_glib_none().0,
            )))
        }
    }
}

impl<T: AsPtr> Caps<T> {
    pub fn get_filter(&self) -> Option<&::CapsRef> {
        unsafe {
            let mut caps = ptr::null_mut();
            gst_sys::gst_query_parse_caps(self.0.as_ptr(), &mut caps);
            if caps.is_null() {
                None
            } else {
                Some(::CapsRef::from_ptr(caps))
            }
        }
    }

    pub fn get_filter_owned(&self) -> Option<::Caps> {
        unsafe { self.get_filter().map(|caps| from_glib_none(caps.as_ptr())) }
    }

    pub fn get_result(&self) -> Option<&::CapsRef> {
        unsafe {
            let mut caps = ptr::null_mut();
            gst_sys::gst_query_parse_caps_result(self.0.as_ptr(), &mut caps);
            if caps.is_null() {
                None
            } else {
                Some(::CapsRef::from_ptr(caps))
            }
        }
    }

    pub fn get_result_owned(&self) -> Option<::Caps> {
        unsafe { self.get_result().map(|caps| from_glib_none(caps.as_ptr())) }
    }
}

impl<T: AsMutPtr> Caps<T> {
    pub fn set_result(&mut self, caps: &::Caps) {
        unsafe {
            gst_sys::gst_query_set_caps_result(self.0.as_mut_ptr(), caps.as_mut_ptr());
        }
    }
}

declare_concrete_query!(Drain, T);
impl Drain<Query> {
    pub fn new() -> Self {
        assert_initialized_main_thread!();
        unsafe { Self(from_glib_full(gst_sys::gst_query_new_drain())) }
    }
}

impl Default for Drain<Query> {
    fn default() -> Self {
        Self::new()
    }
}

declare_concrete_query!(Context, T);
impl Context<Query> {
    pub fn new(context_type: &str) -> Self {
        assert_initialized_main_thread!();
        unsafe {
            Self(from_glib_full(gst_sys::gst_query_new_context(
                context_type.to_glib_none().0,
            )))
        }
    }
}

impl<T: AsPtr> Context<T> {
    pub fn get_context(&self) -> Option<&::ContextRef> {
        unsafe {
            let mut context = ptr::null_mut();
            gst_sys::gst_query_parse_context(self.0.as_ptr(), &mut context);
            if context.is_null() {
                None
            } else {
                Some(::ContextRef::from_ptr(context))
            }
        }
    }

    pub fn get_context_owned(&self) -> Option<::Context> {
        unsafe {
            self.get_context()
                .map(|context| from_glib_none(context.as_ptr()))
        }
    }

    pub fn get_context_type(&self) -> &str {
        unsafe {
            let mut context_type = ptr::null();
            gst_sys::gst_query_parse_context_type(self.0.as_ptr(), &mut context_type);
            CStr::from_ptr(context_type).to_str().unwrap()
        }
    }
}

impl<T: AsMutPtr> Context<T> {
    pub fn set_context(&mut self, context: &::Context) {
        unsafe {
            gst_sys::gst_query_set_context(self.0.as_mut_ptr(), context.as_mut_ptr());
        }
    }
}

declare_concrete_query!(Bitrate, T);

#[cfg(any(feature = "v1_16", feature = "dox"))]
impl Bitrate<Query> {
    pub fn new() -> Self {
        assert_initialized_main_thread!();
        unsafe { Self(from_glib_full(gst_sys::gst_query_new_bitrate())) }
    }
}

#[cfg(any(feature = "v1_16", feature = "dox"))]
impl Default for Bitrate<Query> {
    fn default() -> Self {
        Self::new()
    }
}

impl<T: AsPtr> Bitrate<T> {
    #[cfg(any(feature = "v1_16", feature = "dox"))]
    pub fn get_bitrate(&self) -> u32 {
        unsafe {
            let mut bitrate = mem::MaybeUninit::uninit();
            gst_sys::gst_query_parse_bitrate(self.0.as_ptr(), bitrate.as_mut_ptr());
            bitrate.assume_init()
        }
    }
}

impl<T: AsMutPtr> Bitrate<T> {
    #[cfg(any(feature = "v1_16", feature = "dox"))]
    pub fn set_bitrate(&mut self, bitrate: u32) {
        unsafe {
            gst_sys::gst_query_set_bitrate(self.0.as_mut_ptr(), bitrate);
        }
    }
}

declare_concrete_query!(Other, T);

#[cfg(test)]
mod tests {
    use super::*;
    use std::convert::TryInto;

    #[test]
    fn test_writability() {
        ::init().unwrap();

        fn check_mut(query: &mut QueryRef) {
            skip_assert_initialized!();
            match query.view_mut() {
                QueryView::Position(ref mut p) => {
                    let pos = p.get_result();
                    assert_eq!(pos.try_into(), Ok(::CLOCK_TIME_NONE));
                    p.set(3 * ::SECOND);
                    let pos = p.get_result();
                    assert_eq!(pos.try_into(), Ok(3 * ::SECOND));
                }
                _ => panic!("Wrong concrete Query in Query"),
            }
        }

        fn check_ref(query: &QueryRef) {
            skip_assert_initialized!();
            match query.view() {
                QueryView::Position(ref p) => {
                    let pos = p.get_result();
                    assert_eq!(pos.try_into(), Ok(3 * ::SECOND));
                    unsafe {
                        assert!(!p.as_mut_ptr().is_null());
                    }
                }
                _ => panic!("Wrong concrete Query in Query"),
            }
        }

        let mut p = Position::new(::Format::Time);
        let pos = p.get_result();
        assert_eq!(pos.try_into(), Ok(::CLOCK_TIME_NONE));

        p.get_mut_structure().set("check_mut", &true);

        // deref
        assert!(!p.is_serialized());

        {
            check_mut(&mut p);

            let structure = p.get_structure();
            structure.unwrap().has_field("check_mut");

            // Expected: cannot borrow `p` as mutable because it is also borrowed as immutable
            //check_mut(&mut p);
        }

        check_ref(&p);
    }

    #[test]
    fn test_into_query() {
        ::init().unwrap();
        let d = Duration::new(::Format::Time);

        let mut query: Query = d.into();
        assert!(query.is_writable());

        let query = query.make_mut();
        match query.view_mut() {
            QueryView::Duration(ref mut d) => {
                d.set(2 * ::SECOND);
            }
            _ => (),
        }

        match query.view() {
            QueryView::Duration(ref d) => {
                let duration = d.get_result();
                assert_eq!(duration.try_into(), Ok(2 * ::SECOND));
            }
            _ => (),
        }
    }

    #[test]
    fn test_concrete_to_sys() {
        ::init().unwrap();

        let p = Position::new(::Format::Time);
        unsafe {
            assert!(!p.as_mut_ptr().is_null());
        }
    }
}