LupusNobilis
/
sogo
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

chore(tool): delete memcached entries of expired sessions

snyk-upgrade-0ec09bc7ae34af7c5d0348d49696b8f1
Francis Lachapelle 2021-05-03 16:12:28 -04:00
parent 2c9c38da86
commit ac2853cfcf
1 changed files with 25 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

62
Tools/SOGoToolExpireUserSessions.m
View File

@ -1,6 +1,6 @@
/* SOGoToolExpireUserSessions.m - this file is part of SOGo
*
* Copyright (C) 2012-2020 Inverse inc.
* Copyright (C) 2012-2021 Inverse inc.
*
* This file is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
@ -32,6 +32,7 @@
#import <NGExtensions/NSNull+misc.h>
#import <SOGo/NSString+Utilities.h>
#import <SOGo/SOGoSession.h>
#import "SOGoTool.h"
@ -63,20 +64,20 @@
BOOL rc;
EOAdaptorChannel *channel;
GCSChannelManager *cm;
NSArray *attrs, *qValues;
NSArray *attrs;
NSDictionary *qresult;
NSException *ex;
NSString *sql, *sessionsFolderURL;
NSString *sql, *sessionsFolderURL, *sessionID;
NSURL *tableURL;
NSUserDefaults *ud;
unsigned int now, oldest;
int sessionsToDelete;
rc=YES;
rc = YES;
ud = [NSUserDefaults standardUserDefaults];
now = [[NSCalendarDate calendarDate] timeIntervalSince1970];
oldest = now - (nbMinutes * 60);
sessionID = nil;
sessionsFolderURL = [ud stringForKey: @"OCSSessionsFolderURL"];
if (!sessionsFolderURL)
@ -93,56 +94,43 @@
{
/* FIXME: nice error msg */
NSLog(@"Can't aquire channel");
return rc=NO;
return rc = NO;
}
sql = [NSString stringWithFormat: @"SELECT count(*) FROM %@ WHERE c_lastseen <= %d",
[tableURL gcsTableName], oldest];
sql = [NSString stringWithFormat: @"SELECT c_id FROM %@ WHERE c_lastseen <= %d",
[tableURL gcsTableName], oldest];
ex = [channel evaluateExpressionX: sql];
if (ex)
{
NSLog(@"%@", [ex reason]);
[ex raise];
return rc=NO;
return rc = NO;
}
attrs = [channel describeResults: NO];
/* only one row */
qresult = [channel fetchAttributes: attrs withZone: NULL];
qValues = [qresult allValues];
sessionsToDelete = [[qValues objectAtIndex: 0] intValue];
if (sessionsToDelete)
{
if (verbose)
NSLog(@"Will be removing %d sessions", sessionsToDelete);
[channel cancelFetch];
sql = [NSString stringWithFormat: @"DELETE FROM %@ WHERE c_lastseen <= %d",
[tableURL gcsTableName], oldest];
if (verbose)
NSLog(@"Removing sessions older than %d minute(s)", nbMinutes);
ex = [channel evaluateExpressionX: sql];
if (ex)
while ((qresult = [channel fetchAttributes: attrs withZone: NULL]))
{
NSLog(@"An exception occured while deleting old sessions: %@", [ex reason]);
[ex raise];
return rc=NO;
sessionID = [qresult objectForKey: @"c_id"];
if (sessionID)
{
if (verbose)
NSLog(@"Removing session %@", sessionID);
[SOGoSession deleteValueForSessionKey: sessionID];
}
}
}
else
{
if (verbose)
NSLog(@"No session to remove");
}
[cm releaseChannel: channel immediately: YES];
if (verbose && sessionID == nil)
NSLog(@"No session to remove");
return rc;
}
- (BOOL) run
{
BOOL rc;
int sessionExpireMinutes=0;
int sessionExpireMinutes = -1;
rc = NO;
if ([arguments count])
@ -150,7 +138,7 @@
sessionExpireMinutes = [[arguments objectAtIndex: 0] intValue];
}
if (sessionExpireMinutes > 0)
if (sessionExpireMinutes >= 0)
{
rc = [self expireUserSessionOlderThan: sessionExpireMinutes];
}