Fixed bad usage of nodes list
Fixed bad usage of nodes list

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

import bot.*
import bot.control.*

@Grab("org.neo4j:neo4j:2.1.2")
import org.neo4j.cypher.javacompat.*
import org.neo4j.graphdb.*
import org.neo4j.graphdb.factory.*
import org.neo4j.tooling.*

/**
 * A graph database service backed by an embedded Neo4j graph db
 * @author matt
 */
public class GraphService extends Service {
    
    public static final NODE_LABEL = "node.label"
    public static final NODE_PROPS = "node.props"
    public static final NODE_ID = "node.id"
    public static final NODE_AUTOCREATE = "node.autocreate"

    public static final GRAPH_QUERY = "graph.query"

    public static final OP_RESULT = "graph.op.result"

    def config
    def database
    def exec

    def static graphComm = { comm, service ->
        if(!service.database){
            service.LOG.error "No database for ${comm}"
            return
        }

        def tx = service.database.beginTx()

        try{
            def result
            switch(comm.id){
                case "create": result = service.create(comm); break
                case "read": result = service.read(comm); break;
                case "update": result = service.update(comm); break;
                case "delete": result = service.delete(comm); break;
                case "query": result = service.query(comm); break;
                default: 
                    throw new Exception("Unknown comm ${comm}")
            }
            tx.success()

            // Set the result data
            comm.set(OP_RESULT, result)
        }catch(e){
            service.LOG.error "Failed to process ${comm} : ${e}"
            comm.set(OP_RESULT, e)
            tx.failure()
        }finally{
            tx.close()
        }
    }

    def getAllProps = { node ->
        def all = ["id": node.getId()]
        node.getPropertyKeys().each { all[it] = node.getProperty(it) }
        return all
    }
    
    public GraphService(){
        super("graph", true, 9, graphComm)
        this.config = Bot.CONFIG.graph
    }
    
    public void onStart(){
        LOG.debug "Starting graph db service, loading ${this.config}"
        this.database = 
            new GraphDatabaseFactory().newEmbeddedDatabase(this.config.path)
        this.exec = new ExecutionEngine(this.database)
    }
    
    public void onStop(){
        this.database.shutdown()
    }
    
    public create(comm){
        LOG.debug "Creating node for ${comm}"
        
        def label = DynamicLabel.label(comm.get(NODE_LABEL))
        def node = this.database.createNode(label)
        comm.get(NODE_PROPS).each { k, v -> node.setProperty(k, v) } 
        return node 
    }
    
    public read(comm){
        LOG.debug "Reading nodes for ${comm}"

        def results = []
        getNodes(comm).each { node ->
            results << getAllProps(node)
        }

        return results
    }

    public getNodes(comm){
        LOG.debug "Getting nodes for ${comm}"
        def nodes = []

        if(comm.get(NODE_ID)){
            comm.get(NODE_ID).each { nodes << this.database.getNodeById(it) }
        }else if(comm.get(NODE_LABEL)){
            def label = DynamicLabel.label(comm.get(NODE_LABEL))
    
            if(comm.get(NODE_PROPS)){
                comm.get(NODE_PROPS).each { k, v ->
                    this.database.findNodesByLabelAndProperty(
                        label, k, v).each { nodes << getAllProps(it) }
                }
            }else{
                GlobalGraphOperations.at(this.database)
                    .getAllNodesWithLabel(label).each { nodes << it }
            }
        }else{
            GlobalGraphOperations.at(this.database)
                .getAllNodes().each { nodes << it }
        }

        return nodes
    }
     
    public update(comm){
        LOG.debug "Updating nodes for ${comm}"
        
        // Get nodes
        def nodes = getNodes(comm)
        if(nodes.isEmpty() && comm.get(NODE_AUTOCREATE)){
            create(comm)
        }else{
            nodes.each { node ->
                comm.get(NODE_PROPS).each { k, v ->
                    node.setProperty(k, v)
                }
            }
        }
        return []
    }
    
    public delete(comm){
        LOG.debug "Deleting nodes for ${comm}"
        read(comm).each { it.delete() }
    }

    public query(comm){
        LOG.debug "Performing query for ${comm}"
        
        def results = []
        this.exec.execute(comm.get(GRAPH_QUERY)).each { row ->
            def result = [:]
            row.entrySet().each { col ->
                def value = col.value

                if(col.value instanceof Node)
                    result << getAllProps(col.value)
                else
                    result[col.key] = col.value
            }
            results << result
        }
        return results
    }
}

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

