postgres-inet 0.1.1

// Copyright 2017 Ethan Welker
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

//! Provides Cidr and Inet support for
//! [`postgres`](https://crates.io/crates/postgres).
//!
//! Unlike several other names of this pattern, this is not affiliated
//! with or supported by the [author](https://github.com/sfackler) of
//! `postgres`.
//!
//! Please see the `examples/` folder in the crate root for a simple example.
#![doc(html_root_url="https://docs.rs/postgres-inet/0.1.0")]
#![warn(missing_docs)]

#[macro_use]
extern crate postgres;

extern crate byteorder;
extern crate libc;

use postgres::types::{Type, ToSql, FromSql, IsNull};
use std::error::Error;
use std::fmt;
use std::net::{IpAddr, Ipv4Addr, Ipv6Addr};

const IPV4_NETMASK_FULL: u8 = 32;
const IPV4_ADDRESS_FAMILY: u8 = ::libc::AF_INET as u8;
const IPV4_ADDRESS_SIZE: u8 = 4;

const IPV6_NETMASK_FULL: u8 = 128;
const IPV6_ADDRESS_FAMILY: u8 = (::libc::AF_INET + 1) as u8;
const IPV6_ADDRESS_SIZE: u8 = 16;

#[derive(Clone, Eq, PartialEq, Hash, PartialOrd, Ord)]
/// An IP address with a netmask.
pub struct MaskedIpAddr {
    addr: IpAddr,
    mask: u8,
}

impl MaskedIpAddr {
    /// Creates a new `MaskedIpAddr` from components.
    ///
    /// # Panics
    ///
    /// Panics if the netmask is greater than 32 for an IPv4 address, or is
    /// greater than 128 for an IPv6 address.
    ///
    /// # Examples
    ///
    /// To represent an address:
    ///
    /// ```
    /// # use postgres_inet::MaskedIpAddr;
    /// # use std::net::Ipv4Addr;
    /// let ip = Ipv4Addr::new(192, 0, 2, 142);
    /// MaskedIpAddr::new(ip, 32);
    /// ```
    ///
    /// To represent a network:
    ///
    /// ```
    /// # use postgres_inet::MaskedIpAddr;
    /// # use std::net::Ipv6Addr;
    /// let network = Ipv6Addr::new(0x2001, 0x0DB8, 0, 0, 0, 0, 0, 0);
    /// MaskedIpAddr::new(network, 32);
    /// ```
    pub fn new<I: Into<IpAddr>>(addr: I, mask: u8) -> MaskedIpAddr {
        let addr = addr.into();

        if match addr {
            IpAddr::V4(_) => mask > IPV4_NETMASK_FULL,
            IpAddr::V6(_) => mask > IPV6_NETMASK_FULL,
        } {
            panic!("Mask too big for IP type!");
        }

        MaskedIpAddr {
            addr: addr,
            mask: mask,
        }
    }

    /// Returns true for the special 'unspecified' address.
    ///
    /// # Examples
    ///
    /// ```
    /// # use postgres_inet::MaskedIpAddr;
    /// # use std::net::{Ipv4Addr, Ipv6Addr};
    /// assert!(MaskedIpAddr::new(Ipv4Addr::new(0, 0, 0, 0), 32).is_unspecified());
    /// assert!(MaskedIpAddr::new(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 0), 128).is_unspecified());
    /// ```
    pub fn is_unspecified(&self) -> bool {
        self.addr.is_unspecified()
    }

    /// Returns true if this is a loopback address.
    ///
    /// # Examples
    ///
    /// ```
    /// # use postgres_inet::MaskedIpAddr;
    /// # use std::net::{Ipv4Addr, Ipv6Addr};
    /// assert!(MaskedIpAddr::new(Ipv4Addr::new(127, 0, 0, 1), 32).is_loopback());
    /// assert!(MaskedIpAddr::new(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 1), 128).is_loopback());
    /// ```
    pub fn is_loopback(&self) -> bool {
        self.addr.is_loopback()
    }

