2011-02-24 21:32:27 +01:00
|
|
|
/* MAPIStoreGCSFolder.m - this file is part of SOGo
|
|
|
|
*
|
|
|
|
* Copyright (C) 2011 Inverse inc
|
|
|
|
*
|
|
|
|
* Author: Wolfgang Sourdeau <wsourdeau@inverse.ca>
|
|
|
|
*
|
|
|
|
* 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
|
2011-08-12 17:02:01 +02:00
|
|
|
* the Free Software Foundation; either version 3, or (at your option)
|
2011-02-24 21:32:27 +01:00
|
|
|
* any later version.
|
|
|
|
*
|
|
|
|
* This file is distributed in the hope that it will be useful,
|
|
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
|
* GNU General Public License for more details.
|
|
|
|
*
|
|
|
|
* You should have received a copy of the GNU General Public License
|
|
|
|
* along with this program; see the file COPYING. If not, write to
|
|
|
|
* the Free Software Foundation, Inc., 59 Temple Place - Suite 330,
|
|
|
|
* Boston, MA 02111-1307, USA.
|
|
|
|
*/
|
|
|
|
|
2011-05-30 23:12:56 +02:00
|
|
|
#import <Foundation/NSCalendarDate.h>
|
2011-07-28 02:55:50 +02:00
|
|
|
#import <Foundation/NSDictionary.h>
|
2012-02-02 02:45:17 +01:00
|
|
|
#import <Foundation/NSException.h>
|
2011-07-28 02:55:50 +02:00
|
|
|
#import <NGExtensions/NSObject+Logs.h>
|
2011-02-24 21:32:27 +01:00
|
|
|
#import <EOControl/EOQualifier.h>
|
|
|
|
#import <EOControl/EOFetchSpecification.h>
|
2011-07-28 02:55:50 +02:00
|
|
|
#import <EOControl/EOSortOrdering.h>
|
2011-02-24 21:32:27 +01:00
|
|
|
#import <GDLContentStore/GCSFolder.h>
|
|
|
|
#import <SOGo/NSArray+Utilities.h>
|
|
|
|
#import <SOGo/SOGoGCSFolder.h>
|
2012-02-02 02:45:17 +01:00
|
|
|
#import <SOGo/SOGoParentFolder.h>
|
2011-12-01 22:13:09 +01:00
|
|
|
#import <SOGo/SOGoPermissions.h>
|
|
|
|
#import <SOGo/SOGoUser.h>
|
2011-02-24 21:32:27 +01:00
|
|
|
|
2012-02-20 20:47:58 +01:00
|
|
|
#import "MAPIStoreGCSBaseContext.h"
|
2011-07-28 02:55:50 +02:00
|
|
|
#import "MAPIStoreTypes.h"
|
2012-01-29 20:55:21 +01:00
|
|
|
#import "MAPIStoreUserContext.h"
|
2011-09-20 21:37:03 +02:00
|
|
|
#import "NSData+MAPIStore.h"
|
2011-05-30 23:12:56 +02:00
|
|
|
#import "NSDate+MAPIStore.h"
|
2011-09-20 21:37:03 +02:00
|
|
|
#import "NSString+MAPIStore.h"
|
2011-07-28 02:55:50 +02:00
|
|
|
#import "SOGoMAPIFSMessage.h"
|
2011-05-30 23:12:56 +02:00
|
|
|
|
2011-02-24 21:32:27 +01:00
|
|
|
#import "MAPIStoreGCSFolder.h"
|
2011-06-07 02:17:46 +02:00
|
|
|
|
|
|
|
#undef DEBUG
|
|
|
|
#include <mapistore/mapistore.h>
|
2012-02-02 02:45:17 +01:00
|
|
|
#include <mapistore/mapistore_errors.h>
|
2011-02-24 21:32:27 +01:00
|
|
|
|
2012-03-12 07:03:56 +01:00
|
|
|
static Class NSNumberK;
|
|
|
|
|
2011-02-24 21:32:27 +01:00
|
|
|
@implementation MAPIStoreGCSFolder
|
|
|
|
|
2012-03-12 07:03:56 +01:00
|
|
|
+ (void) initialize
|
|
|
|
{
|
|
|
|
NSNumberK = [NSNumber class];
|
|
|
|
}
|
|
|
|
|
2011-07-28 02:55:50 +02:00
|
|
|
- (id) initWithSOGoObject: (id) newSOGoObject
|
|
|
|
inContainer: (MAPIStoreObject *) newContainer
|
|
|
|
{
|
|
|
|
if ((self = [super initWithSOGoObject: newSOGoObject inContainer: newContainer]))
|
|
|
|
{
|
2011-12-01 22:13:09 +01:00
|
|
|
activeUserRoles = nil;
|
2011-07-28 02:55:50 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
return self;
|
|
|
|
}
|
|
|
|
|
2012-01-29 20:55:21 +01:00
|
|
|
- (void) setupVersionsMessage
|
|
|
|
{
|
|
|
|
ASSIGN (versionsMessage,
|
|
|
|
[SOGoMAPIFSMessage objectWithName: @"versions.plist"
|
|
|
|
inContainer: propsFolder]);
|
|
|
|
}
|
|
|
|
|
2011-07-28 02:55:50 +02:00
|
|
|
- (void) dealloc
|
|
|
|
{
|
|
|
|
[versionsMessage release];
|
2011-12-01 22:13:09 +01:00
|
|
|
[activeUserRoles release];
|
2012-03-12 07:03:56 +01:00
|
|
|
[componentQualifier release];
|
2011-07-28 02:55:50 +02:00
|
|
|
[super dealloc];
|
|
|
|
}
|
|
|
|
|
2012-02-02 02:45:17 +01:00
|
|
|
- (int) deleteFolder
|
|
|
|
{
|
|
|
|
int rc;
|
|
|
|
NSException *error;
|
|
|
|
NSString *name;
|
|
|
|
|
|
|
|
name = [self nameInContainer];
|
|
|
|
if ([name isEqualToString: @"personal"])
|
|
|
|
rc = MAPISTORE_ERR_DENIED;
|
|
|
|
else
|
|
|
|
{
|
|
|
|
[[sogoObject container] removeSubFolder: name];
|
|
|
|
error = [(SOGoGCSFolder *) sogoObject delete];
|
|
|
|
if (error)
|
|
|
|
rc = MAPISTORE_ERROR;
|
|
|
|
else
|
|
|
|
{
|
|
|
|
if (![versionsMessage delete])
|
|
|
|
rc = MAPISTORE_SUCCESS;
|
|
|
|
else
|
|
|
|
rc = MAPISTORE_ERROR;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return (rc == MAPISTORE_SUCCESS) ? [super deleteFolder] : rc;
|
|
|
|
}
|
|
|
|
|
2012-02-20 20:47:58 +01:00
|
|
|
- (void) setDisplayName: (NSString *) newDisplayName
|
|
|
|
{
|
|
|
|
NSString *suffix, *fullSuffix;
|
|
|
|
Class cClass;
|
|
|
|
|
|
|
|
cClass = [(MAPIStoreGCSBaseContext *) [self context] class];
|
|
|
|
|
|
|
|
/* if a suffix exists, we strip it from the final name */
|
|
|
|
suffix = [cClass folderNameSuffix];
|
|
|
|
if ([suffix length] > 0)
|
|
|
|
{
|
|
|
|
fullSuffix = [NSString stringWithFormat: @"(%@)", suffix];
|
|
|
|
if ([newDisplayName hasSuffix: fullSuffix])
|
|
|
|
{
|
|
|
|
newDisplayName = [newDisplayName substringToIndex:
|
|
|
|
[newDisplayName length]
|
|
|
|
- [fullSuffix length]];
|
|
|
|
newDisplayName = [newDisplayName stringByTrimmingSpaces];
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (![[sogoObject displayName] isEqualToString: newDisplayName])
|
|
|
|
[sogoObject renameTo: newDisplayName];
|
|
|
|
}
|
|
|
|
|
2012-03-02 21:44:24 +01:00
|
|
|
- (int) getPidTagDisplayName: (void **) data
|
2012-02-20 20:47:58 +01:00
|
|
|
inMemCtx: (TALLOC_CTX *) memCtx
|
|
|
|
{
|
|
|
|
NSString *displayName;
|
|
|
|
Class cClass;
|
|
|
|
|
|
|
|
cClass = [(MAPIStoreGCSBaseContext *) [self context] class];
|
|
|
|
displayName = [cClass getFolderDisplayName: [sogoObject displayName]];
|
|
|
|
*data = [displayName asUnicodeInMemCtx: memCtx];
|
|
|
|
|
|
|
|
return MAPISTORE_SUCCESS;
|
|
|
|
}
|
|
|
|
|
2012-01-30 22:42:10 +01:00
|
|
|
- (void) addProperties: (NSDictionary *) newProperties
|
|
|
|
{
|
|
|
|
NSString *newDisplayName;
|
|
|
|
NSMutableDictionary *propsCopy;
|
|
|
|
NSNumber *key;
|
|
|
|
|
|
|
|
key = MAPIPropertyKey (PR_DISPLAY_NAME_UNICODE);
|
|
|
|
newDisplayName = [newProperties objectForKey: key];
|
|
|
|
if (newDisplayName)
|
|
|
|
{
|
2012-02-20 20:47:58 +01:00
|
|
|
[self setDisplayName: newDisplayName];
|
2012-01-30 22:42:10 +01:00
|
|
|
propsCopy = [newProperties mutableCopy];
|
|
|
|
[propsCopy removeObjectForKey: key];
|
|
|
|
[propsCopy autorelease];
|
|
|
|
newProperties = propsCopy;
|
|
|
|
}
|
|
|
|
|
|
|
|
[super addProperties: newProperties];
|
|
|
|
}
|
|
|
|
|
2011-07-26 22:13:10 +02:00
|
|
|
- (NSArray *) messageKeysMatchingQualifier: (EOQualifier *) qualifier
|
|
|
|
andSortOrderings: (NSArray *) sortOrderings
|
2011-02-24 21:32:27 +01:00
|
|
|
{
|
|
|
|
static NSArray *fields = nil;
|
2012-01-29 20:55:21 +01:00
|
|
|
SOGoUser *ownerUser;
|
2011-02-24 21:32:27 +01:00
|
|
|
NSArray *records;
|
2011-12-01 22:29:17 +01:00
|
|
|
NSMutableArray *qualifierArray;
|
|
|
|
EOQualifier *fetchQualifier, *aclQualifier;
|
2011-02-24 21:32:27 +01:00
|
|
|
GCSFolder *ocsFolder;
|
|
|
|
EOFetchSpecification *fs;
|
|
|
|
NSArray *keys;
|
|
|
|
|
|
|
|
if (!fields)
|
|
|
|
fields = [[NSArray alloc]
|
|
|
|
initWithObjects: @"c_name", @"c_version", nil];
|
|
|
|
|
2011-12-01 22:29:17 +01:00
|
|
|
qualifierArray = [NSMutableArray new];
|
2012-01-29 20:55:21 +01:00
|
|
|
ownerUser = [[self userContext] sogoUser];
|
|
|
|
if (![[context activeUser] isEqual: ownerUser])
|
2011-02-24 21:32:27 +01:00
|
|
|
{
|
2011-12-01 22:29:17 +01:00
|
|
|
aclQualifier = [self aclQualifier];
|
|
|
|
if (aclQualifier)
|
|
|
|
[qualifierArray addObject: aclQualifier];
|
2011-02-24 21:32:27 +01:00
|
|
|
}
|
2011-12-01 22:29:17 +01:00
|
|
|
[qualifierArray addObject: [self componentQualifier]];
|
|
|
|
if (qualifier)
|
|
|
|
[qualifierArray addObject: qualifier];
|
|
|
|
|
|
|
|
fetchQualifier = [[EOAndQualifier alloc]
|
|
|
|
initWithQualifierArray: qualifierArray];
|
2011-06-07 02:17:46 +02:00
|
|
|
|
2011-02-24 21:32:27 +01:00
|
|
|
ocsFolder = [sogoObject ocsFolder];
|
|
|
|
fs = [EOFetchSpecification
|
|
|
|
fetchSpecificationWithEntityName: [ocsFolder folderName]
|
|
|
|
qualifier: fetchQualifier
|
|
|
|
sortOrderings: sortOrderings];
|
2011-12-01 22:29:17 +01:00
|
|
|
[fetchQualifier release];
|
|
|
|
[qualifierArray release];
|
2011-02-24 21:32:27 +01:00
|
|
|
records = [ocsFolder fetchFields: fields fetchSpecification: fs];
|
|
|
|
keys = [records objectsForKey: @"c_name"
|
|
|
|
notFoundMarker: nil];
|
|
|
|
|
|
|
|
return keys;
|
|
|
|
}
|
|
|
|
|
2011-06-07 02:17:46 +02:00
|
|
|
- (NSDate *) lastMessageModificationTime
|
|
|
|
{
|
2012-03-12 07:03:56 +01:00
|
|
|
NSDate *value;
|
2011-07-28 02:55:50 +02:00
|
|
|
NSNumber *ti;
|
|
|
|
|
2012-03-12 09:20:22 +01:00
|
|
|
[self synchroniseCache];
|
|
|
|
|
2011-07-28 02:55:50 +02:00
|
|
|
ti = [[versionsMessage properties]
|
2012-03-12 07:03:56 +01:00
|
|
|
objectForKey: @"SyncLastModificationDate"];
|
2011-07-28 02:55:50 +02:00
|
|
|
if (ti)
|
|
|
|
value = [NSDate dateWithTimeIntervalSince1970: [ti doubleValue]];
|
|
|
|
else
|
2012-03-12 07:03:56 +01:00
|
|
|
value = nil;
|
2011-07-28 02:55:50 +02:00
|
|
|
|
|
|
|
return value;
|
|
|
|
}
|
|
|
|
|
2011-11-18 16:26:03 +01:00
|
|
|
- (SOGoFolder *) aclFolder
|
|
|
|
{
|
|
|
|
return (SOGoFolder *) sogoObject;
|
|
|
|
}
|
|
|
|
|
2011-07-28 02:55:50 +02:00
|
|
|
/* synchronisation */
|
|
|
|
|
2011-09-20 21:37:03 +02:00
|
|
|
/* Tree
|
2011-07-28 02:55:50 +02:00
|
|
|
{
|
|
|
|
SyncLastModseq = x;
|
|
|
|
SyncLastSynchronisationDate = x; ** not updated until something changed
|
|
|
|
Messages = {
|
|
|
|
MessageKey = {
|
|
|
|
Version = x;
|
|
|
|
Modseq = x;
|
|
|
|
Deleted = b;
|
2011-09-20 21:37:03 +02:00
|
|
|
ChangeKey = d;
|
|
|
|
PredecessorChangeList = { guid1 = globcnt1, guid2 ... };
|
2011-07-28 02:55:50 +02:00
|
|
|
};
|
|
|
|
...
|
|
|
|
};
|
|
|
|
VersionMapping = {
|
2012-03-16 22:05:41 +01:00
|
|
|
Version = last-modified;
|
2011-07-28 02:55:50 +02:00
|
|
|
...
|
|
|
|
}
|
|
|
|
}
|
2011-09-20 21:37:03 +02:00
|
|
|
*/
|
|
|
|
|
|
|
|
- (void) _setChangeKey: (NSData *) changeKey
|
|
|
|
forMessageEntry: (NSMutableDictionary *) messageEntry
|
|
|
|
{
|
|
|
|
struct XID *xid;
|
|
|
|
NSString *guid;
|
|
|
|
NSData *globCnt;
|
|
|
|
NSDictionary *changeKeyDict;
|
|
|
|
NSMutableDictionary *changeList;
|
|
|
|
|
|
|
|
xid = [changeKey asXIDInMemCtx: NULL];
|
|
|
|
guid = [NSString stringWithGUID: &xid->GUID];
|
|
|
|
globCnt = [NSData dataWithBytes: xid->Data length: xid->Size];
|
|
|
|
talloc_free (xid);
|
|
|
|
|
2011-09-22 15:39:38 +02:00
|
|
|
/* 1. set change key association */
|
2011-09-20 21:37:03 +02:00
|
|
|
changeKeyDict = [NSDictionary dictionaryWithObjectsAndKeys:
|
|
|
|
guid, @"GUID",
|
|
|
|
globCnt, @"LocalId",
|
|
|
|
nil];
|
|
|
|
[messageEntry setObject: changeKeyDict forKey: @"ChangeKey"];
|
|
|
|
|
|
|
|
/* 2. append/update predecessor change list */
|
|
|
|
changeList = [messageEntry objectForKey: @"PredecessorChangeList"];
|
|
|
|
if (!changeList)
|
|
|
|
{
|
|
|
|
changeList = [NSMutableDictionary new];
|
|
|
|
[messageEntry setObject: changeList
|
|
|
|
forKey: @"PredecessorChangeList"];
|
|
|
|
[changeList release];
|
|
|
|
}
|
|
|
|
[changeList setObject: globCnt forKey: guid];
|
|
|
|
}
|
2011-07-28 02:55:50 +02:00
|
|
|
|
2012-03-12 07:03:56 +01:00
|
|
|
- (EOQualifier *) componentQualifier
|
|
|
|
{
|
|
|
|
if (!componentQualifier)
|
|
|
|
componentQualifier
|
|
|
|
= [[EOKeyValueQualifier alloc] initWithKey: @"c_component"
|
|
|
|
operatorSelector: EOQualifierOperatorEqual
|
|
|
|
value: [self component]];
|
|
|
|
|
|
|
|
return componentQualifier;
|
|
|
|
}
|
|
|
|
|
|
|
|
- (EOQualifier *) contentComponentQualifier
|
|
|
|
{
|
|
|
|
EOQualifier *contentComponentQualifier;
|
|
|
|
NSString *likeString;
|
|
|
|
|
|
|
|
likeString = [NSString stringWithFormat: @"%%BEGIN:%@%%",
|
|
|
|
[[self component] uppercaseString]];
|
|
|
|
contentComponentQualifier = [[EOKeyValueQualifier alloc]
|
|
|
|
initWithKey: @"c_content"
|
|
|
|
operatorSelector: EOQualifierOperatorLike
|
|
|
|
value: likeString];
|
|
|
|
[contentComponentQualifier autorelease];
|
|
|
|
|
|
|
|
return contentComponentQualifier;
|
|
|
|
}
|
|
|
|
|
2011-07-28 02:55:50 +02:00
|
|
|
- (BOOL) synchroniseCache
|
|
|
|
{
|
|
|
|
BOOL rc = YES, foundChange = NO;
|
|
|
|
uint64_t newChangeNum;
|
2011-09-20 21:37:03 +02:00
|
|
|
NSData *changeKey;
|
2012-03-08 16:24:23 +01:00
|
|
|
NSString *cName;
|
2012-03-12 07:03:56 +01:00
|
|
|
NSNumber *ti, *changeNumber, *lastModificationDate, *cVersion,
|
|
|
|
*cLastModified, *cDeleted;
|
2011-07-28 02:55:50 +02:00
|
|
|
EOFetchSpecification *fs;
|
|
|
|
EOQualifier *searchQualifier, *fetchQualifier;
|
|
|
|
NSUInteger count, max;
|
|
|
|
NSArray *fetchResults;
|
|
|
|
NSDictionary *result;
|
|
|
|
NSMutableDictionary *currentProperties, *messages, *mapping, *messageEntry;
|
|
|
|
NSCalendarDate *now;
|
|
|
|
GCSFolder *ocsFolder;
|
|
|
|
static NSArray *fields = nil;
|
|
|
|
static EOSortOrdering *sortOrdering = nil;
|
|
|
|
|
|
|
|
if (!fields)
|
|
|
|
fields = [[NSArray alloc]
|
|
|
|
initWithObjects: @"c_name", @"c_version", @"c_lastmodified",
|
2012-03-12 07:03:56 +01:00
|
|
|
@"c_deleted", nil];
|
2011-07-28 02:55:50 +02:00
|
|
|
|
|
|
|
if (!sortOrdering)
|
|
|
|
{
|
|
|
|
sortOrdering = [EOSortOrdering sortOrderingWithKey: @"c_lastmodified"
|
|
|
|
selector: EOCompareAscending];
|
|
|
|
[sortOrdering retain];
|
|
|
|
}
|
|
|
|
|
2012-03-12 07:03:56 +01:00
|
|
|
currentProperties = [versionsMessage properties];
|
2011-07-28 02:55:50 +02:00
|
|
|
|
|
|
|
lastModificationDate = [currentProperties objectForKey: @"SyncLastModificationDate"];
|
|
|
|
if (lastModificationDate)
|
|
|
|
{
|
|
|
|
searchQualifier = [[EOKeyValueQualifier alloc]
|
|
|
|
initWithKey: @"c_lastmodified"
|
|
|
|
operatorSelector: EOQualifierOperatorGreaterThanOrEqualTo
|
|
|
|
value: lastModificationDate];
|
|
|
|
fetchQualifier = [[EOAndQualifier alloc]
|
2012-03-12 07:03:56 +01:00
|
|
|
initWithQualifiers: searchQualifier,
|
|
|
|
[self contentComponentQualifier],
|
|
|
|
nil];
|
2011-07-28 02:55:50 +02:00
|
|
|
[fetchQualifier autorelease];
|
|
|
|
[searchQualifier release];
|
|
|
|
}
|
|
|
|
else
|
|
|
|
fetchQualifier = [self componentQualifier];
|
|
|
|
|
|
|
|
ocsFolder = [sogoObject ocsFolder];
|
|
|
|
fs = [EOFetchSpecification
|
|
|
|
fetchSpecificationWithEntityName: [ocsFolder folderName]
|
|
|
|
qualifier: fetchQualifier
|
|
|
|
sortOrderings: [NSArray arrayWithObject: sortOrdering]];
|
2012-03-12 07:03:56 +01:00
|
|
|
fetchResults = [ocsFolder fetchFields: fields
|
|
|
|
fetchSpecification: fs
|
|
|
|
ignoreDeleted: NO];
|
2011-07-28 02:55:50 +02:00
|
|
|
max = [fetchResults count];
|
|
|
|
if (max > 0)
|
|
|
|
{
|
2012-03-12 07:03:56 +01:00
|
|
|
messages = [currentProperties objectForKey: @"Messages"];
|
|
|
|
if (!messages)
|
|
|
|
{
|
|
|
|
messages = [NSMutableDictionary new];
|
|
|
|
[currentProperties setObject: messages forKey: @"Messages"];
|
|
|
|
[messages release];
|
|
|
|
}
|
|
|
|
mapping = [currentProperties objectForKey: @"VersionMapping"];
|
|
|
|
if (!mapping)
|
|
|
|
{
|
|
|
|
mapping = [NSMutableDictionary new];
|
|
|
|
[currentProperties setObject: mapping forKey: @"VersionMapping"];
|
|
|
|
[mapping release];
|
|
|
|
}
|
|
|
|
|
2011-08-31 20:11:09 +02:00
|
|
|
ldb_transaction_start([[self context] connectionInfo]->oc_ctx);
|
|
|
|
|
2011-07-28 02:55:50 +02:00
|
|
|
for (count = 0; count < max; count++)
|
|
|
|
{
|
|
|
|
result = [fetchResults objectAtIndex: count];
|
|
|
|
cName = [result objectForKey: @"c_name"];
|
2012-03-12 07:03:56 +01:00
|
|
|
cDeleted = [result objectForKey: @"c_deleted"];
|
|
|
|
if ([cDeleted isKindOfClass: NSNumberK] && [cDeleted intValue])
|
|
|
|
cVersion = [NSNumber numberWithInt: -1];
|
|
|
|
else
|
|
|
|
cVersion = [result objectForKey: @"c_version"];
|
2011-07-28 02:55:50 +02:00
|
|
|
cLastModified = [result objectForKey: @"c_lastmodified"];
|
|
|
|
|
|
|
|
messageEntry = [messages objectForKey: cName];
|
|
|
|
if (!messageEntry)
|
|
|
|
{
|
|
|
|
messageEntry = [NSMutableDictionary new];
|
|
|
|
[messages setObject: messageEntry forKey: cName];
|
|
|
|
[messageEntry release];
|
|
|
|
}
|
2012-03-12 07:03:56 +01:00
|
|
|
|
2011-07-28 02:55:50 +02:00
|
|
|
if (![[messageEntry objectForKey: @"c_version"]
|
|
|
|
isEqual: cVersion])
|
|
|
|
{
|
2012-03-12 07:03:56 +01:00
|
|
|
[sogoObject removeChildRecordWithName: cName];
|
|
|
|
|
2011-07-28 02:55:50 +02:00
|
|
|
foundChange = YES;
|
|
|
|
|
2011-09-20 21:37:03 +02:00
|
|
|
newChangeNum = [[self context] getNewChangeNumber];
|
2011-07-28 02:55:50 +02:00
|
|
|
changeNumber = [NSNumber numberWithUnsignedLongLong: newChangeNum];
|
|
|
|
|
|
|
|
[messageEntry setObject: cLastModified forKey: @"c_lastmodified"];
|
|
|
|
[messageEntry setObject: cVersion forKey: @"c_version"];
|
|
|
|
[messageEntry setObject: changeNumber forKey: @"version"];
|
|
|
|
|
2011-09-20 21:37:03 +02:00
|
|
|
changeKey = [self getReplicaKeyFromGlobCnt: newChangeNum >> 16];
|
|
|
|
[self _setChangeKey: changeKey forMessageEntry: messageEntry];
|
|
|
|
|
2011-07-28 02:55:50 +02:00
|
|
|
[mapping setObject: cLastModified forKey: changeNumber];
|
|
|
|
|
|
|
|
if (!lastModificationDate
|
|
|
|
|| ([lastModificationDate compare: cLastModified]
|
|
|
|
== NSOrderedAscending))
|
|
|
|
lastModificationDate = cLastModified;
|
|
|
|
}
|
|
|
|
}
|
2011-08-31 20:11:09 +02:00
|
|
|
|
|
|
|
ldb_transaction_commit([[self context] connectionInfo]->oc_ctx);
|
|
|
|
|
2011-07-28 02:55:50 +02:00
|
|
|
if (foundChange)
|
|
|
|
{
|
2012-03-12 07:03:56 +01:00
|
|
|
now = [NSCalendarDate date];
|
2011-07-28 02:55:50 +02:00
|
|
|
ti = [NSNumber numberWithDouble: [now timeIntervalSince1970]];
|
|
|
|
[currentProperties setObject: ti
|
|
|
|
forKey: @"SyncLastSynchronisationDate"];
|
|
|
|
[currentProperties setObject: lastModificationDate
|
|
|
|
forKey: @"SyncLastModificationDate"];
|
|
|
|
[versionsMessage appendProperties: currentProperties];
|
|
|
|
[versionsMessage save];
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return rc;
|
|
|
|
}
|
2012-03-16 22:05:41 +01:00
|
|
|
|
|
|
|
- (void) updateVersionsForMessageWithKey: (NSString *) messageKey
|
|
|
|
withChangeKey: (NSData *) newChangeKey
|
|
|
|
{
|
|
|
|
[self synchroniseCache];
|
|
|
|
|
|
|
|
if (newChangeKey)
|
|
|
|
[self setChangeKey: newChangeKey forMessageWithKey: messageKey];
|
|
|
|
}
|
2011-07-28 02:55:50 +02:00
|
|
|
|
|
|
|
- (NSNumber *) lastModifiedFromMessageChangeNumber: (NSNumber *) changeNum
|
|
|
|
{
|
|
|
|
NSDictionary *mapping;
|
|
|
|
NSNumber *modseq;
|
|
|
|
|
|
|
|
mapping = [[versionsMessage properties] objectForKey: @"VersionMapping"];
|
|
|
|
modseq = [mapping objectForKey: changeNum];
|
|
|
|
|
|
|
|
return modseq;
|
|
|
|
}
|
|
|
|
|
|
|
|
- (NSNumber *) changeNumberForMessageWithKey: (NSString *) messageKey
|
|
|
|
{
|
|
|
|
NSDictionary *messages;
|
|
|
|
NSNumber *changeNumber;
|
|
|
|
|
|
|
|
messages = [[versionsMessage properties] objectForKey: @"Messages"];
|
|
|
|
changeNumber = [[messages objectForKey: messageKey]
|
|
|
|
objectForKey: @"version"];
|
|
|
|
|
|
|
|
return changeNumber;
|
2011-06-07 02:17:46 +02:00
|
|
|
}
|
|
|
|
|
2011-09-20 21:37:03 +02:00
|
|
|
- (void) setChangeKey: (NSData *) changeKey
|
|
|
|
forMessageWithKey: (NSString *) messageKey
|
|
|
|
{
|
|
|
|
NSMutableDictionary *messages;
|
|
|
|
NSMutableDictionary *messageEntry;
|
|
|
|
|
|
|
|
messages = [[versionsMessage properties] objectForKey: @"Messages"];
|
|
|
|
messageEntry = [messages objectForKey: messageKey];
|
|
|
|
if (!messageEntry)
|
2012-03-16 22:13:16 +01:00
|
|
|
{
|
|
|
|
[self synchroniseCache];
|
|
|
|
messageEntry = [messages objectForKey: messageKey];
|
|
|
|
if (!messageEntry)
|
|
|
|
abort ();
|
|
|
|
}
|
2011-09-20 21:37:03 +02:00
|
|
|
[self _setChangeKey: changeKey forMessageEntry: messageEntry];
|
|
|
|
|
|
|
|
[versionsMessage save];
|
|
|
|
}
|
|
|
|
|
|
|
|
- (NSData *) changeKeyForMessageWithKey: (NSString *) messageKey
|
|
|
|
{
|
|
|
|
NSDictionary *messages, *changeKeyDict;
|
|
|
|
NSString *guid;
|
|
|
|
NSData *globCnt, *changeKey = nil;
|
|
|
|
|
|
|
|
messages = [[versionsMessage properties] objectForKey: @"Messages"];
|
|
|
|
changeKeyDict = [[messages objectForKey: messageKey]
|
|
|
|
objectForKey: @"ChangeKey"];
|
|
|
|
if (changeKeyDict)
|
|
|
|
{
|
|
|
|
guid = [changeKeyDict objectForKey: @"GUID"];
|
|
|
|
globCnt = [changeKeyDict objectForKey: @"LocalId"];
|
2012-03-16 21:51:51 +01:00
|
|
|
changeKey = [NSData dataWithChangeKeyGUID: guid andCnt: globCnt];
|
2011-09-20 21:37:03 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
return changeKey;
|
|
|
|
}
|
|
|
|
|
|
|
|
- (NSData *) predecessorChangeListForMessageWithKey: (NSString *) messageKey
|
|
|
|
{
|
2012-03-16 22:09:10 +01:00
|
|
|
NSMutableData *list = nil;
|
2011-09-20 21:37:03 +02:00
|
|
|
NSDictionary *messages, *changeListDict;
|
|
|
|
NSArray *keys;
|
2012-03-16 22:09:10 +01:00
|
|
|
NSMutableArray *changeKeys;
|
2011-09-20 21:37:03 +02:00
|
|
|
NSUInteger count, max;
|
|
|
|
NSData *changeKey;
|
|
|
|
NSString *guid;
|
|
|
|
NSData *globCnt;
|
|
|
|
|
|
|
|
messages = [[versionsMessage properties] objectForKey: @"Messages"];
|
|
|
|
changeListDict = [[messages objectForKey: messageKey]
|
|
|
|
objectForKey: @"PredecessorChangeList"];
|
|
|
|
if (changeListDict)
|
|
|
|
{
|
|
|
|
keys = [changeListDict allKeys];
|
|
|
|
max = [keys count];
|
|
|
|
|
2012-03-16 22:09:10 +01:00
|
|
|
changeKeys = [NSMutableArray arrayWithCapacity: max];
|
2011-09-20 21:37:03 +02:00
|
|
|
for (count = 0; count < max; count++)
|
|
|
|
{
|
|
|
|
guid = [keys objectAtIndex: count];
|
|
|
|
globCnt = [changeListDict objectForKey: guid];
|
2012-03-16 21:51:51 +01:00
|
|
|
changeKey = [NSData dataWithChangeKeyGUID: guid andCnt: globCnt];
|
2012-03-16 22:09:10 +01:00
|
|
|
[changeKeys addObject: changeKey];
|
|
|
|
}
|
|
|
|
[changeKeys sortUsingFunction: MAPIChangeKeyGUIDCompare
|
|
|
|
context: nil];
|
|
|
|
|
|
|
|
list = [NSMutableData data];
|
|
|
|
for (count = 0; count < max; count++)
|
|
|
|
{
|
|
|
|
changeKey = [changeKeys objectAtIndex: count];
|
|
|
|
[list appendUInt8: [changeKey length]];
|
|
|
|
[list appendData: changeKey];
|
2011-09-20 21:37:03 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2012-03-16 22:09:10 +01:00
|
|
|
return list;
|
2011-09-20 21:37:03 +02:00
|
|
|
}
|
|
|
|
|
2011-07-29 04:13:39 +02:00
|
|
|
- (NSArray *) getDeletedKeysFromChangeNumber: (uint64_t) changeNum
|
|
|
|
andCN: (NSNumber **) cnNbr
|
|
|
|
inTableType: (uint8_t) tableType
|
|
|
|
{
|
|
|
|
NSArray *deletedKeys, *deletedCNames, *records;
|
|
|
|
NSNumber *changeNumNbr, *lastModified;
|
|
|
|
NSString *cName;
|
2012-03-12 07:03:56 +01:00
|
|
|
NSDictionary *versionProperties, *messageEntry;
|
|
|
|
NSMutableDictionary *messages;
|
|
|
|
uint64_t maxChangeNum = changeNum, currentChangeNum;
|
2011-07-29 04:13:39 +02:00
|
|
|
EOAndQualifier *fetchQualifier;
|
|
|
|
EOKeyValueQualifier *cDeletedQualifier, *cLastModifiedQualifier;
|
|
|
|
EOFetchSpecification *fs;
|
|
|
|
GCSFolder *ocsFolder;
|
|
|
|
NSUInteger count, max;
|
|
|
|
|
|
|
|
if (tableType == MAPISTORE_MESSAGE_TABLE)
|
|
|
|
{
|
|
|
|
deletedKeys = [NSMutableArray array];
|
|
|
|
|
|
|
|
changeNumNbr = [NSNumber numberWithUnsignedLongLong: changeNum];
|
|
|
|
lastModified = [self lastModifiedFromMessageChangeNumber: changeNumNbr];
|
|
|
|
if (lastModified)
|
|
|
|
{
|
|
|
|
versionProperties = [versionsMessage properties];
|
|
|
|
messages = [versionProperties objectForKey: @"Messages"];
|
|
|
|
|
|
|
|
ocsFolder = [sogoObject ocsFolder];
|
|
|
|
cLastModifiedQualifier = [[EOKeyValueQualifier alloc]
|
|
|
|
initWithKey: @"c_lastmodified"
|
|
|
|
operatorSelector: EOQualifierOperatorGreaterThanOrEqualTo
|
|
|
|
value: lastModified];
|
|
|
|
cDeletedQualifier = [[EOKeyValueQualifier alloc]
|
|
|
|
initWithKey: @"c_deleted"
|
|
|
|
operatorSelector: EOQualifierOperatorEqual
|
|
|
|
value: [NSNumber numberWithInt: 1]];
|
|
|
|
fetchQualifier = [[EOAndQualifier alloc] initWithQualifiers:
|
|
|
|
cLastModifiedQualifier,
|
|
|
|
cDeletedQualifier,
|
|
|
|
nil];
|
|
|
|
[fetchQualifier autorelease];
|
|
|
|
[cLastModifiedQualifier release];
|
|
|
|
[cDeletedQualifier release];
|
|
|
|
|
|
|
|
fs = [EOFetchSpecification
|
|
|
|
fetchSpecificationWithEntityName: [ocsFolder folderName]
|
|
|
|
qualifier: fetchQualifier
|
|
|
|
sortOrderings: nil];
|
|
|
|
records = [ocsFolder
|
|
|
|
fetchFields: [NSArray arrayWithObject: @"c_name"]
|
|
|
|
fetchSpecification: fs
|
|
|
|
ignoreDeleted: NO];
|
|
|
|
deletedCNames = [records objectsForKey: @"c_name" notFoundMarker: nil];
|
|
|
|
max = [deletedCNames count];
|
2012-03-12 07:03:56 +01:00
|
|
|
for (count = 0; count < max; count++)
|
2011-07-29 04:13:39 +02:00
|
|
|
{
|
2012-03-12 07:03:56 +01:00
|
|
|
cName = [deletedCNames objectAtIndex: count];
|
|
|
|
[sogoObject removeChildRecordWithName: cName];
|
|
|
|
messageEntry = [messages objectForKey: cName];
|
|
|
|
if (messageEntry)
|
2011-07-29 04:13:39 +02:00
|
|
|
{
|
2012-03-12 07:03:56 +01:00
|
|
|
currentChangeNum
|
|
|
|
= [[messageEntry objectForKey: @"version"]
|
|
|
|
unsignedLongLongValue];
|
2012-03-16 22:12:12 +01:00
|
|
|
if (MAPICNCompare (changeNum, currentChangeNum, NULL)
|
2012-03-12 07:03:56 +01:00
|
|
|
== NSOrderedAscending)
|
2011-07-29 04:13:39 +02:00
|
|
|
{
|
|
|
|
[(NSMutableArray *) deletedKeys addObject: cName];
|
2012-03-16 22:12:12 +01:00
|
|
|
if (MAPICNCompare (maxChangeNum, currentChangeNum, NULL)
|
2012-03-12 07:03:56 +01:00
|
|
|
== NSOrderedAscending)
|
|
|
|
maxChangeNum = currentChangeNum;
|
2011-07-29 04:13:39 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2012-03-12 07:03:56 +01:00
|
|
|
if (maxChangeNum != changeNum)
|
|
|
|
*cnNbr = [NSNumber numberWithUnsignedLongLong: maxChangeNum];
|
2011-07-29 04:13:39 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
else
|
|
|
|
deletedKeys = [super getDeletedKeysFromChangeNumber: changeNum
|
|
|
|
andCN: cnNbr
|
|
|
|
inTableType: tableType];
|
|
|
|
|
|
|
|
return deletedKeys;
|
|
|
|
}
|
|
|
|
|
2011-12-01 22:13:09 +01:00
|
|
|
- (NSArray *) activeUserRoles
|
|
|
|
{
|
|
|
|
SOGoUser *activeUser;
|
2012-01-29 20:55:21 +01:00
|
|
|
WOContext *woContext;
|
2011-12-01 22:13:09 +01:00
|
|
|
|
|
|
|
if (!activeUserRoles)
|
|
|
|
{
|
|
|
|
activeUser = [[self context] activeUser];
|
2012-01-29 20:55:21 +01:00
|
|
|
woContext = [[self userContext] woContext];
|
2011-12-01 22:13:09 +01:00
|
|
|
activeUserRoles = [activeUser rolesForObject: sogoObject
|
2012-01-29 20:55:21 +01:00
|
|
|
inContext: woContext];
|
2011-12-01 22:13:09 +01:00
|
|
|
[activeUserRoles retain];
|
|
|
|
}
|
|
|
|
|
|
|
|
return activeUserRoles;
|
|
|
|
}
|
|
|
|
|
|
|
|
- (BOOL) subscriberCanCreateMessages
|
|
|
|
{
|
|
|
|
return [[self activeUserRoles] containsObject: SOGoRole_ObjectCreator];
|
|
|
|
}
|
|
|
|
|
|
|
|
- (BOOL) subscriberCanDeleteMessages
|
|
|
|
{
|
|
|
|
return [[self activeUserRoles] containsObject: SOGoRole_ObjectEraser];
|
|
|
|
}
|
|
|
|
|
2011-02-24 21:32:27 +01:00
|
|
|
/* subclasses */
|
|
|
|
|
2011-12-01 22:13:09 +01:00
|
|
|
- (EOQualifier *) aclQualifier
|
|
|
|
{
|
|
|
|
return nil;
|
|
|
|
}
|
|
|
|
|
2012-03-12 07:03:56 +01:00
|
|
|
- (NSString *) component
|
2011-02-24 21:32:27 +01:00
|
|
|
{
|
|
|
|
[self subclassResponsibility: _cmd];
|
|
|
|
|
|
|
|
return nil;
|
|
|
|
}
|
|
|
|
|
|
|
|
@end
|