cypher.go

package cypher

import (
	"errors"
	"strings"
)

/**
 * create a new Node representation with at least one label, the "primary" label. This is required. All other labels
 * are optional.
 *
 * @param primaryLabel     The primary label this node is identified by.
 * @param additionalLabels Additional labels
 * @return A new node representation
 */
func NewNodeWithLabels(accountId string, additionalLabel ...string) Node {
	primaryLabel, err := AccountIdToLabel(accountId)
	if err != nil {
		return NodeError(err)
	}
	var labels = make([]NodeLabel, 0)
	labels = append(labels, NodeLabel{value: primaryLabel})
	for _, label := range additionalLabel {
		labels = append(labels, NodeLabel{value: label})
	}
	node := Node{
		accountId: accountId,
		labels: labels,
		notNil: true,
		properties: PropertiesCreate(NewMapExpression()),
	}
	node.injectKey()

	return node
}

/**
 * create a new Node representation with at least one label, the "primary" label. This is required. All other labels
 * are optional. This method also takes a map of properties. This allows the returned node object to be used In a
 * {@code MATCH} or {@code MERGE} statement.
 *
 * @param primaryLabel     The primary label this node is identified by.
 * @param properties       The properties expected to exist on the node.
 * @param additionalLabels Additional labels
 * @return A new node representation
 */
func NewNodeWithProperties(primaryLabel string, properties MapExpression, additionalLabel ...string) Node {
	return NodeCreate5(primaryLabel, properties, additionalLabel...)
}

/**
 * @param symbolicName The new symbolic name
 * @return A node matching any node with the symbolic the given {@code symbolicName}.
 */
func ANode(primaryLabel string) Node {
	return NodeCreate2(primaryLabel)
}

func ANodeWithLabelWithoutAccountId(additionalLabel ...string) Node {
	for _, label := range additionalLabel {
		if label == "" {
			return NodeError(errors.New("empty label is not allowed"))
		}
	}
	var labels = make([]NodeLabel, 0)
	for _, label := range additionalLabel {
		labels = append(labels, NodeLabelCreate(label))
	}
	node := Node{
		labels: labels,
		properties: PropertiesCreate(NewMapExpression()),
	}
	node.injectKey()
	return node
}

/**
 * @return A node matching any node.
 */
func AnyNode(primaryLabel string) Node {
	return NodeCreate(primaryLabel)
}

func AnyNodeNamed(primaryLabel string, name string) Node {
	return NodeCreate(primaryLabel).NamedByString(name)
}

/**
 * @return The {@code *} wildcard literal.
 */
func AnAsterisk() Asterisk {
	return ASTERISK
}

/**
 * Dereferences a property for a symbolic name, most likely pointing to a property container like a node or a relationship.
 *
 * @param containerName The symbolic name of a property container
 * @param name          The name of the property to dereference
 * @return A new property
 */
func AProperty(containerName string, name string) Property {
	return APropertyByExpression(ASymbolic(containerName), name)
}

/**
 * Dereferences a property on a arbitrary expression.
 *
 * @param expression The expression that describes some sort of accessible map
 * @param name       The name of the property to dereference
 * @return A new property.
 */
func APropertyByExpression(expression Expression, name string) Property {
	return PropertyCreate2(expression, name)
}

/**
 * Starts defining a named path by indicating a name.
 *
 * @param name The name of the new path
 * @return An ongoing definition of a named path
 * @since 1.1
 */
func APath(name string) OngoingDefinitionWithName {
	return NamedPathBuilderWithNameByString(name)
}

/**
 * Starts defining a named path by indicating a name.
 *
 * @param name The name of the new path
 * @return An ongoing definition of a named path
 * @since 1.1
 */
func APathBySymbolic(name SymbolicName) OngoingDefinitionWithName {
	return NamedPathBuilderWithName(name)
}

/**
 * Starts defining a named path defined by the {@code shortestPath} between a relationship by indicating a name.
 *
 * @param name The name of the new shortestPath path
 * @return An ongoing definition of a named path
 * @since 1.1.1
 */
