summaryrefslogtreecommitdiff
path: root/src/db
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2016-12-29 07:49:51 +0900
committersyuilo <syuilotan@yahoo.co.jp>2016-12-29 07:49:51 +0900
commitb3f42e62af698a67c2250533c437569559f1fdf9 (patch)
treecdf6937576e99cccf85e6fa3aa8860a1173c7cfb /src/db
downloadsharkey-b3f42e62af698a67c2250533c437569559f1fdf9.tar.gz
sharkey-b3f42e62af698a67c2250533c437569559f1fdf9.tar.bz2
sharkey-b3f42e62af698a67c2250533c437569559f1fdf9.zip
Initial commit :four_leaf_clover:
Diffstat (limited to 'src/db')
-rw-r--r--src/db/elasticsearch.ts21
-rw-r--r--src/db/mongodb.ts8
-rw-r--r--src/db/redis.ts9
3 files changed, 38 insertions, 0 deletions
diff --git a/src/db/elasticsearch.ts b/src/db/elasticsearch.ts
new file mode 100644
index 0000000000..27040d102a
--- /dev/null
+++ b/src/db/elasticsearch.ts
@@ -0,0 +1,21 @@
+import * as elasticsearch from 'elasticsearch';
+
+// Init ElasticSearch connection
+const client = new elasticsearch.Client({
+ host: `${config.elasticsearch.host}:${config.elasticsearch.port}`
+});
+
+// Send a HEAD request
+client.ping({
+ // Ping usually has a 3000ms timeout
+ requestTimeout: Infinity,
+
+ // Undocumented params are appended to the query string
+ hello: 'elasticsearch!'
+}, error => {
+ if (error) {
+ console.error('elasticsearch is down!');
+ }
+});
+
+export default client;
diff --git a/src/db/mongodb.ts b/src/db/mongodb.ts
new file mode 100644
index 0000000000..e2b2479b49
--- /dev/null
+++ b/src/db/mongodb.ts
@@ -0,0 +1,8 @@
+import * as mongodb from 'mongodb';
+
+export default async function(): Promise<mongodb.Db> {
+ const uri = config.mongodb.user && config.mongodb.pass
+ ? `mongodb://${config.mongodb.user}:${config.mongodb.pass}@${config.mongodb.host}:${config.mongodb.port}/${config.mongodb.db}`
+ : `mongodb://${config.mongodb.host}:${config.mongodb.port}/${config.mongodb.db}`;
+ return await mongodb.MongoClient.connect(uri);
+};
diff --git a/src/db/redis.ts b/src/db/redis.ts
new file mode 100644
index 0000000000..ba4d647811
--- /dev/null
+++ b/src/db/redis.ts
@@ -0,0 +1,9 @@
+import * as redis from 'redis';
+
+export default redis.createClient(
+ config.redis.port,
+ config.redis.host,
+ {
+ auth_pass: config.redis.pass
+ }
+);