    /// Returns true if this is a multicast address.
    ///
    /// # Examples
    ///
    /// ```
    /// # use postgres_inet::MaskedIpAddr;
    /// # use std::net::{Ipv4Addr, Ipv6Addr};
    /// assert!(MaskedIpAddr::new(Ipv4Addr::new(224, 254, 0, 0), 32).is_multicast());
    /// assert!(MaskedIpAddr::new(Ipv6Addr::new(0xff00, 0, 0, 0, 0, 0, 0, 0), 128).is_multicast());
    /// ```
    pub fn is_multicast(&self) -> bool {
        self.addr.is_multicast()
    }

    /// Consumes the `MaskedIpAddr`, returning the IP address and netmask.
    ///
    /// # Examples
    ///
    /// ```
    /// # use postgres_inet::MaskedIpAddr;
    /// # use std::net::Ipv4Addr;
    /// let network = Ipv4Addr::new(198, 51, 100, 0);
    /// let (network_b, netmask) = MaskedIpAddr::new(network.clone(), 24).into_inner();
    /// assert_eq!(network, network_b);
    /// assert_eq!(netmask, 24);
    /// ```
    pub fn into_inner(self) -> (IpAddr, u8) {
        (self.addr, self.mask)
    }
}

impl From<Ipv4Addr> for MaskedIpAddr {
    fn from(ipv4: Ipv4Addr) -> MaskedIpAddr {
        MaskedIpAddr {
            addr: IpAddr::V4(ipv4),
            mask: IPV4_NETMASK_FULL,
        }
    }
}

impl From<Ipv6Addr> for MaskedIpAddr {
    fn from(ipv6: Ipv6Addr) -> MaskedIpAddr {
        MaskedIpAddr {
            addr: IpAddr::V6(ipv6),
            mask: IPV6_NETMASK_FULL,
        }
    }
}

impl From<IpAddr> for MaskedIpAddr {
    fn from(ip: IpAddr) -> MaskedIpAddr {
        MaskedIpAddr {
            mask: match ip {
                IpAddr::V4(_) => IPV4_NETMASK_FULL,
                IpAddr::V6(_) => IPV6_NETMASK_FULL,
            },
            addr: ip,
        }
    }
}

impl From<MaskedIpAddr> for IpAddr {
    fn from(mip: MaskedIpAddr) -> IpAddr {
        mip.addr
    }
}

impl fmt::Display for MaskedIpAddr {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        match self.addr {
            IpAddr::V4(ipv4) => {
                match self.mask {
                    IPV4_NETMASK_FULL => ipv4.fmt(f),
                    _ => write!(f, "{}/{}", ipv4, self.mask),
                }
            }
            IpAddr::V6(ipv6) => {
                match self.mask {
                    IPV6_NETMASK_FULL => ipv6.fmt(f),
                    _ => write!(f, "{}/{}", ipv6, self.mask),
                }
            }
        }

    }
}

impl fmt::Debug for MaskedIpAddr {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        write!(f, "{}/{}", self.addr, self.mask)
    }
}

impl FromSql for MaskedIpAddr {
    fn from_sql(_: &Type, raw: &[u8]) -> Result<Self, Box<Error + 'static + Sync + Send>> {
        // The address family is at raw[0], as AF_INET for ipv4 or (AF_INET + 1)
        // for ipv6.  It's unneeded, as `nb` at raw[3] tells us the version just as
        // well. A bool of the `cidr`ness is at raw[2]. It's also unneeded, as it
        // doesn't affect our codepath in any way whatsoever.

        Ok(MaskedIpAddr {
            addr: match raw[3] {
                IPV4_ADDRESS_SIZE => IpAddr::V4(Ipv4Addr::new(raw[4], raw[5], raw[6], raw[7])),
                IPV6_ADDRESS_SIZE => {
                    // The IPv6 is sent in network byte order, so we need to convert it to the host
                    // order.
                    use byteorder::{NetworkEndian, ReadBytesExt};
                    use std::io::Read;

                    let mut raw = raw;
                    raw.read_exact(&mut [0u8; 4])?; // throw away the first four bytes
                    IpAddr::V6(Ipv6Addr::new(raw.read_u16::<NetworkEndian>()?,
                                             raw.read_u16::<NetworkEndian>()?,
                                             raw.read_u16::<NetworkEndian>()?,
                                             raw.read_u16::<NetworkEndian>()?,
                                             raw.read_u16::<NetworkEndian>()?,
                                             raw.read_u16::<NetworkEndian>()?,
                                             raw.read_u16::<NetworkEndian>()?,
                                             raw.read_u16::<NetworkEndian>()?))
                }
                _ => panic!("Unknown Internet Protocol Version!"),
            },
            mask: raw[1],
        })
    }

    fn accepts(ty: &Type) -> bool {
        match *ty {
            Type::Cidr | Type::Inet => true,
            _ => false,
        }
    }
}