import bot.*
import bot.control.*

@Grab("org.neo4j:neo4j:2.1.2")
import org.neo4j.cypher.javacompat.*
import org.neo4j.graphdb.*
import org.neo4j.graphdb.factory.*
import org.neo4j.tooling.*

/**
 * A graph database service backed by an embedded Neo4j graph db
 * @author matt
 */
public class GraphService extends Service {
    
    public static final NODE_LABEL = "node.label"
    public static final NODE_PROPS = "node.props"
    public static final NODE_ID = "node.id"
    public static final NODE_AUTOCREATE = "node.autocreate"

    public static final GRAPH_QUERY = "graph.query"

    public static final OP_RESULT = "graph.op.result"

    def config
    def database
    def exec

    def static graphComm = { comm, service ->
        if(!service.database){
            service.LOG.error "No database for ${comm}"
            return
        }

        def tx = service.database.beginTx()

        try{
            def result
            switch(comm.id){
                case "create": result = service.create(comm); break
                case "read": result = service.read(comm); break;
                case "update": result = service.update(comm); break;
                case "delete": result = service.delete(comm); break;
                case "query": result = service.query(comm); break;
                default: 
                    throw new Exception("Unknown comm ${comm}")
            }
            tx.success()

            // Set the result data
            comm.set(OP_RESULT, result)
        }catch(e){
            service.LOG.error "Failed to process ${comm} : ${e}"
            comm.set(OP_RESULT, e)
            tx.failure()
        }finally{
            tx.close()
        }
    }

    def getAllProps = { node ->
        def all = ["id": node.getId()]
        node.getPropertyKeys().each { all[it] = node.getProperty(it) }
        return all
    }
    
    public GraphService(){
        super("graph", true, 9, graphComm)
        this.config = Bot.CONFIG.graph
    }
    
    public void onStart(){
        LOG.debug "Starting graph db service, loading ${this.config}"
        this.database = 
            new GraphDatabaseFactory().newEmbeddedDatabase(this.config.path)
        this.exec = new ExecutionEngine(this.database)
    }
    
    public void onStop(){
        this.database.shutdown()
    }
    
    public create(comm){
        LOG.debug "Creating node for ${comm}"
        
        def label = DynamicLabel.label(comm.get(NODE_LABEL))
        def node = this.database.createNode(label)
        comm.get(NODE_PROPS).each { k, v -> node.setProperty(k, v) } 
        return node 
    }
    
    public read(comm){
        LOG.debug "Reading nodes for ${comm}"

        def results = []
        getNodes(comm).each { node ->
            results << getAllProps(node)
        }

        return results
    }

    public getNodes(comm){
        LOG.debug "Getting nodes for ${comm}"
        def nodes = []

        if(comm.get(NODE_ID)){
            comm.get(NODE_ID).each { nodes << this.database.getNodeById(it) }
        }else if(comm.get(NODE_LABEL)){
            def label = DynamicLabel.label(comm.get(NODE_LABEL))
    
            if(comm.get(NODE_PROPS)){
                comm.get(NODE_PROPS).each { k, v ->
                    def nodes = this.database.findNodesByLabelAndProperty(
                        label, k, v)
                    nodes.each { nodes << getAllProps(it) }
                }
            }else{
                GlobalGraphOperations.at(this.database)
                    .getAllNodesWithLabel(label).each { nodes << it }
            }
        }else{
            GlobalGraphOperations.at(this.database)
                .getAllNodes().each { nodes << it }
        }

        return nodes
    }
     
    public update(comm){
        LOG.debug "Updating nodes for ${comm}"
        
        // Get nodes
        def nodes = getNodes(comm)
        if(nodes.isEmpty() && comm.get(NODE_AUTOCREATE)){
            create(comm)
        }else{
            nodes.each { node ->
                comm.get(NODE_PROPS).each { k, v ->
                    node.setProperty(k, v)
                }
            }
        }
        return []
    }
    
    public delete(comm){
        LOG.debug "Deleting nodes for ${comm}"
        read(comm).each { it.delete() }
    }

    public query(comm){
        LOG.debug "Performing query for ${comm}"
        
        def results = []
        this.exec.execute(comm.get(GRAPH_QUERY)).each { row ->
            def result = [:]
            row.entrySet().each { col ->
                def value = col.value

                if(col.value instanceof Node)
                    result << getAllProps(col.value)
                else
                    result[col.key] = col.value
            }
            results << result
        }
        return results
    }
}
