in data-catalog-api/server/service/src/main/java/org/apache/airavata/datacatalog/api/service/DataCatalogAPIService.java [145:166]
public void addDataProductToMetadataSchema(DataProductAddToMetadataSchemaRequest request,
StreamObserver<DataProductAddToMetadataSchemaResponse> responseObserver) {
String dataProductId = request.getDataProductId();
String schemaName = request.getSchemaName();
try {
DataProduct checkDataProduct = dataCatalogService.getDataProduct(request.getDataProductId());
// check that user has WRITE_METADATA access on data product record
if (!checkHasPermission(request.getUserInfo(), checkDataProduct, Permission.WRITE_METADATA,
responseObserver)) {
return;
}
DataProduct dataProduct = dataCatalogService.addDataProductToMetadataSchema(dataProductId, schemaName);
responseObserver
.onNext(DataProductAddToMetadataSchemaResponse.newBuilder().setDataProduct(dataProduct).build());
responseObserver.onCompleted();
} catch (EntityNotFoundException e) {
responseObserver.onError(Status.NOT_FOUND.withDescription(e.getMessage()).asException());
}
}