mspeaker.cpp

Go to the documentation of this file.

/********************************************************************\
 
  Name:         mspeaker.c
  Created by:   Pierre-Andre Amaudruz, Stefan Ritt
 
  Contents:     Speaks midas messages
 
  Requires Microsoft Speech SDK 5.1 to be installed under
 
  \Program Files\Microsoft Speech SDK 5.1\
 
  $Id$
 
\********************************************************************/
 
#include <stdlib.h>
#include <sapi.h>
#include "midas.h"
#include "msystem.h"
 
char mtUserStr[128], mtTalkStr[128];
DWORD shutupTime = 10;
 
ISpVoice* Voice = NULL;          // The voice interface
 
char *type_name[] = {
   "ERROR",
   "INFO",
   "DEBUG" "USER",
   "LOG",
   "TALK",
   "CALL",
};
 
/*----- receive_message --------------------------------------------*/
 
void receive_message(HNDLE hBuf, HNDLE id, EVENT_HEADER * header, void *message)
{
   char str[256], *pc, *sp;
   static DWORD last_beep = 0;
 
   /* print message */
   printf("%s\n", (char *) (message));
 
   /* skip none talking message */
   if (header->trigger_mask == MT_TALK || header->trigger_mask == MT_USER) {
      
      /* strip [<username.] */
      pc = strchr((char *) (message), ']') + 2;
      sp = pc + strlen(pc) - 1;
      while (*sp == ' ' || *sp == '\t')
         sp--;
      *(++sp) = '\0';
 
      if ((ss_time() - last_beep) > shutupTime) {
         switch (header->trigger_mask) {
         case MT_TALK:
            if (mtTalkStr[0])
               sprintf(str, mtTalkStr);
            break;
         case MT_USER:
            if (mtUserStr[0])
               sprintf(str, mtUserStr);
            break;
         }
 
         // beep first
         PlaySound(str, NULL, SND_SYNC);
         last_beep = ss_time();
 
         ss_sleep(500);
 
         wchar_t wcstring[1000];
         MultiByteToWideChar(CP_ACP, MB_PRECOMPOSED, (LPCSTR)pc, -1, wcstring, 1000); 
         
         // Speak!
         Voice->Speak(wcstring, SPF_DEFAULT, NULL );
      }
   }
 
   return;
}
 
/*------------------------------------------------------------------*/
 
int main(int argc, char *argv[])
{
   INT status, i, ch;
   char host_name[NAME_LENGTH];
   char exp_name[NAME_LENGTH];
 
   /* get default from environment */
   cm_get_environment(host_name, sizeof(host_name), exp_name, sizeof(exp_name));
 
   /* default wave files */
   strcpy(mtTalkStr, "\\Windows\\Media\\notify.wav");
   strcpy(mtUserStr, "\\Windows\\Media\\notify.wav");
 
   /* parse command line parameters */
   for (i = 1; i < argc; i++) {
      if (argv[i][0] == '-') {
         if (i + 1 >= argc || argv[i + 1][0] == '-')
            goto usage;
         if (argv[i][1] == 'e')
            strcpy(exp_name, argv[++i]);
         else if (argv[i][1] == 'h')
            strcpy(host_name, argv[++i]);
         else if (argv[i][1] == 't')
            strcpy(mtTalkStr, argv[++i]);
         else if (argv[i][1] == 'u')
            strcpy(mtUserStr, argv[++i]);
         else if (argv[i][1] == 's')
            shutupTime = atoi(argv[++i]);
         else {
          usage:
            printf("usage: mspeaker [-h <hostname>] [-e <experiment>]\n\n");
            printf("  [-t <file>]  Specify the alert wave file for MT_TALK messages\n");
            printf("  [-u <file>]  Specify the alert wave file for MT_USER messages\n");
            printf("  [-s <sec>]   Specify the min time interval between alert [s]\n");
            return 0;
         }
      }
   }
 
   // Initialize COM
   CoInitialize ( NULL );
 
   // Create the voice interface object
   CoCreateInstance ( CLSID_SpVoice, NULL, CLSCTX_ALL, IID_ISpVoice, (void**)&Voice );
   if (Voice == NULL) {
      printf("Cannot initialize speech system\n");
      return 1;
   }
 
 reconnect:
 
   /* now connect to server */
   status = cm_connect_experiment(host_name, exp_name, "Speaker", NULL);
   if (status != CM_SUCCESS)
      return 1;
 
   cm_msg_register(receive_message);
 
   /* increased watchdog timeout for long messages */
   cm_set_watchdog_params(TRUE, 60000);
 
   printf("Midas Message Talker connected to %s. Press \"!\" to exit\n",
          host_name[0] ? host_name : "local host");
 
   do {
      status = cm_yield(1000);
      if (ss_kbhit()) {
         ch = getch();
         if (ch == 'r')
            ss_clear_screen();
         if (ch == '!')
            break;
      }
 
      if (status == SS_ABORT) {
         cm_disconnect_experiment();
         printf("Trying to reconnect...\n");
         ss_sleep(3000);
         goto reconnect;
      }
 
   } while (status != RPC_SHUTDOWN);
 
   // Shutdown the voice
   if (Voice != NULL) 
      Voice->Release();
 
   // Shutdown COM
   CoUninitialize();
 
   cm_disconnect_experiment();
   return 1;
}