Jacek Kowalski
2012-07-08 a29a9307065a3582a6317f9bd27e6d009ec1623e
commit | author | age
8bd4d9 1 <?php
JK 2 class BotAPIGGHTTPException extends Exception {
3     private $httpcode;
4     private $content;
5     
6     function __construct($msg, $httpcode, $content) {
7         $this->httpcode = $httpcode;
8         $this->content = $content;
9         parent::__construct($msg);
10     }
11     
12     function __get($name) {
13         return $this->$name;
14     }
15 }
16 class BotAPIGGXMLException extends Exception {
17     private $content;
18     
19     function __construct($msg, $content) {
20         $this->content = $content;
21         parent::__construct($msg);
22     }
23     
24     function __get($name) {
25         return $this->$name;
26     }
27 }
28
29 class BotAPIGGReplyException extends Exception {
30     private $xml;
31     
32     function __construct($msg, SimpleXMLElement $xml) {
33         $this->xml = $xml;
34         parent::__construct($msg);
35     }
36     
37     function __get($name) {
38         return $this->$name;
39     }
40     
41     function __toString() {
42         return $this->getMessage().' Błąd '.((string)$this->xml->status).': '.((string)$this->xml->errorMsg);
43     }
44 }
45
46 class BotAPIGG extends config {
47     private $token;
48     
49     const STATUS_DOSTEPNY = 2;
50     const STATUS_DOSTEPNY_DESC = 4;
51     const STATUS_ONLINE = 2;
52     const STATUS_ONLINE_DESC = 4;
53     
54     const STATUS_ZAJETY = 3;
55     const STATUS_ZAJETY_DESC = 5;
56     const STATUS_AWAY = 3;
57     const STATUS_AWAY_DESC = 5;
58     
59     const STATUS_NIE_PRZESZKADZAC = 33;
60     const STATUS_NIE_PRZESZKADZAC_DESC = 34;
61     const STATUS_DND = 33;
62     const STATUS_DND_DESC = 34;
63     
64     const STATUS_POROZMAWIAJ = 23;
65     const STATUS_POROZMAWIAJ_DESC = 24;
66     const STATUS_CHAT = 23;
67     const STATUS_CHAT_DESC = 24;
68     
69     const STATUS_NIEWIDOCZNY = 20;
70     const STATUS_NIEWIDOCZNY_DESC = 22;
71     const STATUS_INVISIBLE = 20;
72     const STATUS_INVISIBLE_DESC = 22;
73     
74     private function httpQuery($address, $useToken = TRUE, $curlopts = array()) {
75         if(!is_array($curlopts)) {
76             $curlopts = array();
77         }
78         
79         if($useToken) {
80             if(!isset($curlopts[CURLOPT_HTTPHEADER]) || !is_array($curlopts[CURLOPT_HTTPHEADER])) {
81                 $curlopts[CURLOPT_HTTPHEADER] = array();
82             }
83             
84             $token = $this->getToken();
85             
86             $curlopts[CURLOPT_HTTPHEADER][] = 'Token: '.$token['token'];
87         }
88         
89         $dane = curl_init($address);
90         $curlopts[CURLOPT_RETURNTRANSFER] = TRUE;
91         $curlopts[CURLOPT_USERAGENT] = 'Bot Gadu-Gadu/'.main::VERSION.' (http://jacekk.info/botgg)';
92         $curlopts[CURLOPT_SSL_CIPHER_LIST] = 'HIGH:-MD5:-aNULL:-DES';
93         $curlopts[CURLOPT_SSL_VERIFYPEER] = TRUE;
94         $curlopts[CURLOPT_SSL_VERIFYHOST] = 2;
95         $curlopts[CURLOPT_CAPATH] = BOT_TOPDIR.'/data/ca-certificates/';
96         curl_setopt_array($dane, $curlopts);
97         $tok2 = $tok = curl_exec($dane);
98         $info = curl_getinfo($dane);
99         
100         try {
101             libxml_use_internal_errors(TRUE);
102             $tok = new SimpleXMLElement($tok);
103         }
104         catch(Exception $e) {
105             throw new BotAPIGGXMLException('Otrzymano błędny XML od botmastera.', $tok2);
106         }
107         
108         if(!$tok) {
109             if($info['http_code'] != 200) {
110                 throw new BotAPIGGHTTPException('Nie udało się wykonać zapytania HTTP.', $info['http_code'], $tok2);
111             }
112             else
113             {
114                 throw new BotAPIGGXMLException('Otrzymano błędny XML od botmastera.', $tok2);
115             }
116         }
117         
118         return $tok;
119     }
120     
121     function getToken($force = FALSE) {
122         if($force || !$this->token) {
123             $auth = $this->APIs['Gadu-Gadu'];
124             
125             $tok = $this->httpQuery('https://botapi.gadu-gadu.pl/botmaster/getToken/'.$auth['numer'], FALSE, array(
126                 CURLOPT_USERPWD => $auth['login'].':'.$auth['haslo'],
127                 CURLOPT_HTTPAUTH => CURLAUTH_BASIC,
128             ));
129             
130             if($tok->errorMsg) {
131                 throw new BotAPIGGReplyException('Pobieranie tokena nie powiodło się.', $tok);
132             }
133             
134             $this->token = array('token' => (string)$tok->token, 'host' => (string)$tok->server, 'port' => (int)$tok->port);
135         }
136         
137         return $this->token;
138     }
139     
140     function setStatus($status, $desc = '') {
141         $auth = $this->APIs['Gadu-Gadu'];
142         $token = $this->getToken();
143         
144         $tok = $this->httpQuery('https://'.$token['host'].'/setStatus/'.$auth['numer'], FALSE, array(
145             CURLOPT_HTTPHEADER => array('Content-Type: application/x-www-form-urlencoded'),
146             CURLOPT_POST => TRUE,
147             CURLOPT_POSTFIELDS => 'token='.urlencode($token['token']).'&status='.urlencode($status).'&desc='.urlencode($desc),
148         ));
149         
150         if( (string)$tok->status != '0') {
151             throw new BotAPIGGReplyException('Ustawianie statusu nie powiodło się.', $tok);
152         }
153     }
154     
155     function setUrl($url) {
156         $auth = $this->APIs['Gadu-Gadu'];
157         
158         $tok = $this->httpQuery('https://botapi.gadu-gadu.pl/botmaster/setUrl/'.$auth['numer'], TRUE, array(
159             CURLOPT_POST => TRUE,
160             CURLOPT_POSTFIELDS => $url,
161         ));
162         
163         if( (string)$tok->status != '0') {
164             throw new BotAPIGGReplyException('Ustawianie adresu URL bota nie powiodło się.', $tok);
165         }
166         
167         return $tok;
168     }
169     
170     /**
171      * Wysyła wiadomość do podanych użytkowników
172      * @param array $toURL Lista adresatów wiadomości w postaci: array('Gadu-Gadu://NUMER@gadu-gadu.pl', ...)
173      * @param BotMsg $msg Wiadomość do wysłania
174      * @param array $params Parametry przekazywane funkcji. Aktualnie dostępne:
175      * array( 'SendToOffline' => (bool)TRUE/FALSE )
176      */
177     
178     function sendMessage($toURL, BotMsg $msg, $params = array()) {
179         $to = array();
180         foreach($toURL as $url) {
181             $url = parse_url($url);
182             if($url['scheme'] != 'Gadu-Gadu') {
183                 continue;
184             }
185             
186             if($url['user']=='' || !ctype_digit($url['user'])) {
187                 throw new Exception('Nieznany użytkownik sieci Gadu-Gadu, któremu należy dostarczyć wiadomość.');
188             }
189             
190             $to[] = $url['user'];
191         }
192         
193         if(empty($to)) {
194             return NULL;
195         }
196         
197         $msg = new BotMsgGG($msg);
198         
199         $auth = $this->APIs['Gadu-Gadu'];
200         $token = $this->getToken();
201         
202         $headers = array('Content-Type: application/x-www-form-urlencoded');
203         
204         if($params['SendToOffline'] == FALSE) {
205             $headers[] = 'Send-to-offline: 0';
206         }
207         
208         while(!empty($to)) {
209             $to_part = implode(',', array_splice($to, -5000));
210             
211             $tok = $this->httpQuery('https://'.$token['host'].'/sendMessage/'.$auth['numer'], FALSE, array(
212                 CURLOPT_HTTPHEADER => $headers,
213                 CURLOPT_POST => TRUE,
214                 CURLOPT_POSTFIELDS => 'token='.urlencode($token['token']).'&to='.urlencode($to_part).'&msg='.urlencode($msg->getGG(FALSE)),
215             ));
216             
217             if((string)$tok->status == '18') {
218                 $tok = $this->httpQuery('https://'.$token['host'].'/sendMessage/'.$auth['numer'], FALSE, array(
219                     CURLOPT_HTTPHEADER => $headers,
220                     CURLOPT_POST => TRUE,
221                     CURLOPT_POSTFIELDS => 'token='.urlencode($token['token']).'&to='.urlencode($to_part).'&msg='.urlencode($msg->getGG(FALSE)),
222                 ));
223             }
224             
225             if((string)$tok->status != '0') {
226                 throw new BotAPIGGReplyException('Problemy przy wysyłaniu wiadomości do sieci Gadu-Gadu.', $tok);
227             }
228         }
229         
230         return TRUE;
231     }
232 }
233 ?>