pEp.foundation
/
pEpObjCAdapter
9
0
Fork 1
Code Issues Releases 2 Wiki Activity
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
1440 Commits
162 Branches
19 MiB
 
 
 
 
 
Tree: 28c7143778
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from '28c7143778'
${ noResults }
pEpObjCAdapter/pEpObjCAdapter/PEPSync.m

393 lines
12 KiB
Raw Blame History

//
// PEPSync.m
// pEpObjCAdapter
//
// Created by Dirk Zimmermann on 04.10.18.
// Copyright © 2018 p≡p. All rights reserved.
//
#import <os/log.h>
#import "pEpEngine.h"
#import "PEPSync.h"
#import "PEPSync_Internal.h"
#import "PEPSendMessageDelegate.h"
#import "PEPNotifyHandshakeDelegate.h"
#import "PEPMessageUtil.h"
#import "PEPMessage.h"
#import "PEPQueue.h"
#import "PEPObjCAdapter.h"
#import "NSError+PEP+Internal.h"
#import "PEPSessionProvider.h"
#import "PEPInternalSession.h"
#import "PEPPassphraseCache.h"
// MARK: - Internals
static os_log_t s_logger;
typedef PEP_STATUS (* t_messageToSendCallback)(struct _message * _Nullable msg);
typedef int (* t_injectSyncCallback)(SYNC_EVENT ev, void *management);
@interface PEPSync ()
@property (nonatomic, nonnull) PEPQueue *queue;
@property (nonatomic, nullable) NSThread *syncThread;
@property (nonatomic, nullable) NSConditionLock *conditionLockForJoiningSyncThread;
/// Used to block messageToSend() until the client configured a passphrase.
@property (atomic, nullable) dispatch_group_t blockmessageToSendGroup;
/// The session created and used by the sync loop
@property (nonatomic, nullable) PEPInternalSession *syncLoopSession;
/**
@Return: The callback for message sending that should be used on every session init.
*/
+ (t_messageToSendCallback)messageToSendCallback;
/**
@Return: The callback for injectiong sync messages that should be used on every session init.
*/
+ (t_injectSyncCallback)injectSyncCallback;
- (PEP_STATUS)messageToSend:(struct _message * _Nullable)msg;
- (int)injectSyncEvent:(SYNC_EVENT)event isFromShutdown:(BOOL)isFromShutdown;
- (PEP_STATUS)notifyHandshake:(pEp_identity *)me
partner:(pEp_identity *)partner
signal:(sync_handshake_signal)signal;
- (SYNC_EVENT)retrieveNextSyncEvent:(time_t)threshold;
@end
// MARK: - Callbacks called by the engine, used in session init
static PEP_STATUS s_messageToSendObjc(struct _message * _Nullable msg)
{
PEPSync *pEpSync = [PEPSync sharedInstance];
if (pEpSync) {
return [pEpSync messageToSend:msg];
} else {
return PEP_SYNC_NO_NOTIFY_CALLBACK;
}
}
static int s_inject_sync_event(SYNC_EVENT ev, void *management)
{
PEPSync *pEpSync = [PEPSync sharedInstance];
if (pEpSync) {
// The inject comes from the engine, so we know it's not the
// adapter client calling shutdown.
return [pEpSync injectSyncEvent:ev isFromShutdown:NO];
} else {
return 1;
}
}
// MARK: - Callbacks called by the engine, used in register_sync_callbacks
static PEP_STATUS s_notifyHandshake(pEp_identity *me,
pEp_identity *partner,
sync_handshake_signal signal)
{
PEPSync *pEpSync = [PEPSync sharedInstance];
if (pEpSync) {
return [pEpSync notifyHandshake:me partner:partner signal:signal];
} else {
return PEP_SYNC_NO_NOTIFY_CALLBACK;
}
}
static SYNC_EVENT s_retrieve_next_sync_event(void *management, unsigned threshold)
{
PEPSync *sync = [PEPSync sharedInstance];
return [sync retrieveNextSyncEvent:threshold];
}
// MARK: - Internal globals
static __weak PEPSync *s_pEpSync;
// MARK: - Public PEPSync class
@implementation PEPSync
+ (t_messageToSendCallback)messageToSendCallback
{
return s_messageToSendObjc;
}
+ (t_injectSyncCallback)injectSyncCallback
{
return s_inject_sync_event;
}
+ (PEP_SESSION)createSession:(NSError **)error
{
PEP_SESSION session = NULL;
PEP_STATUS status = init(&session,
[PEPSync messageToSendCallback],
[PEPSync injectSyncCallback]);
if (status != PEP_STATUS_OK) {
if (error) {
*error = [NSError errorWithPEPStatusInternal:status];
os_log(s_logger, "error creating session: %{public}@", *error);
}
return nil;
}
return session;
}
- (instancetype)initWithSendMessageDelegate:(id<PEPSendMessageDelegate>
_Nullable)sendMessageDelegate
notifyHandshakeDelegate:(id<PEPNotifyHandshakeDelegate>
_Nullable)notifyHandshakeDelegate
{
if (self = [super init]) {
_sendMessageDelegate = sendMessageDelegate;
_notifyHandshakeDelegate = notifyHandshakeDelegate;
_queue = [PEPQueue new];
s_pEpSync = self;
}
return self;
}
- (void)startup
{
[self stopWaiting];
if (self.syncThread != nil) {
// already started
return;
}
NSThread *theSyncThread = [[NSThread alloc] initWithTarget:self
selector:@selector(syncThreadLoop:)
object:nil];
theSyncThread.name = @"pEp-sync-loop";
self.syncThread = theSyncThread;
// Make sure queue is empty when we start.
[self.queue removeAllObjects];
[self assureMainSessionExists]; //???: Why do we need that? Afaics syncThreadLoop gets the session from PEPSessionProvider, which should have taken care of main session existance.
self.conditionLockForJoiningSyncThread = [[NSConditionLock alloc] initWithCondition:NO];
[theSyncThread start];
}
- (void)shutdown
{
[self stopWaiting];
if (self.syncThread) {
[self injectSyncEvent:nil isFromShutdown:YES];
}
}
- (void)restartIfRunning
{
if (self.syncThread != nil) { // is running
[self shutdown];
[self startup];
}
}
- (void)handleNewPassphraseConfigured {
[self stopWaiting];
}
// MARK: - Private
+ (void)initialize
{
s_logger = os_log_create("security.pEp.adapter", "PEPSync");
}
+ (PEPSync * _Nullable)sharedInstance //!!!: is not private but internal
{
return s_pEpSync;
}
- (void)assureMainSessionExists
{
PEPInternalSession *session __attribute__((unused)) = [PEPSessionProvider session];
}
- (void)syncThreadLoop:(id)object
{
[self.conditionLockForJoiningSyncThread lock];
os_log(s_logger, "trying to start the sync loop");
self.syncLoopSession = [PEPSessionProvider session];
if (self.syncLoopSession) {
PEP_STATUS status = register_sync_callbacks(self.syncLoopSession.session,
nil,
s_notifyHandshake,
s_retrieve_next_sync_event);
if (status == PEP_STATUS_OK) {
status = do_sync_protocol(self.syncLoopSession.session, nil);
if (status != PEP_STATUS_OK) {
os_log_error(s_logger, "do_sync_protocol returned PEP_STATUS %d", status);
os_log(s_logger, "sync loop is NOT running");
}
unregister_sync_callbacks(self.syncLoopSession.session);
} else {
os_log_error(s_logger, "register_sync_callbacks returned PEP_STATUS %d", status);
os_log(s_logger, "sync loop is NOT running");
}
} else {
os_log_error(s_logger, "could not create session for starting the sync loop");
}
os_log(s_logger, "sync loop finished");
self.syncLoopSession = nil;
self.syncThread = nil;
[self.conditionLockForJoiningSyncThread unlockWithCondition:YES];
}
- (PEP_STATUS)messageToSend:(struct _message * _Nullable)msg
{
[self blockUntilPassphraseIsEnteredIfRequired];
if (msg == NULL && [NSThread currentThread] == self.syncThread) {
static NSMutableArray *passphrasesCopy = nil;
static BOOL makeNewCopy = YES;
if (makeNewCopy) {
passphrasesCopy = [NSMutableArray
arrayWithArray:[self.syncLoopSession.passphraseCache passphrases]];
if (self.syncLoopSession.passphraseCache.storedPassphrase) {
[passphrasesCopy
insertObject:self.syncLoopSession.passphraseCache.storedPassphrase
atIndex:0];
}
if ([passphrasesCopy count] == 0) {
makeNewCopy = YES;
[self nextCallMustWait];
return PEP_PASSPHRASE_REQUIRED;
} else {
makeNewCopy = NO;
}
}
if ([passphrasesCopy count] == 0) {
makeNewCopy = YES;
[self nextCallMustWait];
return PEP_WRONG_PASSPHRASE;
} else {
NSString *password = [passphrasesCopy firstObject];
[passphrasesCopy removeObjectAtIndex:0];
[self.syncLoopSession configurePassphrase:password error:nil];
return PEP_STATUS_OK;
}
} else if (msg != NULL) {
if (self.sendMessageDelegate) {
PEPMessage *theMessage = pEpMessageFromStruct(msg);
return (PEP_STATUS) [self.sendMessageDelegate sendMessage:theMessage];
} else {
return PEP_SYNC_NO_MESSAGE_SEND_CALLBACK;
}
} else {
return PEP_SYNC_ILLEGAL_MESSAGE;
}
}
/// Injects the given event into the queue.
/// @param event The event to inject, which may contain a nil value, which means the
/// sync loop should stop.
/// @param isFromShutdown This is `YES` when coming from `shutdown` itself, and `NO`
/// otherwise (e.g., when the engine requests a shutdown by injecting a nil event.
- (int)injectSyncEvent:(SYNC_EVENT)event isFromShutdown:(BOOL)isFromShutdown
{
NSValue *value = [NSValue valueWithBytes:&event objCType:@encode(SYNC_EVENT)];
if (event) {
[self.queue enqueue:value];
} else {
// This is a nil event, which means shut it all down.
if ([NSThread currentThread] != self.syncThread) {
// Only do this when the shutdown is not coming in on the sync thread.
// Otherwise it will just exit out of the sync loop and be done.
[self.queue prequeue:value];
[self.conditionLockForJoiningSyncThread lockWhenCondition:YES];
[self.conditionLockForJoiningSyncThread unlock];
self.conditionLockForJoiningSyncThread = nil;
}
if (!isFromShutdown) {
// Only inform the delegate if the shutdown came from the engine
[self.notifyHandshakeDelegate engineShutdownKeySync];
}
}
return 0;
}
- (PEP_STATUS)notifyHandshake:(pEp_identity *)me
partner:(pEp_identity *)partner
signal:(sync_handshake_signal)signal
{
if (self.notifyHandshakeDelegate) {
PEPIdentity *meIdentity = PEP_identityFromStruct(me);
PEPIdentity *partnerIdentity = partner != nil ? PEP_identityFromStruct(partner) : nil;
return (PEP_STATUS) [self.notifyHandshakeDelegate
notifyHandshake:NULL
me:meIdentity
partner:partnerIdentity
signal:(PEPSyncHandshakeSignal) signal];
} else {
return PEP_SYNC_NO_NOTIFY_CALLBACK;
}
}
- (SYNC_EVENT)retrieveNextSyncEvent:(time_t)threshold
{
NSValue *value = [self.queue timedDequeue:&threshold];
if (value) {
SYNC_EVENT event;
[value getValue:&event];
return event;
} else {
return new_sync_timeout_event();
}
}
// MARK: Blocking (messageToSend)
- (void)blockUntilPassphraseIsEnteredIfRequired {
if (self.blockmessageToSendGroup) {
dispatch_group_wait(self.blockmessageToSendGroup, DISPATCH_TIME_FOREVER);
}
}
- (void)nextCallMustWait {
if (!self.blockmessageToSendGroup) {
self.blockmessageToSendGroup = dispatch_group_create();
}
dispatch_group_enter(self.blockmessageToSendGroup);
}
- (void)stopWaiting {
if (self.blockmessageToSendGroup) {
dispatch_group_leave(self.blockmessageToSendGroup);
self.blockmessageToSendGroup = nil;
}
}
@end