import "Stream"
import "Serialization"
include "R/RExp"

effect R 
    "r" 
    "org.rosuda.REngine.Rserve.RConnection"

importJava "org.simantics.r.scl.RSessionConfiguration" where
    data SessionConfiguration = 
        @FieldNames [host, port, username, password]
        SessionConfiguration String Integer String String

importJava "org.simantics.r.scl.RSession" where
    data Session
    syncExec :: Session -> (<R> a) -> <Proc> a
    asyncExec :: Session -> (<R> a) -> <Proc> ()
    @JavaName getId
    sessionIdOf :: Session -> String
    @JavaName close
    closeSession :: Session -> <Proc> ()  
    @JavaName refreshVariablesSync
    refreshVariables :: Session -> <Proc> ()

importJava "org.simantics.r.scl.RSessionManager" where
    @JavaName getSession
    sessionById :: String -> <Proc> Maybe Session
    createSession :: SessionConfiguration -> <Proc> Session
    withConfiguration :: SessionConfiguration-> (<R,e> a) -> <Proc,e> a
    getOrCreateSession :: SessionConfiguration -> String -> <Proc> Session
    
importJava "org.rosuda.REngine.Rserve.RConnection" where
    @JavaName eval
    evalRExp:: String -> <R> RExp
    @JavaName voidEval
    evalR_ :: String -> <R> ()
    @JavaName voidEvalS
    evalRS_ :: String -> <R> String
    @JavaName assign
    assignRExp :: String -> RExp -> <R> ()
    @JavaName createFile
    createFileR :: String -> <R> OutputStream
    @JavaName openFile
    openFileR :: String -> <R> InputStream

evalR :: RCompatible a => String -> <R> a
evalR = fromRExp . evalRExp

assignR :: RCompatible a => String -> a -> <R> ()
assignR name = assignRExp name . toRExp

readFileAsStringR :: String -> <R> String
readFileAsStringR name = runProc (readAllString (openFileR name))

test () = do
    conf = SessionConfiguration "130.188.198.138" 6311 "simupedia" "simupedia"
    session = createSession conf
    print $ syncExec session (evalR "1+1")
    closeSession session