/*
* Copyright (c) 2012, Jonathan Schleifer <js@webkeks.org>
*
* https://webkeks.org/git/?p=objxmpp.git
*
* Permission to use, copy, modify, and/or distribute this software for any
* purpose with or without fee is hereby granted, provided that the above
* copyright notice and this permission notice is present in all copies.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGE.
*/
#ifdef HAVE_CONFIG_H
# include "config.h"
#endif
#include <stdlib.h>
#import <ObjFW/OFString.h>
#import <ObjFW/OFArray.h>
#import <ObjFW/OFDictionary.h>
#import <ObjFW/OFNumber.h>
#import <ObjFW/OFDataArray.h>
#import <ObjFW/OFAutoreleasePool.h>
#import <ObjFW/OFNotImplementedException.h>
#import "XMPPFileStorage.h"
@implementation XMPPFileStorage
- init
{
@try {
[self doesNotRecognizeSelector: _cmd];
} @catch (id e) {
[self release];
@throw e;
}
abort();
}
- initWithFile: (OFString*)file
{
self = [super init];
@try {
OFAutoreleasePool *pool = [[OFAutoreleasePool alloc] init];
_file = [file copy];
@try {
_data = [[[OFDataArray dataArrayWithContentsOfFile:
file] messagePackValue] retain];
} @catch (id e) {
_data = [[OFMutableDictionary alloc] init];
}
[pool release];
} @catch (id e) {
[self release];
@throw e;
}
return self;
}
- (void)dealloc
{
[_file release];
[_data release];
[super dealloc];
}
- (void)save
{
[[_data messagePackRepresentation] writeToFile: _file];
}
- (void)XMPP_setObject: (id)object
forPath: (OFString*)path
{
OFArray *pathComponents = [path componentsSeparatedByString: @"."];
OFMutableDictionary *iter = _data;
OFEnumerator *enumerator = [pathComponents objectEnumerator];
OFString *component;
size_t i = 0, components = [pathComponents count];
while ((component = [enumerator nextObject]) != nil) {
if (i++ == components - 1)
continue;
OFMutableDictionary *iter2 = [iter objectForKey: component];
if (iter2 == nil) {
iter2 = [OFMutableDictionary dictionary];
[iter setObject: iter2
forKey: component];
}
iter = iter2;
}
if (object != nil)
[iter setObject: object
forKey: [pathComponents lastObject]];
else
[iter removeObjectForKey: [pathComponents lastObject]];
}
- (id)XMPP_objectForPath: (OFString*)path
{
OFArray *pathComponents = [path componentsSeparatedByString: @"."];
OFEnumerator *enumerator = [pathComponents objectEnumerator];
OFString *component;
id object = _data;
while ((component = [enumerator nextObject]) != nil)
object = [object objectForKey: component];
return object;
}
- (void)setStringValue: (OFString*)string
forPath: (OFString*)path
{
OFAutoreleasePool *pool = [[OFAutoreleasePool alloc] init];
[self XMPP_setObject: string
forPath: path];
[pool release];
}
- (OFString*)stringValueForPath: (OFString*)path
{
OFAutoreleasePool *pool = [[OFAutoreleasePool alloc] init];
OFString *string;
string = [self XMPP_objectForPath: path];
[pool release];
return string;
}
- (void)setBooleanValue: (bool)boolean
forPath: (OFString*)path
{
OFAutoreleasePool *pool = [[OFAutoreleasePool alloc] init];
[self XMPP_setObject: [OFNumber numberWithBool: boolean]
forPath: path];
[pool release];
}
- (bool)booleanValueForPath: (OFString*)path
{
OFAutoreleasePool *pool = [[OFAutoreleasePool alloc] init];
bool boolean;
boolean = [[self XMPP_objectForPath: path] boolValue];
[pool release];
return boolean;
}
- (void)setIntegerValue: (intmax_t)integer
forPath: (OFString*)path
{
OFAutoreleasePool *pool = [[OFAutoreleasePool alloc] init];
[self XMPP_setObject: [OFNumber numberWithIntMax: integer]
forPath: path];
[pool release];
}
- (intmax_t)integerValueForPath: (OFString*)path
{
OFAutoreleasePool *pool = [[OFAutoreleasePool alloc] init];
intmax_t integer;
integer = [[self XMPP_objectForPath: path] intMaxValue];
[pool release];
return integer;
}
- (void)setArray: (OFArray*)array
forPath: (OFString*)path
{
OFAutoreleasePool *pool = [[OFAutoreleasePool alloc] init];
[self XMPP_setObject: array
forPath: path];
[pool release];
}
- (OFArray*)arrayForPath: (OFString*)path
{
OFAutoreleasePool *pool = [[OFAutoreleasePool alloc] init];
OFArray *array;
array = [self XMPP_objectForPath: path];
[pool release];
return array;
}
- (void)setDictionary: (OFDictionary*)dictionary
forPath: (OFString*)path
{
OFAutoreleasePool *pool = [[OFAutoreleasePool alloc] init];
[self XMPP_setObject: dictionary
forPath: path];
[pool release];
}
- (OFDictionary*)dictionaryForPath: (OFString*)path
{
OFAutoreleasePool *pool = [[OFAutoreleasePool alloc] init];
OFDictionary *dictionary;
dictionary = [self XMPP_objectForPath: path];
[pool release];
return dictionary;
}
@end