Delta V Software Forums

Code: Select all

class ServerImpl
{
public:
    void Print(const std::string & s)
    {
        std::cout << "I_Server service: " << s << std::endl;
    }
};


int main()
{
    ... 
    ServerImpl g_srv;
    server.bind<I_Server>(g_srv);
    ...
    return 0;
}

Code: Select all

        // Get current RCF session.
        RCF::RcfSession & rcfSession = RCF::getCurrentRcfSession();

        // Create a MyServerSession for this RCF session, if it has not already been created.
        MyServerSession & mySession = rcfSession.getSessionObject<MyServerSession>(true);        

Code: Select all

#define GET_RCFSES_AND_CLIENT \
  RCF::RcfSession & rcfses = RCF::getCurrentRcfSession(); \
  ClientData * client = rcfses.querySessionObject<ClientData>(); \
  SQLite::Database * sqldb = client->getDB();

#define RCFLOG3()  UTIL_LOG(2, RCF::LogLevel_3) << "[XX] "
#define RCFLOG3S() UTIL_LOG(2, RCF::LogLevel_3) << client->m_sesIdLog

bool ClientData::setSessionData(RCF::RcfSession & session)
{     
  ClientData * client = this;
  if (m_RemoteAddr.empty()) {
    m_RemoteAddr = session.getClientAddress().string();
    g_sesCount++;
    m_sesId = g_sesCount;
    sprintf(m_sesIdLog, "[%04x] ", m_sesId);
    RCFLOG3() << "Create session. RemoteAddr = " << m_RemoteAddr;
    return true;
  }
  return false;
}

bool OnClientAccess(int fnId)
{
  RCF::RcfSession & rcfses = RCF::getCurrentRcfSession();
  
  ClientData & clientObj = rcfses.getSessionObject<ClientData>(true);
  clientObj.setSessionData(rcfses);  
  ClientData * client = rcfses.querySessionObject<ClientData>();
  
  SQLite::Database & sesdbObj = rcfses.getSessionObject<SQLite::Database>(true);
  client->m_db = &sesdbObj;
  SQLite::Database * sesdb = client->getDB();
  
  int aFlags = SQLITE_OPEN_CREATE | SQLITE_OPEN_READWRITE | SQLITE_OPEN_NOMUTEX;
  sesdb->open(GetSrvDatabaseName().c_str(), aFlags);
  if (!sesdb->is_open()) {
    throw std::runtime_error("Can't open database");
  }
  sesdb->setBusyTimeout(2000);

  if (fnId == 0) {
    // Login method !!!
    return true;
  }  
  if (!clientObj.m_Logged) {
    std::string sTokenId = rcfses.getRequestUserData();
    int hr = CheckTokenId(rcfses, client, sesdb, sTokenId);
    RCFLOG3() << "CheckTokenId: TokenId = '" << sTokenId << "' (result = 0x" << std::hex << hr << ")";
    if (hr == S_OK) clientObj.m_Logged = true;
  }
  return clientObj.m_Logged;
}

int ServerImpl::Print(const std::string & text)
{
  GET_RCFSES_AND_CLIENT
  RCFLOG3() << "'Print' service: " << text;
  SQLite::Statement st(*sqldb, "INSERT INTO table_text (text) VALUES (:text)");
  st.bind(":text", text);
  int rows = st.exec();
  if (rows != 1) return S_FALSE;
  return S_OK;
}

Code: Select all

class ClientData
{
public:
	ClientData();

	void initialize();

	// ...

private:
	bool									mInit;
	boost::shared_ptr<SQLite::Database>		mSessionDbPtr;
};

ClientData::ClientData() : mInit(false)
{
}

void ClientData::initialize()
{
	if (!mInit)
	{
		// Log client connection info.
		RCF::RcfSession & rcfSession = RCF::getCurrentRcfSession();
		m_RemoteAddr = pSession->getClientAddress().string();
		g_sesCount++;
		m_sesId = g_sesCount;
		sprintf(m_sesIdLog, "[%04x] ", m_sesId);
		RCFLOG3() << "Create session. RemoteAddr = " << m_RemoteAddr;

		// Setup database connection.
		mSessionDbPtr.reset( new SQLite::Database( /*arguments here*/) );
		int aFlags = SQLITE_OPEN_CREATE | SQLITE_OPEN_READWRITE | SQLITE_OPEN_NOMUTEX;
		mSessionDbPtr->open(GetSrvDatabaseName().c_str(), aFlags);
		if (!mSessionDbPtr->is_open()) {
			throw std::runtime_error("Can't open database");
		}
		mSessionDbPtr->setBusyTimeout(2000);

		// Check token.
		if (!clientData.m_Logged) 
		{
			std::string sTokenId = rcfSession.getRequestUserData();
			int hr = CheckTokenId(rcfSession, client, sesdb, sTokenId);
			RCFLOG3() << "CheckTokenId: TokenId = '" << sTokenId << "' (result = 0x" << std::hex << hr << ")";
			if (hr == S_OK) clientObj.m_Logged = true;
		}

		mInit = true;
	}
}

// The purpose of this function is to ensure that Login() is called before any other remote method.
bool OnClientAccess(int fnId)
{
	// Login() has fnId of zero.
	if (fnId != 0)
	{
		RCF::RcfSession & rcfSession = RCF::getCurrentRcfSession();
		ClientData * pClientData = rcfSession.querySessionObject<ClientData>(true);
		if (!pClientData)
		{
			throw std::runtime_error("Error: client must call Login() before any other remote method.");
		}
	}
}

int ServerImpl::Login()
{
	RCF::RcfSession & rcfSession = RCF::getCurrentRcfSession();
	ClientData & clientData = rcfSession.getSessionObject<ClientData>(true);
	clientData.initialize();
}

int ServerImpl::Print(const std::string & text)
{
	RCF::RcfSession & rcfSession = RCF::getCurrentRcfSession();
	ClientData & clientData = rcfSession.getSessionObject<ClientData>(true);
	SQLite::Database & sqldb = * clientData.mSessionDbPtr;

	// ...
}