42using namespace std::string_literals;
58namespace Experimental {
113 std::list<std::shared_ptr<WebCommand>>
fCmds;
133 void ProcessData(
unsigned connid,
const std::string &arg);
162 void NewDisplay(const std::
string &where) final;
168 void Run(
double tm = 0.) final;
183 return std::make_unique<RCanvasPainter>(canv);
191 R__LOG_ERROR(CanvasPainerLog()) <<
"Generator is already set! Skipping second initialization.";
214RCanvasPainter::RCanvasPainter(
RCanvas &canv) : fCanvas(canv)
238 item.fCallback(
false);
248 std::list<std::shared_ptr<WebCommand>> remainingCmds;
250 for (
auto &&cmd :
fCmds) {
251 if (!connid || (cmd->fConnId == connid)) {
252 cmd->CallBack(
false);
255 remainingCmds.emplace_back(std::move(cmd));
267 uint64_t min_delivered = 0;
268 bool is_any_send =
true;
271 while (is_any_send && (++loopcnt < 10)) {
277 if (conn.fDelivered && (!min_delivered || (min_delivered < conn.fDelivered)))
278 min_delivered = conn.fDelivered;
281 bool need_send_snapshot = (conn.fSend !=
fCanvas.
GetModified()) && (conn.fDelivered == conn.fSend);
284 if (need_send_snapshot && (loopcnt == 0))
285 if (std::find(conn.fSendQueue.begin(), conn.fSendQueue.end(),
""s) == conn.fSendQueue.end())
286 conn.fSendQueue.emplace_back(
""s);
289 if (!
fWindow->CanSend(conn.fConnId,
true))
295 ((
fCmds.front()->fConnId == 0) || (
fCmds.front()->fConnId == conn.fConnId))) {
297 auto &cmd =
fCmds.front();
299 cmd->fConnId = conn.fConnId;
305 }
else if (!conn.fSendQueue.empty()) {
307 buf = conn.fSendQueue.front().c_str();
308 conn.fSendQueue.pop_front();
311 if (!need_send_snapshot && (buf.
Length() == 0) && !conn.fSendQueue.empty()) {
312 buf = conn.fSendQueue.front().c_str();
313 conn.fSendQueue.pop_front();
317 if ((buf.
Length() == 0) && need_send_snapshot) {
347 if (item.fVersion > fSnapshotDelivered)
384 fWindow->WaitForTimed([
this, ver](
double) {
413 if (arg ==
"AddPanel") {
415 connid =
fWindow->GetConnectionId();
427 auto cmd = std::make_shared<WebCommand>(std::to_string(++
fCmdsCnt),
name, arg, callback, connid);
428 fCmds.emplace_back(cmd);
434 int res =
fWindow->WaitForTimed([
this, cmd](
double) {
436 R__LOG_DEBUG(0, CanvasPainerLog()) <<
"Command " << cmd->fName <<
" done";
437 return cmd->fResult ? 1 : -1;
441 if (!
fWindow->HasConnection(cmd->fConnId,
false))
451 R__LOG_ERROR(CanvasPainerLog()) <<
name <<
" fail with " << arg <<
" result = " << res;
465 auto len = fname.length();
466 if ((
len > 4) && ((fname.compare(
len-4,4,
".json") == 0) || (fname.compare(
len-4,4,
".JSON") == 0))) {
467 std::ofstream
f(fname);
469 R__LOG_ERROR(CanvasPainerLog()) <<
"Fail to open file " << fname <<
" to store canvas snapshot";
472 R__LOG_INFO(CanvasPainerLog()) <<
"Store canvas in " << fname;
504 auto check_header = [&arg, &cdata](
const std::string &header) {
505 if (arg.compare(0, header.length(), header) != 0)
507 cdata = arg.substr(header.length());
514 if (check_header(
"READY")) {
516 }
else if (check_header(
"SNAPDONE:")) {
517 conn->fDelivered = (uint64_t)std::stoll(cdata);
518 }
else if (arg ==
"QUIT") {
522 }
else if (arg ==
"RELOAD") {
524 }
else if (arg ==
"INTERRUPT") {
525 gROOT->SetInterrupt();
526 }
else if (check_header(
"REPLY:")) {
527 const char *sid = cdata.c_str();
528 const char *separ = strchr(sid,
':');
531 id.append(sid, separ - sid);
533 R__LOG_ERROR(CanvasPainerLog()) <<
"Get REPLY without command";
535 R__LOG_ERROR(CanvasPainerLog()) <<
"Front command is not running when get reply";
536 }
else if (
fCmds.front()->fId !=
id) {
537 R__LOG_ERROR(CanvasPainerLog()) <<
"Mismatch with front command and ID in REPLY";
541 }
else if (check_header(
"SAVE:")) {
543 }
else if (check_header(
"PRODUCE:")) {
544 R__LOG_DEBUG(0, CanvasPainerLog()) <<
"Create file " << cdata;
549 }
else if (check_header(
"REQ:")) {
550 auto req = TBufferJSON::FromJSON<RDrawableRequest>(cdata);
552 std::shared_ptr<RDrawable> drawable;
553 req->GetContext().SetCanvas(&
fCanvas);
554 if (req->GetId().empty() || (req->GetId() ==
"canvas")) {
555 req->GetContext().SetPad(
nullptr);
556 req->GetContext().SetDrawable(&
fCanvas, 0);
560 req->GetContext().SetPad(
const_cast<RPadBase *
>(subpad));
561 req->GetContext().SetDrawable(drawable.get(), 0);
564 req->GetContext().SetConnection(connid, conn ==
fWebConn.begin());
566 auto reply = req->Process();
568 if (req->ShouldBeReplyed()) {
570 reply = std::make_unique<RDrawableReply>();
572 reply->SetRequestId(req->GetRequestId());
575 conn->fSendQueue.emplace_back(
"REPL_REQ:"s +
json.Data());
579 if (req->NeedCanvasUpdate())
583 R__LOG_ERROR(CanvasPainerLog()) <<
"Fail to parse RDrawableRequest";
585 }
else if (check_header(
"RESIZED:")) {
586 auto sz = TBufferJSON::FromJSON<std::vector<int>>(cdata);
587 if (sz && sz->size() == 2) {
591 }
else if (check_header(
"CLEAR")) {
595 R__LOG_ERROR(CanvasPainerLog()) <<
"Got not recognized message" << arg;
610 fWindow->SetDefaultPage(
"file:rootui5sys/canv/canvas.html");
613 [
this](
unsigned connid) {
618 [
this](
unsigned connid,
const std::string &arg) {
ProcessData(connid, arg); },
620 [
this](
unsigned connid) {
663 return fWindow->NumConnections();
681 if (
gROOT->IsWebDisplayBatch())
685 R__LOG_ERROR(CanvasPainerLog()) <<
"Canvas not yet shown in AddPanel";
690 R__LOG_ERROR(CanvasPainerLog()) <<
"Canvas window was not shown to call AddPanel";
694 std::string addr =
fWindow->GetRelativeAddr(
win);
696 if (addr.length() == 0) {
697 R__LOG_ERROR(CanvasPainerLog()) <<
"Cannot attach panel to canvas";
704 std::string cmd(
"ADDPANEL:");
719 fWindow->SetClearOnClose(handle);
729 auto canvitem = std::make_unique<RCanvasDisplayItem>();
736 canvitem->BuildFullId(
"");
737 canvitem->SetObjectID(
"canvas");
742 static std::vector<const TClass *> exclude_classes = {
743 TClass::GetClass<RAttrMap::NoValue_t>(),
744 TClass::GetClass<RAttrMap::BoolValue_t>(),
745 TClass::GetClass<RAttrMap::IntValue_t>(),
746 TClass::GetClass<RAttrMap::DoubleValue_t>(),
747 TClass::GetClass<RAttrMap::StringValue_t>(),
748 TClass::GetClass<RAttrMap>(),
749 TClass::GetClass<RStyle::Block_t>(),
750 TClass::GetClass<RPadPos>(),
751 TClass::GetClass<RPadLength>(),
752 TClass::GetClass<RPadExtent>(),
753 TClass::GetClass<std::unordered_map<std::string,RAttrMap::Value_t*>>()
756 for (
auto cl : exclude_classes)
757 json.SetSkipClassInfo(cl);
759 auto res =
json.StoreObject(canvitem.get(), TClass::GetClass<RCanvasDisplayItem>());
761 return std::string(res.Data());
768std::shared_ptr<RDrawable>
771 std::string search =
id;
772 size_t pos = search.find(
"#");
774 if (pos != std::string::npos)
788 size_t pos = reply.find(
":");
789 if ((pos == std::string::npos) || (pos == 0)) {
790 R__LOG_ERROR(CanvasPainerLog()) <<
"SaveCreatedFile does not found ':' separator";
794 std::string fname(reply, 0, pos);
795 reply.erase(0, pos + 1);
797 Bool_t isSvg = (fname.length() > 4) && ((fname.rfind(
".svg") == fname.length()-4) || (fname.rfind(
".SVG") == fname.length()-4));
801 std::ofstream ofs(fname, std::ios::binary);
804 file_len = reply.length();
808 file_len = binary.
Length();
812 R__LOG_INFO(CanvasPainerLog()) <<
" Save file from GUI " << fname <<
" len " << file_len;
820 auto cmd =
fCmds.front();
827 if ((cmd->fName ==
"SVG") || (cmd->fName ==
"PNG") || (cmd->fName ==
"JPEG")) {
828 if (reply.length() == 0) {
829 R__LOG_ERROR(CanvasPainerLog()) <<
"Fail to produce image" << cmd->fArg;
832 std::ofstream ofs(cmd->fArg, std::ios::binary);
835 R__LOG_INFO(CanvasPainerLog()) << cmd->fName <<
" create file " << cmd->fArg <<
" length " << content.
Length();
838 }
else if (cmd->fName.find(
"ADDPANEL:") == 0) {
839 R__LOG_DEBUG(0, CanvasPainerLog()) <<
"get reply for ADDPANEL " << reply;
840 result = (reply ==
"true");
842 R__LOG_ERROR(CanvasPainerLog()) <<
"Unknown command " << cmd->fName;
858 std::this_thread::sleep_for(std::chrono::milliseconds(
int(tm*1000)));
struct TNewCanvasPainterReg newCanvasPainterReg
#define R__LOG_ERROR(...)
#define R__LOG_DEBUG(DEBUGLEVEL,...)
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t result
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize id
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t TString Int_t GCValues_t GetPrimarySelectionOwner GetDisplay GetScreen GetColormap GetNativeEvent const char const char dpyName wid window const char font_name cursor keysym reg const char only_if_exist regb h Point_t winding char text const char depth char const char Int_t count const char ColorStruct_t color const char Pixmap_t Pixmap_t PictureAttributes_t attr const char char ret_data h unsigned char height h Atom_t Int_t ULong_t ULong_t unsigned char prop_list Atom_t Atom_t Atom_t Time_t UChar_t len
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t win
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t height
Abstract interface for painting a canvas.
static std::unique_ptr< Generator > & GetGenerator()
generator getter
static void ResetGlobalPainter()
Release the GeneratorImpl object.
std::unique_ptr< RVirtualCanvasPainter > Create(RCanvas &canv) const override
Create a new RCanvasPainter to paint the given RCanvas.
static void SetGlobalPainter()
Set RVirtualCanvasPainter::fgGenerator to a new GeneratorImpl object.
std::list< WebConn > fWebConn
!< configured display
std::list< std::shared_ptr< WebCommand > > fCmds
! list of submitted commands
uint64_t fCmdsCnt
! commands counter
uint64_t fSnapshotDelivered
! minimal version delivered to all connections
bool AddPanel(std::shared_ptr< RWebWindow >) final
Add window as panel inside canvas window.
std::list< WebUpdate > fUpdatesLst
! list of callbacks for canvas update
void CancelCommands(unsigned connid=0)
Cancel command execution on provided connection All commands are cancelled, when connid === 0.
void SaveCreatedFile(std::string &reply)
Method called when GUI sends file to save on local disk File data coded with base64 coding beside SVG...
std::shared_ptr< RWebWindow > fWindow
void CancelUpdates()
Cancel all pending Canvas::Update()
bool ProduceBatchOutput(const std::string &fname, int width, int height) final
Produce batch output, using chrome headless mode with DOM dump.
std::shared_ptr< RDrawable > FindPrimitive(const RCanvas &can, const std::string &id, const RPadBase **subpad=nullptr)
Find drawable in the canvas with specified id Used to communicate with the clients,...
void DoWhenReady(const std::string &name, const std::string &arg, bool async, CanvasCallback_t callback) final
perform special action when drawing is ready
std::vector< Detail::RMenuItem > MenuItemsVector
std::string GetWindowAddr() const final
Returns web window name.
void Run(double tm=0.) final
Run canvas functionality for specified period of time Required when canvas used not from the main thr...
int NumDisplays() const final
Returns number of connected displays.
void FrontCommandReplied(const std::string &reply)
Process reply on the currently active command.
void ProcessData(unsigned connid, const std::string &arg)
Process data from the client.
int fJsonComp
! json compression for data send to client
void CanvasUpdated(uint64_t ver, bool async, CanvasCallback_t callback) final
Method invoked when canvas should be updated on the client side Depending from delivered status,...
void CheckDataToSend()
Check if canvas need to send data to the clients.
virtual ~RCanvasPainter()
Destructor.
void CreateWindow()
Create web window for canvas.
std::string ProduceJSON() final
Produce JSON for the canvas.
bool IsCanvasModified(uint64_t id) const final
return true if canvas modified since last painting
RCanvasPainter & operator=(const RCanvasPainter &)=delete
Disable assignment.
std::string CreateSnapshot(RDrawable::RDisplayContext &ctxt)
Create JSON representation of data, which should be send to the clients Here server-side painting is ...
RCanvasPainter(const RCanvasPainter &)=delete
Disable copy construction.
void SetClearOnClose(const std::shared_ptr< void > &) final
Set handle to window which will be cleared when connection is closed.
void NewDisplay(const std::string &where) final
Create new display for the canvas See RWebWindowsManager::Show() docu for more info.
RCanvas & fCanvas
! Canvas we are painting, *this will be owned by canvas
const std::string & GetTitle() const
Get the canvas's title.
int GetHeight() const
Get canvas height.
uint64_t GetModified() const
Get modify counter.
void SetHeight(int height)
Set canvas height.
void SetWidth(int width)
Set canvas width.
int GetWidth() const
Get canvas width.
void SetConnection(unsigned connid, bool ismain)
Set connection id and ismain flag for connection.
const std::string & GetId() const
A log configuration for a channel, e.g.
Base class for graphic containers for RDrawable-s.
void DisplayPrimitives(RPadBaseDisplayItem &paditem, RDisplayContext &ctxt)
Create display items for all primitives in the pad Each display item gets its special id,...
std::shared_ptr< RDrawable > FindPrimitiveByDisplayId(const std::string &display_id) const
Find primitive with unique id, produce for RDisplayItem Such id used for client-server identification...
const RPadBase * FindPadForPrimitiveWithDisplayId(const std::string &display_id) const
Find subpad which contains primitive with given display id.
void Wipe()
Wipe the pad by clearing the list of primitives.
Holds different arguments for starting browser with RWebDisplayHandle::Display() method.
RWebDisplayArgs & SetHeight(int h=0)
set preferable web window height
RWebDisplayArgs & SetWidgetKind(const std::string &kind)
set widget kind
RWebDisplayArgs & SetWidth(int w=0)
set preferable web window width
static bool ProduceImage(const std::string &fname, const std::string &json, int width=800, int height=600, const char *batch_file=nullptr)
Produce image file using JSON data as source Invokes JSROOT drawing functionality in headless browser...
Represents web window, which can be shown in web browser or any other supported environment.
static std::shared_ptr< RWebWindow > Create()
Create new RWebWindow Using default RWebWindowsManager.
static TString Decode(const char *data)
Decode a base64 string date into a generic TString.
Class for serializing object to and from JavaScript Object Notation (JSON) format.
static TString ToJSON(const T *obj, Int_t compact=0, const char *member_name=nullptr)
@ kNoSpaces
no new lines plus remove all spaces around "," and ":" symbols
virtual Int_t GetValue(const char *name, Int_t dflt) const
Returns the integer value for a resource.
A ROOT file is a suite of consecutive data records (TKey instances) with a well defined format.
static TFile * Open(const char *name, Option_t *option="", const char *ftitle="", Int_t compress=ROOT::RCompressionSetting::EDefaults::kUseCompiledDefault, Int_t netopt=0)
Create / open a file.
const char * Data() const
static TString ULLtoa(ULong64_t value, Int_t base)
Converts a ULong64_t (twice the range of an Long64_t) to a TString with respect to the base specified...
TString & Append(const char *cs)
void swap(RDirectoryEntry &e1, RDirectoryEntry &e2) noexcept
std::function< void(bool)> CanvasCallback_t
This file contains a specialised ROOT message handler to test for diagnostic in unit tests.
static constexpr double s
unsigned fConnId
! connection id for the command, when 0 specified command will be submitted to any available connecti...
std::string fArg
! command arguments
bool fResult
! result of command execution
std::string fName
! command name
CanvasCallback_t fCallback
! callback function associated with command
WebCommand(const std::string &id, const std::string &name, const std::string &arg, CanvasCallback_t callback, unsigned connid)
enum ROOT::Experimental::RCanvasPainter::WebCommand::@64 sInit
! true when command submitted
std::string fId
! command identifier
unsigned fConnId
! connection id
std::list< std::string > fSendQueue
! send queue for the connection
RDrawable::Version_t fDelivered
! indicates version confirmed from canvas
RDrawable::Version_t fSend
! indicates version send to connection
uint64_t fVersion
! canvas version
CanvasCallback_t fCallback
! callback function associated with the update
WebUpdate(uint64_t ver, CanvasCallback_t callback)