lee/puter
1
0
Fork 0
mirror of https://github.com/HeyPuter/puter.git synced 2026-09-25 22:55:58 +00:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

if clichouse exists hit it in _refresh_app_stats

Browse Source
This commit is contained in:
jelveh
2024-12-27 17:47:19 -08:00
parent 7252d2ef4f
commit 9867d26432
1 changed files with 30 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/backend/src/services/AppInformationService.js
+30 -8
View File
@@ -384,18 +384,40 @@ class AppInformationService {
const apps = await db.read(`SELECT uid FROM apps`);
for ( const app of apps ) {
// open count
const key_open_count = `apps:open_count:uid:${app.uid}`;
const { open_count } = (await db.read(
`SELECT COUNT(_id) AS open_count FROM app_opens WHERE app_uid = ?`,
[app.uid]
))[0];
let open_count;
if(global.clickhouseClient) {
const result = await global.clickhouseClient.query({
query: `SELECT COUNT(_id) AS open_count FROM app_opens WHERE app_uid = '${app_uid}'`,
format: 'JSONEachRow'
});
const rows = await result.json();
open_count = rows[0]?.open_count ?? 0;
}else{
open_count = (await db.read(
`SELECT COUNT(_id) AS open_count FROM app_opens WHERE app_uid = ?`,
[app_uid]
))[0].open_count;
}
kv.set(key_open_count, open_count);
// user count
const key_user_count = `apps:user_count:uid:${app.uid}`;
const { user_count } = (await db.read(
`SELECT COUNT(DISTINCT user_id) AS user_count FROM app_opens WHERE app_uid = ?`,
[app.uid]
))[0];
let user_count;
if(global.clickhouseClient) {
const result = await global.clickhouseClient.query({
query: `SELECT COUNT(DISTINCT user_id) AS uniqueUsers FROM app_opens WHERE app_uid = '${app_uid}'`,
format: 'JSONEachRow'
});
const rows = await result.json();
user_count = rows[0]?.uniqueUsers ?? 0;
}else{
user_count = (await db.read(`SELECT COUNT(DISTINCT user_id) AS user_count FROM app_opens WHERE app_uid = ?`, [app_uid]))[0].user_count;
}
kv.set(key_user_count, user_count);
}
}