/* * Copyright (c) 2010-2016 Isode Limited. * All rights reserved. * See the COPYING file for more information. */ #pragma once #include <memory> #include <boost/optional.hpp> #include <boost/signals2.hpp> #include <Swiften/Base/API.h> #include <Swiften/Elements/ErrorPayload.h> #include <Swiften/Elements/IBB.h> #include <Swiften/FileTransfer/FileTransferError.h> #include <Swiften/FileTransfer/ReadBytestream.h> #include <Swiften/JID/JID.h> namespace Swift { class IQRouter; class IBBRequest; class SWIFTEN_API IBBSendSession { public: IBBSendSession( const std::string& id, const JID& from, const JID& to, std::shared_ptr<ReadBytestream> bytestream, IQRouter* router); ~IBBSendSession(); void start(); void stop(); const JID& getSender() const { return from; } const JID& getReceiver() const { return to; } void setBlockSize(unsigned int blockSize) { this->blockSize = blockSize; } boost::signals2::signal<void (boost::optional<FileTransferError>)> onFinished; boost::signals2::signal<void (size_t)> onBytesSent; private: void handleIBBResponse(IBB::ref, ErrorPayload::ref); void finish(boost::optional<FileTransferError>); void sendMoreData(); void handleDataAvailable(); private: std::string id; JID from; JID to; std::shared_ptr<ReadBytestream> bytestream; IQRouter* router; unsigned int blockSize; int sequenceNumber; bool active; bool waitingForData; std::shared_ptr<IBBRequest> currentRequest; }; }