libreoffice-online/loolwsd/ClientSession.hpp

116 lines
3.3 KiB
C++
Raw Normal View History

/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4; fill-column: 100 -*- */
/*
* This file is part of the LibreOffice project.
*
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/
#ifndef INCLUDED_CLIENTSSESSION_HPP
#define INCLUDED_CLIENTSSESSION_HPP
#include <time.h>
#include <Poco/Random.h>
#include "MasterProcessSession.hpp"
#include "LOOLSession.hpp"
#include "MessageQueue.hpp"
class DocumentBroker;
class PrisonerSession;
class ClientSession final : public MasterProcessSession, public std::enable_shared_from_this<ClientSession>
{
public:
ClientSession(const std::string& id,
std::shared_ptr<Poco::Net::WebSocket> ws,
std::shared_ptr<DocumentBroker> docBroker,
std::shared_ptr<BasicTileQueue> queue);
virtual ~ClientSession();
void setEditLock(const bool value);
void markEditLock(const bool value) { _bEditLock = value; }
bool isEditLocked() const { return _bEditLock; }
void setPeer(const std::shared_ptr<PrisonerSession>& peer);
/**
* Return the URL of the saved-as document when it's ready. If called
* before it's ready, the call blocks till then.
*/
std::string getSaveAsUrl()
{
const auto payload = _saveAsQueue.get();
return std::string(payload.data(), payload.size());
}
void setSaveAsUrl(const std::string& url)
{
_saveAsQueue.put(url);
}
bool isLoadFailed() const { return _loadFailed; }
void setLoadFailed(const std::string& reason)
{
Log::warn("Document load failed: " + reason);
_loadFailed = true;
}
void sendToInputQueue(const std::string& message)
{
_queue->put(message);
}
std::shared_ptr<DocumentBroker> getDocumentBroker() const { return _docBroker; }
private:
virtual bool _handleInput(const char *buffer, int length) override;
bool loadDocument(const char *buffer, int length, Poco::StringTokenizer& tokens);
bool getStatus(const char *buffer, int length);
bool getCommandValues(const char *buffer, int length, Poco::StringTokenizer& tokens);
bool getPartPageRectangles(const char *buffer, int length);
void sendTile(const char *buffer, int length, Poco::StringTokenizer& tokens);
void sendCombinedTiles(const char *buffer, int length, Poco::StringTokenizer& tokens);
void sendFontRendering(const char *buffer, int length, Poco::StringTokenizer& tokens);
void dispatchChild();
private:
std::shared_ptr<DocumentBroker> _docBroker;
/// The incoming message queue.
std::shared_ptr<BasicTileQueue> _queue;
// If this document holds the edit lock.
// An edit lock will only allow the current session to make edits,
// while other session opening the same document can only see
bool _bEditLock = false;
std::weak_ptr<PrisonerSession> _peer;
/// Store URLs of completed 'save as' documents.
MessageQueue _saveAsQueue;
/// Marks if document loading failed.
bool _loadFailed;
int _loadPart;
#if 0
bool shutdownPeer(Poco::UInt16 statusCode, const std::string& message);
private:
void forwardToPeer(const char *buffer, int length);
#endif
};
#endif
/* vim:set shiftwidth=4 softtabstop=4 expandtab: */