(root)/iphone/tappity : /source/TappityClient.m (revision 62)

//

//  TappityClient.m

//  tappity

//

//  Created by döme on 25.10.2009.

//

/*

 * Copyright (c) 2009 Doemoetoer Gulyas.

 * All rights reserved.

 *

 * Redistribution and use in source and binary forms, with or without

 * modification, are permitted provided that the following conditions

 * are met:

 * 1. Redistributions of source code must retain the above copyright

 *    notice, this list of conditions and the following disclaimer.

 * 2. Redistributions in binary form must reproduce the above copyright

 *    notice, this list of conditions and the following disclaimer in the

 *    documentation and/or other materials provided with the distribution.

 * 3. The name of the author may not be used to endorse or promote products

 *    derived from this software without specific prior written permission.

 *

 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``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 AUTHOR 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.

 */

#import "TappityClient.h"

#import "Tappity.h"

#include <sys/types.h>

#include <sys/socket.h>

#include <netdb.h>

#include <netinet/in.h>

#include <sys/time.h>

#import <CoreLocation/CoreLocation.h>

@implementation TappityClient

- (id) init

{

	if (!(self = [super init]))

		return nil;

	messenger = [[SocketMessenger alloc] init];

	[messenger setDelegate: self];

	[messenger setReceiveDataOnMainThread: NO];

	[messenger setAutomaticallyReconnect: NO];

	enableFeedbackVideoDisplay = YES;

	return self;

}

- (void) connectionWasTerminated: (SocketMessenger*) theMessenger

{

	NSLog(@"%s", _cmd);

	if ([delegate respondsToSelector: @selector(connectionWasTerminated:)])

		[delegate connectionWasTerminated: theMessenger];

}

- (void) connectionWasEstablished: (SocketMessenger*) theMessenger

{

	if (enableFeedbackVideoDisplay)

	{

		NSLog(@"enabling visual uplink");

		[messenger sendData: [NSData data] withIdentifier: kTapStartSendingVisualFeedback];

	}

}

- (void)locationManager:(CLLocationManager *)manager

	didUpdateToLocation:(CLLocation *)newLoc

	fromLocation:(CLLocation *)oldLocation

{

	NSData* data = [NSKeyedArchiver archivedDataWithRootObject: newLoc];

	assert(data);

	[messenger sendData: data withIdentifier: kTapLocation];

}

- (void)locationManager:(CLLocationManager *)manager didUpdateHeading:(CLHeading *)heading

{

	NSData* data = [NSKeyedArchiver archivedDataWithRootObject: heading];

	assert(data);

	[messenger sendData: data withIdentifier: kTapCompass];

}

- (void) accelerometer: (UIAccelerometer *) accelerometer didAccelerate: (UIAcceleration*) acceleration

{

	NSArray* ary = [NSArray arrayWithObjects: [NSNumber numberWithFloat: [acceleration x]], [NSNumber numberWithFloat: [acceleration y]], [NSNumber numberWithFloat: [acceleration z]], [NSNumber numberWithDouble: [acceleration timestamp]], nil];

	NSData* data = [NSPropertyListSerialization dataFromPropertyList: ary format: NSPropertyListBinaryFormat_v1_0 errorDescription: nil];

	assert(data);

	[messenger sendData: data withIdentifier: kTapAcceleration];

}

- (void) recordApplicationEvent: (NSDictionary*) event

{

//	NSLog(@"%@", event);

	CGRect screenRect = [[UIScreen mainScreen] bounds];

	long type = [[event objectForKey: @"Type"] integerValue];

	if ((type == 2005) || (type == 2007)) // suspend and quit events

		return;

	if (type == 3001) // touch event

	{

		NSMutableDictionary* mdict = [event mutableCopy];

		[mdict setObject: NSStringFromCGRect(screenRect) forKey: @"UIScreen bounds"];

		event = mdict;

	}

	NSData* data = [NSPropertyListSerialization dataFromPropertyList: event format: NSPropertyListBinaryFormat_v1_0 errorDescription: nil];

	assert(data);

	[messenger sendData: data withIdentifier: kTapRecordedEvent];

}

