/*helloWorldRPC.cpp */
/**
 * Copyright - See the COPYRIGHT that is included with this distribution.
 * EPICS pvData is distributed subject to a Software License Agreement found
 * in file LICENSE that is included with this distribution.
 */
/**
 * @author mrk
 */

/* Author: Marty Kraimer */

#include <iostream>
#include <pv/pvData.h>
#include <pv/pvAccess.h>
#include <pv/rpcClient.h>

using namespace std;
using namespace epics::pvData;
using namespace epics::pvAccess;

static FieldCreatePtr fieldCreate = getFieldCreate();
static PVDataCreatePtr pvDataCreate = getPVDataCreate();


static void exampleSimple()
{
    StructureConstPtr  topStructure = fieldCreate->createFieldBuilder()->
        add("value",pvString)->
        createStructure();
    PVStructurePtr pvRequest = pvDataCreate->createPVStructure(topStructure);
    PVStringPtr pvArgument = pvRequest->getSubField<PVString>("value");
    pvArgument->put("World");
    cout << "example channeRPC simple\n";
    try {
        PVStructurePtr pvResult =
            RPCClient::sendRequest("exampleHelloRPC", pvRequest);
        cout << "result\n" << pvResult << endl;
    } catch (RPCRequestException &e) {
        cout << e.what() << endl;
    }
}

void exampleMore()
{
    StructureConstPtr  topStructure = fieldCreate->createFieldBuilder()->
        add("value",pvString)->
        createStructure();
    PVStructurePtr pvRequest = pvDataCreate->createPVStructure(topStructure);
    PVStringPtr pvArgument = pvRequest->getSubField<PVString>("value");
    pvArgument->put("World");
    cout << "example channeRPC more\n";
    try {
        RPCClient::shared_pointer client = RPCClient::create("exampleHelloRPC");
        client->issueConnect();
        if (client->waitConnect())
        {
            client->issueRequest(pvRequest);
            PVStructure::shared_pointer result = client->waitResponse();
            std::cout << *result << std::endl;
        }
        else {
            cout << "waitConnect timeout\n";
            return;
        }
    } catch (RPCRequestException &e) {
        cout << e.what() << endl;
    }
}


int main(int argc,char *argv[])
{
    exampleSimple();
    exampleMore();
    return 0;
}