cypher.go

package neo4j

import "encoding/json"

// Cypher struct
type Cypher struct {
	Query   map[string]string
	Payload interface{}
}

// CypherResponse struct for the Neo4J cyhpher query response
type CypherResponse struct {
	Columns map[string]interface{} `json:"columns"`
	Data    map[string]interface{} `json:"data"`
}

func (c *Cypher) mapBatchResponse(neo4j *Neo4j, data interface{}) (bool, error) {
	encodedData, err := jsonEncode(data)
	err = c.decodeResponse(encodedData)
	if err != nil {
		return false, err
	}

	return true, nil
}

func (c *Cypher) getBatchQuery(operation string) (map[string]interface{}, error) {
	return map[string]interface{}{
		"method": "POST",
		"to":     "/cypher",
		"body":   c.Query,
	}, nil
}

func (c *Cypher) decodeResponse(data string) error {
	resp := map[string]interface{}{}

	err := json.Unmarshal([]byte(data), &resp)
	if err != nil {
		return err
	}

	jsonizedData, err := json.Marshal(resp)
	if err != nil {
		return err
	}

	err = json.Unmarshal(jsonizedData, &c.Payload)
	if err != nil {
		return err
	}

	return nil
}