buzzert/Kordophone
Private
Public Access
1
0
Fork 0
Code Packages Activity

Organize everything into operations

Browse Source
This commit is contained in:
James Magahern
2018-11-13 12:29:15 -08:00
parent 7a3dee7073
commit ce7e6e7dd8
10 changed files with 354 additions and 106 deletions
Download Patch File Download Diff File Expand all files Collapse all files

124
kordophone/Bridge/MBIMBridge.m
View File

@@ -7,6 +7,7 @@
//
#import "MBIMBridge.h"
#import "MBIMBridgeOperation.h"
#import <GCDWebServers/GCDWebServers.h>
@@ -18,12 +19,9 @@
static NSString *const MBIMBridgeToken = @"net.buzzert.kordophone";
static NSString *const kAPIEndpointConversationList = @"conversations";
static NSString *const kAPIEndpointConversationContents = @"messages";
static NSString *const kAPIEndpointSendMessage = @"sendMessage";
@interface MBIMBridge (/* INTERNAL */)
@property (nonatomic, strong) GCDWebServer *webServer;
@property (nonatomic, strong) NSOperationQueue *operationQueue;
- (instancetype)_init;
@end
@@ -50,6 +48,8 @@ static NSString *const kAPIEndpointSendMessage = @"sendMessage";
[sDaemonController setDelegate:self];
[sDaemonListener addHandler:self];
_operationQueue = [[NSOperationQueue alloc] init];
}
return self;
@@ -108,28 +108,21 @@ static NSString *const kAPIEndpointSendMessage = @"sendMessage";
NSLog(@"chat items changed: %@", notification);
}
- (BOOL)_sendMessage:(NSString *)messageBody toChatWithGUID:(NSString *)chatGUID
{
IMAccount *iMessageAccount = [[IMAccountController sharedInstance] bestAccountForService:[IMServiceImpl iMessageService]];
IMHandle *handle = [[iMessageAccount arrayOfAllIMHandles] firstObject];
NSAttributedString *replyAttrString = [[NSAttributedString alloc] initWithString:messageBody];
IMMessage *reply = [IMMessage fromMeIMHandle:handle withText:replyAttrString fileTransferGUIDs:@[] flags:kIMMessageFinished];
IMChat *chat = [sChatRegistry existingChatWithGUID:chatGUID];
if (!chat) {
NSLog(@"Chat does not exist: %@", chatGUID);
return NO;
}
[chat sendMessage:reply];
return YES;
}
#pragma mark -
#pragma mark Web Server initialization
- (void)_handleAsyncServerRequest:(GCDWebServerRequest *)request completion:(GCDWebServerCompletionBlock)completion
{
NSString *endpointName = [[request URL] lastPathComponent];
Class operationClass = [MBIMBridgeOperation operationClassForEndpointName:endpointName];
if (operationClass != nil) {
MBIMBridgeOperation *operation = [[operationClass alloc] initWithRequest:request completion:completion];
[[self operationQueue] addOperation:operation];
} else {
completion([GCDWebServerDataResponse responseWithStatusCode:404]);
}
}
- (void)startWebServer
{
[GCDWebServer setLogLevel:3];
@@ -138,96 +131,15 @@ static NSString *const kAPIEndpointSendMessage = @"sendMessage";
self.webServer = [[GCDWebServer alloc] init];
[self.webServer addDefaultHandlerForMethod:@"GET"
requestClass:[GCDWebServerRequest class]
processBlock:^GCDWebServerResponse * _Nullable(__kindof GCDWebServerRequest * _Nonnull request) { return [weakSelf _handleWebServerRequest:request]; }];
asyncProcessBlock:^(__kindof GCDWebServerRequest * _Nonnull request, GCDWebServerCompletionBlock _Nonnull completionBlock) { [weakSelf _handleAsyncServerRequest:request completion:completionBlock]; }];
[self.webServer addDefaultHandlerForMethod:@"POST"
requestClass:[GCDWebServerURLEncodedFormRequest class]
processBlock:^GCDWebServerResponse * _Nullable(__kindof GCDWebServerRequest * _Nonnull request) { return [weakSelf _handleWebServerPOST:(GCDWebServerURLEncodedFormRequest *)request]; }];
asyncProcessBlock:^(__kindof GCDWebServerRequest * _Nonnull request, GCDWebServerCompletionBlock _Nonnull completionBlock) { [weakSelf _handleAsyncServerRequest:request completion:completionBlock]; }];
[self.webServer startWithPort:8080 bonjourName:nil];
}
- (GCDWebServerResponse *)_handleWebServerPOST:(__kindof GCDWebServerURLEncodedFormRequest * _Nonnull)request
{
NSURLComponents *urlComponents = [NSURLComponents componentsWithURL:[request URL] resolvingAgainstBaseURL:NO];
NSString *endpoint = [[urlComponents path] lastPathComponent];
if ([endpoint isEqualToString:kAPIEndpointSendMessage]) {
NSDictionary *args = [request arguments];
NSString *guid = [args objectForKey:@"guid"];
NSString *messageBody = [args objectForKey:@"body"];
BOOL result = [self _sendMessage:messageBody toChatWithGUID:guid];
if (result) {
return [GCDWebServerDataResponse responseWithStatusCode:200];
} else {
return [GCDWebServerDataResponse responseWithStatusCode:500];
}
}
return [GCDWebServerDataResponse responseWithStatusCode:404];
}
- (GCDWebServerResponse *)_handleWebServerRequest:(__kindof GCDWebServerRequest * _Nonnull)request
{
NSURLComponents *urlComponents = [NSURLComponents componentsWithURL:[request URL] resolvingAgainstBaseURL:NO];
NSString *endpoint = [[urlComponents path] lastPathComponent];
if ([endpoint isEqualToString:kAPIEndpointConversationList]) {
NSArray<IMChat *> *chats = [sChatRegistry allExistingChats];
NSMutableArray *conversations = [NSMutableArray array];
for (IMChat *chat in chats) {
NSMutableDictionary *chatDict = [NSMutableDictionary dictionary];
chatDict[@"guid"] = [chat guid];
chatDict[@"displayName"] = [chat displayName];
chatDict[@"date"] = GCDWebServerFormatRFC822([chat lastFinishedMessageDate]);
[conversations addObject:chatDict];
}
return [GCDWebServerDataResponse responseWithJSONObject:conversations];
}
if ([endpoint isEqualToString:kAPIEndpointConversationContents]) {
NSString *guid = nil;
for (NSURLQueryItem *queryItem in [urlComponents queryItems]) {
if ([[queryItem name] isEqualToString:@"guid"]) {
guid = [queryItem value];
break;
}
}
if (!guid) {
NSLog(@"No query item provided");
return [GCDWebServerDataResponse responseWithStatusCode:500];
}
IMChat *chat = [sChatRegistry existingChatWithGUID:guid];
if (!chat) {
NSLog(@"Chat with guid: %@ not found", guid);
return [GCDWebServerDataResponse responseWithStatusCode:500];
}
// Load messages
[chat loadMessagesBeforeDate:[NSDate date] limit:50 loadImmediately:YES];
NSMutableArray *messages = [NSMutableArray array];
for (IMMessageItem *imMessage in [[chat chatItems] messages]) {
NSMutableDictionary *messageDict = [NSMutableDictionary dictionary];
messageDict[@"text"] = [[imMessage body] string];
messageDict[@"date"] = GCDWebServerFormatRFC822([imMessage time]);
messageDict[@"sender"] = [imMessage sender];
[messages addObject:messageDict];
}
return [GCDWebServerDataResponse responseWithJSONObject:messages];
}
return [GCDWebServerDataResponse responseWithStatusCode:404];
}
#pragma mark -
#pragma mark Daemon lifecycle

