/*
 * 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;
    };
}