ubidots-node/examples/ubidotsServiceExample.js at master · ubidots/ubidots-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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
const ubidots = require('ubidots');
const client = ubidots.createClient('PUT_API_KEY_HERE');

/**
 * Returns DataSource list
 */
function getDataSources() {
    return new Promise(function (resolve, reject) {
        client.auth(function () {
            this.getDatasources(function (err, data) {
                if (err) { reject(err); }
                resolve(data.results);
            });
        });
    });
}

/**
 *
 * @param {string} datasourceId
 */
function getDataSource(datasourceId) {
    return new Promise(function (resolve, reject) {
        client.auth(function () {
            const result = this.getDatasource(datasourceId);
            resolve(result);
        });
    });
}

/**
 *
 * @param {string} datasourceId
 */
function getDataSourceVariables(datasourceId) {
    return new Promise(function (resolve, reject) {
        client.auth(function () {
            const result = this.getDatasource(datasourceId);
            result.getVariables(function (err, data) {
                if (err) { reject(err); }
                resolve(data.results);
            });
        });
    });
}

/**
 *
 * @param {string} datasourceId
 */
function getDataSourceDetails(datasourceId) {
    return new Promise(function (resolve, reject) {
        client.auth(function () {
            const result = this.getDatasource(datasourceId);
            result.getDetails(function (err, details) {
                if (err) { reject(err); }
                resolve(details);
            });
        });
    });
}

/**
 *
 * @param {string} variableId
 */
function getVariable(variableId) {
    return new Promise(function (resolve, reject) {
        client.auth(function () {
            const variable = this.getVariable(variableId);
            resolve(variable);
        });
    });
}

/**
 *
 * @param {string} variableId
 */
function getVariableDetails(variableId) {
    return new Promise(function (resolve, reject) {
        client.auth(function () {
            const variable = this.getVariable(variableId);
            variable.getDetails(function (err, details) {
                resolve(details);
            });
        });
    });
}

/**
 *
 * @param {string} variableId
 * @param {number} value
 */
function saveVariableValue(variableId, value) {
    return new Promise(function (resolve, reject) {
        client.auth(function () {
            const variable = this.getVariable(variableId);
            variable.saveValue(value);
            resolve(true);
        });
    });
}

/**
 *
 * @param {string} variableId
 */
function getValuesFromVariable(variableId) {
    return new Promise(function (resolve, reject) {
        client.auth(function () {
            const variable = this.getVariable(variableId);
            variable.getValues(function (err, data) {
                if (err) { reject(err); }
                resolve(data.results);
            });
        });
    });
}

module.exports = {
    getDataSources,
    getDataSource,
    getDataSourceVariables,
    getDataSourceDetails,
    getVariable,
    getVariableDetails,
    saveVariableValue,
    getValuesFromVariable
}