mirror of
https://github.com/OPM/ResInsight.git
synced 2024-12-28 01:41:42 -06:00
9738e69f8d
* Move several methods to protected * Add delete() to Python rips objects * Move functions to RiaGrpcHelper Co-authored-by: magnesj <magnesj@users.noreply.github.com>
631 lines
29 KiB
C++
631 lines
29 KiB
C++
/////////////////////////////////////////////////////////////////////////////////
|
|
//
|
|
// Copyright (C) 2019- Equinor ASA
|
|
//
|
|
// ResInsight is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU General Public License as published by
|
|
// the Free Software Foundation, either version 3 of the License, or
|
|
// (at your option) any later version.
|
|
//
|
|
// ResInsight is distributed in the hope that it will be useful, but WITHOUT ANY
|
|
// WARRANTY; without even the implied warranty of MERCHANTABILITY or
|
|
// FITNESS FOR A PARTICULAR PURPOSE.
|
|
//
|
|
// See the GNU General Public License at <http://www.gnu.org/licenses/gpl.html>
|
|
// for more details.
|
|
//
|
|
//////////////////////////////////////////////////////////////////////////////////
|
|
|
|
#include "RiaGrpcPdmObjectService.h"
|
|
|
|
#include "RiaApplication.h"
|
|
#include "RiaGrpcCallbacks.h"
|
|
#include "RiaGrpcHelper.h"
|
|
|
|
#include "Rim3dView.h"
|
|
#include "RimEclipseResultDefinition.h"
|
|
#include "RimProject.h"
|
|
|
|
#include "cafPdmAbstractFieldScriptingCapability.h"
|
|
#include "cafPdmObject.h"
|
|
#include "cafPdmObjectMethod.h"
|
|
#include "cafPdmObjectScriptingCapability.h"
|
|
#include "cafPdmObjectScriptingCapabilityRegister.h"
|
|
|
|
using namespace rips;
|
|
|
|
template <typename DataType>
|
|
struct DataHolder : public AbstractDataHolder
|
|
{
|
|
DataHolder( const DataType& data )
|
|
: data( data )
|
|
{
|
|
}
|
|
|
|
size_t dataCount() const override { return data.size(); }
|
|
size_t dataSizeOf() const override { return sizeof( typename DataType::value_type ); }
|
|
|
|
void reserveReplyStorage( rips::PdmObjectGetterReply* reply ) const override;
|
|
void addValueToReply( size_t valueIndex, rips::PdmObjectGetterReply* reply ) const override;
|
|
size_t getValuesFromChunk( size_t startIndex, const rips::PdmObjectSetterChunk* chunk ) override;
|
|
void applyValuesToProxyField( caf::PdmProxyFieldHandle* proxyField ) override;
|
|
|
|
DataType data;
|
|
};
|
|
|
|
template <>
|
|
void DataHolder<std::vector<int>>::reserveReplyStorage( rips::PdmObjectGetterReply* reply ) const
|
|
{
|
|
reply->mutable_ints()->mutable_data()->Reserve( data.size() );
|
|
}
|
|
template <>
|
|
void DataHolder<std::vector<int>>::addValueToReply( size_t valueIndex, rips::PdmObjectGetterReply* reply ) const
|
|
{
|
|
reply->mutable_ints()->add_data( data[valueIndex] );
|
|
}
|
|
template <>
|
|
size_t DataHolder<std::vector<int>>::getValuesFromChunk( size_t startIndex, const rips::PdmObjectSetterChunk* chunk )
|
|
{
|
|
size_t chunkSize = chunk->ints().data_size();
|
|
size_t currentIndex = startIndex;
|
|
size_t chunkIndex = 0u;
|
|
for ( ; chunkIndex < chunkSize && currentIndex < data.size(); ++currentIndex, ++chunkIndex )
|
|
{
|
|
data[currentIndex] = chunk->ints().data()[chunkIndex];
|
|
}
|
|
return chunkSize;
|
|
}
|
|
template <>
|
|
void DataHolder<std::vector<int>>::applyValuesToProxyField( caf::PdmProxyFieldHandle* proxyField )
|
|
{
|
|
auto proxyValueField = dynamic_cast<caf::PdmProxyValueField<std::vector<int>>*>( proxyField );
|
|
CAF_ASSERT( proxyValueField );
|
|
if ( proxyValueField )
|
|
{
|
|
proxyValueField->setValue( data );
|
|
}
|
|
}
|
|
|
|
template <>
|
|
void DataHolder<std::vector<double>>::reserveReplyStorage( rips::PdmObjectGetterReply* reply ) const
|
|
{
|
|
reply->mutable_doubles()->mutable_data()->Reserve( data.size() );
|
|
}
|
|
template <>
|
|
void DataHolder<std::vector<double>>::addValueToReply( size_t valueIndex, rips::PdmObjectGetterReply* reply ) const
|
|
{
|
|
reply->mutable_doubles()->add_data( data[valueIndex] );
|
|
}
|
|
template <>
|
|
size_t DataHolder<std::vector<double>>::getValuesFromChunk( size_t startIndex, const rips::PdmObjectSetterChunk* chunk )
|
|
{
|
|
size_t chunkSize = chunk->doubles().data_size();
|
|
size_t currentIndex = startIndex;
|
|
size_t chunkIndex = 0u;
|
|
for ( ; chunkIndex < chunkSize && currentIndex < data.size(); ++currentIndex, ++chunkIndex )
|
|
{
|
|
data[currentIndex] = chunk->doubles().data()[chunkIndex];
|
|
}
|
|
return chunkSize;
|
|
}
|
|
template <>
|
|
void DataHolder<std::vector<double>>::applyValuesToProxyField( caf::PdmProxyFieldHandle* proxyField )
|
|
{
|
|
auto proxyValueField = dynamic_cast<caf::PdmProxyValueField<std::vector<double>>*>( proxyField );
|
|
CAF_ASSERT( proxyValueField );
|
|
if ( proxyValueField )
|
|
{
|
|
proxyValueField->setValue( data );
|
|
}
|
|
}
|
|
|
|
template <>
|
|
void DataHolder<std::vector<QString>>::reserveReplyStorage( rips::PdmObjectGetterReply* reply ) const
|
|
{
|
|
reply->mutable_strings()->mutable_data()->Reserve( data.size() );
|
|
}
|
|
template <>
|
|
void DataHolder<std::vector<QString>>::addValueToReply( size_t valueIndex, rips::PdmObjectGetterReply* reply ) const
|
|
{
|
|
reply->mutable_strings()->add_data( data[valueIndex].toStdString() );
|
|
}
|
|
template <>
|
|
size_t DataHolder<std::vector<QString>>::getValuesFromChunk( size_t startIndex, const rips::PdmObjectSetterChunk* chunk )
|
|
{
|
|
size_t chunkSize = chunk->strings().data_size();
|
|
size_t currentIndex = startIndex;
|
|
size_t chunkIndex = 0u;
|
|
for ( ; chunkIndex < chunkSize && currentIndex < data.size(); ++currentIndex, ++chunkIndex )
|
|
{
|
|
data[currentIndex] = QString::fromStdString( chunk->strings().data()[chunkIndex] );
|
|
}
|
|
return chunkSize;
|
|
}
|
|
template <>
|
|
void DataHolder<std::vector<QString>>::applyValuesToProxyField( caf::PdmProxyFieldHandle* proxyField )
|
|
{
|
|
auto proxyValueField = dynamic_cast<caf::PdmProxyValueField<std::vector<QString>>*>( proxyField );
|
|
CAF_ASSERT( proxyValueField );
|
|
if ( proxyValueField )
|
|
{
|
|
proxyValueField->setValue( data );
|
|
}
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
RiaPdmObjectMethodStateHandler::RiaPdmObjectMethodStateHandler( bool clientToServerStreamer )
|
|
: m_fieldOwner( nullptr )
|
|
, m_proxyField( nullptr )
|
|
, m_currentDataIndex( 0u )
|
|
, m_clientToServerStreamer( clientToServerStreamer )
|
|
{
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
Status RiaPdmObjectMethodStateHandler::init( const rips::PdmObjectGetterRequest* request )
|
|
{
|
|
CAF_ASSERT( !m_clientToServerStreamer );
|
|
m_fieldOwner = RiaGrpcHelper::findCafObjectFromRipsObject( request->object() );
|
|
QString fieldName = QString::fromStdString( request->method() );
|
|
|
|
std::vector<caf::PdmFieldHandle*> fields = m_fieldOwner->fields();
|
|
for ( auto field : fields )
|
|
{
|
|
auto scriptability = field->capability<caf::PdmAbstractFieldScriptingCapability>();
|
|
if ( scriptability && scriptability->scriptFieldName() == fieldName )
|
|
{
|
|
caf::PdmProxyFieldHandle* proxyField = dynamic_cast<caf::PdmProxyFieldHandle*>( field );
|
|
if ( proxyField )
|
|
{
|
|
m_proxyField = proxyField;
|
|
|
|
if ( dynamic_cast<caf::PdmProxyValueField<std::vector<int>>*>( field ) )
|
|
{
|
|
auto dataField = dynamic_cast<caf::PdmProxyValueField<std::vector<int>>*>( field );
|
|
m_dataHolder.reset( new DataHolder<std::vector<int>>( dataField->value() ) );
|
|
return grpc::Status::OK;
|
|
}
|
|
else if ( dynamic_cast<caf::PdmProxyValueField<std::vector<double>>*>( field ) )
|
|
{
|
|
auto dataField = dynamic_cast<caf::PdmProxyValueField<std::vector<double>>*>( field );
|
|
m_dataHolder.reset( new DataHolder<std::vector<double>>( dataField->value() ) );
|
|
return grpc::Status::OK;
|
|
}
|
|
else if ( dynamic_cast<caf::PdmProxyValueField<std::vector<QString>>*>( field ) )
|
|
{
|
|
auto dataField = dynamic_cast<caf::PdmProxyValueField<std::vector<QString>>*>( field );
|
|
m_dataHolder.reset( new DataHolder<std::vector<QString>>( dataField->value() ) );
|
|
return grpc::Status::OK;
|
|
}
|
|
else
|
|
{
|
|
CAF_ASSERT( false && "The proxy field data type is not yet supported for streaming fields" );
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
return grpc::Status( grpc::NOT_FOUND, "Proxy field not found" );
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
Status RiaPdmObjectMethodStateHandler::init( const rips::PdmObjectSetterChunk* chunk )
|
|
{
|
|
CAF_ASSERT( m_clientToServerStreamer );
|
|
CAF_ASSERT( chunk->has_set_request() );
|
|
auto setRequest = chunk->set_request();
|
|
auto methodRequest = setRequest.request();
|
|
m_fieldOwner = RiaGrpcHelper::findCafObjectFromRipsObject( methodRequest.object() );
|
|
QString fieldName = QString::fromStdString( methodRequest.method() );
|
|
int valueCount = setRequest.data_count();
|
|
|
|
std::vector<caf::PdmFieldHandle*> fields = m_fieldOwner->fields();
|
|
for ( auto field : fields )
|
|
{
|
|
auto scriptability = field->capability<caf::PdmAbstractFieldScriptingCapability>();
|
|
if ( scriptability && scriptability->scriptFieldName() == fieldName )
|
|
{
|
|
auto* proxyField = dynamic_cast<caf::PdmProxyFieldHandle*>( field );
|
|
if ( proxyField )
|
|
{
|
|
m_proxyField = proxyField;
|
|
|
|
if ( dynamic_cast<caf::PdmProxyValueField<std::vector<int>>*>( field ) )
|
|
{
|
|
m_dataHolder = std::make_unique<DataHolder<std::vector<int>>>( std::vector<int>( valueCount ) );
|
|
return grpc::Status::OK;
|
|
}
|
|
if ( dynamic_cast<caf::PdmProxyValueField<std::vector<double>>*>( field ) )
|
|
{
|
|
m_dataHolder = std::make_unique<DataHolder<std::vector<double>>>( std::vector<double>( valueCount ) );
|
|
return grpc::Status::OK;
|
|
}
|
|
if ( dynamic_cast<caf::PdmProxyValueField<std::vector<QString>>*>( field ) )
|
|
{
|
|
m_dataHolder = std::make_unique<DataHolder<std::vector<QString>>>( std::vector<QString>( valueCount ) );
|
|
return grpc::Status::OK;
|
|
}
|
|
|
|
CAF_ASSERT( false && "The proxy field data type is not yet supported for streaming fields" );
|
|
}
|
|
}
|
|
}
|
|
return grpc::Status( grpc::NOT_FOUND, "Proxy field not found" );
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
Status RiaPdmObjectMethodStateHandler::assignReply( rips::PdmObjectGetterReply* reply )
|
|
{
|
|
CAF_ASSERT( m_dataHolder );
|
|
const size_t packageSize = RiaGrpcHelper::numberOfDataUnitsInPackage( m_dataHolder->dataSizeOf() );
|
|
size_t indexInPackage = 0u;
|
|
m_dataHolder->reserveReplyStorage( reply );
|
|
|
|
for ( ; indexInPackage < packageSize && m_currentDataIndex < m_dataHolder->dataCount(); ++indexInPackage )
|
|
{
|
|
m_dataHolder->addValueToReply( m_currentDataIndex, reply );
|
|
m_currentDataIndex++;
|
|
}
|
|
if ( indexInPackage > 0u )
|
|
{
|
|
return grpc::Status::OK;
|
|
}
|
|
return grpc::Status( grpc::OUT_OF_RANGE,
|
|
"We've reached the end. This is not an error but means transmission is finished" );
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
Status RiaPdmObjectMethodStateHandler::receiveRequest( const rips::PdmObjectSetterChunk* chunk,
|
|
rips::ClientToServerStreamReply* reply )
|
|
{
|
|
size_t valuesWritten = m_dataHolder->getValuesFromChunk( m_currentDataIndex, chunk );
|
|
m_currentDataIndex += valuesWritten;
|
|
|
|
if ( m_currentDataIndex > totalValueCount() )
|
|
{
|
|
return grpc::Status( grpc::OUT_OF_RANGE, "Attempting to write out of bounds" );
|
|
}
|
|
reply->set_accepted_value_count( static_cast<int64_t>( m_currentDataIndex ) );
|
|
return grpc::Status::OK;
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
size_t RiaPdmObjectMethodStateHandler::streamedValueCount() const
|
|
{
|
|
return m_currentDataIndex;
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
size_t RiaPdmObjectMethodStateHandler::totalValueCount() const
|
|
{
|
|
return m_dataHolder->dataCount();
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
void RiaPdmObjectMethodStateHandler::finish()
|
|
{
|
|
if ( m_proxyField )
|
|
{
|
|
QVariant before = m_proxyField->toQVariant();
|
|
m_dataHolder->applyValuesToProxyField( m_proxyField );
|
|
QVariant after = m_proxyField->toQVariant();
|
|
m_fieldOwner->fieldChangedByUi( m_proxyField, before, after );
|
|
}
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
grpc::Status RiaGrpcPdmObjectService::GetAncestorPdmObject( grpc::ServerContext* context,
|
|
const rips::PdmParentObjectRequest* request,
|
|
rips::PdmObject* reply )
|
|
{
|
|
RimProject* project = RimProject::current();
|
|
std::vector<caf::PdmObject*> objectsOfCurrentClass;
|
|
|
|
QString scriptClassName = QString::fromStdString( request->object().class_keyword() );
|
|
QString classKeyword = caf::PdmObjectScriptingCapabilityRegister::classKeywordFromScriptClassName( scriptClassName );
|
|
|
|
project->descendantsIncludingThisFromClassKeyword( classKeyword, objectsOfCurrentClass );
|
|
|
|
caf::PdmObject* matchingObject = nullptr;
|
|
for ( caf::PdmObject* testObject : objectsOfCurrentClass )
|
|
{
|
|
if ( reinterpret_cast<uint64_t>( testObject ) == request->object().address() )
|
|
{
|
|
matchingObject = testObject;
|
|
}
|
|
}
|
|
|
|
if ( matchingObject )
|
|
{
|
|
caf::PdmObject* parentObject = nullptr;
|
|
QString ancestorScriptName = QString::fromStdString( request->parent_keyword() );
|
|
QString ancestorClassKeyword =
|
|
caf::PdmObjectScriptingCapabilityRegister::classKeywordFromScriptClassName( ancestorScriptName );
|
|
matchingObject->firstAncestorOrThisFromClassKeyword( ancestorClassKeyword, parentObject );
|
|
if ( parentObject )
|
|
{
|
|
copyPdmObjectFromCafToRips( parentObject, reply );
|
|
return grpc::Status::OK;
|
|
}
|
|
}
|
|
return grpc::Status( grpc::NOT_FOUND, "Parent PdmObject not found" );
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
grpc::Status RiaGrpcPdmObjectService::GetDescendantPdmObjects( grpc::ServerContext* context,
|
|
const rips::PdmDescendantObjectRequest* request,
|
|
rips::PdmObjectArray* reply )
|
|
{
|
|
auto matchingObject = RiaGrpcHelper::findCafObjectFromRipsObject( request->object() );
|
|
|
|
if ( matchingObject )
|
|
{
|
|
std::vector<caf::PdmObject*> childObjects;
|
|
QString childClassKeyword = caf::PdmObjectScriptingCapabilityRegister::classKeywordFromScriptClassName(
|
|
QString::fromStdString( request->child_keyword() ) );
|
|
matchingObject->descendantsIncludingThisFromClassKeyword( childClassKeyword, childObjects );
|
|
for ( auto pdmChild : childObjects )
|
|
{
|
|
rips::PdmObject* ripsChild = reply->add_objects();
|
|
copyPdmObjectFromCafToRips( pdmChild, ripsChild );
|
|
}
|
|
return grpc::Status::OK;
|
|
}
|
|
return grpc::Status( grpc::NOT_FOUND, "Current PdmObject not found" );
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
grpc::Status RiaGrpcPdmObjectService::GetChildPdmObjects( grpc::ServerContext* context,
|
|
const rips::PdmChildObjectRequest* request,
|
|
rips::PdmObjectArray* reply )
|
|
{
|
|
auto matchingObject = RiaGrpcHelper::findCafObjectFromRipsObject( request->object() );
|
|
if ( matchingObject )
|
|
{
|
|
QString fieldName = QString::fromStdString( request->child_field() );
|
|
std::vector<caf::PdmFieldHandle*> fields = matchingObject->fields();
|
|
for ( auto field : fields )
|
|
{
|
|
auto scriptability = field->capability<caf::PdmAbstractFieldScriptingCapability>();
|
|
if ( scriptability && scriptability->scriptFieldName() == fieldName )
|
|
{
|
|
std::vector<caf::PdmObjectHandle*> childObjects = field->children();
|
|
for ( auto pdmChild : childObjects )
|
|
{
|
|
rips::PdmObject* ripsChild = reply->add_objects();
|
|
copyPdmObjectFromCafToRips( static_cast<caf::PdmObject*>( pdmChild ), ripsChild );
|
|
}
|
|
return grpc::Status::OK;
|
|
}
|
|
}
|
|
return grpc::Status( grpc::NOT_FOUND, "Child field not found" );
|
|
}
|
|
return grpc::Status( grpc::NOT_FOUND, "Current PdmObject not found" );
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
grpc::Status RiaGrpcPdmObjectService::UpdateExistingPdmObject( grpc::ServerContext* context,
|
|
const rips::PdmObject* request,
|
|
rips::Empty* response )
|
|
{
|
|
auto matchingObject = RiaGrpcHelper::findCafObjectFromRipsObject( *request );
|
|
|
|
if ( matchingObject )
|
|
{
|
|
copyPdmObjectFromRipsToCaf( request, matchingObject );
|
|
RimEclipseResultDefinition* resultDefinition = dynamic_cast<RimEclipseResultDefinition*>( matchingObject );
|
|
// TODO: Make this more general. Perhaps we need an interface method for updating UI fields
|
|
if ( resultDefinition )
|
|
{
|
|
resultDefinition->updateUiFieldsFromActiveResult();
|
|
resultDefinition->loadResult();
|
|
}
|
|
|
|
matchingObject->updateAllRequiredEditors();
|
|
RimProject::current()->scheduleCreateDisplayModelAndRedrawAllViews();
|
|
|
|
Rim3dView* view = dynamic_cast<Rim3dView*>( matchingObject );
|
|
if ( view )
|
|
{
|
|
view->applyBackgroundColorAndFontChanges();
|
|
}
|
|
return grpc::Status::OK;
|
|
}
|
|
return grpc::Status( grpc::NOT_FOUND, "PdmObject not found" );
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
grpc::Status RiaGrpcPdmObjectService::DeleteExistingPdmObject( grpc::ServerContext* context,
|
|
const rips::PdmObject* request,
|
|
rips::Empty* response )
|
|
{
|
|
auto matchingObject = RiaGrpcHelper::findCafObjectFromRipsObject( *request );
|
|
|
|
if ( matchingObject && matchingObject->parentField() )
|
|
{
|
|
auto parentField = matchingObject->parentField();
|
|
parentField->removeChild( matchingObject );
|
|
|
|
auto obj = parentField->ownerObject();
|
|
if ( obj && obj->uiCapability() )
|
|
{
|
|
std::vector<caf::PdmObjectHandle*> referringObjects;
|
|
|
|
obj->onChildDeleted( nullptr, referringObjects );
|
|
obj->uiCapability()->updateAllRequiredEditors();
|
|
}
|
|
|
|
delete matchingObject;
|
|
|
|
return grpc::Status::OK;
|
|
}
|
|
return grpc::Status( grpc::NOT_FOUND, "PdmObject not found" );
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
grpc::Status RiaGrpcPdmObjectService::CreateChildPdmObject( grpc::ServerContext* context,
|
|
const rips::CreatePdmChildObjectRequest* request,
|
|
rips::PdmObject* reply )
|
|
{
|
|
auto matchingObject = RiaGrpcHelper::findCafObjectFromRipsObject( request->object() );
|
|
|
|
if ( matchingObject )
|
|
{
|
|
CAF_ASSERT( request );
|
|
|
|
QString keywordClassToCreate = QString::fromStdString( request->class_keyword() );
|
|
QString fieldKeyword = QString::fromStdString( request->child_field() );
|
|
|
|
caf::PdmObjectHandle* pdmObjectHandle = emplaceChildField( matchingObject, fieldKeyword, keywordClassToCreate );
|
|
if ( pdmObjectHandle )
|
|
{
|
|
copyPdmObjectFromCafToRips( pdmObjectHandle, reply );
|
|
matchingObject->uiCapability()->updateConnectedEditors();
|
|
|
|
return grpc::Status::OK;
|
|
}
|
|
return grpc::Status( grpc::NOT_FOUND, "Could not create PdmObject" );
|
|
}
|
|
return grpc::Status( grpc::NOT_FOUND, "Could not find PdmObject" );
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
grpc::Status RiaGrpcPdmObjectService::CallPdmObjectGetter( grpc::ServerContext* context,
|
|
const rips::PdmObjectGetterRequest* request,
|
|
rips::PdmObjectGetterReply* reply,
|
|
RiaPdmObjectMethodStateHandler* stateHandler )
|
|
{
|
|
return stateHandler->assignReply( reply );
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
grpc::Status RiaGrpcPdmObjectService::CallPdmObjectSetter( grpc::ServerContext* context,
|
|
const rips::PdmObjectSetterChunk* chunk,
|
|
rips::ClientToServerStreamReply* reply,
|
|
RiaPdmObjectMethodStateHandler* stateHandler )
|
|
{
|
|
return stateHandler->receiveRequest( chunk, reply );
|
|
}
|
|
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
grpc::Status RiaGrpcPdmObjectService::CallPdmObjectMethod( grpc::ServerContext* context,
|
|
const rips::PdmObjectMethodRequest* request,
|
|
rips::PdmObject* reply )
|
|
{
|
|
auto matchingObject = RiaGrpcHelper::findCafObjectFromRipsObject( request->object() );
|
|
if ( matchingObject )
|
|
{
|
|
QString methodKeyword = QString::fromStdString( request->method() );
|
|
|
|
std::shared_ptr<caf::PdmObjectMethod> method =
|
|
caf::PdmObjectMethodFactory::instance()->createMethod( matchingObject, methodKeyword );
|
|
if ( method )
|
|
{
|
|
copyPdmObjectFromRipsToCaf( &( request->params() ), method.get() );
|
|
|
|
caf::PdmObjectHandle* result = method->execute();
|
|
if ( result )
|
|
{
|
|
copyPdmObjectFromCafToRips( result, reply );
|
|
if ( !method->resultIsPersistent() )
|
|
{
|
|
delete result;
|
|
}
|
|
return grpc::Status::OK;
|
|
}
|
|
|
|
if ( method->isNullptrValidResult() )
|
|
{
|
|
return grpc::Status::OK;
|
|
}
|
|
|
|
return grpc::Status( grpc::NOT_FOUND, "No result returned from Method" );
|
|
}
|
|
return grpc::Status( grpc::NOT_FOUND, "Could not find Method" );
|
|
}
|
|
return grpc::Status( grpc::NOT_FOUND, "Could not find PdmObject" );
|
|
}
|
|
//--------------------------------------------------------------------------------------------------
|
|
///
|
|
//--------------------------------------------------------------------------------------------------
|
|
std::vector<RiaGrpcCallbackInterface*> RiaGrpcPdmObjectService::createCallbacks()
|
|
{
|
|
typedef RiaGrpcPdmObjectService Self;
|
|
return {
|
|
new RiaGrpcUnaryCallback<Self, PdmParentObjectRequest, PdmObject>( this,
|
|
&Self::GetAncestorPdmObject,
|
|
&Self::RequestGetAncestorPdmObject ),
|
|
new RiaGrpcUnaryCallback<Self, PdmDescendantObjectRequest, PdmObjectArray>( this,
|
|
&Self::GetDescendantPdmObjects,
|
|
&Self::RequestGetDescendantPdmObjects ),
|
|
new RiaGrpcUnaryCallback<Self, PdmChildObjectRequest, PdmObjectArray>( this,
|
|
&Self::GetChildPdmObjects,
|
|
&Self::RequestGetChildPdmObjects ),
|
|
new RiaGrpcUnaryCallback<Self, PdmObject, Empty>( this,
|
|
&Self::UpdateExistingPdmObject,
|
|
&Self::RequestUpdateExistingPdmObject ),
|
|
new RiaGrpcUnaryCallback<Self, PdmObject, Empty>( this,
|
|
&Self::DeleteExistingPdmObject,
|
|
&Self::RequestDeleteExistingPdmObject ),
|
|
new RiaGrpcUnaryCallback<Self, CreatePdmChildObjectRequest, PdmObject>( this,
|
|
&Self::CreateChildPdmObject,
|
|
&Self::RequestCreateChildPdmObject ),
|
|
new RiaGrpcServerToClientStreamCallback<Self,
|
|
PdmObjectGetterRequest,
|
|
PdmObjectGetterReply,
|
|
RiaPdmObjectMethodStateHandler>( this,
|
|
&Self::CallPdmObjectGetter,
|
|
&Self::RequestCallPdmObjectGetter,
|
|
new RiaPdmObjectMethodStateHandler ),
|
|
|
|
new RiaGrpcClientToServerStreamCallback<Self,
|
|
PdmObjectSetterChunk,
|
|
ClientToServerStreamReply,
|
|
RiaPdmObjectMethodStateHandler>( this,
|
|
&Self::CallPdmObjectSetter,
|
|
&Self::RequestCallPdmObjectSetter,
|
|
new RiaPdmObjectMethodStateHandler( true ) ),
|
|
new RiaGrpcUnaryCallback<Self, PdmObjectMethodRequest, PdmObject>( this,
|
|
&Self::CallPdmObjectMethod,
|
|
&Self::RequestCallPdmObjectMethod ),
|
|
|
|
};
|
|
}
|
|
|
|
static bool RiaGrpcPdmObjectService_init = RiaGrpcServiceFactory::instance()->registerCreator<RiaGrpcPdmObjectService>(
|
|
typeid( RiaGrpcPdmObjectService ).hash_code() );
|