libreoffice-online/loolwsd/ClientSession.hpp

116 lines
3.6 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:
using MasterProcessSession::MasterProcessSession;
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) { MasterProcessSession::_peer = _peer = 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);
}
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);
private:
// 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;
#if 0
public:
MasterProcessSession(const std::string& id,
const Kind kind,
std::shared_ptr<Poco::Net::WebSocket> ws,
std::shared_ptr<DocumentBroker> docBroker,
std::shared_ptr<BasicTileQueue> queue);
virtual ~MasterProcessSession();
/**
* 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 getSaveAs();
std::shared_ptr<DocumentBroker> getDocumentBroker() const { return _docBroker; }
std::shared_ptr<BasicTileQueue> getQueue() const { return _queue; }
bool shutdownPeer(Poco::UInt16 statusCode, const std::string& message);
public:
// Raise this flag on ToClient from ToPrisoner to let ToClient know of load failures
bool _bLoadError = false;
protected:
private:
void dispatchChild();
void forwardToPeer(const char *buffer, int length);
int _curPart;
int _loadPart;
std::shared_ptr<DocumentBroker> _docBroker;
std::shared_ptr<BasicTileQueue> _queue;
#endif
};
#endif
/* vim:set shiftwidth=4 softtabstop=4 expandtab: */