RegexBot/ConfigItem/DatabaseConfig.cs
2017-11-11 19:12:24 -08:00

67 lines
2 KiB
C#

using Newtonsoft.Json.Linq;
using Npgsql;
using System.Threading.Tasks;
namespace Noikoio.RegexBot.ConfigItem
{
class DatabaseConfig
{
private readonly bool _enabled;
private readonly string _host;
private readonly string _user;
private readonly string _pass;
private readonly string _dbname;
private readonly string _parsemsg;
/// <summary>
/// Gets whether database storage is available.
/// </summary>
public bool Available => _enabled;
/// <summary>
/// Constructor error message (only if not enabled)
/// </summary>
public string ParseMsg => _parsemsg;
public DatabaseConfig(JToken ctok)
{
if (ctok == null || ctok.Type != JTokenType.Object)
{
_enabled = false;
_parsemsg = "Database configuration not defined.";
return;
}
var conf = (JObject)ctok;
_host = conf["hostname"]?.Value<string>() ?? "localhost"; // default to localhost
_user = conf["username"]?.Value<string>();
_pass = conf["password"]?.Value<string>();
_dbname = conf["database"]?.Value<string>();
if (string.IsNullOrWhiteSpace(_user) || string.IsNullOrWhiteSpace(_pass) || string.IsNullOrWhiteSpace(_dbname))
{
_parsemsg = "One or more required values are invalid or not defined.";
_enabled = false;
}
_parsemsg = null;
_enabled = true;
}
public async Task<NpgsqlConnection> GetOpenConnectionAsync()
{
if (!Available) return null;
var cs = new NpgsqlConnectionStringBuilder()
{
Host = _host,
Username = _user,
Password = _pass,
Database = _dbname
};
var db = new NpgsqlConnection(cs.ToString());
await db.OpenAsync();
return db;
}
}
}