lavab · pzduniak · Dec 28, 2014 · Dec 9, 2014 · Dec 10, 2014 · Dec 10, 2014
diff --git a/.gitignore b/.gitignore
@@ -1,2 +1,4 @@
 *~
 *.exe
+_vagrant/.vagrant
+.config.conf
diff --git a/.travis.yml b/.travis.yml
diff --git a/README.md b/README.md
@@ -56,5 +56,5 @@ version=v0
 
 ## Build status:
 
- - `master` - [![Build Status](https://magnum.travis-ci.com/lavab/api.svg?token=kJbppXeTxzqpCVvt4t5X&branch=master)](https://magnum.travis-ci.com/lavab/api)
- - `develop` - [![Build Status](https://magnum.travis-ci.com/lavab/api.svg?token=kJbppXeTxzqpCVvt4t5X&branch=develop)](https://magnum.travis-ci.com/lavab/api)
+ - `master` - [![Circle CI](https://circleci.com/gh/lavab/api/tree/master.svg?style=svg&circle-token=4a52d619a03d0249906195d6447ceb60a475c0c5)](https://circleci.com/gh/lavab/api/tree/master)
+ - `develop` - [![Circle CI](https://circleci.com/gh/lavab/api/tree/develop.svg?style=svg&circle-token=4a52d619a03d0249906195d6447ceb60a475c0c5)](https://circleci.com/gh/lavab/api/tree/develop)
diff --git a/_research/vote_storage/benchmark_test.go b/_research/vote_storage/benchmark_test.go
@@ -0,0 +1,115 @@
+package vote_storage_test
+
+import (
+	"math/rand"
+	"testing"
+
+	"github.com/dancannon/gorethink"
+	"github.com/dchest/uniuri"
+)
+
+var (
+	session      *gorethink.Session
+	key2find     string
+	table2search string
+)
+
+func init() {
+	var err error
+	session, err = gorethink.Connect(gorethink.ConnectOpts{
+		Address: "127.0.0.1:28015",
+	})
+	if err != nil {
+		panic(err)
+	}
+
+	key2find = uniuri.New()
+
+	// Create a new table
+	gorethink.Db("test").TableDrop("benchmark_keys_list").Run(session)
+	gorethink.Db("test").TableCreate("benchmark_keys_list").Run(session)
+
+	var klist []*KeysList
+
+	// Populate with sample data
+	for n := 0; n < 300; n++ {
+		keys := rndStringSlice(999)
+		keys = randomlyInsert(keys, key2find)
+
+		y := uniuri.New()
+		if n == 153 {
+			table2search = y
+		}
+
+		klist = append(klist, &KeysList{
+			ID:    y,
+			Voted: keys,
+		})
+	}
+
+	gorethink.Db("test").Table("benchmark_keys_list").Insert(klist).Run(session)
+}
+
+func rndStringSlice(count int) []string {
+	var r []string
+	for i := 0; i < count; i++ {
+		r = append(r, uniuri.New())
+	}
+	return r
+}
+
+func randomlyInsert(s []string, x string) []string {
+	i := rand.Intn(len(s) - 1)
+
+	s = append(s[:i], append([]string{x}, s[i:]...)...)
+
+	return s
+}
+
+type KeysList struct {
+	ID    string   `gorethink:"id"`
+	Voted []string `gorethink:"voted"`
+}
+
+func BenchmarkContains(b *testing.B) {
+	for n := 0; n < b.N; n++ {
+		contains, err := gorethink.Db("test").Table("benchmark_keys_list").Get(table2search).Field("voted").Contains(key2find).Run(session)
+		if err != nil {
+			b.Log(err)
+			b.Fail()
+		}
+
+		var res bool
+		err = contains.One(&res)
+		if err != nil {
+			b.Log(err)
+			b.Fail()
+		}
+		if !res {
+			b.Log("invalid response")
+			b.Fail()
+		}
+	}
+}
+
+func BenchmarkAppend(b *testing.B) {
+	for n := 0; n < b.N; n++ {
+		_, err := gorethink.Db("test").Table("benchmark_keys_list").Get(table2search).Field("voted").Append(uniuri.New()).Run(session)
+		if err != nil {
+			b.Log(err)
+			b.Fail()
+		}
+	}
+}
+
+func BenchmarkDelete(b *testing.B) {
+	for n := 0; n < b.N; n++ {
+		_, err := gorethink.Db("test").Table("benchmark_keys_list").Get(table2search).Field("voted").DeleteAt(
+			gorethink.Expr(gorethink.Db("test").Table("benchmark_keys_list").Get(table2search).Field("voted").IndexesOf(key2find).AtIndex(0)),
+		).Run(session)
+		if err != nil {
+			b.Log(err)
+			b.Fail()
+		}
+	}
+}
diff --git a/_research/ws_client/index.html b/_research/ws_client/index.html
@@ -0,0 +1,40 @@
+<!DOCTYPE html>
+<html>
+    <head>
+        <meta charset="utf-8">
+        <title>lavab client</title>
+    </head>
+    <body>
+        <select id="method">
+            <option>GET</option>
+            <option>POST</option>
+            <option>PUT</option>
+            <option>DELETE</option>
+        </select>
+
+        <input type="text" id="path" /><br>
+        <textarea id="body"></textarea><br>
+        <button id="send">Query</button>
+
+        <script src="//code.jquery.com/jquery-1.11.2.min.js"></script>
+        <script src="//cdn.jsdelivr.net/sockjs/0.3.4/sockjs.min.js"></script>
+        <script type="text/javascript">
+            $(function() {
+                var sock = new SockJS("http://127.0.0.1:5000/ws");
+
+                $("#send").click(function() {
+                    sock.send(JSON.stringify({
+                        id:     "random id",
+                        method: $("#method").val(),
+                        path:   $("#path").val(),
+                        body:   $("#body").val(),
+                    }));
+                });
+
+                sock.onmessage = function(e) {
+                    console.log(JSON.parse(e.data));
+                };
+            });
+        </script>
+    </body>
+</html>
diff --git a/_vagrant/Vagrantfile b/_vagrant/Vagrantfile
@@ -0,0 +1,58 @@
+# -*- mode: ruby -*-
+# vi: set ft=ruby :
+
+# Vagrantfile API/syntax version. Don't touch unless you know what you're doing!
+VAGRANTFILE_API_VERSION = "2"
+
+Vagrant.configure(VAGRANTFILE_API_VERSION) do |config|
+
+  #config.vm.define "redisthink" do |rethinkdb|
+    #rethinkdb.vm.box = "ubuntu/trusty64"
+
+    # rethinkdb
+    #rethinkdb.vm.network "forwarded_port", guest: 8080, host: 8080
+    #rethinkdb.vm.network "forwarded_port", guest: 28015, host: 28015
+    #rethinkdb.vm.network "forwarded_port", guest: 29015, host: 29015
+
+    # redis
+    #rethinkdb.vm.network "forwarded_port", guest: 6379, host: 6379
+
+    #rethinkdb.vm.provider "virtualbox" do |v|
+    #v.memory = 2048
+    #v.cpus = 4
+    #end
+
+    # load ansible playbook
+    #rethinkdb.vm.provision "shell", path: "deploy.sh"
+  #end
+
+  config.vm.define "docker" do |docker|
+    docker.vm.box = "ubuntu/trusty64"
+
+    docker.vm.network "forwarded_port", guest: 4222, host: 4222
+    docker.vm.network "forwarded_port", guest: 8333, host: 8333
+    docker.vm.network "forwarded_port", guest: 6379, host: 6379
+    docker.vm.network "forwarded_port", guest: 8080, host: 8080
+    docker.vm.network "forwarded_port", guest: 28015, host: 28015
+    docker.vm.network "forwarded_port", guest: 29015, host: 29015
+
+    docker.vm.provider "virtualbox" do |v|
+      v.customize ["modifyvm", :id, "--natdnshostresolver1", "on"]
+      v.customize ["modifyvm", :id, "--natdnsproxy1", "on"]
+    end
+
+    docker.vm.provision "docker" do |d|
+      d.pull_images "apcera/gnatsd"
+      d.run "apcera/gnatsd",
+        args: "--name gnatsd -p 4222:4222 -p 8333:8333"
+
+      d.pull_images "dockerfile/rethinkdb"
+      d.run "dockerfile/rethinkdb",
+        args: "--name rethinkdb -p 8080:8080 -p 28015:28015 -p 29015:29015"
+
+      d.pull_images "dockerfile/redis"
+      d.run "dockerfile/redis",
+        args: "--name redis -p 6379:6379"
+    end
+  end
+end
diff --git a/_vagrant/deploy.sh b/_vagrant/deploy.sh
@@ -0,0 +1,14 @@
+#!/usr/bin/env bash
+
+export DEBIAN_FRONTEND=noninteractive
+
+apt-get update -qq
+apt-get install -y python2.7 python-pip
+
+pip install ansible
+
+mkdir /etc/ansible
+echo "localhost" > /etc/ansible/hosts
+
+cd /vagrant
+ansible-playbook -vvvv playbook.yml
diff --git a/_vagrant/playbook.yml b/_vagrant/playbook.yml
@@ -0,0 +1,46 @@
+---
+- hosts: 127.0.0.1
+  connection: local
+  sudo: true
+  tasks:
+    # install rethinkdb
+    - name: add rethinkdb sources
+      shell: . /etc/lsb-release && echo "deb http://download.rethinkdb.com/apt $DISTRIB_CODENAME main" | tee /etc/apt/sources.list.d/rethinkdb.list
+    - name: add rethinkdb key
+      shell: wget -qO- http://download.rethinkdb.com/apt/pubkey.gpg | apt-key add -
+    - name: update apt cache
+      apt: update_cache=yes
+    - name: install rethinkdb
+      apt: pkg=rethinkdb state=present
+    # configure rethinkdb
+    - name: ensure group is present
+      group: name=rethinkdb state=present
+    - name: ensure user is present
+      user: name=rethinkdb state=present
+    - name: copy master config file
+      copy: src=./rethinkdb.conf dest=/etc/rethinkdb/instances.d/rethinkdb.conf owner=rethinkdb group=rethinkdb mode=664
+    - name: start rethinkdb
+      service: name=rethinkdb state=restarted
+    # install redis
+    - name: prepare a directory
+      shell: mkdir /tmp/redis-stable
+    - name: download redis
+      get_url: url=http://download.redis.io/redis-stable.tar.gz dest=/tmp/redis-stable.tar.gz
+    - name: unpack redis
+      unarchive: src=/tmp/redis-stable.tar.gz dest=/tmp/redis-stable copy=no
+    - name: make redis
+      shell: 'cd /tmp/redis-stable/redis-stable && make && make install'
+    - name: ensure group is present
+      group: name=redis state=present
+    - name: ensure user is present
+      user: name=redis state=present
+    - name: prepare config and storage directories for redis
+      shell: mkdir /etc/redis; mkdir /var/redis; sudo mkdir /var/redis/6379
+    - name: prepare the config and an init script for redis
+      shell: sudo cp /tmp/redis-stable/redis-stable/utils/redis_init_script /etc/init.d/redis_6379
+    - name: upload the config to the vm
+      copy: src=./redis.conf dest=/etc/redis/6379.conf owner=redis group=redis mode=664
+    - name: put the prepared config on the server
+      shell: sudo update-rc.d redis_6379 defaults
+    - name: start redis_6379
+      service: name=redis_6379 state=restarted