static size_t _write_i8(void* buf, uint8_t val)

{

	memcpy(buf, &val, 1);

	return 1;

}

static size_t _write_i16(void* buf, uint16_t val)

{

	val = CFSwapInt16HostToBig(val);

	memcpy(buf, &val, 2);

	return 2;

}

static size_t _write_i32(void* buf, uint32_t val)

{

	val = CFSwapInt32HostToBig(val);

	memcpy(buf, &val, 4);

	return 4;

}

static size_t _write_i64(void* buf, uint64_t val)

{

	val = CFSwapInt64HostToBig(val);

	memcpy(buf, &val, 8);

	return 8;

}

static size_t _write_float(void* buf, float val)

{

	CFSwappedFloat32 v = CFConvertFloat32HostToSwapped(val);

	memcpy(buf, &v, 4);

	return 4;

}

/*

static size_t _write_gspoint(void* buf, GSTouchPointRef p)

{

	size_t bc = 0;

	bc += _write_i32(buf+bc, p->unk0);

	bc += _write_float(buf+bc, p->unk1);

	bc += _write_float(buf+bc, p->touchSize);

	bc += _write_float(buf+bc, p->x);

	bc += _write_float(buf+bc, p->y);

	bc += _write_i32(buf+bc, (uint32_t)p->window);

	return bc;

}

*/

/*

- (id) plistWithTouches: (NSSet*) touches

{

	NSMutableArray* ary = [NSMutableArray array];

	for (UITouch* touch in touches)

	{

		NSMutableData* tdata = [NSMutableData dataWithLength: sizeof(UITouch)];

		size_t bc = 0;

		void* buf = [tdata mutableBytes];

		bc += _write_double(buf+bc, touch->_timestamp);

	}

	return ary;

}

*/

- (void) sendTouch: (UIEvent*) event inPhase: (int) phase

{

	return;

/*

	NSMutableDictionary* touchDict = [NSMutableDictionary dictionaryWithObjectsAndKeys: [NSNumber numberWithInt: kTapTouchEvent], TapIdKey, nil];

//	[touchDict setObject: [self touchesAsPlist: [event allTouches]] forKey: TapTouchesKey];

	GSEvent* gse = [event _gsEvent];

	NSMutableData* gsData = [NSMutableData dataWithLength: sizeof(GSEvent)];

	size_t bc = 0;

	void* buf = [gsData mutableBytes];

	bc += _write_i32(buf + bc, gse->type0);

	bc += _write_i32(buf + bc, gse->type1);

	bc += _write_i32(buf + bc, gse->r3);

	bc += _write_float(buf + bc, gse->avgX0);

	bc += _write_float(buf + bc, gse->avgY0);

	bc += _write_float(buf + bc, gse->avgX1);

	bc += _write_float(buf + bc, gse->avgY1);

	bc += _write_i32(buf + bc, gse->processId);

	bc += _write_i64(buf + bc, gse->timestamp);

	bc += _write_i32(buf + bc, (uint32_t)gse->window);

	bc += _write_i32(buf + bc, gse->r11);

	bc += _write_i32(buf + bc, gse->type12);

	bc += _write_i32(buf + bc, gse->gesture13);

	bc += _write_i32(buf + bc, gse->gesture14);

	bc += _write_i16(buf + bc, gse->numInitialTouches);

	bc += _write_i16(buf + bc, gse->numCurrentTouches);

	bc += _write_i32(buf + bc, gse->r16);

	bc += _write_i32(buf + bc, gse->r17);

	bc += _write_i32(buf + bc, gse->r18);

	bc += _write_i32(buf + bc, gse->r19);

	bc += _write_i32(buf + bc, gse->r20);

	bc += _write_i32(buf + bc, gse->r21);

	bc += _write_i8(buf + bc, gse->r22_0);

	bc += _write_i8(buf + bc, gse->numPoints);

	bc += _write_i8(buf + bc, gse->r22_2);

	for (size_t i = 0; i < gse->numPoints; ++i)

		bc += _write_gspoint(buf+bc, gse->points+i);

	[touchDict setObject: gsData forKey: TapGSEventKey];

	[touchDict setObject: [NSNumber numberWithInt: phase] forKey: TapTouchPhaseKey];

	//[touchDict setObject: [self plistWithTouches: [event allTouches]] forKey: TapTouchesKey];

	NSData* data = [NSPropertyListSerialization dataFromPropertyList: touchDict format: NSPropertyListBinaryFormat_v1_0 errorDescription: nil];

	assert(data);

	[self sendData: data];

*/

}