25
kordophone/Bridge/Operations/MBIMBridgeOperation.h Normal file
View File

@@ -0,0 +1,25 @@
//
// MBIMBridgeOperation.h
// kordophoned
//
// Created by James Magahern on 11/13/18.
// Copyright © 2018 James Magahern. All rights reserved.
//
#import <Foundation/Foundation.h>
#import <GCDWebServers/GCDWebServers.h>
NS_ASSUME_NONNULL_BEGIN
@interface MBIMBridgeOperation : NSOperation
@property (class, nonatomic, readonly) NSString *endpointName;
@property (nonatomic, readonly) GCDWebServerRequest *request;
@property (nonatomic, readonly) GCDWebServerCompletionBlock serverCompletionBlock;
+ (nullable Class)operationClassForEndpointName:(NSString *)endpointName;
- (instancetype)initWithRequest:(GCDWebServerRequest *)request completion:(GCDWebServerCompletionBlock)completionBlock;
@end
NS_ASSUME_NONNULL_END

58
kordophone/Bridge/Operations/MBIMBridgeOperation.m Normal file
View File

@@ -0,0 +1,58 @@
//
// MBIMBridgeOperation.m
// kordophoned
//
// Created by James Magahern on 11/13/18.
// Copyright © 2018 James Magahern. All rights reserved.
//
#import "MBIMBridgeOperation.h"
@interface MBIMBridgeOperation (/*INTERNAL*/)
@property (nonatomic, copy) GCDWebServerCompletionBlock serverCompletionBlock;
@property (nonatomic, strong) GCDWebServerRequest *request;
@end
@implementation MBIMBridgeOperation
+ (NSString *)endpointName
{
// To be inplemented by subclasses
return @"__unimplemented__";
}
+ (NSMutableDictionary *)_operationClassMapping
{
static dispatch_once_t onceToken;
static NSMutableDictionary *operationClassMapping = nil;
dispatch_once(&onceToken, ^{
operationClassMapping = [[NSMutableDictionary alloc] init];
});
return operationClassMapping;
}
+ (void)load
{
if ([self class] != [MBIMBridgeOperation class]) {
[[self _operationClassMapping] setObject:[self class] forKey:[self endpointName]];
}
}
+ (nullable Class)operationClassForEndpointName:(NSString *)endpointName
{
return [[self _operationClassMapping] objectForKey:endpointName];
}
- (instancetype)initWithRequest:(GCDWebServerRequest *)request completion:(GCDWebServerCompletionBlock)completionBlock
{
self = [super init];
if (self) {
self.request = request;
self.serverCompletionBlock = completionBlock;
}
return self;
}
@end

