File indexing completed on 2024-05-12 11:32:33

 /*
     SPDX-License-Identifier: GPL-2.0-or-later
     SPDX-FileCopyrightText: 2009 Alexander Rieder <alexanderrieder@gmail.com>
 */
 
 #include "rcallbacks.h"
 
 #include "rserver.h"
 
 #include <QDebug>
 #include <QStringList>
 
 #include <R_ext/Rdynload.h>
 #include <R_ext/Callbacks.h>
 #include <Rinternals.h>
 
 #ifdef Q_OS_WIN
 #include <winsock2.h>
 #include <windows.h>
 #undef ERROR     // clashes with R
 #define Win32    // needed for R includes
 #include <R_ext/RStartup.h>
 #include <R_ext/Utils.h>
 #include <R_ext/libextern.h>
 
 structRstart RK_R_Params;
 
 extern "C" {
     // why oh why isn't Rinterface.h available on Windows?
     LibExtern void* R_GlobalContext;
     LibExtern uintptr_t R_CStackLimit;
     LibExtern void R_SaveGlobalEnvToFile(char*);
 }
 #else
 #include <Rinterface.h>
 #endif
 
 #include <stdio.h>
 
 RServer* server;
 Expression* currentExpression;
 
 void setupCallbacks(RServer* r)
 {
     qDebug()<<"RServer: "<<"setting up callbacks";
 
     server=r;
     currentExpression=nullptr;
 
     R_Outputfile=nullptr;
     R_Consolefile=nullptr;
 
     ptr_R_WriteConsole=nullptr;
     ptr_R_WriteConsoleEx=onWriteConsoleEx;
     ptr_R_ShowMessage=onShowMessage;
     ptr_R_Busy=onBusy;
     ptr_R_ReadConsole=onReadConsole;
     ptr_R_ShowFiles=onShowFiles;
 }
 
 void setCurrentExpression(Expression* expr)
 {
     currentExpression=expr;
 }
 
 
 enum OutputType { NormalOutput=0, ErrorOutput=1 };
 
 void onWriteConsoleEx(const char* text, int size, int otype)
 {
     const QString string=QString::fromUtf8(text, size);
     if (otype==NormalOutput)
     {
         currentExpression->std_buffer+=string;
     }else
     {
         currentExpression->err_buffer+=string;
     }
 }
 
 void onShowMessage(const char* text)
 {
     const QString string=QString::fromUtf8(text);
     currentExpression->std_buffer+=string;
 }
 
 void onBusy(int which)
 {
     qDebug()<<"RServer: "<<"onBusy: "<<which;
 }
 
 int onReadConsole(const char* prompt, unsigned char* buf, int buflen, int hist)
 {
     Q_UNUSED(hist);
     qDebug()<<"RServer: "<<"readConsole: "<<prompt;
 
     QString input=server->requestInput(QLatin1String(prompt));
 
     if(input.size()>buflen)
         input.truncate(buflen);
 
     strcpy( (char*) buf, input.toStdString().c_str());
 
     return input.size();
 }
 
 int  onShowFiles(int nfile, const char** file, const char** headers, const char* wtitle, Rboolean del, const char* pager)
 {
     int i;
     qDebug()<<"RServer: "<<"show files: ";
     for (i=0;i<nfile; i++)
     {
         qDebug()<<"RServer: "<<"show file "<<file[i]<<" header: "<<headers[i];
     }
 
     qDebug()<<"RServer: "<<" title: "<<wtitle[i];
     qDebug()<<"RServer: "<<"del: "<<del;
     qDebug()<<"RServer: "<<"pager: "<<pager;
 
     QStringList files;
     for(int i=0;i<nfile; i++)
         server->addFileToOutput(QString::fromLocal8Bit(file[i]));
 
     currentExpression->hasOtherResults=true;
 
     return 0;
 }