initial commit

Author: NikolayS

circle.yml

@@ -0,0 +1,13 @@
+machine:
+    services:
+        - postgresql
+database:
+    override:
+        - sudo -u postgres psql -c "create database test;"
+        - sudo -u postgres psql test -c "create extension if not exists plpythonu;"
+        - sudo -u postgres psql test -f ~/postgrest-google-translate/install.sql
+test:
+    override:
+        - sudo -u postgres psql test -v ON_ERROR_STOP=1 -f ~/postgrest-google-translate/uninstall_api.sql
+        - sudo -u postgres psql test -v ON_ERROR_STOP=1 -f ~/postgrest-google-translate/uninstall_core.sql
+

install.sql

@@ -0,0 +1,64 @@
+create schema http_client;
+
+do $$
+begin
+    execute 'alter database '||current_database()||' set http_client.connect_timeout = 2;';
+end;
+$$ language plpgsql;
+
+create type http_client.response as (
+    url_requested text,
+    url_received text,
+    status_code integer,
+    headers json,
+    body text,
+    is_json boolean
+);
+
+create or replace function http_client._get(url text, timeout integer, headers jsonb) returns http_client.response as $$
+try:
+    from urllib2 import Request, urlopen, HTTPError
+    import json
+    res = {}
+    res['url_requested'] = url
+    res['body'] = res['status_code'] = res['url_received'] = None
+    res['is_json'] = res['headers'] = None
+    try:
+        req = Request(url)
+        if headers:
+            for k, v in json.loads(headers).iteritems():
+                req.add_header(k, v)
+        conn = urlopen(req, timeout = timeout)
+        res['body'] = conn.read()
+        res['status_code'] = conn.getcode()
+        res['url_received'] = conn.geturl()
+        respHeaders = conn.info().dict
+        res['headers'] = json.dumps(respHeaders)
+        if 'content-type' in respHeaders and respHeaders['content-type'].find('application/json') >= 0:
+            res['is_json'] = True
+            #res['body_jsonb'] = json.loads(res['body']) # try/except
+        else:
+            res['is_json'] = False
+        conn.close()
+    except HTTPError as e:
+        res['status_code'] = e.code
+        res['headers'] = json.dumps(e.headers.dict) # undocumented http://stackoverflow.com/a/6402083/4677351
+        res['body'] = e.read()
+
+
+    return res
+except Exception as e:
+    msg = "Error in http_clien._get(): exception {0} occured."
+    res = msg.format(e.__class__.__name__)
+    return res
+$$ language plpython2u volatile;
+
+create or replace function http_client._post(
+
+create or replace function http_client.get(query text) returns http_client.response as $$
+    select http_client._get(query, current_setting('http_client.connect_timeout')::integer, null::jsonb);
+$$ language sql volatile;
+
+
+
+

uninstall.sql

@@ -0,0 +1,7 @@
+do $$
+begin
+    execute 'alter database '||current_database()||' reset http_client.connect_timeout;';
+end;
+$$ language plpgsql;
+
+drop schema http_client cascade;