impl ToSql for MaskedIpAddr {
    fn to_sql(&self, ty: &Type, w: &mut Vec<u8>) -> Result<IsNull, Box<Error + Sync + Send>> {
        // We're relying on the optimizer to clean this up.

        w.push(match self.addr { // Address Family
            IpAddr::V4(_) => IPV4_ADDRESS_FAMILY,
            IpAddr::V6(_) => IPV6_ADDRESS_FAMILY,
        });
        w.push(self.mask); // Subnet mask
        w.push(match *ty { // cidr
            Type::Cidr => true as u8,
            Type::Inet => false as u8,
            _ => unreachable!(),
        });
        w.push(match self.addr {
            IpAddr::V4(_) => IPV4_ADDRESS_SIZE,
            IpAddr::V6(_) => IPV6_ADDRESS_SIZE,
        });
        match self.addr { // Luckily, ipv6.octets() outputs in Network Byte Order.
            IpAddr::V4(ipv4) => w.append(&mut ipv4.octets().to_vec()),
            IpAddr::V6(ipv6) => w.append(&mut ipv6.octets().to_vec()),
        };

        Ok(IsNull::No)
    }

    accepts!(Type::Cidr, Type::Inet);
    to_sql_checked!();
}

#[cfg(test)]
mod tests {

    use postgres::{Connection, TlsMode};
    use std::net::{IpAddr, Ipv4Addr, Ipv6Addr};
    use super::*;

    fn _db() -> Connection {
        let conn = Connection::connect("postgres://postgres@localhost", TlsMode::None).unwrap();
        conn.execute("CREATE TEMPORARY TABLE foo (id SERIAL PRIMARY KEY, cidr CIDR, inet INET)",
                     &[])
            .unwrap();
        conn
    }

    fn _new_full_ipv4() -> (MaskedIpAddr, IpAddr, u8) {
        let expected = IpAddr::V4(Ipv4Addr::new(192, 0, 2, 0));
        let mask = IPV4_NETMASK_FULL;

        (MaskedIpAddr::new(expected, mask), expected, mask)
    }

    fn _new_full_ipv6() -> (MaskedIpAddr, IpAddr, u8) {
        let expected = IpAddr::V6(Ipv6Addr::new(0x2001, 0xDB8, 0, 0, 0, 0, 0, 0));
        let mask = IPV6_NETMASK_FULL;

        (MaskedIpAddr::new(expected, mask), expected, mask)
    }

    fn _new_masked_ipv4() -> (MaskedIpAddr, IpAddr, u8) {
        let expected = IpAddr::V4(Ipv4Addr::new(192, 0, 2, 0));
        let mask = 24;

        (MaskedIpAddr::new(expected, mask), expected, mask)
    }

    fn _new_masked_ipv6() -> (MaskedIpAddr, IpAddr, u8) {
        let expected = IpAddr::V6(Ipv6Addr::new(0x2001, 0xDB8, 0, 0, 0, 0, 0, 0));
        let mask = 32;

        (MaskedIpAddr::new(expected, mask), expected, mask)
    }

    #[test]
    fn new_full_ipv4() {
        let (mip, expected, mask) = _new_full_ipv4();
        assert_eq!(mip.addr, expected);
        assert_eq!(mip.mask, mask);
    }

    #[test]
    fn new_full_ipv6() {
        let (mip, expected, mask) = _new_full_ipv6();
        assert_eq!(mip.addr, expected);
        assert_eq!(mip.mask, mask);
    }

    #[test]
    fn new_masked_ipv4() {
        let (mip, expected, mask) = _new_masked_ipv4();
        assert_eq!(mip.addr, expected);
        assert_eq!(mip.mask, mask);
    }

