- * Copyright (c) 2010-2013 Isode Limited.

-#include <boost/date_time/posix_time/posix_time.hpp>

-#include <iostream>

-#include <Swiften/Base/Log.h>

-#include <Swiften/Network/BoostTimer.h>

-#include <Swiften/Network/TimerFactory.h>

-#include <Swiften/Network/BoostNetworkFactories.h>

-#include <Swiften/Client/ClientXMLTracer.h>

-#include <Swiften/FileTransfer/OutgoingSIFileTransfer.h>

-#include <Swiften/FileTransfer/SOCKS5BytestreamServer.h>

-#include <Swiften/Network/BoostConnectionServer.h>

-#include <Swiften/FileTransfer/OutgoingFileTransferManager.h>

-#include <Swiften/Disco/EntityCapsManager.h>

-#include <Swiften/Base/ByteArray.h>

-#include <Swiften/FileTransfer/FileTransferManager.h>

-/*

- * Copyright (c) 2010-2013 Isode Limited.

- * All rights reserved.

- * See the COPYING file for more information.

- */

-

-#include <Swiften/FileTransfer/OutgoingSIFileTransfer.h>

-

-#include <boost/bind.hpp>

-#include <boost/smart_ptr/make_shared.hpp>

-

-#include <Swiften/FileTransfer/StreamInitiationRequest.h>

-#include <Swiften/FileTransfer/BytestreamsRequest.h>

-#include <Swiften/FileTransfer/SOCKS5BytestreamServer.h>

-#include <Swiften/FileTransfer/IBBSendSession.h>

-

-namespace Swift {

-

-OutgoingSIFileTransfer::OutgoingSIFileTransfer(const std::string& id, const JID& from, const JID& to, const std::string& name, unsigned long long size, const std::string& description, boost::shared_ptr<ReadBytestream> bytestream, IQRouter* iqRouter, SOCKS5BytestreamServer* socksServer) : id(id), from(from), to(to), name(name), size(size), description(description), bytestream(bytestream), iqRouter(iqRouter), socksServer(socksServer) {

-}

-

-void OutgoingSIFileTransfer::start() {

- /*

- StreamInitiation::ref streamInitiation(new StreamInitiation());

- streamInitiation->setID(id);

- streamInitiation->setFileInfo(StreamInitiationFileInfo(name, description, size));

- //streamInitiation->addProvidedMethod("http://jabber.org/protocol/bytestreams");

- streamInitiation->addProvidedMethod("http://jabber.org/protocol/ibb");

- StreamInitiationRequest::ref request = StreamInitiationRequest::create(to, streamInitiation, iqRouter);

- request->onResponse.connect(boost::bind(&OutgoingSIFileTransfer::handleStreamInitiationRequestResponse, this, _1, _2));

- request->send();

- */

-}

-

-void OutgoingSIFileTransfer::stop() {

-}

-

-void OutgoingSIFileTransfer::handleStreamInitiationRequestResponse(StreamInitiation::ref, ErrorPayload::ref) {

- /*

- if (error) {

- finish(FileTransferError());

- }

- else {

- if (response->getRequestedMethod() == "http://jabber.org/protocol/bytestreams") {

- socksServer->addReadBytestream(id, from, to, bytestream);

- Bytestreams::ref bytestreams(new Bytestreams());

- bytestreams->setStreamID(id);

- HostAddressPort addressPort = socksServer->getAddressPort();

- bytestreams->addStreamHost(Bytestreams::StreamHost(addressPort.getAddress().toString(), from, addressPort.getPort()));

- BytestreamsRequest::ref request = BytestreamsRequest::create(to, bytestreams, iqRouter);

- request->onResponse.connect(boost::bind(&OutgoingSIFileTransfer::handleBytestreamsRequestResponse, this, _1, _2));

- request->send();

- }

- else if (response->getRequestedMethod() == "http://jabber.org/protocol/ibb") {

- ibbSession = boost::make_shared<IBBSendSession>(id, from, to, bytestream, iqRouter);

- ibbSession->onFinished.connect(boost::bind(&OutgoingSIFileTransfer::handleIBBSessionFinished, this, _1));

- ibbSession->start();

- }

- }

- */

-}

-

-void OutgoingSIFileTransfer::handleBytestreamsRequestResponse(Bytestreams::ref, ErrorPayload::ref) {

- /*

- if (error) {

- finish(FileTransferError());

- }

- */

- //socksServer->onTransferFinished.connect();

-}

-

-void OutgoingSIFileTransfer::finish(boost::optional<FileTransferError>) {

- /*

- if (ibbSession) {

- ibbSession->onFinished.disconnect(boost::bind(&OutgoingSIFileTransfer::handleIBBSessionFinished, this, _1));

- ibbSession.reset();

- }

- socksServer->removeReadBytestream(id, from, to);

- onFinished(error);

- */

-}

-

-void OutgoingSIFileTransfer::handleIBBSessionFinished(boost::optional<FileTransferError>) {

- //finish(error);

-}

-

-}

-/*

- * Copyright (c) 2010-2015 Isode Limited.

- * All rights reserved.

- * See the COPYING file for more information.

- */

-

-#pragma once

-

-#include <boost/shared_ptr.hpp>

-

-#include <Swiften/Base/API.h>

-#include <Swiften/FileTransfer/OutgoingFileTransfer.h>

-#include <Swiften/FileTransfer/ReadBytestream.h>

-#include <Swiften/Base/boost_bsignals.h>

-#include <Swiften/FileTransfer/FileTransferError.h>

-#include <Swiften/FileTransfer/SOCKS5BytestreamServer.h>

-#include <Swiften/JID/JID.h>

-#include <Swiften/Elements/StreamInitiation.h>

-#include <Swiften/Elements/Bytestreams.h>

-#include <Swiften/Elements/ErrorPayload.h>

-#include <Swiften/FileTransfer/IBBSendSession.h>

-

-namespace Swift {

- class IQRouter;

- class SOCKS5BytestreamServer;

-

- class SWIFTEN_API OutgoingSIFileTransfer : public OutgoingFileTransfer {

- public:

- OutgoingSIFileTransfer(const std::string& id, const JID& from, const JID& to, const std::string& name, unsigned long long size, const std::string& description, boost::shared_ptr<ReadBytestream> bytestream, IQRouter* iqRouter, SOCKS5BytestreamServer* socksServer);

-

- virtual void start();

- virtual void stop();

-

- boost::signal<void (const boost::optional<FileTransferError>&)> onFinished;

-

- private:

- void handleStreamInitiationRequestResponse(StreamInitiation::ref, ErrorPayload::ref);

- void handleBytestreamsRequestResponse(Bytestreams::ref, ErrorPayload::ref);

- void finish(boost::optional<FileTransferError> error);

- void handleIBBSessionFinished(boost::optional<FileTransferError> error);

-

- private:

- std::string id;

- JID from;

- JID to;

- std::string name;

- unsigned long long size;

- std::string description;

- boost::shared_ptr<ReadBytestream> bytestream;

- IQRouter* iqRouter;

- SOCKS5BytestreamServer* socksServer;

- boost::shared_ptr<IBBSendSession> ibbSession;

- };

-}

- "OutgoingSIFileTransfer.cpp",