vos/metaobjects/misc/festtalk.cc

Go to the documentation of this file.

/* $Id: festtalk.cc,v 1.27 2003/07/23 00:17:26 reed Exp $ */


/** @file festtalk.cc
    Defines FestTalk a subclass of Talkative that sends messages to a Festival speech synthesis server.

    I am a moron. I deleted this file, and now I have to rewrite it.
    @author Reed Hedges <reed@zerohour.net> December, 2001
    Portions of this code were developed at the University of Massachusetts.
*/


/* an idea for future improvement: be a listener to the voice property directly, and only set the voice (with festival_eval_command) when it changes. */


#include <sys/types.h>
#include <unistd.h>
#include <errno.h>

#include <vos/corelibs/vos/vos.hh>

#include "festtalk.hh"


// Initialize static class members:
char* FestTalk::festival_host = "127.0.0.1";
int FestTalk::festival_port = 1314;



void FestTalk::set_server(char *host, int port) {
    festival_host = host;
    festival_port = port;
}


void FestTalk::festival_server_command(const char *cmd) throw (ServerCommError) {
    if(strcmp(cmd, VOS_TALK_NO_VOICE) != 0) {
        if( fprintf(socket_fp, "%s\n", cmd) <= 0)
            throw ServerCommError("Error writing command.");
        fflush(socket_fp);
    }
}

/* replaces substrings.  */
string sreplace( const string& s, const string& key, const string& value) {
    string tmp(s);
    unsigned int k;
    while( (k = tmp.find(key)) != tmp.npos )
        tmp = tmp.replace( k, key.length(), value);
    return tmp;
}
void FestTalk::festival_server_saytext(const string& text) throw (ServerCommError) {

    string::size_type f = 0;
    string::size_type pos = 0;


    // divide text up in phrases?
    // XXX TODO: broken -- see apps/tour/tourguide.cc for more complete
    if(phrase_delim != NULL) {
        while( (f = text.find_first_of(phrase_delim, pos)) != text.npos) {
            if( fprintf(socket_fp, "(SayText \"%s\")", text.substr(pos, f).c_str()) <= 0)
                throw ServerCommError("Error writing command.");
            pos = f;
        }
    } else {
        if( fprintf(socket_fp, "(SayText \"%s\")\n", text.c_str()) <= 0 )
            throw ServerCommError("Error writing command.");
    }
    fflush(socket_fp);
}


void FestTalk::open_server(char *host, int port) throw (ServerCommError) {
    struct sockaddr_in address;
    LOG("Festival Talkative", 3, "Opening connection to Festival server at " << host << ":" << port);
    if( (socket_fd = socket(PF_INET, SOCK_STREAM, 0)) == -1) {
        LOG("Festival Talkative", 0, "Error creating socket. " << strerror(errno));
        throw ServerCommError(string("Error opening server: ") + strerror(errno));
        return;
    }
    struct hostent* he;
    if(!(he = gethostbyname(host))) {
        LOG("Festival Talkative", 0, "Error: Invalid address. " << host);
        throw ServerCommError("Invalid address.");
        return;
    }
    memset(&address, 0, sizeof(address));
    address.sin_port=htons(port);
    address.sin_family=AF_INET;
    address.sin_addr=*((struct in_addr *)he->h_addr);
    if( connect(socket_fd, (struct sockaddr *)&address, sizeof(address)) == -1) {
        LOG("Festival Talkative", 0, "Error connecting to server " << host << ":" << port << ". " << strerror(errno));
        throw ServerCommError(string("Error connecting to server: ") + strerror(errno));
        return;
    }

    if(! (socket_fp = fdopen(socket_fd, "r+")) ) {
        LOG("Festival Talkative", 0, "Error opening stream from fd.");
        throw ServerCommError("Error opening stream fp from socket file descriptor!!");

        return;
    }
}



void FestTalk::close_server() {
    fclose(socket_fp);
    if ( shutdown(socket_fd, 2) < 0 ) {
        LOG("Festival Talkative", 0, "Warning: Error closing socket. " << strerror(errno));
    }
}


/** Constructor: opens socket to Festival server */
FestTalk::FestTalk(MetaObject *super)  throw (ServerCommError)
    : LocalTalkative(super), Talkative(super), MetaObject(super) {
    phrase_delim = NULL;
    try {
        open_server(festival_host, festival_port);
    } catch (ServerCommError e) {
        throw e;
    }
//  open_server("127.0.0.1", 1314);
}

/** Destructor: closes connection to festival server */
FestTalk::~FestTalk() {
    close_server();

}


/** Say message actuator. */
void FestTalk::do_say(TalkMessage& m) throw (ServerCommError) {
    LOG("Festival Talkative", 3, "Speaking message...");
    try {
        festival_server_command(m.sender.get_voice().c_str());
        festival_server_saytext(m.text);
    } catch (ServerCommError e) {
        throw e;
    }
    LOG("Festival Talkative", 3, "Done speaking.");
}

void FestTalk::registerExtenders() {
    LocalSite::addLocalObjectExtension(typeid(FestTalk).name(), new_FestTalk);
    RemoteSite::addRemoteObjectExtension(typeid(FestTalk).name(), new_FestTalk);
}

/** Static generator, for factory. */
MetaObject* FestTalk::new_FestTalk(MetaObject* superobject, const string& type) {
    return new FestTalk(superobject);
}

---