jens@6: //
jens@6: //  MYOttoman.mm
jens@6: //  Ottoman
jens@6: //
jens@6: //  Created by Jens Alfke on 9/21/09.
jens@6: //  Copyright 2009 Jens Alfke. All rights reserved.
jens@6: //
jens@6: 
jens@6: #import "MYOttoman.h"
jens@6: #import "MYOttoman_internal.h"
jens@6: extern "C" {
jens@6: #import "Test.h"
jens@6: }
jens@6: 
jens@6: #include "Ottoman.h"
jens@6: #include "VersionDictionary.h"
jens@6: #include "File.h"
jens@6: 
jens@6: 
jens@6: @interface MYOttoman ()
jens@6: - (void) _versionsChanged;
jens@6: @end
jens@6: 
jens@6: 
jens@6: namespace Mooseyard {
jens@6: 
jens@6:     class ObjCOwnedOttoman :public Ottoman {
jens@6:     public:
jens@6:         ObjCOwnedOttoman (MYOttoman *owner)
jens@6:         :_owner(owner)
jens@6:         { }
jens@6:         
jens@6:         ObjCOwnedOttoman (MYOttoman *owner, NSURL *fileURL, bool writeable)
jens@6:         :Ottoman(fileURL.path.fileSystemRepresentation, writeable),
jens@6:         _owner(owner)
jens@6:         { }
jens@6:         
jens@6:     protected:
jens@6:         virtual void versionsChanged() {
jens@6:             [_owner _versionsChanged];
jens@6:         }
jens@6:     private:
jens@6:         MYOttoman *_owner;
jens@6:     };
jens@6:     
jens@6: }
jens@6: 
jens@6: 
jens@6: using namespace Mooseyard;
jens@6: 
jens@6: 
jens@6: static BOOL ErrorToNSError (const File::Error &x, NSError **outError) {
jens@6:     if (outError) {
jens@6:         *outError = [NSError errorWithDomain: NSPOSIXErrorDomain
jens@6:                                         code: x.code
jens@6:                                     userInfo: nil];
jens@6:     }
jens@6:     return NO;
jens@6: }
jens@6: 
jens@6: 
jens@6: @interface MYOttoman ()
jens@6: @property (readonly) Ottoman* ottoman;
jens@6: @end
jens@6: 
jens@6: 
jens@6: @implementation MYOttoman
jens@6: 
jens@6: 
jens@6: - (id) init {
jens@6:     return [self initWithURL: nil writeable: YES error: nil];
jens@6: }
jens@6: 
jens@6: - (id) initWithURL: (NSURL*)fileURL
jens@6:          writeable: (BOOL)writeable
jens@6:              error: (NSError**)outError
jens@6: {
jens@6:     self = [super init];
jens@6:     if (self) {
jens@6:         try {
jens@6:             if (fileURL) {
jens@6:                 NSAssert([fileURL isFileURL], @"MYOttoman only supports file: URLs");
jens@6:                 _ottoman = new ObjCOwnedOttoman(self, fileURL, writeable);
jens@6:             } else {
jens@6:                 _ottoman = new ObjCOwnedOttoman(self);
jens@6:             }
jens@6:         } catch (const File::Error &x) {
jens@6:             ErrorToNSError(x,outError);
jens@6:             [self release];
jens@6:             return nil;
jens@6:         }
jens@6:         
jens@6:         if (writeable)
jens@6:             _currentVersion = [[MYCurrentVersionDictionary alloc]
jens@6:                                         _initWithOverlayDictionary: self.ottoman->currentVersion()];
jens@6:     }
jens@6:     return self;
jens@6: }
jens@6: 
jens@6: - (void) dealloc
jens@6: {
jens@6:     [_lastVersion release];
jens@6:     [_currentVersion release];
jens@6:     delete (Ottoman*)_ottoman;
jens@6:     [super dealloc];
jens@6: }
jens@6: 
jens@6: - (void) finalize {
jens@6:     delete (Ottoman*)_ottoman;
jens@6:     [super finalize];
jens@6: }
jens@6: 
jens@6: - (void) close {
jens@6:     delete (Ottoman*)_ottoman;
jens@6:     _ottoman = nil;
jens@6: }
jens@6: 
jens@6: 
jens@6: - (Ottoman*) ottoman {
jens@6:     Assert(_ottoman, @"MYOttoman has already been closed");
jens@6:     return (Ottoman*) _ottoman;
jens@6: }
jens@6: 
jens@6: - (NSURL*) URL {
jens@6:     const char *path = self.ottoman->filename();
jens@6:     return path ?[NSURL fileURLWithPath: [NSString stringWithUTF8String: path]] :nil;
jens@6: }
jens@6: 
jens@6: 
jens@6: - (MYVersionDictionary*) lastVersion {
jens@6:     if (!_lastVersion)
jens@6:         _lastVersion = [[MYVersionDictionary alloc] _initWithVersionDictionary: self.ottoman->lastVersion()];
jens@6:     return _lastVersion;
jens@6: }
jens@6: 
jens@6: - (MYCurrentVersionDictionary*) currentVersion {
jens@6:     return _currentVersion;
jens@6: }
jens@6: 
jens@6: - (void) _versionsChanged {
jens@6:     [_lastVersion autorelease];
jens@6:     _lastVersion = nil;
jens@6: }
jens@6: 
jens@6: 
jens@6: - (BOOL) needsSync {
jens@6:     return self.ottoman->needsSync();
jens@6: }
jens@6: 
jens@6: 
jens@6: - (BOOL) sync: (NSError**)outError {
jens@6:     if (outError) *outError = nil;
jens@6:     try {
jens@6:         return self.ottoman->sync();
jens@6:     } catch (const File::Error &x) {
jens@6:         return ErrorToNSError(x,outError);
jens@6:     }
jens@6: }
jens@6: 
jens@6: - (BOOL) save: (NSError**)outError {
jens@6:     if (outError) *outError = nil;
jens@6:     try {
jens@6:         return self.ottoman->save();
jens@6:     } catch (const File::Error &x) {
jens@6:         return ErrorToNSError(x,outError);
jens@6:     }
jens@6: }
jens@6: 
jens@6: - (BOOL) saveAndCompact: (NSError**)outError {
jens@6:     if (outError) *outError = nil;
jens@6:     try {
jens@6:         return self.ottoman->saveAndCompact();
jens@6:     } catch (const File::Error &x) {
jens@6:         return ErrorToNSError(x,outError);
jens@6:     }
jens@6: }
jens@6: 
jens@6: - (BOOL) saveAs: (NSURL*)newFileURL
jens@6:          overwriteAllowed: (BOOL)overwriteAllowed
jens@6:          error: (NSError**)outError
jens@6: {
jens@6:     NSParameterAssert(newFileURL!=nil);
jens@6:     NSAssert([newFileURL isFileURL], @"MYOttoman only supports file: URLs");
jens@6:     if (outError) *outError = nil;
jens@6:     try {
jens@6:         self.ottoman->saveAs(newFileURL.path.fileSystemRepresentation, overwriteAllowed);
jens@6:         return YES;
jens@6:     } catch (const File::Error &x) {
jens@6:         return ErrorToNSError(x,outError);
jens@6:     }
jens@6: }
jens@6: 
jens@6: 
jens@6: - (BOOL) scavengeAndRepair: (BOOL)repair error: (NSError**)outError {
jens@6:     if (outError) *outError = nil;
jens@6:     try {
jens@6:         return self.ottoman->scavenge(repair);
jens@6:     } catch (const File::Error &x) {
jens@6:         return ErrorToNSError(x,outError);
jens@6:     }
jens@6: }
jens@6: 
jens@6: 
jens@6: @end
jens@6: