kopete/protocols/telepathy/telepathychatsession.cpp

   1 /*
   2  * telepathychatsession.cpp - Telepathy Chat Session.
   3  *
   4  * Copyright (c) 2006 by Michaël Larouche <larouche@kde.org>
   5  *
   6  * Kopete    (c) 2002-2006 by the Kopete developers  <kopete-devel@kde.org>
   7  *
   8  *************************************************************************
   9  *                                                                       *
  10  * This program is free software; you can redistribute it and/or modify  *
  11  * it under the terms of the GNU General Public License as published by  *
  12  * the Free Software Foundation; either version 2 of the License, or     *
  13  * (at your option) any later version.                                   *
  14  *                                                                       *
  15  *************************************************************************
  16  */
  17 #include "telepathychatsession.h"
  18
  19 // Qt includes
  20 #include <QtCore/QPointer>
  21
  22 // KDE includes
  23 #include <kdebug.h>
  24 #include <klocale.h>
  25
  26 // Kopete includes
  27 #include <kopetechatsessionmanager.h>
  28
  29 // QtTapioca includes
  30 #include <QtTapioca/Contact>
  31
  32 // Local includes
  33 #include "telepathyprotocol.h"
  34 #include "telepathyaccount.h"
  35 #include "telepathycontact.h"
  36
  37 using namespace QtTapioca;
  38
  39 class TelepathyChatSession::Private
  40 {
  41 public:
  42         QPointer<QtTapioca::TextChannel> textChannel;
  43 };
  44
  45 TelepathyChatSession::TelepathyChatSession(const Kopete::Contact *user, Kopete::ContactPtrList others, Kopete::Protocol *protocol)
  46  : Kopete::ChatSession(user, others, protocol), d(new Private)
  47 {
  48         Kopete::ChatSessionManager::self()->registerChatSession(this);
  49
  50         connect(this, SIGNAL(messageSent(Kopete::Message&, Kopete::ChatSession*)), this, SLOT(sendMessage(Kopete::Message&)));
  51 }
  52
  53 TelepathyChatSession::~TelepathyChatSession()
  54 {
  55         kDebug(TELEPATHY_DEBUG_AREA) ;
  56
  57         // End text channel session
  58         d->textChannel->close();
  59
  60         delete d;
  61 }
  62
  63 QtTapioca::TextChannel* TelepathyChatSession::textChannel()
  64 {
  65         Q_ASSERT( !d->textChannel.isNull() );
  66
  67         return d->textChannel;
  68 }
  69
  70 void TelepathyChatSession::setTextChannel(QtTapioca::TextChannel *textChannel)
  71 {
  72         // Disconnect previous signals connection
  73         if( !d->textChannel.isNull() )
  74         {
  75                 d->textChannel->disconnect();
  76         }
  77
  78         d->textChannel = textChannel;
  79
  80         // Connect signal/slots
  81         connect(d->textChannel, SIGNAL(messageReceived(QtTapioca::TextChannel::Message)), this, SLOT(telepathyMessageReceived(QtTapioca::TextChannel::Message)));
  82
  83         connect(d->textChannel, SIGNAL(messageDeliveryError(QtTapioca::TextChannel::Message, QtTapioca::TextChannel::Message::DeliveryError)), this, SLOT(telepathyMessageDeliveryError(QtTapioca::TextChannel::Message, QtTapioca::TextChannel::Message::DeliveryError)));
  84
  85         connect(d->textChannel, SIGNAL(messageSent(QtTapioca::TextChannel::Message)), this, SLOT(telepathyMessageSent(QtTapioca::TextChannel::Message)));
  86 }
  87
  88 void TelepathyChatSession::telepathyMessageReceived(const QtTapioca::TextChannel::Message &message)
  89 {
  90         kDebug(TELEPATHY_DEBUG_AREA) ;
  91
  92         // Create a new Kopete::Message
  93         Kopete::Message::MessageType messageType = Kopete::Message::TypeNormal;
  94
  95         if( message.type() == QtTapioca::TextChannel::Message::Action )
  96         {
  97                 messageType = Kopete::Message::TypeAction;
  98         }
  99
 100         Kopete::Message newMessage( members().first(), myself() );
 101         newMessage.setPlainBody( message.contents() );
 102         newMessage.setDirection( Kopete::Message::Inbound );
 103         newMessage.setType( messageType );
 104
 105         appendMessage( newMessage );
 106 }
 107
 108 void TelepathyChatSession::telepathyMessageSent(const QtTapioca::TextChannel::Message &message)
 109 {
 110         kDebug(TELEPATHY_DEBUG_AREA) << "Message contents: " << message.contents();
 111
 112         Kopete::Message::MessageType messageType = Kopete::Message::TypeNormal;
 113
 114         if( message.type() == QtTapioca::TextChannel::Message::Action )
 115         {
 116                 messageType = Kopete::Message::TypeAction;
 117         }
 118
 119         Kopete::Message newMessage( myself(), members() );
 120         newMessage.setPlainBody( message.contents() );
 121         newMessage.setDirection( Kopete::Message::Outbound );
 122         newMessage.setType( messageType );
 123
 124         // Append successfully sent message to chat window and notify other components of success
 125         appendMessage( newMessage );
 126         messageSucceeded();
 127 }
 128
 129 void TelepathyChatSession::telepathyMessageDeliveryError(const QtTapioca::TextChannel::Message &message, QtTapioca::TextChannel::Message::DeliveryError error)
 130 {
 131         kDebug(TELEPATHY_DEBUG_AREA) ;
 132         QString internalErrorMessage, errorMessageText;
 133         switch(error)
 134         {
 135                 case TextChannel::Message::ContactOffline:
 136                         internalErrorMessage = i18n("Contact is offline.");
 137                         break;
 138                 case TextChannel::Message::InvalidContact:
 139                         internalErrorMessage = i18n("Contact is invalid.");
 140                         break;
 141                 case TextChannel::Message::PermissionDenied:
 142                         internalErrorMessage = i18n("You do not have permission to send a message to this contact.");
 143                         break;
 144                 case TextChannel::Message::MessageTooLong:
 145                         internalErrorMessage = i18n("Message is too long.");
 146                         break;
 147                 case TextChannel::Message::Unknown:
 148                         internalErrorMessage = i18n("Unknown reason");
 149                         break;
 150         }
 151
 152         // The following message:
 153         // "test
 154         //  testsfaefe"
 155         // could not be delivered. Reason: Contact is offline.
 156         errorMessageText = i18n("The following message:\n \"%1\"\ncould not be delivered. Reason: %2", message.contents(), internalErrorMessage);
 157
 158         Kopete::Message errorMessage( myself(), members() );
 159         errorMessage.setPlainBody( errorMessageText );
 160         errorMessage.setDirection( Kopete::Message::Internal );
 161
 162         appendMessage( errorMessage );
 163 }
 164
 165 void TelepathyChatSession::sendMessage(Kopete::Message &message)
 166 {
 167         kDebug(TELEPATHY_DEBUG_AREA) << "Sending: " << message.plainBody();
 168
 169         // TODO: Support other type of message (when QtTapioca will support it)
 170         QtTapioca::TextChannel::Message messageSend( message.plainBody() );
 171
 172         textChannel()->sendMessage( messageSend );
 173 }
 174
 175 #include "telepathychatsession.moc"