snrest-node/snrest.js at master · mak42/snrest-node · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
var promise = require('promise');
var request = require('request-promise');
var querystring = require('querystring');

function SnRestClient(config) {

    function getBaseUrl(host, table) {
        return 'https://' + host + '/' + table + '.do?JSONv2=&';
    }

    function getHttpClient(config) {
        return request.defaults({
            json: true,
            auth: {
                user: config.user,
                pass: config.pass,
                sendImmediately: true
            },
            headers: {
                'Content-Type': 'application/json',
                'Accepts': 'application/json'
            }
        });
    }

    return function(table) {
        return {
            baseUrl: getBaseUrl(config.host, table),
            httpClient: getHttpClient(config),
            getKeys: function(query) {
                var params = querystring.stringify({
                    "sysparm_action": "getKeys",
                    "sysparm_query": query
                });
                return this.httpClient.get(this.baseUrl + params);
            },
            get: function(sysId) {
                var params = querystring.stringify({
                    "sysparm_action": "get",
                    "sysparm_sys_id": sysId
                });
                return this.httpClient.get(this.baseUrl + params);
            },
            getRecords: function(query) {
                var params = querystring.stringify({
                    "sysparm_action": "getRecords",
                    "sysparm_query": query
                });
                return this.httpClient.get(this.baseUrl + params);
            },
            update: function(object, query) {
                var params = querystring.stringify({
                    "sysparm_action": "update",
                    "sysparm_query": query
                });
                var opts = { body: object };
                return this.httpClient.post(this.baseUrl + params, opts);
            },
            insert: function(object) {
                var params = querystring.stringify({
                    "sysparm_action": "insert"
                });
                var opts = { body: object };
                return this.httpClient.post(this.baseUrl + params, opts);
            },
            insertMultiple: function(recordArray) {
                var params = querystring.stringify({
                    "sysparm_action": "insertMultiple"
                });
                var opts = { body: recordArray };
                return this.httpClient.post(this.baseUrl + params, opts);
            },
            deleteRecord: function(sysId) {
                var params = querystring.stringify({
                    "sysparm_action": "deleteRecord"
                });
                var opts = { body: { "sysparm_sys_id": sysId } };
                return this.httpClient.post(this.baseUrl + params, opts);
            },
            deleteMultiple: function(query) {
                var params = querystring.stringify({
                    "sysparm_action": "deleteMultiple",
                    "sysparm_query": query
                });
                return this.httpClient.get(this.baseUrl + params);
            }
        };
    };
}
module.exports = SnRestClient;