Initial commit.

Based on from https://github.com/RedisLabs/JRediSearch

Author: itamarhaber

.gitignore

@@ -0,0 +1,7 @@
+*
+!/**/
+!**/*.java
+!**/*.jar
+!**/*.md
+!.gitignore
+!pom.xml

README.md

@@ -0,0 +1,24 @@
+# JReJSON
+
+A Java Client Library for [ReJSON](https://https://github.com/redislabsmodules/rejson)
+
+## Overview 
+
+
+## Usage example
+
+Initializing the client:
+
+```java
+
+import io.rejson.Client;
+
+...
+
+Client client = new Client("localhost", 6379);
+
+```
+
+Setting a value:
+
+...

lib/commons-pool2-2.4.2.jar

@@ -0,0 +1,81 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.redislabs</groupId>
+    <artifactId>jrejson</artifactId>
+    <version>1.0-SNAPSHOT</version>
+    <dependencies>
+        <dependency>
+            <groupId>redis.clients</groupId>
+            <artifactId>jedis</artifactId>
+            <version>3.0.0-SNAPSHOT</version>
+            <scope>system</scope>
+            <systemPath>${project.basedir}/lib/jedis-3.0.0.jar</systemPath>
+        </dependency>
+        <dependency>
+            <groupId>com.google.code.gson</groupId>
+            <artifactId>gson</artifactId>
+            <version>2.8.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-pool2</artifactId>
+            <version>2.4.2</version>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.12</version>
+        </dependency>
+    </dependencies>
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+        <maven.test.source>8</maven.test.source>
+        <maven.test.target>8</maven.test.target>
+    </properties>
+
+
+    <build>
+        <plugins>
+            <plugin>
+                <artifactId>maven-assembly-plugin</artifactId>
+                <configuration>
+                    <archive>
+                        <manifest>
+                            <addClasspath>true</addClasspath>
+                            <!--<mainClass></mainClass>-->
+                        </manifest>
+                    </archive>
+                    <descriptorRefs>
+                        <descriptorRef>jar-with-dependencies</descriptorRef>
+                    </descriptorRefs>
+                </configuration>
+                <executions>
+                    <execution>
+                        <id>make-my-jar-with-dependencies</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>single</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.0</version>
+                <configuration>
+                    <source>1.8</source>
+                    <target>1.8</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+
+
+
+</project>

lib/hamcrest-core-1.3.jar

@@ -0,0 +1,120 @@
+package io.rejson;
+
+import redis.clients.jedis.Jedis;
+import redis.clients.jedis.JedisPool;
+import redis.clients.jedis.JedisPoolConfig;
+
+import com.google.gson.Gson;
+import redis.clients.jedis.commands.ProtocolCommand;
+import redis.clients.util.SafeEncoder;
+
+import java.util.*;
+
+/**
+ * Client is the main ReJSON client class, wrapping connection management and all ReJSON commands
+ */
+public class Client {
+
+    private JedisPool pool;
+    private Gson gson;
+
+    Jedis _conn() {
+        return pool.getResource();
+    }
+
+    private enum Command implements ProtocolCommand {
+
+        SET("JSON.SET"),
+        GET("JSON.GET");
+        private final byte[] raw;
+
+        Command(String alt) {
+            raw = SafeEncoder.encode(alt);
+        }
+
+        public byte[] getRaw() {
+            return raw;
+        }
+    }
+
+    private void assertReplyNotError(String str) throws Exception {
+        if (str.startsWith("-ERR"))
+            throw new Exception(str.substring(5));
+    }
+
+    private void assertReplyOK(String str) throws Exception {
+        if (!str.equals("OK"))
+            throw new Exception(str);
+    }
+
+    /**
+     * Create a new client
+     * @param host the redis host
+     * @param port the redis port
+     */
+    public Client(String host, int port, int timeout, int poolSize) {
+        JedisPoolConfig conf = new JedisPoolConfig();
+        conf.setMaxTotal(poolSize);
+        conf.setTestOnBorrow(false);
+        conf.setTestOnReturn(false);
+        conf.setTestOnCreate(false);
+        conf.setTestWhileIdle(false);
+        conf.setMinEvictableIdleTimeMillis(60000);
+        conf.setTimeBetweenEvictionRunsMillis(30000);
+        conf.setNumTestsPerEvictionRun(-1);
+        conf.setFairness(true);
+
+        pool = new JedisPool(conf, host, port, timeout);
+        gson = new Gson();
+
+    }
+
+    public Client(String host, int port) {
+        this(host, port, 500, 100);
+    }
+
+    /**
+     * Sets an object
+     * @param key the key name
+     * @param path a path in the object
+     * @param object the Java object to store
+     */
+    public void set(String key, String path, Object object) throws Exception {
+        Jedis conn = _conn();
+        ArrayList<byte[]> args = new ArrayList(3);
+
+        args.add(key.getBytes());
+        args.add(path.getBytes());
+        args.add(gson.toJson(object).getBytes());
+
+        String status = conn.getClient()
+                .sendCommand(Command.SET, args.toArray(new byte[args.size()][]))
+                .getStatusCodeReply();
+        conn.close();
+
+        assertReplyOK(status);
+    }
+
+    /**
+     * Gets an object
+     * @param key the key name
+     * @param path a path in the object
+     * @return the requested object
+     */
+    public Object get(String key, String path) throws Exception {
+        Jedis conn = _conn();
+        ArrayList<byte[]> args = new ArrayList(2);
+
+        args.add(key.getBytes());
+        args.add(path.getBytes());
+
+        String rep = conn.getClient()
+                .sendCommand(Command.GET, args.toArray(new byte[args.size()][]))
+                .getBulkReply();
+        conn.close();
+
+        assertReplyNotError(rep);
+        return gson.fromJson(rep, Object.class);
+    }
+
+}

lib/jedis-3.0.0-sources.jar

@@ -0,0 +1,46 @@
+package io.rejson;
+
+import org.junit.Before;
+import org.junit.Test;
+
+import static junit.framework.TestCase.*;
+
+public class ClientTest {
+
+    private Client c;
+
+    @Before
+    public void initialize() {
+        c = new Client("localhost", 6379);
+    }
+
+    @Test
+    public void set() throws Exception {
+        c._conn().flushDB();
+
+        // basic set  - should succeed
+        c.set("test", ".", null);
+    }
+
+    @Test(expected = Exception.class)
+    public void setException() throws Exception {
+        c._conn().flushDB();
+
+        // should error on non root path for new key
+        c.set("test", ".foo", "bar");
+    }
+
+    @Test
+    public void get() throws Exception {
+        c._conn().flushDB();
+        c.set("test", ".", "foo");
+        assertEquals("foo", c.get("test", "."));
+    }
+
+    @Test(expected = Exception.class)
+    public void getException() throws Exception {
+        c._conn().flushDB();
+        c.set("test", ".", "foo");
+        c.get("test", ".bar");
+    }
+}