17
kordophone/Bridge/Operations/MBIMConversationListOperation.h Normal file
View File

@@ -0,0 +1,17 @@
//
// MBIMConversationListOperation.h
// kordophoned
//
// Created by James Magahern on 11/13/18.
// Copyright © 2018 James Magahern. All rights reserved.
//
#import "MBIMBridgeOperation.h"
NS_ASSUME_NONNULL_BEGIN
@interface MBIMConversationListOperation : MBIMBridgeOperation
@end
NS_ASSUME_NONNULL_END

40
kordophone/Bridge/Operations/MBIMConversationListOperation.m Normal file
View File

@@ -0,0 +1,40 @@
//
// MBIMConversationListOperation.m
// kordophoned
//
// Created by James Magahern on 11/13/18.
// Copyright © 2018 James Magahern. All rights reserved.
//
#import "MBIMConversationListOperation.h"
#import <IMCore/IMCore.h>
@implementation MBIMConversationListOperation
+ (void)load { [super load]; }
+ (NSString *)endpointName
{
return @"conversations";
}
- (void)main
{
NSArray<IMChat *> *chats = [sChatRegistry allExistingChats];
NSMutableArray *conversations = [NSMutableArray array];
for (IMChat *chat in chats) {
NSMutableDictionary *chatDict = [NSMutableDictionary dictionary];
chatDict[@"guid"] = [chat guid];
chatDict[@"displayName"] = [chat displayName];
chatDict[@"date"] = GCDWebServerFormatRFC822([chat lastFinishedMessageDate]);
[conversations addObject:chatDict];
}
GCDWebServerResponse *response = [GCDWebServerDataResponse responseWithJSONObject:conversations];
self.serverCompletionBlock(response);
}
@end

17
kordophone/Bridge/Operations/MBIMMessagesListOperation.h Normal file
View File

@@ -0,0 +1,17 @@
//
// MBIMMessagesListOperation.h
// kordophoned
//
// Created by James Magahern on 11/13/18.
// Copyright © 2018 James Magahern. All rights reserved.
//
#import "MBIMBridgeOperation.h"
NS_ASSUME_NONNULL_BEGIN
@interface MBIMMessagesListOperation : MBIMBridgeOperation
@end
NS_ASSUME_NONNULL_END

67
kordophone/Bridge/Operations/MBIMMessagesListOperation.m Normal file
View File

