use crate::error::GremlinError;
use crate::structure::{Edge, GValue, Vertex};
use crate::GremlinResult;
use crate::Token;
use std::collections::hash_map::IntoIter;
use std::collections::{BTreeMap, HashMap};
use std::convert::{TryFrom, TryInto};
#[derive(Debug, PartialEq, Clone)]
pub struct Map(HashMap<GKey, GValue>);
impl Map {
pub fn empty() -> Map {
Map(HashMap::default())
}
}
impl From<HashMap<GKey, GValue>> for Map {
fn from(val: HashMap<GKey, GValue>) -> Self {
Map(val)
}
}
impl From<Map> for HashMap<GKey, GValue> {
fn from(map: Map) -> Self {
map.0
}
}
impl From<HashMap<String, GValue>> for Map {
fn from(val: HashMap<String, GValue>) -> Self {
let map = val.into_iter().map(|(k, v)| (GKey::String(k), v)).collect();
Map(map)
}
}
impl TryFrom<Map> for HashMap<String, GValue> {
type Error = GremlinError;
fn try_from(map: Map) -> Result<Self, Self::Error> {
map.into_iter().map(|(k, v)| Ok((k.try_into()?, v))).collect()
}
}
impl From<BTreeMap<String, GValue>> for Map {
fn from(val: BTreeMap<String, GValue>) -> Self {
let map = val.into_iter().map(|(k, v)| (GKey::String(k), v)).collect();
Map(map)
}
}
impl TryFrom<Map> for BTreeMap<String, GValue> {
type Error = GremlinError;
fn try_from(map: Map) -> Result<Self, Self::Error> {
map.into_iter().map(|(k, v)| Ok((k.try_into()?, v))).collect()
}
}
impl Map {
pub fn remove<T>(&mut self, key: T) -> Option<GValue>
where
T: Into<GKey>,
{
self.0.remove(&key.into())
}
pub fn iter(&self) -> impl Iterator<Item = (&GKey, &GValue)> {
self.0.iter()
}
pub fn get<T>(&self, key: T) -> Option<&GValue>
where
T: Into<GKey>,
{
self.0.get(&key.into())
}
pub fn try_get<K, V>(&self, key: K) -> GremlinResult<V>
where
K: Into<GKey>,
V: std::convert::TryFrom<GValue, Error = GremlinError>,
{
self.0
.get(&key.into())
.cloned()
.or(Some(GValue::Null))
.map(V::try_from)
.ok_or_else(|| GremlinError::Cast(String::from("field not found")))?
}
pub fn len(&self) -> usize {
self.0.len()
}
pub fn is_empty(&self) -> bool {
self.0.is_empty()
}
}
impl<T: Into<GKey>> std::ops::Index<T> for Map {
type Output = GValue;
fn index(&self, key: T) -> &GValue {
self.0.get(&key.into()).expect("no entry found for key")
}
}
impl IntoIterator for Map {
type Item = (GKey, GValue);
type IntoIter = IntoIter<GKey, GValue>;
fn into_iter(self) -> Self::IntoIter {
self.0.into_iter()
}
}
impl std::iter::FromIterator<(String, GValue)> for Map {
fn from_iter<I: IntoIterator<Item = (String, GValue)>>(iter: I) -> Self {
Map(iter.into_iter().map(|(k, v)| (GKey::String(k), v)).collect())
}
}
#[allow(clippy::large_enum_variant)]
#[derive(Debug, PartialEq, Clone, Eq, Hash)]
pub enum GKey {
String(String),
Token(Token),
Vertex(Vertex),
Edge(Edge),
}
impl From<&str> for GKey {
fn from(val: &str) -> Self {
GKey::String(String::from(val))
}
}
impl From<String> for GKey {
fn from(val: String) -> Self {
GKey::String(val)
}
}
impl TryFrom<GKey> for String {
type Error = GremlinError;
fn try_from(k: GKey) -> Result<Self, Self::Error> {
if let GKey::String(s) = k {
Ok(s)
} else {
Err(GremlinError::Cast(format!("Cannot cast from {:?} to String", k)))
}
}
}
impl From<&Vertex> for GKey {
fn from(val: &Vertex) -> Self {
GKey::Vertex(val.clone())
}
}
impl From<&Edge> for GKey {
fn from(val: &Edge) -> Self {
GKey::Edge(val.clone())
}
}