Nitro/functions/loadDB.js at master · mahmoudzuine/Nitro · 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
const r = require('rethinkdb')
const auth = require('../config')
const store = require('./storeMessages')


module.exports = () => {

    return new Promise((resolve, reject) => {

        r.connect({

            host: "localhost",
            port: '28015',
            db: "Nitro",
            password: auth.rethink

        }).then(conn => {

            let connection = conn

            store.connect(conn)

            loadConfig(connection, (err, config) => {

                if (err) return reject(err)

                loadProfile(connection, (err, profile) => {

                    if (err) return reject(err)

                    loadSystem(connection, (err, system) => {

                        if (err) return reject(err)

                        return resolve({
                            connection,
                            config,
                            profile,
                            system
                        })

                    })

                })

            })

        }).catch(err => reject(err));

    })

}

function loadConfig(connection, callback) {

    r.table("config").run(connection, (err, res) => {

        if (err) return callback(err, false)

        res.toArray((err, data) => {

            return callback(false, data)

        })

    })

}

function loadProfile(connection, callback) {

    r.table("profile").run(connection, (err, res) => {

        if (err) return callback(err, false)

        res.toArray((err, data) => {

            return callback(false, data)

        })
    })
}

function loadSystem(connection, callback) {

    r.table('system').run(connection, (err, res) => {

        if (err) return callback(err, false)

        res.toArray((err, data) => {

            return callback(false, data)

        })

    })

}