Add support for sending stats to Matrix, split out some code into more generic classes. #1

Open
rory.gay wants to merge 35 commits from rory.gay/freepbx-stats:main into main
Showing only changes of commit 568651e39b - Show all commits

View file

@ -29,6 +29,7 @@ function getYesterday() {
* @returns {Promise<int>} * @returns {Promise<int>}
*/ */
async function queryScalarAsync(query, ...params) { async function queryScalarAsync(query, ...params) {
const start = Date.now();
const connection = await mysql.createConnection({ const connection = await mysql.createConnection({
host: process.env.DATABASE_HOST, host: process.env.DATABASE_HOST,
user: process.env.DATABASE_USER, user: process.env.DATABASE_USER,
@ -41,6 +42,7 @@ async function queryScalarAsync(query, ...params) {
if (err) { if (err) {
reject(err); reject(err);
} else { } else {
if(process.env.DATABASE_LOG_TIMINGS) console.log(`Query took ${Date.now() - start}ms:`, query, params, "=>", results);
resolve(results[0][Object.keys(results[0])[0]]); resolve(results[0][Object.keys(results[0])[0]]);
} }
connection.end(); connection.end();