- (void) stopUpdatingHeading

{

	[lm stopUpdatingHeading];

}

- (void) stopUpdatingLocation

{

	[lm stopUpdatingLocation];

}

- (void) startUpdatingHeading

{

	if (!lm)

	{

		lm = [[CLLocationManager alloc] init];

		[lm setDelegate: self];

	}

	if (enableCompass)

	{

		[lm setHeadingFilter: kCLHeadingFilterNone];

		[lm startUpdatingHeading];

	}

}

- (void) startUpdatingLocation

{

	if (!lm)

	{

		lm = [[CLLocationManager alloc] init];

		[lm setDelegate: self];

	}

	if (enableLocation)

	{

		[lm setDistanceFilter: kCLDistanceFilterNone];

		[lm setDesiredAccuracy: kCLLocationAccuracyBest];

		[lm startUpdatingLocation];

	}

}

- (void) setAccelerometerUpdateInterval: (NSNumber*) num

{

	if (!enableAccelerometer)

		return;

	[[UIAccelerometer sharedAccelerometer] setDelegate: self];

	[[UIAccelerometer sharedAccelerometer] setUpdateInterval: [num doubleValue]];

}

- (void) dataReceived: (NSDictionary*) dataDict

{

	uint32_t messageId = [[dataDict objectForKey: SocketMessageIdKey] intValue];

	NSData* data = [dataDict objectForKey: SocketMessageDataKey];

	switch (messageId)

	{

		case kTapRawScreenshot:

		{

			UIImage* img = [UIImage imageWithData: data];

		//	NSLog(@"got image %@", img);

			if(delegate)

				[delegate setImage: img];

			break;

		}

		case kTapPlacedScreenshot:

		{

			NSDictionary* dict = [NSPropertyListSerialization propertyListFromData: data mutabilityOption: NSPropertyListImmutable format: nil errorDescription: nil];

			UIImage* img = [UIImage imageWithData: [dict objectForKey: TapImageDataKey]];

		//	NSLog(@"got image %@", img);

			if(delegate)

				[delegate setImage: img];

			break;

		}

		case kTapStartUpdatingHeading:

			[self performSelectorOnMainThread: @selector(startUpdatingHeading) withObject: nil waitUntilDone: NO];

			break;

		case kTapStopUpdatingHeading:

			[self performSelectorOnMainThread: @selector(stopUpdatingHeading) withObject: nil waitUntilDone: NO];

			break;

		case kTapStartUpdatingLocation:

			[self performSelectorOnMainThread: @selector(startUpdatingLocation) withObject: nil waitUntilDone: NO];

			break;

		case kTapStopUpdatingLocation:

			[self performSelectorOnMainThread: @selector(stopUpdatingLocation) withObject: nil waitUntilDone: NO];

			break;

		case kTapAccelerometerUpdateInterval:

		{

			CFSwappedFloat64 sf = *(CFSwappedFloat64*)[data bytes];

			[self performSelectorOnMainThread: @selector(setAccelerometerUpdateInterval:) withObject: [NSNumber numberWithDouble: CFConvertFloat64SwappedToHost(sf)] waitUntilDone: NO];

			break;

		}

	}

	[data release];

}

- (void) connectToService: (NSNetService*) service

{

	[messenger connectToService: service];

}

- (void) terminateConnection

{

	[messenger terminateConnection];

}

- (void) dealloc

{

	[messenger terminateConnection];

	[messenger release];

	[lm release];

	[super dealloc];

}

@synthesize delegate, enableAccelerometer, enableCompass, enableLocation, enableFeedbackVideoDisplay;

@end