func AShortestPath(name string) OngoingShortestPathDefinitionWithName {
	return NamedPathShortestPathWithNameByString(name, SHORTEST_PATH)
}

/**
 * Starts defining a named path defined by the {@code shortestPath} between a relationship by indicating a name.
 *
 * @param name The name of the new shortestPath path
 * @return An ongoing definition of a named path
 * @since 1.1.1
 */
func AShortestPathBySymbolic(name SymbolicName) OngoingShortestPathDefinitionWithName {
	return NamedPathShortestPathWithName(name, SHORTEST_PATH)
}

/**
 * Creates a new symbolic name.
 *
 * @param value The value of the symbolic name
 * @return A new symbolic name
 */
func ASymbolic(value string) SymbolicName {
	return SymbolicNameCreate(value)
}

/**
 * Creates a new parameter placeholder. Existing $-signs will be removed.
 *
 * @param name The name of the parameter, must not be null
 * @return The new parameter
 */
func AParam(name string) Parameter {
	return ParameterCreate(name)
}

/**
 * Prepares an optional MatchPhrase statement.
 *
 * @param pattern The patterns to MatchPhrase
 * @return An ongoing MatchPhrase that is used to specify an optional Where and a required return clause
 */
func AnOptionalMatch(element ...PatternElement) OngoingReadingWithoutWhere {
	return DefaultStatementBuilderCreate().OptionalMatch(element...)
}

/**
 * Starts building a statement based on a MatchPhrase clause. Use {@link Cypher#node(String, String...)} and related to
 * retrieve a node or a relationship, which both are pattern elements.
 *
 * @param pattern The patterns to MatchPhrase
 * @return An ongoing MatchPhrase that is used to specify an optional Where and a required return clause
 */
func Match(element ...PatternElement) OngoingReadingWithoutWhere {
	return DefaultStatementBuilderCreate().Match(element...)
}

/**
 * Starts building a statement based on a MatchPhrase clause. Use {@link Cypher#node(String, String...)} and related to
 * retrieve a node or a relationship, which both are pattern elements.
 *
 * @param optional A flag whether the {@code MATCH} clause includes the {@code OPTIONAL} keyword.
 * @param pattern  The patterns to MatchPhrase
 * @return An ongoing MatchPhrase that is used to specify an optional Where and a required return clause
 * @since 2020.1.3
 */
func MatchWithOption(optional bool, element ...PatternElement) OngoingReadingWithoutWhere {
	return DefaultStatementBuilderCreate().MatchDefault(optional, element...)
}

/**
 * Starts building a statement based on a {@code CREATE} clause.
 *
 * @param pattern The patterns to create
 * @param <T>     The type of the next step
 * @return An ongoing {@code CREATE} that can be used to specify {@code WITH} and {@code RETURNING} etc.
 */
func Create(patterns ...PatternElement) OngoingUpdateAndExposesSet {
	return DefaultStatementBuilderCreate().Create(patterns...)
}

/**
 * Starts a statement with a leading {@code WITH}. Those are useful for passing on lists of various type that
 * can be unwound later on etc. A leading {@code WITH} cannot be used with patterns obviously and needs its
 * arguments to have an alias.
 *
 * @param variables One ore more variables.
 * @return An ongoing with clause.
 * @since 2020.1.2
 */
func WithByString(variables ...string) OrderableOngoingReadingAndWithWithoutWhere {
	return DefaultStatementBuilderCreate().WithByString(variables...)
}

/**
 * Starts a statement with a leading {@code WITH}. Those are useful for passing on lists of various type that
 * can be unwound later on etc. A leading {@code WITH} cannot be used with patterns obviously and needs its
 * arguments to have an alias.
 *
 * @param variables One ore more variables.
 * @return An ongoing with clause.
 * @since 2020.1.2
 */
func WithByNamed(variables ...Named) OrderableOngoingReadingAndWithWithoutWhere {
	return DefaultStatementBuilderCreate().WithByNamed(variables...)
}

