summaryrefslogtreecommitdiff
path: root/src/db
diff options
context:
space:
mode:
authorAya Morisawa <AyaMorisawa4869@gmail.com>2019-02-06 22:44:55 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2019-02-06 22:44:55 +0900
commit96bc17aa1014983d5e6bf8b4c05d898156995a0d (patch)
treefdf7c68bdbf3784988351004127db988d7c40c29 /src/db
parentFix bug (diff)
downloadmisskey-96bc17aa1014983d5e6bf8b4c05d898156995a0d.tar.gz
misskey-96bc17aa1014983d5e6bf8b4c05d898156995a0d.tar.bz2
misskey-96bc17aa1014983d5e6bf8b4c05d898156995a0d.zip
Check config on load (#4170)
Co-authored-by: syuilo <syuilotan@yahoo.co.jp>
Diffstat (limited to 'src/db')
-rw-r--r--src/db/elasticsearch.ts7
-rw-r--r--src/db/mongodb.ts4
-rw-r--r--src/db/redis.ts12
3 files changed, 11 insertions, 12 deletions
diff --git a/src/db/elasticsearch.ts b/src/db/elasticsearch.ts
index cbe6afbbb9..68ad736b25 100644
--- a/src/db/elasticsearch.ts
+++ b/src/db/elasticsearch.ts
@@ -42,9 +42,10 @@ const index = {
};
// Init ElasticSearch connection
-const client = config.elasticsearch ? new elasticsearch.Client({
- host: `${config.elasticsearch.host}:${config.elasticsearch.port}`
-}) : null;
+
+const client = config.elasticsearch.map(({ host, port }) => {
+ return new elasticsearch.Client({ host: `${host}:${port}` });
+}).getOrElse(null);
if (client) {
// Send a HEAD request
diff --git a/src/db/mongodb.ts b/src/db/mongodb.ts
index dedb289ce9..3e7d40fde7 100644
--- a/src/db/mongodb.ts
+++ b/src/db/mongodb.ts
@@ -1,7 +1,7 @@
import config from '../config';
-const u = config.mongodb.user ? encodeURIComponent(config.mongodb.user) : null;
-const p = config.mongodb.pass ? encodeURIComponent(config.mongodb.pass) : null;
+const u = config.mongodb.user.map(x => encodeURIComponent(x)).getOrElse(null);
+const p = config.mongodb.pass.map(x => encodeURIComponent(x)).getOrElse(null);
const uri = `mongodb://${u && p ? `${u}:${p}@` : ''}${config.mongodb.host}:${config.mongodb.port}/${config.mongodb.db}`;
diff --git a/src/db/redis.ts b/src/db/redis.ts
index 48e3f4e43e..4193ac7e7b 100644
--- a/src/db/redis.ts
+++ b/src/db/redis.ts
@@ -1,10 +1,8 @@
import * as redis from 'redis';
import config from '../config';
-export default config.redis ? redis.createClient(
- config.redis.port,
- config.redis.host,
- {
- auth_pass: config.redis.pass
- }
-) : null;
+export default config.redis.map(({ host, port, pass }) => {
+ return redis.createClient(port, host, {
+ auth_pass: pass.getOrElse(null)
+ });
+}).getOrElse(null);