    #[test]
    fn new_masked_ipv6() {
        let (mip, expected, mask) = _new_masked_ipv6();
        assert_eq!(mip.addr, expected);
        assert_eq!(mip.mask, mask);
    }

    #[test]
    fn is_unspec_ipv4() {
        let mip = MaskedIpAddr::new(IpAddr::V4(Ipv4Addr::new(0, 0, 0, 0)), IPV4_NETMASK_FULL);
        assert!(mip.is_unspecified());
    }

    #[test]
    fn is_unspec_ipv6() {
        let mip = MaskedIpAddr::new(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 0)),
                                    IPV6_NETMASK_FULL);
        assert!(mip.is_unspecified());
    }

    #[test]
    fn is_unspec_ipv4_false() {
        let (mip, _, _) = _new_full_ipv4();
        assert!(!mip.is_unspecified());
    }

    #[test]
    fn is_unspec_ipv6_false() {
        let (mip, _, _) = _new_full_ipv6();
        assert!(!mip.is_unspecified());
    }

    #[test]
    fn is_loop_ipv4() {
        let mip = MaskedIpAddr::new(IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)), IPV4_NETMASK_FULL);
        assert!(mip.is_loopback());
    }

    #[test]
    fn is_loop_ipv6() {
        let mip = MaskedIpAddr::new(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 1)),
                                    IPV6_NETMASK_FULL);
        assert!(mip.is_loopback());
    }

    #[test]
    fn is_loop_ipv4_false() {
        let (mip, _, _) = _new_full_ipv4();
        assert!(!mip.is_loopback());
    }

    #[test]
    fn is_loop_ipv6_false() {
        let (mip, _, _) = _new_full_ipv6();
        assert!(!mip.is_loopback());
    }

    #[test]
    fn is_multi_ipv4() {
        let mip = MaskedIpAddr::new(IpAddr::V4(Ipv4Addr::new(224, 0, 0, 0)), IPV4_NETMASK_FULL);
        assert!(mip.is_multicast());
    }

    #[test]
    fn is_multi_ipv6() {
        let mip = MaskedIpAddr::new(IpAddr::V6(Ipv6Addr::new(0xff00, 0, 0, 0, 0, 0, 0, 0)),
                                    IPV6_NETMASK_FULL);
        assert!(mip.is_multicast());
    }

    #[test]
    fn is_multi_ipv4_false() {
        let (mip, _, _) = _new_full_ipv4();
        assert!(!mip.is_multicast());
    }

    #[test]
    fn is_multi_ipv6_false() {
        let (mip, _, _) = _new_full_ipv6();
        assert!(!mip.is_multicast());
    }

    #[test]
    fn into_inner_ipv4() {
        let (mip, expected, mask) = _new_full_ipv4();
        let (expected_b, mask_b) = mip.into_inner();

        assert_eq!(expected, expected_b);
        assert_eq!(mask, mask_b);
    }

    #[test]
    fn into_inner_ipv6() {
        let (mip, expected, mask) = _new_full_ipv6();
        let (expected_b, mask_b) = mip.into_inner();

        assert_eq!(expected, expected_b);
        assert_eq!(mask, mask_b);
    }

    #[test]
    fn new_from_ipv4() {
        let ipv4 = Ipv4Addr::new(198, 51, 100, 255);
        let mask = IPV4_NETMASK_FULL;

        let (ipv4_b, mask_b) = MaskedIpAddr::new(ipv4, mask).into_inner();

        assert_eq!(ipv4, ipv4_b);
        assert_eq!(mask, mask_b);
    }

    #[test]
    fn from_ipv4_to_mip() {
        let ipv4 = Ipv4Addr::new(198, 51, 100, 255);

        let mip: MaskedIpAddr = From::from(ipv4);
        let (ipv4_b, mask) = mip.into_inner();

        assert_eq!(ipv4, ipv4_b);
        assert_eq!(mask, IPV4_NETMASK_FULL);
    }

    #[test]
    fn new_from_ipv6() {
        let ipv6 = Ipv6Addr::new(0x2001, 0xDB8, 0, 0, 0, 0, 0, 0);
        let mask = IPV6_NETMASK_FULL;

        let (ipv6_b, mask_b) = MaskedIpAddr::new(ipv6, mask).into_inner();

        assert_eq!(ipv6, ipv6_b);
        assert_eq!(mask, mask_b);
    }

    #[test]
    fn from_ipv6_to_mip() {
        let ipv6 = Ipv6Addr::new(0x2001, 0xDB8, 0, 0, 0, 0, 0, 0);

        let mip: MaskedIpAddr = From::from(ipv6);
        let (ipv6_b, mask) = mip.into_inner();

        assert_eq!(ipv6, ipv6_b);
        assert_eq!(mask, IPV6_NETMASK_FULL);
    }

    #[test]
    fn new_from_ip() {
        let ip = IpAddr::V4(Ipv4Addr::new(203, 0, 113, 128));
        let mask = IPV4_NETMASK_FULL;

        let (ip_b, mask_b) = MaskedIpAddr::new(ip, mask).into_inner();

        assert_eq!(ip, ip_b);
        assert_eq!(mask, mask_b);
    }

    #[test]
    fn from_ip_to_mip() {
        let ip = IpAddr::V6(Ipv6Addr::new(0x2001, 0xDB8, 0, 0, 0, 0, 0, 0));

        let mip: MaskedIpAddr = From::from(ip);
        let (ip_b, mask) = mip.into_inner();

        assert_eq!(ip, ip_b);
        assert_eq!(mask, IPV6_NETMASK_FULL);
    }

    #[test]
    fn display_omit_netmask_when_full_ipv4() {
        let (mip, expected, _) = _new_full_ipv4();

        assert_eq!(format!("{}", mip), format!("{}", expected));
    }

    #[test]
    fn display_omit_netmask_when_full_ipv6() {
        let (mip, expected, _) = _new_full_ipv6();

        assert_eq!(format!("{}", mip), format!("{}", expected));
    }

    #[test]
    fn display_with_netmask_when_masked_ipv4() {
        let (mip, expected, mask) = _new_masked_ipv4();

        assert_eq!(format!("{}", mip), format!("{}/{}", expected, mask));
    }

    #[test]
    fn display_with_netmask_when_masked_ipv6() {
        let (mip, expected, mask) = _new_masked_ipv6();

        assert_eq!(format!("{}", mip), format!("{}/{}", expected, mask));
    }

    #[test]
    fn debug_with_netmask_when_full_ipv4() {
        let (mip, expected, mask) = _new_full_ipv4();

        assert_eq!(format!("{:?}", mip), format!("{}/{}", expected, mask));
    }

    #[test]
    fn debug_with_netmask_when_full_ipv6() {
        let (mip, expected, mask) = _new_full_ipv6();

        assert_eq!(format!("{:?}", mip), format!("{}/{}", expected, mask));
    }

    #[test]
    fn debug_with_netmask_when_masked_ipv4() {
        let (mip, expected, mask) = _new_masked_ipv4();

        assert_eq!(format!("{:?}", mip), format!("{}/{}", expected, mask));
    }

    #[test]
    fn debug_with_netmask_when_masked_ipv6() {
        let (mip, expected, mask) = _new_masked_ipv6();

        assert_eq!(format!("{:?}", mip), format!("{}/{}", expected, mask));
    }

    #[test]
    fn cidr_insert_full_ipv4() {
        let (mip, _, _) = _new_full_ipv4();
        _db().execute("INSERT INTO foo (cidr) VALUES ($1)", &[&mip]).unwrap();
    }

    #[test]
    fn cidr_insert_full_ipv6() {
        let (mip, _, _) = _new_full_ipv6();
        _db().execute("INSERT INTO foo (cidr) VALUES ($1)", &[&mip]).unwrap();
    }

    #[test]
    fn cidr_insert_masked_ipv4() {
        let (mip, _, _) = _new_masked_ipv4();
        _db().execute("INSERT INTO foo (cidr) VALUES ($1)", &[&mip]).unwrap();
    }

    #[test]
    fn cidr_insert_masked_ipv6() {
        let (mip, _, _) = _new_masked_ipv6();
        _db().execute("INSERT INTO foo (cidr) VALUES ($1)", &[&mip]).unwrap();
    }

    #[test]
    fn inet_insert_full_ipv4() {
        let (mip, _, _) = _new_full_ipv4();
        _db().execute("INSERT INTO foo (inet) VALUES ($1)", &[&mip]).unwrap();
    }

    #[test]
    fn inet_insert_full_ipv6() {
        let (mip, _, _) = _new_full_ipv6();
        _db().execute("INSERT INTO foo (inet) VALUES ($1)", &[&mip]).unwrap();
    }

    #[test]
    fn inet_insert_masked_ipv4() {
        let (mip, _, _) = _new_masked_ipv4();
        _db().execute("INSERT INTO foo (inet) VALUES ($1)", &[&mip]).unwrap();
    }

    #[test]
    fn inet_insert_masked_ipv6() {
        let (mip, _, _) = _new_masked_ipv6();
        _db().execute("INSERT INTO foo (inet) VALUES ($1)", &[&mip]).unwrap();
    }

    #[test]
    fn cidr_insert_and_select_full_ipv4() {
        let db = _db();
        let (mip, _, _) = _new_full_ipv4();

        db.execute("INSERT INTO foo (cidr) VALUES ($1)", &[&mip]).unwrap();

        let mip_b = db.query("SELECT cidr FROM foo LIMIT 1", &[]).unwrap().get(0).get(0);
        assert_eq!(mip, mip_b);
    }

    #[test]
    fn cidr_insert_and_select_full_ipv6() {
        let db = _db();
        let (mip, _, _) = _new_full_ipv6();

        db.execute("INSERT INTO foo (cidr) VALUES ($1)", &[&mip]).unwrap();

        let mip_b = db.query("SELECT cidr FROM foo LIMIT 1", &[]).unwrap().get(0).get(0);
        assert_eq!(mip, mip_b);
    }

    #[test]
    fn cidr_insert_and_select_masked_ipv4() {
        let db = _db();
        let (mip, _, _) = _new_masked_ipv4();

        db.execute("INSERT INTO foo (cidr) VALUES ($1)", &[&mip]).unwrap();

        let mip_b = db.query("SELECT cidr FROM foo LIMIT 1", &[]).unwrap().get(0).get(0);
        assert_eq!(mip, mip_b);
    }

    #[test]
    fn cidr_insert_and_select_masked_ipv6() {
        let db = _db();
        let (mip, _, _) = _new_masked_ipv6();

        db.execute("INSERT INTO foo (cidr) VALUES ($1)", &[&mip]).unwrap();

        let mip_b = db.query("SELECT cidr FROM foo LIMIT 1", &[]).unwrap().get(0).get(0);
        assert_eq!(mip, mip_b);
    }

    #[test]
    fn inet_insert_and_select_full_ipv4() {
        let db = _db();
        let (mip, _, _) = _new_full_ipv4();

        db.execute("INSERT INTO foo (inet) VALUES ($1)", &[&mip]).unwrap();

        let mip_b = db.query("SELECT inet FROM foo LIMIT 1", &[]).unwrap().get(0).get(0);
        assert_eq!(mip, mip_b);
    }

    #[test]
    fn inet_insert_and_select_full_ipv6() {
        let db = _db();
        let (mip, _, _) = _new_full_ipv6();

        db.execute("INSERT INTO foo (inet) VALUES ($1)", &[&mip]).unwrap();

        let mip_b = db.query("SELECT inet FROM foo LIMIT 1", &[]).unwrap().get(0).get(0);
        assert_eq!(mip, mip_b);
    }

    #[test]
    fn inet_insert_and_select_masked_ipv4() {
        let db = _db();
        let (mip, _, _) = _new_masked_ipv4();

        db.execute("INSERT INTO foo (inet) VALUES ($1)", &[&mip]).unwrap();

        let mip_b = db.query("SELECT inet FROM foo LIMIT 1", &[]).unwrap().get(0).get(0);
        assert_eq!(mip, mip_b);
    }

    #[test]
    fn inet_insert_and_select_masked_ipv6() {
        let db = _db();
        let (mip, _, _) = _new_masked_ipv6();

        db.execute("INSERT INTO foo (inet) VALUES ($1)", &[&mip]).unwrap();

        let mip_b = db.query("SELECT inet FROM foo LIMIT 1", &[]).unwrap().get(0).get(0);
        assert_eq!(mip, mip_b);
    }
}