tubes: stop collaborating when the contact leaves

Change-Id: I779aededb95eac6cbfb2fec3e97d207704244e25

sc/source/ui/collab/sccollaboration.cxx

@@ -21,6 +21,17 @@ ScCollaboration::~ScCollaboration()
 {
 }
 
+void ScCollaboration::ContactLeft()
+{
+    SAL_INFO( "sc.tubes", "Contact has left the collaboration" );
+    ScDocFuncSend* pSender = GetScDocFuncSend();
+    if (pSender)
+    {
+        delete pSender;
+        mpScDocShell->SetDocFunc( new ScDocFuncDirect( *mpScDocShell ) );
+    }
+}
+
 TeleConference* ScCollaboration::GetConference()
 {
     ScDocFuncSend* pSender = GetScDocFuncSend();

sc/source/ui/collab/sendfunc.cxx

@@ -356,7 +356,9 @@ ScDocFunc *ScDocShell::CreateDocFunc()
         ScDocFuncDirect *pDirect = new ScDocFuncDirect( *this );
         ScDocFuncRecv *pReceiver = new ScDocFuncRecv( pDirect );
         ScDocFuncSend *pSender = new ScDocFuncSend( *this, pReceiver );
-        pSender->SetCollaboration( TeleManager::getConference() );
+        TeleConference* pConference = TeleManager::getConference();
+        pConference->setCollaboration( mpCollaboration );
+        pSender->SetCollaboration( pConference );
         return pSender;
     }
     else

sc/source/ui/inc/sccollaboration.hxx

@@ -21,6 +21,7 @@ public:
                             ScCollaboration( ScDocShell* pScDocShell );
     virtual                 ~ScCollaboration();
 
+    virtual void            ContactLeft();
     virtual TeleConference* GetConference();
     virtual sal_uInt64      GetId();
     virtual void            SetCollaboration( TeleConference* pConference );

tubes/inc/tubes/collaboration.hxx

@@ -23,6 +23,7 @@ public:
             Collaboration() {}
     virtual ~Collaboration() {}
 
+    virtual void                ContactLeft() = 0;
     virtual TeleConference*     GetConference() = 0;
     virtual sal_uInt64          GetId() = 0;
     virtual void                SetCollaboration( TeleConference* pConference ) = 0;

tubes/inc/tubes/conference.hxx

@@ -34,6 +34,7 @@
 #include <rtl/ustring.hxx>
 #include <tubes/warnings_guard_boost_signals2.hpp>
 
+class Collaboration;
 class TeleManager;
 class TeleConferenceImpl;
 typedef struct _TpAccount TpAccount;
@@ -73,6 +74,9 @@ public:
     TUBES_DLLPUBLIC void    sendFile( TpContact* pContact, rtl::OUString &localUri, FileSentCallback pCallback, void* pUserData);
     const OString&          getUuid() const { return msUuid; }
 
+    Collaboration*          getCollaboration() const { return mpCollaboration; }
+    void                    setCollaboration( Collaboration* pCollaboration ) { mpCollaboration = pCollaboration; }
+
     // --- following only to be called only by manager's callbacks ---
     // TODO: make friends instead
     void                    setChannel( TpAccount* pAccount, TpDBusTubeChannel* pChannel );
@@ -98,6 +102,7 @@ private:
     // Private:
     bool                    spinUntilTubeEstablished();
 
+    Collaboration*          mpCollaboration;
     TeleManager*            mpManager;
     TpAccount*              mpAccount;
     TpDBusTubeChannel*      mpChannel;

tubes/source/contact-list.cxx

@@ -71,8 +71,7 @@ ContactList::~ContactList()
     mpAccountManager = NULL;
 }
 
-static bool
-tb_contact_is_online (TpContact *contact)
+bool tb_contact_is_online( TpContact *contact )
 {
     switch (tp_contact_get_presence_type (contact))
     {

tubes/source/contacts.cxx

@@ -124,6 +124,7 @@ class TubeContacts : public ModelessDialog
                         tp_contact_get_identifier( pContact ) );
             else
             {
+                pConference->setCollaboration( mpCollaboration );
                 mpCollaboration->SetCollaboration( pConference );
                 mpCollaboration->SendFile( pContact, OStringToOUString(
                             pConference->getUuid(), RTL_TEXTENCODING_UTF8 ) );
@@ -146,6 +147,7 @@ class TubeContacts : public ModelessDialog
                 SAL_WARN( "tubes", "Could not start group session." );
             else
             {
+                pConference->setCollaboration( mpCollaboration );
                 mpCollaboration->SetCollaboration( pConference );
             }
         }

tubes/source/manager.cxx

@@ -27,6 +27,8 @@
  */
 
 #include <tubes/manager.hxx>
+
+#include <tubes/collaboration.hxx>
 #include <tubes/conference.hxx>
 #include <tubes/constants.h>
 #include <tubes/contact-list.hxx>
@@ -103,6 +105,22 @@ public:
                             ~TeleManagerImpl();
 };
 
+bool tb_contact_is_online( TpContact* pContact );
+
+static void contact_presence_changed_cb( TpContact* pContact,
+                                         guint      /* type */,
+                                         gchar*     /* status */,
+                                         gchar*     /* message */,
+                                         gpointer   pConference )
+{
+    if (!tb_contact_is_online( pContact ))
+    {
+        Collaboration* pCollaboration =
+            reinterpret_cast<TeleConference*> (pConference)->getCollaboration();
+        if (pCollaboration)
+            pCollaboration->ContactLeft();
+    }
+}
 
 void TeleManager_DBusChannelHandler(
         TpSimpleHandler*            /*handler*/,
@@ -139,6 +157,10 @@ void TeleManager_DBusChannelHandler(
             TeleConference* pConference = new TeleConference( pManager, pAccount, TP_DBUS_TUBE_CHANNEL( pChannel ) );
             pConference->acceptTube();
             pManager->addConference( pConference );
+            TpContact* pContact = tp_channel_get_target_contact( pChannel );
+            if (pContact)
+                g_signal_connect( pContact, "presence-changed",
+                        G_CALLBACK (contact_presence_changed_cb), pConference );
         }
         else
         {
@@ -689,6 +711,9 @@ TeleConference* TeleManager::startBuddySession( TpAccount *pAccount, TpContact *
     if (!pConference->isReady())
         return NULL;
 
+    g_signal_connect( pBuddy, "presence-changed",
+            G_CALLBACK (contact_presence_changed_cb), pConference );
+
     return pConference;
 }