*****************************************************
Summary
-------
Generated at: 2016-12-26T18:18:07-06:00

Notes: 0
Binaries: 0
Archives: 0
Standards: 7

Apache Licensed: 4
Generated Documents: 0

JavaDocs are generated, thus a license header is optional.
Generated files do not require license headers.

3 Unknown Licenses

*****************************************************

Files with unapproved licenses:

  /Users/sblackmon/Dropbox/git/incubator-streams-release/streams-contrib/streams-persist-neo4j/src/main/java/org/apache/streams/neo4j/bolt/Neo4jBoltClient.java
  /Users/sblackmon/Dropbox/git/incubator-streams-release/streams-contrib/streams-persist-neo4j/src/main/java/org/apache/streams/neo4j/bolt/Neo4jBoltPersistWriter.java
  /Users/sblackmon/Dropbox/git/incubator-streams-release/streams-contrib/streams-persist-neo4j/src/main/jsonschema/org/apache/streams/neo4j/bolt/Neo4jBoltConfiguration.json

*****************************************************

*****************************************************
  Files with Apache License headers will be marked AL
  Binary files (which do not require any license headers) will be marked B
  Compressed archives will be marked A
  Notices, licenses etc. will be marked N
  AL    /Users/sblackmon/Dropbox/git/incubator-streams-release/streams-contrib/streams-persist-neo4j/pom.xml
 !????? /Users/sblackmon/Dropbox/git/incubator-streams-release/streams-contrib/streams-persist-neo4j/src/main/java/org/apache/streams/neo4j/bolt/Neo4jBoltClient.java
 !????? /Users/sblackmon/Dropbox/git/incubator-streams-release/streams-contrib/streams-persist-neo4j/src/main/java/org/apache/streams/neo4j/bolt/Neo4jBoltPersistWriter.java
  AL    /Users/sblackmon/Dropbox/git/incubator-streams-release/streams-contrib/streams-persist-neo4j/src/main/java/org/apache/streams/neo4j/CypherQueryGraphHelper.java
  AL    /Users/sblackmon/Dropbox/git/incubator-streams-release/streams-contrib/streams-persist-neo4j/src/main/java/org/apache/streams/neo4j/http/Neo4jHttpGraphHelper.java
 !????? /Users/sblackmon/Dropbox/git/incubator-streams-release/streams-contrib/streams-persist-neo4j/src/main/jsonschema/org/apache/streams/neo4j/bolt/Neo4jBoltConfiguration.json
  AL    /Users/sblackmon/Dropbox/git/incubator-streams-release/streams-contrib/streams-persist-neo4j/src/test/java/org/apache/streams/graph/test/TestCypherQueryGraphHelper.java
 
*****************************************************

 Printing headers for text files without a valid license header...
 
=====================================================
== File: /Users/sblackmon/Dropbox/git/incubator-streams-release/streams-contrib/streams-persist-neo4j/src/main/java/org/apache/streams/neo4j/bolt/Neo4jBoltClient.java
=====================================================
package org.apache.streams.neo4j.bolt;

import com.google.common.base.Preconditions;
import com.peoplepattern.streams.neo4j.bolt.Neo4jBoltConfiguration;
import org.apache.commons.lang3.StringUtils;
import org.neo4j.driver.v1.AuthToken;
import org.neo4j.driver.v1.AuthTokens;
import org.neo4j.driver.v1.Driver;
import org.neo4j.driver.v1.GraphDatabase;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

public class Neo4jBoltClient {

    private static final Logger LOGGER = LoggerFactory
            .getLogger(Neo4jBoltClient.class);

    private Driver client;

    public Neo4jBoltConfiguration config;

    private Neo4jBoltClient(Neo4jBoltConfiguration neo4jBoltConfiguration) {
        this.config = neo4jBoltConfiguration;
        try {
            this.start();
        } catch (Exception e) {
            e.printStackTrace();
            this.client = null;
        }
    }

    private static Map<Neo4jBoltConfiguration, Neo4jBoltClient> INSTANCE_MAP = new ConcurrentHashMap<Neo4jBoltConfiguration, Neo4jBoltClient>();

    public static Neo4jBoltClient getInstance(Neo4jBoltConfiguration neo4jBoltConfiguration) {
        if (    INSTANCE_MAP != null &&
                INSTANCE_MAP.size() > 0 &&
                INSTANCE_MAP.containsKey(neo4jBoltConfiguration)
                )
            return INSTANCE_MAP.get(neo4jBoltConfiguration);
        else {
            Neo4jBoltClient instance = new Neo4jBoltClient(neo4jBoltConfiguration);
            if( instance != null && instance.client != null ) {
                INSTANCE_MAP.put(neo4jBoltConfiguration, instance);
                return instance;
            } else {
                return null;

=====================================================
== File: /Users/sblackmon/Dropbox/git/incubator-streams-release/streams-contrib/streams-persist-neo4j/src/main/java/org/apache/streams/neo4j/bolt/Neo4jBoltPersistWriter.java
=====================================================
package org.apache.streams.neo4j.bolt;

import org.apache.streams.core.StreamsDatum;
import org.apache.streams.core.StreamsPersistWriter;
import org.apache.streams.neo4j.bolt.Neo4jBoltClient;
import org.apache.streams.pojo.json.Activity;
import org.apache.streams.pojo.json.ActivityObject;

import com.peoplepattern.streams.neo4j.bolt.Neo4jBoltConfiguration;

/**
 * Created by sblackmon on 12/16/16.
 */
public class Neo4jBoltPersistWriter implements StreamsPersistWriter {

  Neo4jBoltClient client;

  @Override
  public String getId() {
    return Neo4jBoltPersistWriter.class.getSimpleName();
  }

  @Override
  public void prepare(Object configurationObject) {
    client = Neo4jBoltClient.getInstance((Neo4jBoltConfiguration)configurationObject);
  }

  @Override
  public void cleanUp() {
    //
  }

  @Override
  public void write(StreamsDatum entry) {

    String id = entry.getId();
    Object document = entry.getDocument();


    if( document instanceof Activity) {
      // verb,edge
    }

    else if( document instanceof ActivityObject) {
      // object,vertex
    }

  }
}

=====================================================
== File: /Users/sblackmon/Dropbox/git/incubator-streams-release/streams-contrib/streams-persist-neo4j/src/main/jsonschema/org/apache/streams/neo4j/bolt/Neo4jBoltConfiguration.json
=====================================================
{
  "$schema": "http://json-schema.org/draft-03/schema",
  "id": "#",
  "type": "object",
  "javaType" : "com.peoplepattern.streams.neo4j.bolt.Neo4jBoltConfiguration",
  "javaInterfaces": ["java.io.Serializable"],
  "properties": {
    "scheme": {
      "type": "string"
    },
    "hosts": {
      "type": "array",
      "items": {
        "type": "string"
      }
    },
    "port": {
      "type": "integer"
    },
    "username": {
      "type": "string"
    },
    "password": {
      "type": "string"
    }
  }
}