gistfile1.java

@ExtensionNaming(namespace = "egosystem", name = "faunus")
class FaunusExtension extends AbstractRexsterExtension {

    private static FaunusGremlinScriptEngine engine = new FaunusGremlinScriptEngine();
    static {
        Configuration configuration = new Configuration();
        Properties properties = new Properties();
        properties.load(FaunusExtension.class.getResourceAsStream("titan-cassandra-input.properties"));
        for (Map.Entry<Object, Object> entry : properties.entrySet()) {
            configuration.set(entry.getKey().toString(), entry.getValue().toString());
        }
        FaunusGraph graph = new FaunusGraph(configuration);
        engine.put("g", graph);
    }


    @ExtensionDefinition(extensionPoint = ExtensionPoint.GRAPH, method = HttpMethod.GET)
    @ExtensionDescriptor(description = "Execute a discovery algorithm")
    public ExtensionResponse evaluate(@RexsterContext RexsterResourceContext context,
                                      @RexsterContext Graph g) {


        ((FaunusPipeline) engine.eval((String) context.getRequestObject().get('script'))).submit();
        return ExtensionResponse.ok(new JSONObject("{ 'status' : 'done' }"));

    }
}