missing fi
[oweals/gnunet.git] / src / conversation / conversation_api_call.c
1 /*
2   This file is part of GNUnet
3   (C) 2013 Christian Grothoff (and other contributing authors)
4
5   GNUnet is free software; you can redistribute it and/or modify
6   it under the terms of the GNU General Public License as published
7   by the Free Software Foundation; either version 3, or (at your
8   option) any later version.
9
10   GNUnet is distributed in the hope that it will be useful, but
11   WITHOUT ANY WARRANTY; without even the implied warranty of
12   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
13   General Public License for more details.
14
15   You should have received a copy of the GNU General Public License
16   along with GNUnet; see the file COPYING.  If not, write to the
17   Free Software Foundation, Inc., 59 Temple Place - Suite 330,
18   Boston, MA 02111-1307, USA.
19  */
20
21 /**
22  * @file conversation/conversation_api_call.c
23  * @brief call API to the conversation service
24  * @author Simon Dieterle
25  * @author Andreas Fuchs
26  * @author Christian Grothoff
27  */
28 #include "platform.h"
29 #include "gnunet_conversation_service.h"
30 #include "gnunet_gnsrecord_lib.h"
31 #include "gnunet_gns_service.h"
32 #include "conversation.h"
33
34
35 /**
36  * Possible states of the phone.
37  */
38 enum CallState
39 {
40   /**
41    * We still need to lookup the callee.
42    */
43   CS_LOOKUP = 0,
44
45   /**
46    * The call is ringing.
47    */
48   CS_RINGING,
49
50   /**
51    * The call is in an active conversation.
52    */
53   CS_ACTIVE,
54
55   /**
56    * The call is in termination.
57    */
58   CS_SHUTDOWN,
59
60   /**
61    * The call was suspended by the caller.
62    */
63   CS_SUSPENDED_CALLER,
64
65   /**
66    * The call was suspended by the callee.
67    */
68   CS_SUSPENDED_CALLEE,
69
70   /**
71    * The call was suspended by both caller and callee.
72    */
73   CS_SUSPENDED_BOTH
74 };
75
76
77 /**
78  * Handle for an outgoing call.
79  */
80 struct GNUNET_CONVERSATION_Call
81 {
82
83   /**
84    * Our configuration.
85    */
86   const struct GNUNET_CONFIGURATION_Handle *cfg;
87
88   /**
89    * Handle to talk with CONVERSATION service.
90    */
91   struct GNUNET_CLIENT_Connection *client;
92
93   /**
94    * Our caller identity.
95    */
96   struct GNUNET_IDENTITY_Ego *caller_id;
97
98   /**
99    * Target callee as a GNS address/name.
100    */
101   char *callee;
102
103   /**
104    * Our speaker.
105    */
106   struct GNUNET_SPEAKER_Handle *speaker;
107
108   /**
109    * Our microphone.
110    */
111   struct GNUNET_MICROPHONE_Handle *mic;
112
113   /**
114    * Function to call with events.
115    */
116   GNUNET_CONVERSATION_CallEventHandler event_handler;
117
118   /**
119    * Closure for @e event_handler
120    */
121   void *event_handler_cls;
122
123   /**
124    * Handle for transmitting to the CONVERSATION service.
125    */
126   struct GNUNET_MQ_Handle *mq;
127
128   /**
129    * Connection to GNS (can be NULL).
130    */
131   struct GNUNET_GNS_Handle *gns;
132
133   /**
134    * Active GNS lookup (or NULL).
135    */
136   struct GNUNET_GNS_LookupRequest *gns_lookup;
137
138   /**
139    * Target phone record, only valid after the lookup is done.
140    */
141   struct GNUNET_CONVERSATION_PhoneRecord phone_record;
142
143   /**
144    * State machine for the call.
145    */
146   enum CallState state;
147
148 };
149
150
151 /**
152  * The call got disconnected, reconnect to the service.
153  *
154  * @param call call to reconnect
155  */
156 static void
157 reconnect_call (struct GNUNET_CONVERSATION_Call *call);
158
159
160 /**
161  * Process recorded audio data.
162  *
163  * @param cls closure with the `struct GNUNET_CONVERSATION_Call`
164  * @param data_size number of bytes in @a data
165  * @param data audio data to play
166  */
167 static void
168 transmit_call_audio (void *cls,
169                      size_t data_size,
170                      const void *data)
171 {
172   struct GNUNET_CONVERSATION_Call *call = cls;
173   struct GNUNET_MQ_Envelope *e;
174   struct ClientAudioMessage *am;
175
176   GNUNET_assert (CS_ACTIVE == call->state);
177   e = GNUNET_MQ_msg_extra (am,
178                            data_size,
179                            GNUNET_MESSAGE_TYPE_CONVERSATION_CS_AUDIO);
180   memcpy (&am[1], data, data_size);
181   GNUNET_MQ_send (call->mq, e);
182 }
183
184
185 /**
186  * We received a `struct ClientPhoneSuspendMessage`
187  *
188  * @param cls the `struct GNUNET_CONVERSATION_Call`
189  * @param msg the message
190  */
191 static void
192 handle_call_suspend (void *cls,
193                      const struct GNUNET_MessageHeader *msg)
194 {
195   struct GNUNET_CONVERSATION_Call *call = cls;
196
197   switch (call->state)
198   {
199   case CS_LOOKUP:
200     GNUNET_break (0);
201     reconnect_call (call);
202     break;
203   case CS_RINGING:
204     GNUNET_break_op (0);
205     reconnect_call (call);
206     break;
207   case CS_SUSPENDED_CALLER:
208     call->state = CS_SUSPENDED_BOTH;
209     call->event_handler (call->event_handler_cls,
210                          GNUNET_CONVERSATION_EC_CALL_SUSPENDED);
211     break;
212   case CS_SUSPENDED_CALLEE:
213   case CS_SUSPENDED_BOTH:
214     GNUNET_break_op (0);
215     break;
216   case CS_ACTIVE:
217     call->state = CS_SUSPENDED_CALLEE;
218     call->event_handler (call->event_handler_cls,
219                          GNUNET_CONVERSATION_EC_CALL_SUSPENDED);
220     call->speaker->disable_speaker (call->speaker->cls);
221     call->mic->disable_microphone (call->mic->cls);
222     break;
223   case CS_SHUTDOWN:
224     GNUNET_CONVERSATION_call_stop (call);
225     break;
226   }
227 }
228
229
230 /**
231  * We received a `struct ClientPhoneResumeMessage`
232  *
233  * @param cls the `struct GNUNET_CONVERSATION_Call`
234  * @param msg the message
235  */
236 static void
237 handle_call_resume (void *cls,
238                      const struct GNUNET_MessageHeader *msg)
239 {
240   struct GNUNET_CONVERSATION_Call *call = cls;
241
242   switch (call->state)
243   {
244   case CS_LOOKUP:
245     GNUNET_break (0);
246     reconnect_call (call);
247     break;
248   case CS_RINGING:
249     GNUNET_break_op (0);
250     reconnect_call (call);
251     break;
252   case CS_SUSPENDED_CALLER:
253     GNUNET_break_op (0);
254     break;
255   case CS_SUSPENDED_CALLEE:
256     call->state = CS_ACTIVE;
257     call->speaker->enable_speaker (call->speaker->cls);
258     call->mic->enable_microphone (call->mic->cls,
259                                   &transmit_call_audio,
260                                   call);
261     call->event_handler (call->event_handler_cls,
262                          GNUNET_CONVERSATION_EC_CALL_RESUMED);
263     break;
264   case CS_SUSPENDED_BOTH:
265     call->state = CS_SUSPENDED_CALLER;
266     call->event_handler (call->event_handler_cls,
267                          GNUNET_CONVERSATION_EC_CALL_RESUMED);
268     break;
269   case CS_ACTIVE:
270     GNUNET_break_op (0);
271     break;
272   case CS_SHUTDOWN:
273     GNUNET_CONVERSATION_call_stop (call);
274     break;
275   }
276 }
277
278
279 /**
280  * We received a `struct ClientPhonePickedupMessage`
281  *
282  * @param cls the `struct GNUNET_CONVERSATION_Call`
283  * @param msg the message
284  */
285 static void
286 handle_call_picked_up (void *cls,
287                        const struct GNUNET_MessageHeader *msg)
288 {
289   struct GNUNET_CONVERSATION_Call *call = cls;
290
291   switch (call->state)
292   {
293   case CS_LOOKUP:
294     GNUNET_break (0);
295     reconnect_call (call);
296     break;
297   case CS_RINGING:
298     call->state = CS_ACTIVE;
299     call->speaker->enable_speaker (call->speaker->cls);
300     call->mic->enable_microphone (call->mic->cls,
301                                   &transmit_call_audio,
302                                   call);
303     call->event_handler (call->event_handler_cls,
304                          GNUNET_CONVERSATION_EC_CALL_PICKED_UP);
305     break;
306   case CS_SUSPENDED_CALLER:
307   case CS_SUSPENDED_CALLEE:
308   case CS_SUSPENDED_BOTH:
309   case CS_ACTIVE:
310     GNUNET_break (0);
311     reconnect_call (call);
312     break;
313   case CS_SHUTDOWN:
314     GNUNET_CONVERSATION_call_stop (call);
315     break;
316   }
317 }
318
319
320 /**
321  * We received a `struct ClientPhoneHangupMessage`
322  *
323  * @param cls the `struct GNUNET_CONVERSATION_Call`
324  * @param msg the message
325  */
326 static void
327 handle_call_hangup (void *cls,
328                     const struct GNUNET_MessageHeader *msg)
329 {
330   struct GNUNET_CONVERSATION_Call *call = cls;
331
332   switch (call->state)
333   {
334   case CS_LOOKUP:
335     GNUNET_break (0);
336     reconnect_call (call);
337     break;
338   case CS_RINGING:
339   case CS_SUSPENDED_CALLER:
340   case CS_SUSPENDED_CALLEE:
341   case CS_SUSPENDED_BOTH:
342   case CS_ACTIVE:
343     call->event_handler (call->event_handler_cls,
344                          GNUNET_CONVERSATION_EC_CALL_HUNG_UP);
345     GNUNET_CONVERSATION_call_stop (call);
346     return;
347   case CS_SHUTDOWN:
348     GNUNET_CONVERSATION_call_stop (call);
349     break;
350   }
351 }
352
353
354 /**
355  * We received a `struct ClientAudioMessage`
356  *
357  * @param cls the `struct GNUNET_CONVERSATION_Call`
358  * @param msg the message
359  */
360 static void
361 handle_call_audio_message (void *cls,
362                            const struct GNUNET_MessageHeader *msg)
363 {
364   struct GNUNET_CONVERSATION_Call *call = cls;
365   const struct ClientAudioMessage *am;
366
367   am = (const struct ClientAudioMessage *) msg;
368   switch (call->state)
369   {
370   case CS_LOOKUP:
371     GNUNET_break (0);
372     reconnect_call (call);
373     break;
374   case CS_RINGING:
375     GNUNET_break (0);
376     reconnect_call (call);
377     break;
378   case CS_SUSPENDED_CALLER:
379     /* can happen: we suspended, other peer did not yet
380        learn about this. */
381     break;
382   case CS_SUSPENDED_CALLEE:
383   case CS_SUSPENDED_BOTH:
384     /* can (rarely) also happen: other peer suspended, but mesh might
385        have had delayed data on the unreliable channel */
386     break;
387   case CS_ACTIVE:
388     call->speaker->play (call->speaker->cls,
389                          ntohs (msg->size) - sizeof (struct ClientAudioMessage),
390                          &am[1]);
391     break;
392   case CS_SHUTDOWN:
393     GNUNET_CONVERSATION_call_stop (call);
394     break;
395   }
396 }
397
398
399 /**
400  * Iterator called on obtained result for a GNS lookup.
401  *
402  * @param cls closure with the `struct GNUNET_CONVERSATION_Call`
403  * @param rd_count number of records in @a rd
404  * @param rd the records in reply
405  */
406 static void
407 handle_gns_response (void *cls,
408                      uint32_t rd_count,
409                      const struct GNUNET_GNSRECORD_Data *rd)
410 {
411   struct GNUNET_CONVERSATION_Call *call = cls;
412   uint32_t i;
413   struct GNUNET_MQ_Envelope *e;
414   struct ClientCallMessage *ccm;
415
416   call->gns_lookup = NULL;
417   for (i=0;i<rd_count;i++)
418   {
419     if (GNUNET_GNSRECORD_TYPE_PHONE == rd[i].record_type)
420     {
421       if (rd[i].data_size != sizeof (struct GNUNET_CONVERSATION_PhoneRecord))
422       {
423         GNUNET_break_op (0);
424         continue;
425       }
426       memcpy (&call->phone_record,
427               rd[i].data,
428               rd[i].data_size);
429       e = GNUNET_MQ_msg (ccm, GNUNET_MESSAGE_TYPE_CONVERSATION_CS_PHONE_CALL);
430       ccm->line = call->phone_record.line;
431       ccm->target = call->phone_record.peer;
432       ccm->caller_id = *GNUNET_IDENTITY_ego_get_private_key (call->caller_id);
433       GNUNET_MQ_send (call->mq, e);
434       call->state = CS_RINGING;
435       call->event_handler (call->event_handler_cls,
436                            GNUNET_CONVERSATION_EC_CALL_RINGING);
437       return;
438     }
439   }
440   /* not found */
441   call->event_handler (call->event_handler_cls,
442                        GNUNET_CONVERSATION_EC_CALL_GNS_FAIL);
443   GNUNET_CONVERSATION_call_stop (call);
444 }
445
446
447 /**
448  * We encountered an error talking with the conversation service.
449  *
450  * @param cls the `struct GNUNET_CONVERSATION_Call`
451  * @param error details about the error
452  */
453 static void
454 call_error_handler (void *cls,
455                     enum GNUNET_MQ_Error error)
456 {
457   struct GNUNET_CONVERSATION_Call *call = cls;
458
459   if (CS_SHUTDOWN == call->state)
460   {
461     GNUNET_CONVERSATION_call_stop (call);
462     return;
463   }
464   GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
465               _("Connection to conversation service lost, trying to reconnect\n"));
466   reconnect_call (call);
467 }
468
469
470 /**
471  * The call got disconnected, reconnect to the service.
472  *
473  * @param call call to reconnect
474  */
475 static void
476 reconnect_call (struct GNUNET_CONVERSATION_Call *call)
477 {
478   static struct GNUNET_MQ_MessageHandler handlers[] =
479   {
480     { &handle_call_suspend,
481       GNUNET_MESSAGE_TYPE_CONVERSATION_CS_PHONE_SUSPEND,
482       sizeof (struct ClientPhoneSuspendMessage) },
483     { &handle_call_resume,
484       GNUNET_MESSAGE_TYPE_CONVERSATION_CS_PHONE_RESUME,
485       sizeof (struct ClientPhoneResumeMessage) },
486     { &handle_call_picked_up,
487       GNUNET_MESSAGE_TYPE_CONVERSATION_CS_PHONE_PICKED_UP,
488       sizeof (struct ClientPhonePickedupMessage) },
489     { &handle_call_hangup,
490       GNUNET_MESSAGE_TYPE_CONVERSATION_CS_PHONE_HANG_UP,
491       sizeof (struct ClientPhoneHangupMessage) },
492     { &handle_call_audio_message,
493       GNUNET_MESSAGE_TYPE_CONVERSATION_CS_AUDIO,
494       0 },
495     { NULL, 0, 0 }
496   };
497   struct GNUNET_CRYPTO_EcdsaPublicKey my_zone;
498
499   if (CS_ACTIVE == call->state)
500   {
501     call->speaker->disable_speaker (call->speaker->cls);
502     call->mic->disable_microphone (call->mic->cls);
503   }
504   if (NULL != call->mq)
505   {
506     GNUNET_MQ_destroy (call->mq);
507     call->mq = NULL;
508   }
509   if (NULL != call->client)
510   {
511     GNUNET_CLIENT_disconnect (call->client);
512     call->client = NULL;
513   }
514   call->state = CS_SHUTDOWN;
515   call->client = GNUNET_CLIENT_connect ("conversation", call->cfg);
516   if (NULL == call->client)
517     return;
518   call->mq = GNUNET_MQ_queue_for_connection_client (call->client,
519                                                     handlers,
520                                                     &call_error_handler,
521                                                     call);
522   call->state = CS_LOOKUP;
523   GNUNET_IDENTITY_ego_get_public_key (call->caller_id,
524                                       &my_zone);
525   call->gns_lookup = GNUNET_GNS_lookup (call->gns,
526                                         call->callee,
527                                         &my_zone,
528                                         GNUNET_GNSRECORD_TYPE_PHONE,
529                                         GNUNET_NO,
530                                         NULL /* FIXME: add shortening support */,
531                                         &handle_gns_response, call);
532   GNUNET_assert (NULL != call->gns_lookup);
533 }
534
535
536 /**
537  * Call the phone of another user.
538  *
539  * @param cfg configuration to use, specifies our phone service
540  * @param caller_id identity of the caller
541  * @param callee GNS name of the callee (used to locate the callee's record)
542  * @param speaker speaker to use (will be used automatically immediately once the
543  *        #GNUNET_CONVERSATION_EC_CALL_PICKED_UP event is generated); we will NOT generate
544  *        a ring tone on the speaker
545  * @param mic microphone to use (will be used automatically immediately once the
546  *        #GNUNET_CONVERSATION_EC_CALL_PICKED_UP event is generated)
547  * @param event_handler how to notify the owner of the phone about events
548  * @param event_handler_cls closure for @a event_handler
549  */
550 struct GNUNET_CONVERSATION_Call *
551 GNUNET_CONVERSATION_call_start (const struct GNUNET_CONFIGURATION_Handle *cfg,
552                                 struct GNUNET_IDENTITY_Ego *caller_id,
553                                 const char *callee,
554                                 struct GNUNET_SPEAKER_Handle *speaker,
555                                 struct GNUNET_MICROPHONE_Handle *mic,
556                                 GNUNET_CONVERSATION_CallEventHandler event_handler,
557                                 void *event_handler_cls)
558 {
559   struct GNUNET_CONVERSATION_Call *call;
560
561   call = GNUNET_new (struct GNUNET_CONVERSATION_Call);
562   call->cfg = cfg;
563   call->caller_id = caller_id;
564   call->callee = GNUNET_strdup (callee);
565   call->speaker = speaker;
566   call->mic = mic;
567   call->event_handler = event_handler;
568   call->event_handler_cls = event_handler_cls;
569   call->gns = GNUNET_GNS_connect (cfg);
570   reconnect_call (call);
571
572   if ( (NULL == call->client) ||
573        (NULL == call->gns) )
574   {
575     GNUNET_CONVERSATION_call_stop (call);
576     return NULL;
577   }
578   return call;
579 }
580
581
582 /**
583  * We've sent the hang up message, now finish terminating the call.
584  *
585  * @param cls the `struct GNUNET_CONVERSATION_Call` to terminate
586  */
587 static void
588 finish_stop (void *cls)
589 {
590   struct GNUNET_CONVERSATION_Call *call = cls;
591
592   GNUNET_assert (CS_SHUTDOWN == call->state);
593   GNUNET_CONVERSATION_call_stop (call);
594 }
595
596
597 /**
598  * Terminate a call.  The call may be ringing or ready at this time.
599  *
600  * @param call call to terminate
601  */
602 void
603 GNUNET_CONVERSATION_call_stop (struct GNUNET_CONVERSATION_Call *call)
604 {
605   struct GNUNET_MQ_Envelope *e;
606   struct ClientPhoneHangupMessage *hang;
607
608   if ( (NULL != call->speaker) &&
609        (CS_ACTIVE == call->state) )
610     call->speaker->disable_speaker (call->speaker->cls);
611   if ( (NULL != call->mic) &&
612        (CS_ACTIVE == call->state) )
613     call->mic->disable_microphone (call->mic->cls);
614   if (CS_SHUTDOWN != call->state)
615   {
616     call->state = CS_SHUTDOWN;
617     e = GNUNET_MQ_msg (hang, GNUNET_MESSAGE_TYPE_CONVERSATION_CS_PHONE_HANG_UP);
618     GNUNET_MQ_notify_sent (e, &finish_stop, call);
619     GNUNET_MQ_send (call->mq, e);
620     return;
621   }
622   if (NULL != call->mq)
623   {
624     GNUNET_MQ_destroy (call->mq);
625     call->mq = NULL;
626   }
627   if (NULL != call->client)
628   {
629     GNUNET_CLIENT_disconnect (call->client);
630     call->client = NULL;
631   }
632   if (NULL != call->gns_lookup)
633   {
634     GNUNET_GNS_lookup_cancel (call->gns_lookup);
635     call->gns_lookup = NULL;
636   }
637   if (NULL != call->gns)
638   {
639     GNUNET_GNS_disconnect (call->gns);
640     call->gns = NULL;
641   }
642   GNUNET_free (call->callee);
643   GNUNET_free (call);
644 }
645
646
647 /**
648  * Pause a call.  Temporarily suspends the use of speaker and
649  * microphone.
650  *
651  * @param call call to pause
652  */
653 void
654 GNUNET_CONVERSATION_call_suspend (struct GNUNET_CONVERSATION_Call *call)
655 {
656   struct GNUNET_MQ_Envelope *e;
657   struct ClientPhoneSuspendMessage *suspend;
658
659   GNUNET_assert ( (CS_SUSPENDED_CALLEE == call->state) ||
660                   (CS_ACTIVE == call->state) );
661   if (CS_ACTIVE == call->state)
662   {
663     call->speaker->disable_speaker (call->speaker->cls);
664     call->mic->disable_microphone (call->mic->cls);
665   }
666   call->speaker = NULL;
667   call->mic = NULL;
668   e = GNUNET_MQ_msg (suspend, GNUNET_MESSAGE_TYPE_CONVERSATION_CS_PHONE_SUSPEND);
669   GNUNET_MQ_send (call->mq, e);
670   if (CS_SUSPENDED_CALLER == call->state)
671     call->state = CS_SUSPENDED_BOTH;
672   else
673     call->state = CS_SUSPENDED_CALLER;
674 }
675
676
677 /**
678  * Resumes a call after #GNUNET_CONVERSATION_call_suspend.
679  *
680  * @param call call to resume
681  * @param speaker speaker to use
682  *        a ring tone on the speaker
683  * @param mic microphone to use
684  */
685 void
686 GNUNET_CONVERSATION_call_resume (struct GNUNET_CONVERSATION_Call *call,
687                                  struct GNUNET_SPEAKER_Handle *speaker,
688                                  struct GNUNET_MICROPHONE_Handle *mic)
689 {
690   struct GNUNET_MQ_Envelope *e;
691   struct ClientPhoneResumeMessage *resume;
692
693   GNUNET_assert ( (CS_SUSPENDED_CALLER == call->state) ||
694                   (CS_SUSPENDED_BOTH == call->state) );
695   e = GNUNET_MQ_msg (resume, GNUNET_MESSAGE_TYPE_CONVERSATION_CS_PHONE_RESUME);
696   GNUNET_MQ_send (call->mq, e);
697   call->speaker = speaker;
698   call->mic = mic;
699   if (CS_SUSPENDED_CALLER == call->state)
700   {
701     call->state = CS_ACTIVE;
702     call->speaker->enable_speaker (call->speaker->cls);
703     call->mic->enable_microphone (call->mic->cls,
704                                   &transmit_call_audio,
705                                   call);
706   }
707   else
708   {
709     call->state = CS_SUSPENDED_CALLEE;
710   }
711 }
712
713
714 /* end of conversation_api_call.c */