62 lines
1.2 KiB
Haskell
62 lines
1.2 KiB
Haskell
{-# LANGUAGE CPP #-}
|
|
|
|
|
|
import Transient.Base
|
|
--import Transient.Internals((!>))
|
|
import Transient.Move
|
|
import Transient.Move.Utils
|
|
import Transient.Logged
|
|
import Transient.Move.Services
|
|
import Control.Applicative
|
|
import Control.Monad
|
|
import Data.Typeable
|
|
import Data.IORef
|
|
import Control.Concurrent (threadDelay)
|
|
import Control.Monad.IO.Class
|
|
|
|
#ifdef Library
|
|
#else
|
|
|
|
clientStub params= do
|
|
r <- callService "" ("service","service") params
|
|
lliftIO $ print (r :: String)
|
|
|
|
|
|
|
|
main= keep $ runCloud $ do
|
|
runEmbeddedService ("service","service") serviceImplementation
|
|
empty
|
|
<|> do
|
|
-- runTestNodes [2001]
|
|
-- local $ option "start1" "start1"
|
|
clientStub ("hello","world")
|
|
empty
|
|
|
|
|
|
|
|
--addService s= do
|
|
-- con@Connection{myNode= mynode} <- getSData <|> error "connection not set. please initialize it"
|
|
--
|
|
-- let mynode'= mynode{nodeServices= s:nodeServices mynode}
|
|
-- addNodes [mynode']
|
|
-- setData con{myNode= mynode'}
|
|
|
|
|
|
|
|
|
|
serviceImplementation :: (String,String) -> Cloud String
|
|
serviceImplementation (x,y)= do
|
|
lliftIO $ print x
|
|
return y
|
|
|
|
|
|
--service' params= wormhole undefined . loggedc $ do
|
|
-- (x,y) <- local $ return params
|
|
-- lliftIO $ print x
|
|
-- local $ return y
|
|
-- teleport
|
|
-- empty
|
|
|
|
#endif
|
|
|
|
|