You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by sp...@apache.org on 2017/07/13 17:47:57 UTC
[09/52] [abbrv] tinkerpop git commit: Add Gremlin-CSharp and
Gremlin-DotNet
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/TraversalSerializer.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/TraversalSerializer.cs b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/TraversalSerializer.cs
new file mode 100644
index 0000000..cc809aa
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/TraversalSerializer.cs
@@ -0,0 +1,38 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System.Collections.Generic;
+using Gremlin.Net.Process.Traversal;
+
+namespace Gremlin.Net.Structure.IO.GraphSON
+{
+ internal class TraversalSerializer : IGraphSONSerializer
+ {
+ public Dictionary<string, dynamic> Dictify(dynamic objectData, GraphSONWriter writer)
+ {
+ ITraversal traversal = objectData;
+ var bytecode = traversal.Bytecode;
+ return writer.ToDict(bytecode);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/TraversalStrategySerializer.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/TraversalStrategySerializer.cs b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/TraversalStrategySerializer.cs
new file mode 100644
index 0000000..9b70978
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/TraversalStrategySerializer.cs
@@ -0,0 +1,37 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System.Collections.Generic;
+using Gremlin.Net.Process.Traversal.Strategy;
+
+namespace Gremlin.Net.Structure.IO.GraphSON
+{
+ internal class TraversalStrategySerializer : IGraphSONSerializer
+ {
+ public Dictionary<string, dynamic> Dictify(dynamic objectData, GraphSONWriter writer)
+ {
+ AbstractTraversalStrategy strategy = objectData;
+ return GraphSONUtil.ToTypedValue(strategy.StrategyName, writer.ToDict(strategy.Configuration));
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/TraverserReader.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/TraverserReader.cs b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/TraverserReader.cs
new file mode 100644
index 0000000..abbb45f
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/TraverserReader.cs
@@ -0,0 +1,38 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using Gremlin.Net.Process.Traversal;
+using Newtonsoft.Json.Linq;
+
+namespace Gremlin.Net.Structure.IO.GraphSON
+{
+ internal class TraverserReader : IGraphSONDeserializer
+ {
+ public dynamic Objectify(JToken graphsonObject, GraphSONReader reader)
+ {
+ var bulkObj = reader.ToObject(graphsonObject["bulk"]);
+ var valueObj = reader.ToObject(graphsonObject["value"]);
+ return new Traverser(valueObj, bulkObj);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/UuidDeserializer.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/UuidDeserializer.cs b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/UuidDeserializer.cs
new file mode 100644
index 0000000..82ca43d
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/UuidDeserializer.cs
@@ -0,0 +1,36 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System;
+using Newtonsoft.Json.Linq;
+
+namespace Gremlin.Net.Structure.IO.GraphSON
+{
+ internal class UuidDeserializer : IGraphSONDeserializer
+ {
+ public dynamic Objectify(JToken graphsonObject, GraphSONReader reader)
+ {
+ return graphsonObject.ToObject<Guid>();
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/UuidSerializer.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/UuidSerializer.cs b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/UuidSerializer.cs
new file mode 100644
index 0000000..5f31bfc
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/UuidSerializer.cs
@@ -0,0 +1,37 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System;
+using System.Collections.Generic;
+
+namespace Gremlin.Net.Structure.IO.GraphSON
+{
+ internal class UuidSerializer : IGraphSONSerializer
+ {
+ public Dictionary<string, dynamic> Dictify(dynamic objectData, GraphSONWriter writer)
+ {
+ Guid guid = objectData;
+ return GraphSONUtil.ToTypedValue("UUID", guid);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexDeserializer.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexDeserializer.cs b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexDeserializer.cs
new file mode 100644
index 0000000..f1d64ed
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexDeserializer.cs
@@ -0,0 +1,37 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using Newtonsoft.Json.Linq;
+
+namespace Gremlin.Net.Structure.IO.GraphSON
+{
+ internal class VertexDeserializer : IGraphSONDeserializer
+ {
+ public dynamic Objectify(JToken graphsonObject, GraphSONReader reader)
+ {
+ var id = reader.ToObject(graphsonObject["id"]);
+ var label = (string) graphsonObject["label"] ?? Vertex.DefaultLabel;
+ return new Vertex(id, label);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexPropertyDeserializer.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexPropertyDeserializer.cs b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexPropertyDeserializer.cs
new file mode 100644
index 0000000..7c2505f
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexPropertyDeserializer.cs
@@ -0,0 +1,41 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using Newtonsoft.Json.Linq;
+
+namespace Gremlin.Net.Structure.IO.GraphSON
+{
+ internal class VertexPropertyDeserializer : IGraphSONDeserializer
+ {
+ public dynamic Objectify(JToken graphsonObject, GraphSONReader reader)
+ {
+ var id = reader.ToObject(graphsonObject["id"]);
+ var label = (string) graphsonObject["label"];
+ var value = reader.ToObject(graphsonObject["value"]);
+ var vertex = graphsonObject["vertex"] != null
+ ? new Vertex(reader.ToObject(graphsonObject["vertex"]))
+ : null;
+ return new VertexProperty(id, label, value, vertex);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexPropertySerializer.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexPropertySerializer.cs b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexPropertySerializer.cs
new file mode 100644
index 0000000..12cc7ac
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexPropertySerializer.cs
@@ -0,0 +1,43 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System.Collections.Generic;
+
+namespace Gremlin.Net.Structure.IO.GraphSON
+{
+ internal class VertexPropertySerializer : IGraphSONSerializer
+ {
+ public Dictionary<string, dynamic> Dictify(dynamic objectData, GraphSONWriter writer)
+ {
+ VertexProperty vertexProperty = objectData;
+ var valueDict = new Dictionary<string, dynamic>
+ {
+ {"id", writer.ToDict(vertexProperty.Id)},
+ {"label", vertexProperty.Label},
+ {"value", writer.ToDict(vertexProperty.Value)},
+ {"vertex", writer.ToDict(vertexProperty.Vertex.Id)}
+ };
+ return GraphSONUtil.ToTypedValue(nameof(VertexProperty), valueDict);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexSerializer.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexSerializer.cs b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexSerializer.cs
new file mode 100644
index 0000000..d3ad9f1
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Structure/IO/GraphSON/VertexSerializer.cs
@@ -0,0 +1,41 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System.Collections.Generic;
+
+namespace Gremlin.Net.Structure.IO.GraphSON
+{
+ internal class VertexSerializer : IGraphSONSerializer
+ {
+ public Dictionary<string, dynamic> Dictify(dynamic objectData, GraphSONWriter writer)
+ {
+ Vertex vertex = objectData;
+ var vertexDict = new Dictionary<string, dynamic>
+ {
+ {"id", writer.ToDict(vertex.Id)},
+ {"label", writer.ToDict(vertex.Label)}
+ };
+ return GraphSONUtil.ToTypedValue(nameof(Vertex), vertexDict);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/src/Gremlin.Net/Structure/Path.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Structure/Path.cs b/gremlin-dotnet/src/Gremlin.Net/Structure/Path.cs
new file mode 100644
index 0000000..01a436a
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Structure/Path.cs
@@ -0,0 +1,193 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.Linq;
+using Gremlin.Net.Process.Traversal;
+
+namespace Gremlin.Net.Structure
+{
+ /// <summary>
+ /// A Path denotes a particular walk through a graph as defined by a <see cref="ITraversal" />.
+ /// </summary>
+ /// <remarks>
+ /// In abstraction, any Path implementation maintains two lists: a list of sets of labels and a list of objects.
+ /// The list of labels are the labels of the steps traversed. The list of objects are the objects traversed.
+ /// </remarks>
+ public class Path : IReadOnlyList<object>, IEquatable<Path>
+ {
+ /// <summary>
+ /// Initializes a new instance of the <see cref="Path" /> class.
+ /// </summary>
+ /// <param name="labels">The labels associated with the path</param>
+ /// <param name="objects">The objects in the <see cref="Path" />.</param>
+ public Path(List<List<string>> labels, List<object> objects)
+ {
+ Labels = labels;
+ Objects = objects;
+ }
+
+ /// <summary>
+ /// Gets an ordered list of the labels associated with the <see cref="Path" />.
+ /// </summary>
+ public List<List<string>> Labels { get; }
+
+ /// <summary>
+ /// Gets an ordered list of the objects in the <see cref="Path" />.
+ /// </summary>
+ public List<object> Objects { get; }
+
+ /// <summary>
+ /// Gets the object associated with the particular label of the path.
+ /// </summary>
+ /// <remarks>If the path has multiple labels of the type, then get a collection of those objects.</remarks>
+ /// <param name="label">The label of the path</param>
+ /// <returns>The object associated with the label of the path</returns>
+ /// <exception cref="KeyNotFoundException">Thrown if the path does not contain the label.</exception>
+ public object this[string label]
+ {
+ get
+ {
+ var objFound = TryGetValue(label, out object obj);
+ if (!objFound)
+ throw new KeyNotFoundException($"The step with label {label} does not exist");
+ return obj;
+ }
+ }
+
+ /// <inheritdoc />
+ public bool Equals(Path other)
+ {
+ if (ReferenceEquals(null, other)) return false;
+ if (ReferenceEquals(this, other)) return true;
+ return ObjectsEqual(other.Objects) && LabelsEqual(other.Labels);
+ }
+
+ /// <summary>
+ /// Get the object associated with the specified index into the path.
+ /// </summary>
+ /// <param name="index">The index of the path</param>
+ /// <returns>The object associated with the index of the path</returns>
+ public dynamic this[int index] => Objects[index];
+
+ /// <summary>
+ /// Gets the number of steps in the path.
+ /// </summary>
+ public int Count => Objects.Count;
+
+ /// <inheritdoc />
+ public IEnumerator<object> GetEnumerator()
+ {
+ return ((IReadOnlyList<object>) Objects).GetEnumerator();
+ }
+
+ IEnumerator IEnumerable.GetEnumerator()
+ {
+ return ((IReadOnlyList<object>) Objects).GetEnumerator();
+ }
+
+ /// <inheritdoc />
+ public override string ToString()
+ {
+ return $"[{string.Join(", ", Objects)}]";
+ }
+
+ /// <summary>
+ /// Returns true if the path has the specified label, else return false.
+ /// </summary>
+ /// <param name="key">The label to search for.</param>
+ /// <returns>True if the label exists in the path.</returns>
+ public bool ContainsKey(string key)
+ {
+ return Labels.Any(objLabels => objLabels.Contains(key));
+ }
+
+ /// <summary>
+ /// Tries to get the object associated with the particular label of the path.
+ /// </summary>
+ /// <remarks>If the path has multiple labels of the type, then get a collection of those objects.</remarks>
+ /// <param name="label">The label of the path.</param>
+ /// <param name="value">The object associated with the label of the path.</param>
+ /// <returns>True, if an object was found for the label.</returns>
+ public bool TryGetValue(string label, out object value)
+ {
+ value = null;
+ for (var i = 0; i < Labels.Count; i++)
+ {
+ if (!Labels[i].Contains(label)) continue;
+ if (value == null)
+ value = Objects[i];
+ else if (value.GetType() == typeof(List<object>))
+ ((List<object>) value).Add(Objects[i]);
+ else
+ value = new List<object> {value, Objects[i]};
+ }
+ return value != null;
+ }
+
+ private bool ObjectsEqual(IReadOnlyCollection<object> otherObjects)
+ {
+ if (Objects == null)
+ return otherObjects == null;
+ return Objects.SequenceEqual(otherObjects);
+ }
+
+ private bool LabelsEqual(IReadOnlyList<List<string>> otherLabels)
+ {
+ if (Labels == null)
+ return otherLabels == null;
+ if (Labels.Count != otherLabels.Count)
+ return false;
+ var foundUnequalObjLabels = Labels.Where((objLabels, i) => !objLabels.SequenceEqual(otherLabels[i])).Any();
+ return !foundUnequalObjLabels;
+ }
+
+ /// <inheritdoc />
+ public override bool Equals(object obj)
+ {
+ if (ReferenceEquals(null, obj)) return false;
+ if (ReferenceEquals(this, obj)) return true;
+ if (obj.GetType() != GetType()) return false;
+ return Equals((Path) obj);
+ }
+
+ /// <inheritdoc />
+ public override int GetHashCode()
+ {
+ unchecked
+ {
+ var hashCode = 19;
+ if (Labels != null)
+ hashCode = Labels.Where(objLabels => objLabels != null)
+ .Aggregate(hashCode,
+ (current1, objLabels) => objLabels.Aggregate(current1,
+ (current, label) => current * 31 + label.GetHashCode()));
+ if (Objects != null)
+ hashCode = Objects.Aggregate(hashCode, (current, obj) => current * 31 + obj.GetHashCode());
+ return hashCode;
+ }
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/src/Gremlin.Net/Structure/Property.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Structure/Property.cs b/gremlin-dotnet/src/Gremlin.Net/Structure/Property.cs
new file mode 100644
index 0000000..daa052a
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Structure/Property.cs
@@ -0,0 +1,96 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System;
+
+namespace Gremlin.Net.Structure
+{
+ /// <summary>
+ /// A <see cref="Property" /> denotes a key/value pair associated with an <see cref="Edge" />.
+ /// </summary>
+ public class Property : IEquatable<Property>
+ {
+ /// <summary>
+ /// Initializes a new instance of the <see cref="Property" /> class.
+ /// </summary>
+ /// <param name="key">The key of the property.</param>
+ /// <param name="value">The value of the property.</param>
+ /// <param name="element">The element that the property is associated with.</param>
+ public Property(string key, dynamic value, Element element)
+ {
+ Key = key;
+ Value = value;
+ Element = element;
+ }
+
+ /// <summary>
+ /// Gets the key of the property.
+ /// </summary>
+ public string Key { get; }
+
+ /// <summary>
+ /// Gets the value of the property.
+ /// </summary>
+ public dynamic Value { get; }
+
+ /// <summary>
+ /// Gets the element that this property is associated with.
+ /// </summary>
+ public Element Element { get; }
+
+ /// <inheritdoc />
+ public bool Equals(Property other)
+ {
+ if (ReferenceEquals(null, other)) return false;
+ if (ReferenceEquals(this, other)) return true;
+ return string.Equals(Key, other.Key) && Equals(Value, other.Value) && Equals(Element, other.Element);
+ }
+
+ /// <inheritdoc />
+ public override string ToString()
+ {
+ return $"p[{Key}->{Value}]";
+ }
+
+ /// <inheritdoc />
+ public override bool Equals(object obj)
+ {
+ if (ReferenceEquals(null, obj)) return false;
+ if (ReferenceEquals(this, obj)) return true;
+ if (obj.GetType() != GetType()) return false;
+ return Equals((Property) obj);
+ }
+
+ /// <inheritdoc />
+ public override int GetHashCode()
+ {
+ unchecked
+ {
+ var hashCode = Key?.GetHashCode() ?? 0;
+ hashCode = (hashCode * 397) ^ (Value != null ? Value.GetHashCode() : 0);
+ hashCode = (hashCode * 397) ^ (Element?.GetHashCode() ?? 0);
+ return hashCode;
+ }
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/src/Gremlin.Net/Structure/Vertex.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Structure/Vertex.cs b/gremlin-dotnet/src/Gremlin.Net/Structure/Vertex.cs
new file mode 100644
index 0000000..f667d26
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Structure/Vertex.cs
@@ -0,0 +1,52 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Structure
+{
+ /// <summary>
+ /// Represents a vertex.
+ /// </summary>
+ public class Vertex : Element
+ {
+ /// <summary>
+ /// The default label to use for a vertex.
+ /// </summary>
+ public const string DefaultLabel = "vertex";
+
+ /// <summary>
+ /// Initializes a new instance of the <see cref="Vertex" /> class.
+ /// </summary>
+ /// <param name="id">The id of the vertex.</param>
+ /// <param name="label">The label of the vertex.</param>
+ public Vertex(object id, string label = DefaultLabel)
+ : base(id, label)
+ {
+ }
+
+ /// <inheritdoc />
+ public override string ToString()
+ {
+ return $"v[{Id}]";
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/src/Gremlin.Net/Structure/VertexProperty.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/Gremlin.Net/Structure/VertexProperty.cs b/gremlin-dotnet/src/Gremlin.Net/Structure/VertexProperty.cs
new file mode 100644
index 0000000..8e20723
--- /dev/null
+++ b/gremlin-dotnet/src/Gremlin.Net/Structure/VertexProperty.cs
@@ -0,0 +1,66 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+namespace Gremlin.Net.Structure
+{
+ /// <summary>
+ /// A <see cref="VertexProperty" /> denotes a key/value pair associated with a <see cref="Vertex" />.
+ /// </summary>
+ public class VertexProperty : Element
+ {
+ /// <summary>
+ /// Initializes a new instance of the <see cref="VertexProperty" /> class.
+ /// </summary>
+ /// <param name="id">The id of the vertex property.</param>
+ /// <param name="label">The label of the vertex property.</param>
+ /// <param name="value">The id of the vertex property.</param>
+ /// <param name="vertex">The <see cref="Vertex" /> that owns this <see cref="VertexProperty" />.</param>
+ public VertexProperty(object id, string label, dynamic value, Vertex vertex)
+ : base(id, label)
+ {
+ Value = value;
+ Vertex = vertex;
+ }
+
+ /// <summary>
+ /// The value of this <see cref="VertexProperty" />.
+ /// </summary>
+ public dynamic Value { get; }
+
+ /// <summary>
+ /// The <see cref="Vertex" /> that owns this <see cref="VertexProperty" />.
+ /// </summary>
+ public Vertex Vertex { get; }
+
+ /// <summary>
+ /// The key of this <see cref="VertexProperty" />.
+ /// </summary>
+ public string Key => Label;
+
+ /// <inheritdoc />
+ public override string ToString()
+ {
+ return $"vp[{Label}->{Value}]";
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/src/pom.xml
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/src/pom.xml b/gremlin-dotnet/src/pom.xml
new file mode 100644
index 0000000..5fef134
--- /dev/null
+++ b/gremlin-dotnet/src/pom.xml
@@ -0,0 +1,55 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.tinkerpop</groupId>
+ <artifactId>gremlin-dotnet</artifactId>
+ <version>3.2.5-SNAPSHOT</version>
+ </parent>
+ <artifactId>Gremlin-DotNet-Source</artifactId>
+ <packaging>${packaging.type}</packaging>
+ <profiles>
+ <profile>
+ <id>gremlin-dotnet-standard</id>
+ <activation>
+ <activeByDefault>true</activeByDefault>
+ </activation>
+ <properties>
+ <packaging.type>pom</packaging.type>
+ </properties>
+ </profile>
+ <!-- activates the building of .NET components and requires that the .NET Core SDK be installed on the system -->
+ <profile>
+ <id>gremlin-dotnet</id>
+ <activation>
+ <activeByDefault>false</activeByDefault>
+ <file>
+ <exists>.glv</exists>
+ </file>
+ </activation>
+ <properties>
+ <packaging.type>dotnet-library</packaging.type>
+ </properties>
+ <build>
+ <directory>${basedir}/target</directory>
+ <finalName>${project.artifactId}-${project.version}</finalName>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-surefire-plugin</artifactId>
+ </plugin>
+ <plugin>
+ <groupId>org.eobjects.build</groupId>
+ <artifactId>dotnet-maven-plugin</artifactId>
+ <extensions>true</extensions>
+ <configuration>
+ <packOutput>${project.parent.basedir}/target/nuget</packOutput>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+</project>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/BytecodeGeneration/BytecodeGenerationTests.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/BytecodeGeneration/BytecodeGenerationTests.cs b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/BytecodeGeneration/BytecodeGenerationTests.cs
new file mode 100644
index 0000000..672ff35
--- /dev/null
+++ b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/BytecodeGeneration/BytecodeGenerationTests.cs
@@ -0,0 +1,76 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using Gremlin.CSharp.Process;
+using Gremlin.CSharp.Structure;
+using Xunit;
+
+namespace Gremlin.CSharp.IntegrationTest.BytecodeGeneration
+{
+ public class BytecodeGenerationTests
+ {
+ [Fact]
+ public void g_V_OutXcreatedX()
+ {
+ var g = new Graph().Traversal();
+
+ var bytecode = g.V().Out("created").Bytecode;
+
+ Assert.Equal(0, bytecode.SourceInstructions.Count);
+ Assert.Equal(2, bytecode.StepInstructions.Count);
+ Assert.Equal("V", bytecode.StepInstructions[0].OperatorName);
+ Assert.Equal("out", bytecode.StepInstructions[1].OperatorName);
+ Assert.Equal("created", bytecode.StepInstructions[1].Arguments[0]);
+ Assert.Equal(1, bytecode.StepInstructions[1].Arguments.Length);
+ }
+
+ [Fact]
+ public void g_WithSackX1X_E_GroupCount_ByXweightX()
+ {
+ var g = new Graph().Traversal();
+
+ var bytecode = g.WithSack(1).E().GroupCount().By("weight").Bytecode;
+
+ Assert.Equal(1, bytecode.SourceInstructions.Count);
+ Assert.Equal("withSack", bytecode.SourceInstructions[0].OperatorName);
+ Assert.Equal(1, bytecode.SourceInstructions[0].Arguments[0]);
+ Assert.Equal(3, bytecode.StepInstructions.Count);
+ Assert.Equal("E", bytecode.StepInstructions[0].OperatorName);
+ Assert.Equal("groupCount", bytecode.StepInstructions[1].OperatorName);
+ Assert.Equal("by", bytecode.StepInstructions[2].OperatorName);
+ Assert.Equal("weight", bytecode.StepInstructions[2].Arguments[0]);
+ Assert.Equal(0, bytecode.StepInstructions[0].Arguments.Length);
+ Assert.Equal(0, bytecode.StepInstructions[1].Arguments.Length);
+ Assert.Equal(1, bytecode.StepInstructions[2].Arguments.Length);
+ }
+
+ [Fact]
+ public void AnonymousTraversal_Start_EmptyBytecode()
+ {
+ var bytecode = __.Start().Bytecode;
+
+ Assert.Equal(0, bytecode.SourceInstructions.Count);
+ Assert.Equal(0, bytecode.StepInstructions.Count);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/BytecodeGeneration/StrategiesTests.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/BytecodeGeneration/StrategiesTests.cs b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/BytecodeGeneration/StrategiesTests.cs
new file mode 100644
index 0000000..6afda71
--- /dev/null
+++ b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/BytecodeGeneration/StrategiesTests.cs
@@ -0,0 +1,170 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System.Collections.Generic;
+using Gremlin.CSharp.Process;
+using Gremlin.CSharp.Structure;
+using Gremlin.Net.Process.Traversal.Strategy.Decoration;
+using Gremlin.Net.Process.Traversal.Strategy.Finalization;
+using Gremlin.Net.Process.Traversal.Strategy.Optimization;
+using Gremlin.Net.Process.Traversal.Strategy.Verification;
+using Xunit;
+
+namespace Gremlin.CSharp.IntegrationTest.BytecodeGeneration
+{
+ public class StrategiesTests
+ {
+ [Fact]
+ public void TraversalWithoutStrategies_AfterWithStrategiesWasCalled_WithStrategiesNotAffected()
+ {
+ var graph = new Graph();
+ var g = graph.Traversal().WithStrategies(new ReadOnlyStrategy(), new IncidentToAdjacentStrategy());
+
+ var bytecode = g.WithoutStrategies(new ReadOnlyStrategy()).Bytecode;
+
+ Assert.Equal(2, bytecode.SourceInstructions.Count);
+ Assert.Equal("withStrategies", bytecode.SourceInstructions[0].OperatorName);
+ Assert.Equal(2, bytecode.SourceInstructions[0].Arguments.Length);
+ Assert.Equal(new ReadOnlyStrategy(), bytecode.SourceInstructions[0].Arguments[0]);
+ Assert.Equal(new IncidentToAdjacentStrategy(), bytecode.SourceInstructions[0].Arguments[1]);
+
+ Assert.Equal("withoutStrategies", bytecode.SourceInstructions[1].OperatorName);
+ Assert.Equal(1, bytecode.SourceInstructions[1].Arguments.Length);
+ Assert.Equal(new ReadOnlyStrategy(), bytecode.SourceInstructions[1].Arguments[0]);
+ }
+
+ [Fact]
+ public void ShouldIncludeMultipleStrategiesInBytecodeWhenGivenToWithoutStrategies()
+ {
+ var graph = new Graph();
+ var g = graph.Traversal();
+
+ var bytecode = g.WithoutStrategies(new ReadOnlyStrategy(), new LazyBarrierStrategy()).Bytecode;
+
+ Assert.Equal(1, bytecode.SourceInstructions.Count);
+ Assert.Equal(2, bytecode.SourceInstructions[0].Arguments.Length);
+ Assert.Equal("withoutStrategies", bytecode.SourceInstructions[0].OperatorName);
+ Assert.Equal(new ReadOnlyStrategy(), bytecode.SourceInstructions[0].Arguments[0]);
+ Assert.Equal(new LazyBarrierStrategy(), bytecode.SourceInstructions[0].Arguments[1]);
+ }
+
+ [Fact]
+ public void ShouldIncludeOneStrategyInBytecodeWhenGivenToWithoutStrategies()
+ {
+ var graph = new Graph();
+ var g = graph.Traversal();
+
+ var bytecode = g.WithoutStrategies(new ReadOnlyStrategy()).Bytecode;
+
+ Assert.Equal(1, bytecode.SourceInstructions.Count);
+ Assert.Equal(1, bytecode.SourceInstructions[0].Arguments.Length);
+ Assert.Equal("withoutStrategies", bytecode.SourceInstructions[0].OperatorName);
+ Assert.Equal(new ReadOnlyStrategy(), bytecode.SourceInstructions[0].Arguments[0]);
+ }
+
+ [Fact]
+ public void ShouldIncludeConfigurationInBytecodeWhenGivenToWithStrategies()
+ {
+ var graph = new Graph();
+ var g = graph.Traversal();
+
+ var bytecode = g.WithStrategies(new MatchAlgorithmStrategy("greedy")).Bytecode;
+
+ Assert.Equal(1, bytecode.SourceInstructions.Count);
+ Assert.Equal(1, bytecode.SourceInstructions[0].Arguments.Length);
+ Assert.Equal("withStrategies", bytecode.SourceInstructions[0].OperatorName);
+ Assert.Equal(new MatchAlgorithmStrategy(), bytecode.SourceInstructions[0].Arguments[0]);
+ Assert.Contains("greedy",
+ ((MatchAlgorithmStrategy) bytecode.SourceInstructions[0].Arguments[0]).Configuration.Values);
+ }
+
+ [Fact]
+ public void ShouldIncludeMultipleStrategiesInBytecodeWhenGivenToWithStrategies()
+ {
+ var graph = new Graph();
+ var g = graph.Traversal();
+
+ var bytecode = g.WithStrategies(new ReadOnlyStrategy(), new IncidentToAdjacentStrategy()).Bytecode;
+
+ Assert.Equal(1, bytecode.SourceInstructions.Count);
+ Assert.Equal(2, bytecode.SourceInstructions[0].Arguments.Length);
+ Assert.Equal("withStrategies", bytecode.SourceInstructions[0].OperatorName);
+ Assert.Equal(new ReadOnlyStrategy(), bytecode.SourceInstructions[0].Arguments[0]);
+ Assert.Equal(new IncidentToAdjacentStrategy(), bytecode.SourceInstructions[0].Arguments[1]);
+ }
+
+ [Fact]
+ public void ShouldIncludeOneStrategyInBytecodeWhenGivenToWithStrategies()
+ {
+ var graph = new Graph();
+ var g = graph.Traversal();
+
+ var bytecode = g.WithStrategies(new ReadOnlyStrategy()).Bytecode;
+
+ Assert.Equal(1, bytecode.SourceInstructions.Count);
+ Assert.Equal(1, bytecode.SourceInstructions[0].Arguments.Length);
+ Assert.Equal("withStrategies", bytecode.SourceInstructions[0].OperatorName);
+ Assert.Equal(new ReadOnlyStrategy(), bytecode.SourceInstructions[0].Arguments[0]);
+ Assert.Equal("ReadOnlyStrategy", bytecode.SourceInstructions[0].Arguments[0].ToString());
+ Assert.Equal(new ReadOnlyStrategy().GetHashCode(), bytecode.SourceInstructions[0].Arguments[0].GetHashCode());
+ Assert.Equal(0, g.TraversalStrategies.Count);
+ }
+
+ [Fact]
+ public void TraversalWithStrategies_Strategies_ApplyToReusedGraphTraversalSource()
+ {
+ var graph = new Graph();
+ var g = graph.Traversal().WithStrategies(new ReadOnlyStrategy(), new IncidentToAdjacentStrategy());
+
+ var bytecode = g.V().Bytecode;
+
+ Assert.Equal(1, bytecode.SourceInstructions.Count);
+ Assert.Equal(2, bytecode.SourceInstructions[0].Arguments.Length);
+ Assert.Equal("withStrategies", bytecode.SourceInstructions[0].OperatorName);
+ Assert.Equal(new ReadOnlyStrategy(), bytecode.SourceInstructions[0].Arguments[0]);
+ Assert.Equal(new IncidentToAdjacentStrategy(), bytecode.SourceInstructions[0].Arguments[1]);
+ Assert.Equal(1, bytecode.StepInstructions.Count);
+ Assert.Equal("V", bytecode.StepInstructions[0].OperatorName);
+ }
+
+ [Fact]
+ public void TraversalWithStrategies_StrategyWithTraversalInConfig_IncludeTraversalInInConfigInBytecode()
+ {
+ var graph = new Graph();
+ var g = graph.Traversal();
+
+ var bytecode = g.WithStrategies(new SubgraphStrategy(__.Has("name", "marko"))).Bytecode;
+
+ Assert.Equal(1, bytecode.SourceInstructions.Count);
+ Assert.Equal(1, bytecode.SourceInstructions[0].Arguments.Length);
+ Assert.Equal("withStrategies", bytecode.SourceInstructions[0].OperatorName);
+ Assert.Equal(new SubgraphStrategy(), bytecode.SourceInstructions[0].Arguments[0]);
+ SubgraphStrategy strategy = bytecode.SourceInstructions[0].Arguments[0];
+ Assert.Equal(1, strategy.Configuration.Count);
+ Assert.Equal(typeof(GraphTraversal), strategy.Configuration["vertices"].GetType());
+ GraphTraversal traversal = strategy.Configuration["vertices"];
+ Assert.Equal("has", traversal.Bytecode.StepInstructions[0].OperatorName);
+ Assert.Equal(new List<string> {"name", "marko"}, traversal.Bytecode.StepInstructions[0].Arguments);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/ConfigProvider.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/ConfigProvider.cs b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/ConfigProvider.cs
new file mode 100644
index 0000000..27e7009
--- /dev/null
+++ b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/ConfigProvider.cs
@@ -0,0 +1,47 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System.IO;
+using Microsoft.Extensions.Configuration;
+
+namespace Gremlin.CSharp.IntegrationTest
+{
+ public static class ConfigProvider
+ {
+ static ConfigProvider()
+ {
+ Configuration = GetConfig();
+ }
+
+ public static IConfiguration Configuration { get; }
+
+ private static IConfiguration GetConfig()
+ {
+ var configFile = Path.Combine(Directory.GetCurrentDirectory(), "appsettings.json");
+ var builder = new ConfigurationBuilder()
+ .AddJsonFile(configFile, false, false);
+
+ return builder.Build();
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/EnumTests.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/EnumTests.cs b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/EnumTests.cs
new file mode 100644
index 0000000..a49a09d
--- /dev/null
+++ b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/EnumTests.cs
@@ -0,0 +1,59 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System.Collections.Generic;
+using Gremlin.CSharp.Process;
+using Gremlin.CSharp.Structure;
+using Xunit;
+
+namespace Gremlin.CSharp.IntegrationTest.DriverRemoteConnection
+{
+ public class EnumTests
+ {
+ private readonly RemoteConnectionFactory _connectionFactory = new RemoteConnectionFactory();
+
+ [Fact]
+ public void ShouldUseOrderDecrInByStep()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var orderedAges = g.V().Values("age").Order().By(Order.decr).ToList();
+
+ Assert.Equal(new List<object> {35, 32, 29, 27}, orderedAges);
+ }
+
+ [Fact]
+ public void ShouldUseTLabelInHasStep()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var personsCount = g.V().Has(T.label, "person").Count().Next();
+
+ Assert.Equal((long) 4, personsCount);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/GraphTraversalSourceTests.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/GraphTraversalSourceTests.cs b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/GraphTraversalSourceTests.cs
new file mode 100644
index 0000000..f8c12e2
--- /dev/null
+++ b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/GraphTraversalSourceTests.cs
@@ -0,0 +1,55 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System.Collections.Generic;
+using Gremlin.CSharp.Process;
+using Gremlin.CSharp.Structure;
+using Xunit;
+
+namespace Gremlin.CSharp.IntegrationTest.DriverRemoteConnection
+{
+ public class GraphTraversalSourceTests
+ {
+ private readonly RemoteConnectionFactory _connectionFactory = new RemoteConnectionFactory();
+
+ [Fact]
+ public void ShouldUseSideEffectSpecifiedInWithSideEffect()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var results = g.WithSideEffect("a", new List<string> {"josh", "peter"})
+ .V(1)
+ .Out("created")
+ .In("created")
+ .Values("name")
+ .Where(P.Within("a"))
+ .ToList();
+
+ Assert.Equal(2, results.Count);
+ Assert.Contains("josh", results);
+ Assert.Contains("peter", results);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/GraphTraversalTests.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/GraphTraversalTests.cs b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/GraphTraversalTests.cs
new file mode 100644
index 0000000..91a41ba
--- /dev/null
+++ b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/GraphTraversalTests.cs
@@ -0,0 +1,171 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Gremlin.CSharp.Process;
+using Gremlin.CSharp.Structure;
+using Gremlin.Net.Process.Traversal;
+using Gremlin.Net.Structure;
+using Xunit;
+
+namespace Gremlin.CSharp.IntegrationTest.DriverRemoteConnection
+{
+ public class GraphTraversalTests
+ {
+ private readonly RemoteConnectionFactory _connectionFactory = new RemoteConnectionFactory();
+
+ [Fact]
+ public void g_V_Count()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var count = g.V().Count().Next();
+
+ Assert.Equal((long) 6, count);
+ }
+
+ [Fact]
+ public void g_VX1X_Next()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var vertex = (Vertex) g.V(1).Next();
+
+ Assert.Equal(new Vertex((long) 1), vertex);
+ Assert.Equal((long) 1, vertex.Id);
+ }
+
+ [Fact]
+ public void g_VX1X_NextTraverser()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var traverser = g.V(1).NextTraverser();
+
+ Assert.Equal(new Traverser(new Vertex((long)1)), traverser);
+ }
+
+ [Fact]
+ public void g_VX1X_ToList()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var list = g.V(1).ToList();
+
+ Assert.Equal(1, list.Count);
+ }
+
+ [Fact]
+ public void g_V_RepeatXBothX_TimesX5X_NextX10X()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var result = g.V().Repeat(__.Both()).Times(5).Next(10);
+
+ Assert.Equal(10, result.Count());
+ }
+
+ [Fact]
+ public void g_V_HasXname_markoX_ValueMap_Next()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var receivedValueMap = g.V().Has("name", "marko").ValueMap().Next();
+
+ var expectedValueMap = new Dictionary<string, dynamic>
+ {
+ {"age", new List<object> {29}},
+ {"name", new List<object> {"marko"}}
+ };
+ Assert.Equal(expectedValueMap, receivedValueMap);
+ }
+
+ [Fact]
+ public void g_V_RepeatXOutX_TimesX2X_ValuesXNameX()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var t = g.V().Repeat(__.Out()).Times(2).Values("name");
+ var names = t.ToList();
+
+ Assert.Equal((long) 2, names.Count);
+ Assert.Contains("lop", names);
+ Assert.Contains("ripple", names);
+ }
+
+ [Fact]
+ public void ShortestPathTest()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var shortestPath =
+ (Path) g.V(5).Repeat(__.Both().SimplePath()).Until(__.HasId(6)).Limit(1).Path().Next();
+
+ Assert.Equal((long) 4, shortestPath.Count);
+ Assert.Equal(new Vertex((long) 6), shortestPath[3]);
+ }
+
+ [Fact]
+ public void ShouldUseBindingsInTraversal()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var b = new Bindings();
+ var count = g.V().Has(b.Of("propertyKey", "name"), b.Of("propertyValue", "marko")).OutE().Count().Next();
+
+ Assert.Equal((long) 3, count);
+ }
+
+ [Fact]
+ public async Task ShouldExecuteAsynchronouslyWhenPromiseIsCalled()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var count = await g.V().Count().Promise(t => t.Next());
+
+ Assert.Equal((long) 6, count);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/PredicateTests.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/PredicateTests.cs b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/PredicateTests.cs
new file mode 100644
index 0000000..8dffa43
--- /dev/null
+++ b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/PredicateTests.cs
@@ -0,0 +1,58 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using Gremlin.CSharp.Process;
+using Gremlin.CSharp.Structure;
+using Xunit;
+
+namespace Gremlin.CSharp.IntegrationTest.DriverRemoteConnection
+{
+ public class PredicateTests
+ {
+ private readonly RemoteConnectionFactory _connectionFactory = new RemoteConnectionFactory();
+
+ [Fact]
+ public void ShouldUsePredicatesCombinedWithPAndInHasStep()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var count = g.V().Has("age", P.Gt(30).And(P.Lt(35))).Count().Next();
+
+ Assert.Equal((long) 1, count);
+ }
+
+ [Fact]
+ public void ShouldUsePWithinInHasStep()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var count = g.V().Has("name", P.Within("josh", "vadas")).Count().Next();
+
+ Assert.Equal((long) 2, count);
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/RemoteConnectionFactory.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/RemoteConnectionFactory.cs b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/RemoteConnectionFactory.cs
new file mode 100644
index 0000000..53b6e50
--- /dev/null
+++ b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/RemoteConnectionFactory.cs
@@ -0,0 +1,41 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System;
+using Gremlin.Net.Driver;
+using Gremlin.Net.Process.Remote;
+
+namespace Gremlin.CSharp.IntegrationTest.DriverRemoteConnection
+{
+ internal class RemoteConnectionFactory
+ {
+ private static readonly string TestHost = ConfigProvider.Configuration["TestServerIpAddress"];
+ private static readonly int TestPort = Convert.ToInt32(ConfigProvider.Configuration["TestServerPort"]);
+
+ public IRemoteConnection CreateRemoteConnection()
+ {
+ return new Net.Driver.Remote.DriverRemoteConnection(
+ new GremlinClient(new GremlinServer(TestHost, TestPort)));
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/SideEffectTests.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/SideEffectTests.cs b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/SideEffectTests.cs
new file mode 100644
index 0000000..8051167
--- /dev/null
+++ b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/SideEffectTests.cs
@@ -0,0 +1,221 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Gremlin.CSharp.Structure;
+using Xunit;
+
+namespace Gremlin.CSharp.IntegrationTest.DriverRemoteConnection
+{
+ public class SideEffectTests
+ {
+ private readonly RemoteConnectionFactory _connectionFactory = new RemoteConnectionFactory();
+
+ [Fact]
+ public void ShouldReturnCachedSideEffectWhenGetIsCalledAfterClose()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+ var t = g.V().Aggregate("a").Iterate();
+
+ t.SideEffects.Get("a");
+ t.SideEffects.Close();
+ var results = t.SideEffects.Get("a");
+
+ Assert.NotNull(results);
+ }
+
+ [Fact]
+ public void ShouldThrowWhenGetIsCalledAfterCloseAndNoSideEffectsAreCachec()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+ var t = g.V().Aggregate("a").Iterate();
+
+ t.SideEffects.Close();
+ Assert.Throws<InvalidOperationException>(() => t.SideEffects.Get("a"));
+ }
+
+ [Fact]
+ public void ShouldThrowWhenGetIsCalledAfterDisposeAndNoSideEffectsAreCachec()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+ var t = g.V().Aggregate("a").Iterate();
+
+ t.SideEffects.Dispose();
+ Assert.Throws<InvalidOperationException>(() => t.SideEffects.Get("a"));
+ }
+
+ [Fact]
+ public void ShouldReturnSideEffectValueWhenGetIsCalledForGroupCountTraversal()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+ var t = g.V().Out("created").GroupCount("m").By("name").Iterate();
+ t.SideEffects.Keys();
+
+ var m = t.SideEffects.Get("m") as Dictionary<string, dynamic>;
+
+ Assert.Equal(2, m.Count);
+ Assert.Equal((long) 3, m["lop"]);
+ Assert.Equal((long) 1, m["ripple"]);
+ }
+
+ [Fact]
+ public void ShouldReturnSideEffectValueWhenGetIsCalledOnATraversalWithSideEffect()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+ var t = g.WithSideEffect("a", new List<string> {"first", "second"}).V().Iterate();
+ t.SideEffects.Keys();
+
+ var a = t.SideEffects.Get("a") as List<object>;
+
+ Assert.Equal(2, a.Count);
+ Assert.Equal("first", a[0]);
+ Assert.Equal("second", a[1]);
+ }
+
+ [Fact]
+ public void ShouldThrowWhenGetIsCalledWithAnUnknownKey()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+ var t = g.V().Iterate();
+
+ Assert.Throws<KeyNotFoundException>(() => t.SideEffects.Get("m"));
+ }
+
+ [Fact]
+ public void ShouldReturnBothSideEffectForTraversalWithTwoSideEffects_()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var t = g.V().Out("created").GroupCount("m").By("name").Values("name").Aggregate("n").Iterate();
+
+ var keys = t.SideEffects.Keys().ToList();
+ Assert.Equal(2, keys.Count);
+ Assert.Contains("m", keys);
+ Assert.Contains("n", keys);
+ var n = (Dictionary<object, long>) t.SideEffects.Get("n");
+ Assert.Equal(2, n.Count);
+ Assert.Equal(3, n["lop"]);
+ Assert.Equal(1, n["ripple"]);
+ }
+
+ [Fact]
+ public void ShouldReturnAnEmptyCollectionWhenKeysIsCalledForTraversalWithoutSideEffect()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var t = g.V().Iterate();
+ var keys = t.SideEffects.Keys();
+
+ Assert.Equal(0, keys.Count);
+ }
+
+ [Fact]
+ public void ShouldReturnCachedKeysWhenForCloseAfterSomeGet()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+ var t = g.V().Aggregate("a").Aggregate("b").Iterate();
+
+ t.SideEffects.Get("a");
+ t.SideEffects.Close();
+ var keys = t.SideEffects.Keys();
+
+ Assert.Equal(2, keys.Count);
+ Assert.Contains("a", keys);
+ Assert.Contains("b", keys);
+ }
+
+ [Fact]
+ public void ShouldReturnSideEffectKeyWhenKeysIsCalledForNamedGroupCount()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+ var t = g.V().Out("created").GroupCount("m").By("name").Iterate();
+
+ var keys = t.SideEffects.Keys();
+
+ var keysList = keys.ToList();
+ Assert.Equal(1, keysList.Count);
+ Assert.Contains("m", keysList);
+ }
+
+ [Fact]
+ public async Task ShouldReturnSideEffectsKeysWhenKeysIsCalledOnTraversalThatExecutedAsynchronously()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var t = await g.V().Aggregate("a").Promise(x => x);
+ var keys = t.SideEffects.Keys();
+
+ Assert.Equal(1, keys.Count);
+ Assert.Contains("a", keys);
+ }
+
+ [Fact]
+ public async Task ShouldReturnSideEffectValueWhenGetIsCalledOnTraversalThatExecutedAsynchronously()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var t = await g.V().Aggregate("a").Promise(x => x);
+ var value = t.SideEffects.Get("a");
+
+ Assert.NotNull(value);
+ }
+
+ [Fact]
+ public async Task ShouldNotThrowWhenCloseIsCalledOnTraversalThatExecutedAsynchronously()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection);
+
+ var t = await g.V().Aggregate("a").Promise(x => x);
+ t.SideEffects.Close();
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/StrategiesTests.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/StrategiesTests.cs b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/StrategiesTests.cs
new file mode 100644
index 0000000..59e2092
--- /dev/null
+++ b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/DriverRemoteConnection/StrategiesTests.cs
@@ -0,0 +1,193 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using System.Threading.Tasks;
+using Gremlin.CSharp.Process;
+using Gremlin.CSharp.Structure;
+using Gremlin.Net.Driver.Exceptions;
+using Gremlin.Net.Process.Traversal.Strategy.Decoration;
+using Gremlin.Net.Process.Traversal.Strategy.Verification;
+using Xunit;
+
+namespace Gremlin.CSharp.IntegrationTest.DriverRemoteConnection
+{
+ public class StrategiesTests
+ {
+ private readonly RemoteConnectionFactory _connectionFactory = new RemoteConnectionFactory();
+
+ [Fact]
+ public void g_V_Count_Next_WithVertexLabelSubgraphStrategy()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g =
+ graph.Traversal()
+ .WithRemote(connection)
+ .WithStrategies(new SubgraphStrategy(vertexCriterion: __.HasLabel("person")));
+
+ var count = g.V().Count().Next();
+
+ Assert.Equal((long) 4, count);
+ }
+
+ [Fact]
+ public void g_E_Count_Next_WithVertexAndEdgeLabelSubgraphStrategy()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g =
+ graph.Traversal()
+ .WithRemote(connection)
+ .WithStrategies(new SubgraphStrategy(vertexCriterion: __.HasLabel("person"),
+ edgeCriterion: __.HasLabel("created")));
+
+ var count = g.E().Count().Next();
+
+ Assert.Equal((long)0, count);
+ }
+
+ [Fact]
+ public void g_V_Label_Dedup_Count_Next_WithVertexLabelSubgraphStrategy()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g =
+ graph.Traversal()
+ .WithRemote(connection)
+ .WithStrategies(new SubgraphStrategy(vertexCriterion: __.HasLabel("person")));
+
+ var count = g.V().Label().Dedup().Count().Next();
+
+ Assert.Equal((long)1, count);
+ }
+
+ [Fact]
+ public void g_V_Label_Dedup_Next_WWithVertexLabelSubgraphStrategy()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g =
+ graph.Traversal()
+ .WithRemote(connection)
+ .WithStrategies(new SubgraphStrategy(vertexCriterion: __.HasLabel("person")));
+
+ var label = g.V().Label().Dedup().Next();
+
+ Assert.Equal("person", label);
+ }
+
+ [Fact]
+ public void g_V_Count_Next_WithVertexHasPropertySubgraphStrategy()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g =
+ graph.Traversal()
+ .WithRemote(connection)
+ .WithStrategies(new SubgraphStrategy(vertexCriterion: __.Has("name", "marko")));
+
+ var count = g.V().Count().Next();
+
+ Assert.Equal((long)1, count);
+ }
+
+ [Fact]
+ public void g_E_Count_Next_WithEdgeLimitSubgraphStrategy()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g =
+ graph.Traversal()
+ .WithRemote(connection)
+ .WithStrategies(new SubgraphStrategy(edgeCriterion: __.Limit(0)));
+
+ var count = g.E().Count().Next();
+
+ Assert.Equal((long)0, count);
+ }
+
+ [Fact]
+ public void g_V_Label_Dedup_Next_WithVertexHasPropertySubgraphStrategy()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g =
+ graph.Traversal()
+ .WithRemote(connection)
+ .WithStrategies(new SubgraphStrategy(vertexCriterion: __.Has("name", "marko")));
+
+ var label = g.V().Label().Dedup().Next();
+
+ Assert.Equal("person", label);
+ }
+
+ [Fact]
+ public void g_V_ValuesXnameX_Next_WithVertexHasPropertySubgraphStrategy()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g =
+ graph.Traversal()
+ .WithRemote(connection)
+ .WithStrategies(new SubgraphStrategy(vertexCriterion: __.Has("name", "marko")));
+
+ var name = g.V().Values("name").Next();
+
+ Assert.Equal("marko", name);
+ }
+
+ [Fact]
+ public void g_V_Count_Next_WithComputer()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection).WithComputer();
+
+ var count = g.V().Count().Next();
+
+ Assert.Equal((long)6, count);
+ }
+
+ [Fact]
+ public void g_E_Count_Next_WithComputer()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection).WithComputer();
+
+ var count = g.E().Count().Next();
+
+ Assert.Equal((long)6, count);
+ }
+
+ [Fact]
+ public async Task ShouldThrowWhenModifyingTraversalSourceWithReadOnlyStrategy()
+ {
+ var graph = new Graph();
+ var connection = _connectionFactory.CreateRemoteConnection();
+ var g = graph.Traversal().WithRemote(connection).WithStrategies(new ReadOnlyStrategy());
+
+ await Assert.ThrowsAsync<ResponseException>(async () => await g.AddV("person").Promise(t => t.Next()));
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/GraphSONWriterTests.cs
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/GraphSONWriterTests.cs b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/GraphSONWriterTests.cs
new file mode 100644
index 0000000..99a1b65
--- /dev/null
+++ b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/GraphSONWriterTests.cs
@@ -0,0 +1,50 @@
+#region License
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.
+ */
+
+#endregion
+
+using Gremlin.CSharp.Process;
+using Gremlin.Net.Structure.IO.GraphSON;
+using Xunit;
+
+namespace Gremlin.CSharp.IntegrationTest
+{
+ public class GraphSONWriterTests
+ {
+ [Fact]
+ public void ShouldSerializeLongPredicateCorrectly()
+ {
+ var writer = CreateStandardGraphSONWriter();
+ var predicate = P.Lt("b").Or(P.Gt("c")).And(P.Neq("d"));
+
+ var graphSon = writer.WriteObject(predicate);
+
+ const string expected =
+ "{\"@type\":\"g:P\",\"@value\":{\"predicate\":\"and\",\"value\":[{\"@type\":\"g:P\",\"@value\":{\"predicate\":\"or\",\"value\":[{\"@type\":\"g:P\",\"@value\":{\"predicate\":\"lt\",\"value\":\"b\"}},{\"@type\":\"g:P\",\"@value\":{\"predicate\":\"gt\",\"value\":\"c\"}}]}},{\"@type\":\"g:P\",\"@value\":{\"predicate\":\"neq\",\"value\":\"d\"}}]}}";
+ Assert.Equal(expected, graphSon);
+ }
+
+ private GraphSONWriter CreateStandardGraphSONWriter()
+ {
+ return new GraphSONWriter();
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/792fca27/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/Gremlin.CSharp.IntegrationTest.csproj
----------------------------------------------------------------------
diff --git a/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/Gremlin.CSharp.IntegrationTest.csproj b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/Gremlin.CSharp.IntegrationTest.csproj
new file mode 100644
index 0000000..1e7a7d2
--- /dev/null
+++ b/gremlin-dotnet/test/Gremlin.CSharp.IntegrationTest/Gremlin.CSharp.IntegrationTest.csproj
@@ -0,0 +1,38 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+ <PropertyGroup>
+ <TargetFramework>netcoreapp1.0</TargetFramework>
+ <AssemblyName>Gremlin.CSharp.IntegrationTest</AssemblyName>
+ <PackageId>Gremlin.CSharp.IntegrationTest</PackageId>
+ <GenerateRuntimeConfigurationFiles>true</GenerateRuntimeConfigurationFiles>
+ <RuntimeFrameworkVersion>1.0.4</RuntimeFrameworkVersion>
+ <GenerateAssemblyConfigurationAttribute>false</GenerateAssemblyConfigurationAttribute>
+ <GenerateAssemblyCompanyAttribute>false</GenerateAssemblyCompanyAttribute>
+ <GenerateAssemblyProductAttribute>false</GenerateAssemblyProductAttribute>
+ </PropertyGroup>
+
+ <ItemGroup>
+ <ProjectReference Include="..\..\src\Gremlin.CSharp\Gremlin.CSharp.csproj" />
+ <ProjectReference Include="..\..\src\Gremlin.Net.Process\Gremlin.Net.Process.csproj" />
+ <ProjectReference Include="..\..\src\Gremlin.Net\Gremlin.Net.csproj" />
+ </ItemGroup>
+
+ <ItemGroup>
+ <PackageReference Include="Microsoft.NET.Test.Sdk" Version="15.0.0" />
+ <PackageReference Include="xunit.runner.visualstudio" Version="2.2.0" />
+ <PackageReference Include="xunit" Version="2.2.0" />
+ <PackageReference Include="Microsoft.Extensions.Configuration" Version="1.1.1" />
+ <PackageReference Include="Microsoft.Extensions.Configuration.Json" Version="1.1.1" />
+ </ItemGroup>
+
+ <ItemGroup>
+ <Service Include="{82a7f48d-3b50-4b1e-b82e-3ada8210c358}" />
+ </ItemGroup>
+
+ <ItemGroup>
+ <None Update="appsettings.json">
+ <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+ </None>
+ </ItemGroup>
+
+</Project>