src/PEPThread.m

   1 /*
   2  * Copyright (c) 2011, Florian Zeitz <florob@babelmonkeys.de>
   3  *
   4  * http://cgit.babelmonkeys.de/cgit.cgi/mpdbot/
   5  *
   6  * Permission to use, copy, modify, and/or distribute this software for any
   7  * purpose with or without fee is hereby granted, provided that the above
   8  * copyright notice and this permission notice is present in all copies.
   9  *
  10  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
  11  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  12  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  13  * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
  14  * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  15  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  16  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  17  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  18  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  19  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
  20  * POSSIBILITY OF SUCH DAMAGE.
  21  */
  22
  23 #import <ObjFW/ObjFW.h>
  24 #import <ObjXMPP/ObjXMPP.h>
  25
  26 #import "PEPThread.h"
  27
  28 #define NS_PUBSUB @"http://jabber.org/protocol/pubsub"
  29 #define NS_TUNE @"http://jabber.org/protocol/tune"
  30
  31 @implementation PEPThread: OFThread
  32 - (void)dealloc
  33 {
  34         [conn release];
  35
  36         [super dealloc];
  37 }
  38
  39 - (id)main
  40 {
  41         OFString *mpd_host;
  42         uint16_t mpd_port;
  43         OFDictionary *environment = [OFApplication environment];
  44         OFString *mpd_port_string;
  45         mpd_host = [environment objectForKey: @"MPD_HOST"];
  46         if (mpd_host == nil)
  47                 mpd_host = @"localhost";
  48         mpd_port_string = [environment objectForKey: @"MPD_PORT"];
  49         if (mpd_port_string && [mpd_port_string decimalValue] <= UINT16_MAX)
  50                 mpd_port = (uint16_t) [mpd_port_string decimalValue];
  51         else
  52                 mpd_port = 6600;
  53         conn = [[MPDConnection alloc] initWithHost: mpd_host
  54                                               port: mpd_port];
  55         [conn connect];
  56         while (1) {
  57                 OFAutoreleasePool *pool = [[OFAutoreleasePool alloc] init];
  58                 @try {
  59                         OFMutableDictionary *response;
  60                         OFString *answer;
  61                         XMPPIQ *tuneIQ;
  62                         OFXMLElement *pubsub, *publish, *item, *tune;
  63
  64                         tuneIQ = [XMPPIQ IQWithType: @"set"
  65                                                  ID: [object generateStanzaID]];
  66                         pubsub = [OFXMLElement elementWithName: @"pubsub"
  67                                                      namespace: NS_PUBSUB];
  68                         [tuneIQ addChild: pubsub];
  69                         publish = [OFXMLElement elementWithName: @"publish"
  70                                                       namespace: NS_PUBSUB];
  71                         [publish addAttributeWithName: @"node"
  72                                           stringValue: NS_TUNE];
  73                         [pubsub addChild: publish];
  74                         item = [OFXMLElement elementWithName: @"item"
  75                                                    namespace: NS_PUBSUB];
  76                         [publish addChild: item];
  77                         tune = [OFXMLElement elementWithName: @"tune"
  78                                                    namespace: NS_TUNE];
  79                         [item addChild: tune];
  80                         [conn send: @"status"];
  81                         response = [conn response];
  82                         if ([[response objectForKey: @"state"]
  83                             isEqual: @"play"]) {
  84                                 [conn send: @"currentsong"];
  85                                 response = [conn response];
  86                                 if ((answer =
  87                                     [response objectForKey: @"Artist"]))
  88                                         [tune addChild: [OFXMLElement
  89                                             elementWithName: @"artist"
  90                                                   namespace: NS_TUNE
  91                                                 stringValue: answer]];
  92                                 if ((answer = [response objectForKey: @"Time"]))
  93                                         [tune addChild: [OFXMLElement
  94                                             elementWithName: @"length"
  95                                                   namespace: NS_TUNE
  96                                                 stringValue: answer]];
  97                                 if ((answer =
  98                                     [response objectForKey: @"Album"]))
  99                                         [tune addChild: [OFXMLElement
 100                                             elementWithName: @"source"
 101                                                   namespace: NS_TUNE
 102                                                 stringValue: answer]];
 103                                 if ((answer =
 104                                     [response objectForKey: @"Title"]))
 105                                         [tune addChild: [OFXMLElement
 106                                             elementWithName: @"title"
 107                                                   namespace: NS_TUNE
 108                                                 stringValue: answer]];
 109                                 else if ((answer =
 110                                     [response objectForKey: @"file"]))
 111                                         [tune addChild: [OFXMLElement
 112                                             elementWithName: @"title"
 113                                                   namespace: NS_TUNE
 114                                                 stringValue: answer]];
 115                                 if ((answer =
 116                                     [response objectForKey: @"Track"]))
 117                                         [tune addChild: [OFXMLElement
 118                                             elementWithName: @"track"
 119                                                   namespace: NS_TUNE
 120                                                 stringValue: answer]];
 121                         }
 122                         [object sendStanza: tuneIQ];
 123                         [conn idle];
 124                 } @catch (id e) {
 125                         [conn connect];
 126                         [e release];
 127                 }
 128                 [pool release];
 129         }
 130
 131         return nil;
 132 }
 133 @end