40 lines
1.1 KiB
TypeScript
40 lines
1.1 KiB
TypeScript
|
import * as plugins from './smartdata.plugins'
|
||
|
|
|
||
|
|
export class DbCollection<T> {
|
||
|
|
constructor(nameArg: string, db: plugins.mongodb.Db) {
|
||
|
|
let collection = db.collection(nameArg)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
export type TDbConnectionStatus = 'disconnected' | 'connected' | 'failed'
|
||
|
|
|
||
|
|
export class DbConnection {
|
||
|
|
dbUrl: string
|
||
|
|
db: plugins.mongodb.Db
|
||
|
|
status: TDbConnectionStatus
|
||
|
|
|
||
|
|
constructor(dbUrl: string) {
|
||
|
|
this.dbUrl = dbUrl
|
||
|
|
}
|
||
|
|
|
||
|
|
connect(): plugins.q.Promise<any> {
|
||
|
|
let done = plugins.q.defer()
|
||
|
|
plugins.mongodb.MongoClient.connect(this.dbUrl, (err, db) => {
|
||
|
|
if (err) { console.log(err) }
|
||
|
|
plugins.assert.equal(null, err)
|
||
|
|
this.db = db
|
||
|
|
plugins.beautylog.success(`connected to database at ${this.dbUrl}`)
|
||
|
|
done.resolve(this.db)
|
||
|
|
})
|
||
|
|
return done.promise
|
||
|
|
}
|
||
|
|
|
||
|
|
close(): plugins.q.Promise<any> {
|
||
|
|
let done = plugins.q.defer()
|
||
|
|
this.db.close()
|
||
|
|
plugins.beautylog.ok(`disconnected to database at ${this.dbUrl}`)
|
||
|
|
done.resolve()
|
||
|
|
return done.promise
|
||
|
|
}
|
||
|
|
}
|