@@ -0,0 +1,67 @@
//
// MBIMMessagesListOperation.m
// kordophoned
//
// Created by James Magahern on 11/13/18.
// Copyright © 2018 James Magahern. All rights reserved.
//
#import "MBIMMessagesListOperation.h"
#import <IMCore/IMCore.h>
@implementation MBIMMessagesListOperation
+ (void)load { [super load]; }
+ (NSString *)endpointName
{
return @"messages";
}
- (void)main
{
GCDWebServerResponse *response = nil;
do {
NSURLComponents *urlComponents = [NSURLComponents componentsWithURL:[self.request URL] resolvingAgainstBaseURL:NO];
NSString *guid = nil;
for (NSURLQueryItem *queryItem in [urlComponents queryItems]) {
if ([[queryItem name] isEqualToString:@"guid"]) {
guid = [queryItem value];
break;
}
}
if (!guid) {
NSLog(@"No query item provided");
response = [GCDWebServerDataResponse responseWithStatusCode:500];
break;
}
IMChat *chat = [sChatRegistry existingChatWithGUID:guid];
if (!chat) {
NSLog(@"Chat with guid: %@ not found", guid);
response = [GCDWebServerDataResponse responseWithStatusCode:500];
break;
}
// Load messages
[chat loadMessagesBeforeDate:[NSDate date] limit:50 loadImmediately:YES];
NSMutableArray *messages = [NSMutableArray array];
for (IMMessageItem *imMessage in [[chat chatItems] messages]) {
NSMutableDictionary *messageDict = [NSMutableDictionary dictionary];
messageDict[@"text"] = [[imMessage body] string];
messageDict[@"date"] = GCDWebServerFormatRFC822([imMessage time]);
messageDict[@"sender"] = [imMessage sender];
[messages addObject:messageDict];
}
response = [GCDWebServerDataResponse responseWithJSONObject:messages];
} while (0);
self.serverCompletionBlock(response);
}
@end

17
kordophone/Bridge/Operations/MBIMSendMessageOperation.h Normal file
View File

@@ -0,0 +1,17 @@
//
// MBIMSendMessageOperation.h
// kordophoned
//
// Created by James Magahern on 11/13/18.
// Copyright © 2018 James Magahern. All rights reserved.
//
#import "MBIMBridgeOperation.h"
NS_ASSUME_NONNULL_BEGIN
@interface MBIMSendMessageOperation : MBIMBridgeOperation
@end
NS_ASSUME_NONNULL_END

63
kordophone/Bridge/Operations/MBIMSendMessageOperation.m Normal file
View File

@@ -0,0 +1,63 @@
//
// MBIMSendMessageOperation.m
// kordophoned
//
// Created by James Magahern on 11/13/18.
// Copyright © 2018 James Magahern. All rights reserved.
//
#import "MBIMSendMessageOperation.h"
#import <IMCore/IMCore.h>
#import <IMCore/IMCore_Private.h>
@implementation MBIMSendMessageOperation
+ (void)load { [super load]; }
+ (NSString *)endpointName
{
return @"sendMessage";
}
- (BOOL)_sendMessage:(NSString *)messageBody toChatWithGUID:(NSString *)chatGUID
{
IMAccount *iMessageAccount = [[IMAccountController sharedInstance] bestAccountForService:[IMServiceImpl iMessageService]];
IMHandle *handle = [[iMessageAccount arrayOfAllIMHandles] firstObject];
NSAttributedString *replyAttrString = [[NSAttributedString alloc] initWithString:messageBody];
IMMessage *reply = [IMMessage fromMeIMHandle:handle withText:replyAttrString fileTransferGUIDs:@[] flags:kIMMessageFinished];
IMChat *chat = [sChatRegistry existingChatWithGUID:chatGUID];
if (!chat) {
NSLog(@"Chat does not exist: %@", chatGUID);
return NO;
}
[chat sendMessage:reply];
return YES;
}
- (void)main
{
assert([self.request isKindOfClass:[GCDWebServerURLEncodedFormRequest class]]);
GCDWebServerURLEncodedFormRequest *formRequest = (GCDWebServerURLEncodedFormRequest *)self.request;
NSDictionary *args = [formRequest arguments];
NSString *guid = [args objectForKey:@"guid"];
NSString *messageBody = [args objectForKey:@"body"];
BOOL result = [self _sendMessage:messageBody toChatWithGUID:guid];
GCDWebServerResponse *response = nil;
if (result) {
response = [GCDWebServerDataResponse responseWithStatusCode:200];
} else {
response = [GCDWebServerDataResponse responseWithStatusCode:500];
}
self.serverCompletionBlock(response);
}
@end