/**
 * Starts a statement with a leading {@code WITH}. Those are useful for passing on lists of various type that
 * can be unwound later on etc. A leading {@code WITH} cannot be used with patterns obviously and needs its
 * arguments to have an alias.
 *
 * @param expressions One ore more aliased expressions.
 * @return An ongoing with clause.
 */
func With(variables ...Expression) OrderableOngoingReadingAndWithWithoutWhere {
	return DefaultStatementBuilderCreate().With(variables...)
}

/**
 * Starts building a statement based on a {@code MERGE} clause.
 *
 * @param pattern The patterns to merge
 * @param <T>     The type of the next step
 * @return An ongoing {@code MERGE} that can be used to specify {@code WITH} and {@code RETURNING} etc.
 */
func Merge(patterns ...PatternElement) OngoingUpdateAndExposesSet {
	return DefaultStatementBuilderCreate().Merge(patterns...)
}

/**
 * Starts building a statement starting with an {@code UNWIND} clause. The expression needs to be an expression
 * evaluating to a list, otherwise the query will fail.
 *
 * @param expression The expression to UnwindPhrase
 * @return An ongoing {@code UNWIND}.
 */
func Unwind(expression Expression) OngoingUnwind {
	return DefaultStatementBuilderCreate().Unwind(expression)
}

/**
 * Starts building a statement starting with an {@code UNWIND} clause. The expressions passed will be turned into a
 * list expression
 *
 * @param expressions expressions to UnwindPhrase
 * @return a new instance of {@link StatementBuilder.OngoingUnwind}
 */
func UnwindMulti(expressions ...Expression) OngoingUnwind {
	return DefaultStatementBuilderCreate().Unwind(ListOf(expressions...))
}

/**
 * Creates a new {@link SortItem} to be used as part of an {@link Order}.
 *
 * @param expression The expression by which things should be sorted
 * @return A sort item, providing means to specify ascending or descending order
 */
func Sort(expression Expression) SortItem {
	return SortItemCreate(expression, UNDEFINED)
}

/**
 * Creates a map of expression from a list of key/value pairs.
 *
 * @param keysAndValues A list of key and values. Must be an even number, with alternating {@link String} and {@link Expression}
 * @return A new map expression.
 */
func MapOf(objects ...interface{}) MapExpression {
	return NewMapExpression(objects...)
}

/**
 * Creates a {@link ListExpression list-expression} from several expressions.
 *
 * @param expressions expressions to get combined into a list
 * @return a new instance of {@link ListExpression}
 */
func ListOf(expressions ...Expression) ListExpression {
	return ListExpressionCreate1(expressions...)
}

func ListOfRaw(elements ...interface{}) ListExpression {
	expressions := make([]Expression, len(elements))
	for index, element := range elements {
		literal := LiteralOf(element)
		if literal.GetError() != nil {
			return ListExpressionError(literal.GetError())
		}
		expressions[index] = LiteralOf(element)
	}
	return ListExpressionCreate1(expressions...)
}

func SortItemsOfRaw(elements ...string) []SortItem {
	sortItems := make([]SortItem, len(elements))
	for index, element := range elements {
		sortElements := strings.Split(element, " ")
		literal := LiteralOf(sortElements[0])
		direction := UNDEFINED
		if sortElements[1] == "ASC" {
			direction = ASC
		}else if sortElements[1] == "DESC" {
			direction = DESC
		}
		sortItems[index] = SortItemCreate(literal, direction)
	}
	return sortItems
}

/**
 * @return The {@literal true} literal.
 */
func LiteralTrue() BooleanLiteral {
	return TRUE
}

/**
 * @return The {@literal false} literal.
 */
func LiteralFalse() BooleanLiteral {
	return FALSE
}

/**
 * Creates a {@code UNION} statement from several other statements. No checks are applied for matching return types.
 *
 * @param statements the statements to union.
 * @return A union statement.
 */
func Union(statements ...Statement) Statement {
	return unionImpl(false, statements...)
}

