2007-02-25 02:43:56 +00:00
|
|
|
/*
|
|
|
|
* $Id: AudioScrobbler.m 238 2007-01-26 22:55:20Z stephen_booth $
|
|
|
|
*
|
|
|
|
* Copyright (C) 2006 - 2007 Stephen F. Booth <me@sbooth.org>
|
|
|
|
*
|
|
|
|
* This program is free software; you can redistribute it and/or modify
|
|
|
|
* it under the terms of the GNU General Public License as published by
|
|
|
|
* the Free Software Foundation; either version 2 of the License, or
|
|
|
|
* (at your option) any later version.
|
|
|
|
*
|
|
|
|
* This program is distributed in the hope that it will be useful,
|
|
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
|
* GNU General Public License for more details.
|
|
|
|
*
|
|
|
|
* You should have received a copy of the GNU General Public License
|
|
|
|
* along with this program; if not, write to the Free Software
|
|
|
|
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
|
|
|
*/
|
|
|
|
|
|
|
|
#import "AudioScrobbler.h"
|
|
|
|
|
|
|
|
#import "AudioScrobblerClient.h"
|
|
|
|
#import "PlaylistEntry.h"
|
|
|
|
|
2013-10-11 12:03:55 +00:00
|
|
|
#import "Logging.h"
|
|
|
|
|
2007-07-05 23:24:25 +00:00
|
|
|
// ========================================
|
|
|
|
// Symbolic Constants
|
|
|
|
// ========================================
|
2007-10-12 03:25:11 +00:00
|
|
|
NSString * const AudioScrobblerRunLoopMode = @"org.cogx.Cog.AudioScrobbler.RunLoopMode";
|
2007-07-05 23:24:25 +00:00
|
|
|
|
|
|
|
// ========================================
|
|
|
|
// Helpers
|
|
|
|
// ========================================
|
2007-02-25 02:43:56 +00:00
|
|
|
static NSString *
|
|
|
|
escapeForLastFM(NSString *string)
|
|
|
|
{
|
|
|
|
NSMutableString *result = [string mutableCopy];
|
|
|
|
|
|
|
|
[result replaceOccurrencesOfString:@"&"
|
|
|
|
withString:@"&&"
|
|
|
|
options:NSLiteralSearch
|
|
|
|
range:NSMakeRange(0, [result length])];
|
|
|
|
|
|
|
|
return (nil == result ? @"" : [result autorelease]);
|
|
|
|
}
|
|
|
|
|
|
|
|
@interface AudioScrobbler (Private)
|
|
|
|
|
|
|
|
- (NSMutableArray *) queue;
|
|
|
|
- (NSString *) pluginID;
|
|
|
|
|
|
|
|
- (void) sendCommand:(NSString *)command;
|
|
|
|
|
|
|
|
- (BOOL) keepProcessingAudioScrobblerCommands;
|
|
|
|
- (void) setKeepProcessingAudioScrobblerCommands:(BOOL)keepProcessingAudioScrobblerCommands;
|
|
|
|
|
|
|
|
- (BOOL) audioScrobblerThreadCompleted;
|
|
|
|
- (void) setAudioScrobblerThreadCompleted:(BOOL)audioScrobblerThreadCompleted;
|
|
|
|
|
|
|
|
- (semaphore_t) semaphore;
|
|
|
|
|
2009-03-28 03:00:45 +00:00
|
|
|
- (void) processAudioScrobblerCommands:(id)unused;
|
2007-02-25 02:43:56 +00:00
|
|
|
|
|
|
|
@end
|
|
|
|
|
|
|
|
@implementation AudioScrobbler
|
|
|
|
|
|
|
|
- (id) init
|
|
|
|
{
|
|
|
|
if((self = [super init])) {
|
|
|
|
|
2007-07-05 23:25:10 +00:00
|
|
|
_pluginID = @"cog";
|
2013-10-11 12:37:11 +00:00
|
|
|
|
|
|
|
if([[NSUserDefaults standardUserDefaults] boolForKey:@"automaticallyLaunchLastFM"]) {
|
|
|
|
|
|
|
|
NSArray *launchedApps = [[NSWorkspace sharedWorkspace] runningApplications];
|
|
|
|
BOOL running = NO;
|
|
|
|
for(NSRunningApplication *app in launchedApps) {
|
2013-10-12 21:43:46 +00:00
|
|
|
if([[app bundleIdentifier] isEqualToString:@"fm.last.Last.fm"] ||
|
|
|
|
[[app bundleIdentifier] isEqualToString:@"fm.last.Scrobbler"]) {
|
2013-10-11 12:37:11 +00:00
|
|
|
running = YES;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if(!running) {
|
|
|
|
[[NSWorkspace sharedWorkspace] launchApplication:@"Last.fm.app"];
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2007-02-25 02:43:56 +00:00
|
|
|
_keepProcessingAudioScrobblerCommands = YES;
|
|
|
|
|
|
|
|
kern_return_t result = semaphore_create(mach_task_self(), &_semaphore, SYNC_POLICY_FIFO, 0);
|
|
|
|
|
|
|
|
if(KERN_SUCCESS != result) {
|
2013-10-11 12:03:55 +00:00
|
|
|
ALog(@"Couldn't create semaphore (%s).", mach_error_type(result));
|
2007-02-25 02:43:56 +00:00
|
|
|
|
|
|
|
[self release];
|
|
|
|
return nil;
|
|
|
|
}
|
|
|
|
|
2009-03-28 03:00:45 +00:00
|
|
|
[NSThread detachNewThreadSelector:@selector(processAudioScrobblerCommands:) toTarget:self withObject:nil];
|
2007-02-25 02:43:56 +00:00
|
|
|
}
|
|
|
|
return self;
|
|
|
|
}
|
|
|
|
|
|
|
|
- (void) dealloc
|
|
|
|
{
|
2007-07-05 23:24:25 +00:00
|
|
|
if([self keepProcessingAudioScrobblerCommands] || NO == [self audioScrobblerThreadCompleted])
|
2007-02-25 02:43:56 +00:00
|
|
|
[self shutdown];
|
|
|
|
|
|
|
|
[_queue release], _queue = nil;
|
|
|
|
|
|
|
|
semaphore_destroy(mach_task_self(), _semaphore), _semaphore = 0;
|
|
|
|
|
|
|
|
[super dealloc];
|
|
|
|
}
|
|
|
|
|
|
|
|
- (void) start:(PlaylistEntry *)pe
|
|
|
|
{
|
2007-07-05 23:24:25 +00:00
|
|
|
[self sendCommand:[NSString stringWithFormat:@"START c=%@&a=%@&t=%@&b=%@&m=%@&l=%i&p=%@\n",
|
|
|
|
[self pluginID],
|
|
|
|
escapeForLastFM([pe artist]),
|
|
|
|
escapeForLastFM([pe title]),
|
|
|
|
escapeForLastFM([pe album]),
|
|
|
|
@"", // TODO: MusicBrainz support
|
2008-03-09 16:19:14 +00:00
|
|
|
[[pe length] intValue],
|
2008-02-20 00:44:40 +00:00
|
|
|
escapeForLastFM([[pe URL] path])
|
2007-07-05 23:24:25 +00:00
|
|
|
]];
|
2007-02-25 02:43:56 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
- (void) stop
|
|
|
|
{
|
|
|
|
[self sendCommand:[NSString stringWithFormat:@"STOP c=%@\n", [self pluginID]]];
|
|
|
|
}
|
|
|
|
|
|
|
|
- (void) pause
|
|
|
|
{
|
|
|
|
[self sendCommand:[NSString stringWithFormat:@"PAUSE c=%@\n", [self pluginID]]];
|
|
|
|
}
|
|
|
|
|
|
|
|
- (void) resume
|
|
|
|
{
|
|
|
|
[self sendCommand:[NSString stringWithFormat:@"RESUME c=%@\n", [self pluginID]]];
|
|
|
|
}
|
|
|
|
|
|
|
|
- (void) shutdown
|
|
|
|
{
|
|
|
|
[self setKeepProcessingAudioScrobblerCommands:NO];
|
|
|
|
semaphore_signal([self semaphore]);
|
|
|
|
|
|
|
|
// Wait for the thread to terminate
|
2007-07-05 23:24:25 +00:00
|
|
|
while(NO == [self audioScrobblerThreadCompleted])
|
|
|
|
[[NSRunLoop currentRunLoop] runMode:AudioScrobblerRunLoopMode beforeDate:[NSDate dateWithTimeIntervalSinceNow:0.2]];
|
2007-02-25 02:43:56 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
@end
|
|
|
|
|
|
|
|
@implementation AudioScrobbler (Private)
|
|
|
|
|
|
|
|
- (NSMutableArray *) queue
|
|
|
|
{
|
2007-07-05 23:24:25 +00:00
|
|
|
if(nil == _queue)
|
2007-02-25 02:43:56 +00:00
|
|
|
_queue = [[NSMutableArray alloc] init];
|
|
|
|
|
|
|
|
return _queue;
|
|
|
|
}
|
|
|
|
|
|
|
|
- (NSString *) pluginID
|
|
|
|
{
|
|
|
|
return _pluginID;
|
|
|
|
}
|
|
|
|
|
|
|
|
- (void) sendCommand:(NSString *)command
|
|
|
|
{
|
|
|
|
@synchronized([self queue]) {
|
|
|
|
[[self queue] addObject:command];
|
|
|
|
}
|
|
|
|
semaphore_signal([self semaphore]);
|
|
|
|
}
|
|
|
|
|
|
|
|
- (BOOL) keepProcessingAudioScrobblerCommands
|
|
|
|
{
|
|
|
|
return _keepProcessingAudioScrobblerCommands;
|
|
|
|
}
|
|
|
|
|
|
|
|
- (void) setKeepProcessingAudioScrobblerCommands:(BOOL)keepProcessingAudioScrobblerCommands
|
|
|
|
{
|
|
|
|
_keepProcessingAudioScrobblerCommands = keepProcessingAudioScrobblerCommands;
|
|
|
|
}
|
|
|
|
|
|
|
|
- (BOOL) audioScrobblerThreadCompleted
|
|
|
|
{
|
|
|
|
return _audioScrobblerThreadCompleted;
|
|
|
|
}
|
|
|
|
|
|
|
|
- (void) setAudioScrobblerThreadCompleted:(BOOL)audioScrobblerThreadCompleted
|
|
|
|
{
|
|
|
|
_audioScrobblerThreadCompleted = audioScrobblerThreadCompleted;
|
|
|
|
}
|
|
|
|
|
|
|
|
- (semaphore_t) semaphore
|
|
|
|
{
|
|
|
|
return _semaphore;
|
|
|
|
}
|
|
|
|
|
2009-03-28 03:00:45 +00:00
|
|
|
- (void) processAudioScrobblerCommands:(id)unused
|
2007-02-25 02:43:56 +00:00
|
|
|
{
|
2007-10-13 07:51:42 +00:00
|
|
|
NSAutoreleasePool *pool = [[NSAutoreleasePool alloc] init];
|
2007-02-25 02:43:56 +00:00
|
|
|
AudioScrobblerClient *client = [[AudioScrobblerClient alloc] init];
|
|
|
|
mach_timespec_t timeout = { 5, 0 };
|
|
|
|
NSString *command = nil;
|
|
|
|
NSString *response = nil;
|
|
|
|
in_port_t port = 33367;
|
|
|
|
|
2009-03-28 03:00:45 +00:00
|
|
|
while([self keepProcessingAudioScrobblerCommands]) {
|
2007-10-13 07:51:42 +00:00
|
|
|
NSAutoreleasePool *pool = [[NSAutoreleasePool alloc] init];
|
2007-02-25 02:43:56 +00:00
|
|
|
|
|
|
|
// Get the first command to be sent
|
2009-03-28 03:00:45 +00:00
|
|
|
@synchronized([self queue]) {
|
2013-10-10 08:44:45 +00:00
|
|
|
if ([[self queue] count]) {
|
|
|
|
command = [[self queue] objectAtIndex:0];
|
|
|
|
[[self queue] removeObjectAtIndex:0];
|
|
|
|
}
|
2007-02-25 02:43:56 +00:00
|
|
|
}
|
|
|
|
|
2009-03-28 03:00:45 +00:00
|
|
|
if(nil != command) {
|
2007-02-25 02:43:56 +00:00
|
|
|
@try {
|
2007-07-05 23:24:25 +00:00
|
|
|
if([client connectToHost:@"localhost" port:port]) {
|
|
|
|
port = [client connectedPort];
|
|
|
|
[client send:command];
|
|
|
|
[command release];
|
|
|
|
|
|
|
|
response = [client receive];
|
|
|
|
if(2 > [response length] || NSOrderedSame != [response compare:@"OK" options:NSLiteralSearch range:NSMakeRange(0,2)])
|
2013-10-11 12:03:55 +00:00
|
|
|
ALog(@"AudioScrobbler error: %@", response);
|
2007-07-05 23:24:25 +00:00
|
|
|
|
|
|
|
[client shutdown];
|
2007-02-25 02:43:56 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
@catch(NSException *exception) {
|
|
|
|
[client shutdown];
|
2013-10-11 12:03:55 +00:00
|
|
|
// ALog(@"Exception: %@",exception);
|
2007-10-13 07:51:42 +00:00
|
|
|
[pool release];
|
2007-02-25 02:43:56 +00:00
|
|
|
continue;
|
|
|
|
}
|
|
|
|
}
|
2007-10-13 07:51:42 +00:00
|
|
|
|
2009-03-28 03:00:45 +00:00
|
|
|
semaphore_timedwait([self semaphore], timeout);
|
2007-10-13 07:51:42 +00:00
|
|
|
[pool release];
|
2007-02-25 02:43:56 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
// Send a final stop command to cleanup
|
|
|
|
@try {
|
2007-07-05 23:24:25 +00:00
|
|
|
if([client connectToHost:@"localhost" port:port]) {
|
2009-03-28 03:00:45 +00:00
|
|
|
[client send:[NSString stringWithFormat:@"STOP c=%@\n", [self pluginID]]];
|
2007-07-05 23:24:25 +00:00
|
|
|
|
|
|
|
response = [client receive];
|
|
|
|
if(2 > [response length] || NSOrderedSame != [response compare:@"OK" options:NSLiteralSearch range:NSMakeRange(0,2)])
|
2013-10-11 12:03:55 +00:00
|
|
|
ALog(@"AudioScrobbler error: %@", response);
|
2007-07-05 23:24:25 +00:00
|
|
|
|
|
|
|
[client shutdown];
|
2007-02-25 02:43:56 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
@catch(NSException *exception) {
|
|
|
|
[client shutdown];
|
|
|
|
}
|
|
|
|
|
|
|
|
[client release];
|
2009-03-28 03:00:45 +00:00
|
|
|
[self setAudioScrobblerThreadCompleted:YES];
|
2007-10-13 07:51:42 +00:00
|
|
|
|
2007-07-05 23:24:25 +00:00
|
|
|
[pool release];
|
2007-02-25 02:43:56 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
@end
|