mirror/puter
1
0
Fork 0
mirror of https://github.com/HeyPuter/puter.git synced 2026-02-22 14:38:48 -06:00
Code Issues Packages Projects Releases Wiki Activity

Revert "if clichouse exists hit it in _refresh_app_stats"

Browse Source 
This reverts commit 9867d26432.
This commit is contained in:
jelveh
2024-12-27 17:53:43 -08:00
parent 9867d26432
commit d7aa08b345
1 changed files with 8 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
src/backend/src/services/AppInformationService.js
View File

@@ -384,40 +384,18 @@ 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}`;
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;
}
const { open_count } = (await db.read(
`SELECT COUNT(_id) AS open_count FROM app_opens WHERE app_uid = ?`,
[app.uid]
))[0];
kv.set(key_open_count, open_count);
// user count
const key_user_count = `apps:user_count:uid:${app.uid}`;
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;
}
const { user_count } = (await db.read(
`SELECT COUNT(DISTINCT user_id) AS user_count FROM app_opens WHERE app_uid = ?`,
[app.uid]
))[0];
kv.set(key_user_count, user_count);
}
}