/**
 * Creates a {@code UNION ALL} statement from several other statements. No checks are applied for matching return types.
 *
 * @param statements the statements to union.
 * @return A union statement.
 */
func UnionAll(statements ...Statement) Statement {
	return unionImpl(true, statements...)
}

/**
 * A {@literal RETURN} statement without a previous MatchPhrase.
 *
 * @param expressions The expressions to return
 * @return A buildable statement
 * @since 1.0.1
 */
func CypherReturning(expressions ...Expression) OngoingReadingAndReturn {
	return DefaultStatementBuilderCreate().Returning(expressions...)
}

/**
 * Creates a list comprehension starting with a {@link Relationship} or a {@link RelationshipChain chain of relationships}.
 *
 * @param relationshipPattern The relationship pattern on which the new list comprehension is based on.
 * @return An ongoing definition.
 * @since 2020.0.0
 */
func ListBasedOn(pattern RelationshipPattern) PatternComprehensionOngoingDefinitionWithPattern {
	return PatternComprehensionBasedOn(pattern)
}

/**
 * Creates a list comprehension starting with a {@link NamedPath named path}.
 *
 * @param namedPath The named path on which the new list comprehension is based on.
 * @return An ongoing definition.
 * @since 2020.1.1
 */
func ListBasedOnNamed(namedPath NamedPath) PatternComprehensionOngoingDefinitionWithPattern {
	return PatternComprehensionBasedOnNamePath(namedPath)
}

/**
 * Starts defining a {@link ListComprehension list comprehension}.
 *
 * @param variable The variable to which each element of the list is assigned.
 * @return An ongoing definition of a list comprehension
 * @since 1.0.1
 */
func CypherListWith(variable SymbolicName) OngoingDefinitionWithVariable {
	return ListComprehensionBuilderCreate(variable)
}

/**
 * Escapes and quotes the {@code unquotedString} for safe usage In Neo4j-Browser and Shell.
 *
 * @param unquotedString An unquoted string
 * @return A quoted string with special chars escaped.
 */
func AQuote(unquotedString string) string {
	return StringLiteralCreate(unquotedString).AsString()
}

/**
 * @return generic case expression start
 */
func GenericCaseExpression() Case {
	return GenericCaseCreate1()
}

/**
 * @param expression initial expression for the simple case statement
 * @return simple case expression start
 */
func CaseExpression(expression Expression) Case {
	return SimpleCaseCreate1(expression)
}

func ACallSimple(procedureName string) OngoingStandaloneCallWithoutArguments {
	if procedureName == "" {
		return StandaloneCallBuilderError(errors.New("the procedure name must not be nil or empty"))
	}
	return ACall(strings.Split(procedureName, "\\.")...)
}

/**
 * Starts defining a procedure call of the procedure with the given qualified name.
 *
 * @param namespaceAndProcedure The procedure name of the procedure to call.
 * @return An ongoing definition of a call
 */
func ACall(namespaceAndProcedure ...string) OngoingStandaloneCallWithoutArguments {
	return StatementCall(namespaceAndProcedure...)
}

/**
 * Starts building a statement based on one subquery.
 *
 * @param subquery The statement representing the subquery
 * @neo4j.version 4.0.0
 * @see ExposesSubqueryCall#call(Statement)
 * @since 2020.1.2
 * @return A new ongoing read without any further conditions or returns.
 */
func ACallByStatement(subquery Statement) OngoingReadingWithoutWhere {
	return DefaultStatementBuilderCreate().Call(subquery)
}

/**
 * Creates a closed range with given boundaries.
 *
 * @param targetExpression The target expression for the range
 * @param start            The inclusive start
 * @param end              The exclusive end
 * @return A range literal.
 * @since 2020.1.0
 */
func ASubList(targetExpression Expression, start int, end int) Expression {
	return SubList(targetExpression, NumberLiteralCreate1(start), NumberLiteralCreate1(end))
}

/**
 * Creates an open range starting at {@code start}.
 *
 * @param targetExpression The target expression for the range
 * @param start            The inclusive start
 * @return A range literal.
 * @since 2020.1.0
 */
