diff options
Diffstat (limited to 'sc/source/ui/collab')
| -rw-r--r-- | sc/source/ui/collab/collab.cxx | 99 | ||||
| -rw-r--r-- | sc/source/ui/collab/sendfunc.cxx | 58 |
2 files changed, 153 insertions, 4 deletions
diff --git a/sc/source/ui/collab/collab.cxx b/sc/source/ui/collab/collab.cxx new file mode 100644 index 000000000000..bc0c99e8a05e --- /dev/null +++ b/sc/source/ui/collab/collab.cxx @@ -0,0 +1,99 @@ +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ +/* + * Version: MPL 1.1 / GPLv3+ / LGPLv3+ + * + * The contents of this file are subject to the Mozilla Public License Version + * 1.1 (the "License"); you may not use this file except in compliance with + * the License or as specified alternatively below. You may obtain a copy of + * the License at http://www.mozilla.org/MPL/ + * + * Software distributed under the License is distributed on an "AS IS" basis, + * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License + * for the specific language governing rights and limitations under the + * License. + * + * Major Contributor(s): + * Copyright (C) 2012 Red Hat, Inc., Eike Rathke <erack@redhat.com> + * + * All Rights Reserved. + * + * For minor contributions see the git repository. + * + * Alternatively, the contents of this file may be used under the terms of + * either the GNU General Public License Version 3 or later (the "GPLv3+"), or + * the GNU Lesser General Public License Version 3 or later (the "LGPLv3+"), + * in which case the provisions of the GPLv3+ or the LGPLv3+ are applicable + * instead of those above. + */ + +#include "collab.hxx" +#include <tubes/manager.hxx> +#include <tubes/conference.hxx> +#include <tubes/contact-list.hxx> + +ScCollaboration::ScCollaboration( const Link& rLink ) + : + maLink( rLink), + mpAccount( NULL), + mpContact( NULL), + mpManager( NULL) +{ +} + + +ScCollaboration::~ScCollaboration() +{ + if (mpAccount) + g_object_unref( mpAccount); + if (mpContact) + g_object_unref( mpContact); + delete mpManager; +} + + +bool ScCollaboration::initManager() +{ + mpManager = new TeleManager( maLink); + bool bOk = mpManager->connect(); + return bOk; +} + + +bool ScCollaboration::initAccountContact() +{ + ContactList aContacts; + AccountContactPairV aVec( aContacts.getContacts()); + if (aVec.empty()) + return false; + + /* TODO: select a pair, for now just take the first */ + mpAccount = aVec[0].first; + mpContact = aVec[0].second; + return true; +} + + +bool ScCollaboration::startCollaboration() +{ + bool bOk = mpManager->startBuddySession( mpAccount, mpContact); + return bOk; +} + + +bool ScCollaboration::sendPacket( const rtl::OString& rString ) +{ + TelePacket aPacket( "sender", rString.getStr(), rString.getLength()); + bool bOk = mpManager->sendPacket( aPacket); + return bOk; +} + + +bool ScCollaboration::recvPacket( rtl::OString& rString, TeleConference* pConference ) +{ + TelePacket aPacket; + bool bOk = (pConference ? pConference->popPacket( aPacket) : mpManager->popPacket( aPacket)); + rString = rtl::OString( aPacket.getData(), aPacket.getSize()); + return bOk; +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ diff --git a/sc/source/ui/collab/sendfunc.cxx b/sc/source/ui/collab/sendfunc.cxx index 9d9a10c37297..ed089558ee25 100644 --- a/sc/source/ui/collab/sendfunc.cxx +++ b/sc/source/ui/collab/sendfunc.cxx @@ -33,6 +33,8 @@ #include "cell.hxx" #include "docsh.hxx" #include "docfunc.hxx" +#include "collab.hxx" +#include <tubes/conference.hxx> // new file send/recv fun ... #include <unotools/tempfile.hxx> @@ -233,16 +235,25 @@ public: class ScDocFuncRecv : public ScDocFunc { ScDocFunc *mpChain; + ScCollaboration* mpCollab; public: // FIXME: really ScDocFunc should be an abstract base ScDocFuncRecv( ScDocShell& rDocSh, ScDocFunc *pChain ) : ScDocFunc( rDocSh ), - mpChain( pChain ) + mpChain( pChain ), + mpCollab( NULL) { fprintf( stderr, "Receiver created !\n" ); } virtual ~ScDocFuncRecv() {} + void SetCollaboration( ScCollaboration* pCollab ) + { + mpCollab = pCollab; + } + + DECL_LINK( ReceiverCallback, TeleConference* ); + void RecvMessage( const rtl::OString &rString ) { try { @@ -280,14 +291,26 @@ public: } }; +IMPL_LINK( ScDocFuncRecv, ReceiverCallback, TeleConference*, pConference ) +{ + rtl::OString aStr; + if (mpCollab && mpCollab->recvPacket( aStr, pConference)) + RecvMessage( aStr); + return 0; +} + class ScDocFuncSend : public ScDocFunc { ScDocFuncRecv *mpChain; + ScCollaboration* mpCollab; void SendMessage( ScChangeOpWriter &rOp ) { fprintf( stderr, "Op: '%s'\n", rOp.toString().getStr() ); - mpChain->RecvMessage( rOp.toString() ); + if (mpCollab) + mpCollab->sendPacket( rOp.toString()); + else + mpChain->RecvMessage( rOp.toString() ); } void SendFile( const rtl::OUString &rURL ) @@ -321,12 +344,18 @@ public: // we don't need the rDocSh hack/pointer ScDocFuncSend( ScDocShell& rDocSh, ScDocFuncRecv *pChain ) : ScDocFunc( rDocSh ), - mpChain( pChain ) + mpChain( pChain ), + mpCollab( NULL) { fprintf( stderr, "Sender created !\n" ); } virtual ~ScDocFuncSend() {} + void SetCollaboration( ScCollaboration* pCollab ) + { + mpCollab = pCollab; + } + virtual void EnterListAction( sal_uInt16 nNameResId ) { // Want to group these operations for the other side ... @@ -441,9 +470,30 @@ public: SC_DLLPRIVATE ScDocFunc *ScDocShell::CreateDocFunc() { - // FIXME: the chains should be auto-ptrs. + // FIXME: the chains should be auto-ptrs, so should be collab if (getenv ("INTERCEPT")) return new ScDocFuncSend( *this, new ScDocFuncRecv( *this, new ScDocFuncDirect( *this ) ) ); + else if (getenv ("LIBO_TUBES")) + { + ScDocFuncRecv* pReceiver = new ScDocFuncRecv( *this, new ScDocFuncDirect( *this ) ); + ScDocFuncSend* pSender = new ScDocFuncSend( *this, pReceiver ); + bool bOk = true; + ScCollaboration* pCollab = new ScCollaboration( LINK( pReceiver, ScDocFuncRecv, ReceiverCallback)); + bOk = bOk && pCollab->initManager(); + bOk = bOk && pCollab->initAccountContact(); + bOk = bOk && pCollab->startCollaboration(); + if (bOk) + { + pReceiver->SetCollaboration( pCollab); + pSender->SetCollaboration( pCollab); + } + else + { + fprintf( stderr, "Could not start collaboration.\n"); + delete pCollab; + } + return pSender; + } else return new ScDocFuncDirect( *this ); } |