xinyin025/ChatGPT-Next-Web
1
0
Fork 0
mirror of https://github.com/ChatGPTNextWeb/ChatGPT-Next-Web.git synced 2025-10-09 03:26:38 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

redis null

Browse Source
This commit is contained in:
DirkSchlossmacher 2023-11-14 12:29:22 +01:00
parent cc8b1e35c6
commit c93d001be5
1 changed files with 25 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
app/utils/cloud/redisRestClient.ts
View File

@ -31,6 +31,10 @@ export const incrementSignInCount = async (email: string | undefined, dateKey: s
}
const redis = getRedisClient();
if (!redis) {
console.error('Redis client is not initialized.');
return;
}
try {
await redis.hincrby(`signin_count:${email}`, dateKey, 1);
@ -46,6 +50,10 @@ export const incrementSessionRefreshCount = async (email: string | undefined, da
}
const redis = getRedisClient();
if (!redis) {
console.error('Redis client is not initialized.');
return;
}
try {
await redis.hincrby(`session_refreshes:${email}`, dateKey, 1);
@ -66,6 +74,10 @@ export const incrementTokenCounts = async (
}
const redis = getRedisClient();
if (!redis) {
console.error('Redis client is not initialized.');
return;
}
try {
await redis.hincrby(`tokens:${email}`, `${dateKey}:completion_tokens`, completionTokens);
@ -79,6 +91,10 @@ export const incrementTokenCounts = async (
export const getAvailableDateKeys = async (): Promise<string[]> => {
const redis = getRedisClient();
if (!redis) {
console.error('Redis client is not initialized.');
return;
}
try {
const keys = await redis.keys('signin_count:*');
@ -92,6 +108,10 @@ export const getAvailableDateKeys = async (): Promise<string[]> => {
export const getSignInCountForPeriod = async (dateKey: string): Promise<number> => {
const redis = getRedisClient();
if (!redis) {
console.error('Redis client is not initialized.');
return;
}
try {
const counts = await redis.hgetall(`signin_count:${dateKey}`);
@ -117,7 +137,11 @@ export const getSignInCountForPeriod = async (dateKey: string): Promise<number>
export const getDetailsByUser = async (dateKey: string): Promise<Record<string, number>> => {
const redis = getRedisClient();
if (!redis) {
console.error('Redis client is not initialized.');
return;
}
try {
const rawCounts = await redis.hgetall(`signin_count:${dateKey}`);
const counts: Record<string, number> = {};