func CypherSubListFrom(targetExpression Expression, start int) Expression {
	return SubListFrom(targetExpression, NumberLiteralCreate1(start))
}

/**
 * Creates an open range starting at {@code start}.
 *
 * @param targetExpression The target expression for the range
 * @param start            The inclusive start
 * @return A range literal.
 * @since 2020.1.0
 */
func ASubListFromByExpression(targetExpression Expression, start Expression) Expression {
	return SubListFrom(targetExpression, start)
}

/**
 * Creates an open range starting at {@code start}.
 *
 * @param targetExpression The target expression for the range
 * @param end              The exclusive end
 * @return A range literal.
 * @since 2020.1.0
 */
func ASubListUntil(targetExpression Expression, end int) Expression {
	return SubListUntil(targetExpression, NumberLiteralCreate1(end))
}

/**
 * Creates an open range starting at {@code start}.
 *
 * @param targetExpression The target expression for the range
 * @param end              The exclusive end
 * @return A range literal.
 * @since 2020.1.0
 */
func CypherSubListUntilByExpression(targetExpression Expression, end Expression) Expression {
	return SubListUntil(targetExpression, end)
}

/**
 * Creates a single valued range at {@code index}.
 *
 * @param targetExpression The target expression for the range
 * @param index            The index of the range
 * @return A range literal.
 * @since 2020.1.0
 */
func CypherValueAt(targetExpression Expression, index int) Expression {
	return ValueAt(targetExpression, NumberLiteralCreate1(index))
}

/**
 * Creates a single valued range at {@code index}.
 *
 * @param targetExpression The target expression for the range
 * @param index            The index of the range
 * @return A range literal.
 * @since 2020.1.0
 */
func CypherValueAtByExpression(targetExpression Expression, index Expression) Expression {
	return ValueAt(targetExpression, index)
}

func LiteralOf(object interface{}) Literal {
	//TODO: maybe we need to handle more literal type
	if object == nil {
		return NIL_INSTANCE
	}
	if stringValue, isString := object.(string); isString {
		return StringLiteralCreate(stringValue)
	}
	if intValue, isInt := object.(int); isInt {
		return NumberLiteralCreate1(intValue)
	}

	if intValue, isInt := object.(int32); isInt {
		return NumberLiteralCreate3(intValue)
	}

	if intValue, isInt := object.(int64); isInt {
		return NumberLiteralCreate(intValue)
	}

	if floatValue, isFloat := object.(float64); isFloat {
		return NumberLiteralCreate2(floatValue)
	}
	if literalSlice, isLiteralSlice := object.([]Literal); isLiteralSlice {
		return ListLiteralCreate(literalSlice)
	}
	if booleanValue, isBoolean := object.(bool); isBoolean {
		return BooleanLiteralCreate(booleanValue)
	}
	return StringLiteralError(errors.New("cypher literal of: unsupported literal type"))
}

func unionImpl(unionAll bool, statements ...Statement) Statement {
	if statements == nil || len(statements) < 2 {
		return UnionQueryError(errors.New("at least 2 statements are required"))
	}
	i := 0
	existingUnionQuery := UnionQuery{}
	if unionQuery, isUnion := statements[0].(UnionQuery); isUnion {
		existingUnionQuery = unionQuery
		if existingUnionQuery.all != unionAll {
			return UnionQueryError(errors.New("cannot mix union and union all"))
		}
		i = 1
	}
	listOfQueries := make([]SingleQuery, 0)
	for _, query := range statements[i:] {
		if singleQuery, isSingle := query.(SingleQuery); isSingle {
			listOfQueries = append(listOfQueries, singleQuery)
			continue
		}
		return UnionQueryError(errors.New("can only union single queries"))
	}
	if !existingUnionQuery.notNil {
		return UnionQueryCreate(unionAll, listOfQueries)
	} else {
		return existingUnionQuery.addAdditionalQueries(listOfQueries)
	}
}