Main iTwin APIs in Cesium for Unreal

Author: azrogers

Source/CesiumRuntime/Private/CesiumITwinAPIBlueprintLibrary.cpp

@@ -209,7 +209,7 @@ void UCesiumITwinAPIGetIModelsAsyncAction::Activate() {
               LogCesium,
               Warning,
               TEXT(
-                  "Get itwins finished but get itwins async action is no longer valid."));
+                  "Get imodels finished but get imodels async action is no longer valid."));
           return;
         }
 
@@ -233,3 +233,184 @@ void UCesiumITwinAPIGetIModelsAsyncAction::Activate() {
         }
       });
 }
+
+UCesiumITwinAPIGetIModelMeshExportsAsyncAction*
+UCesiumITwinAPIGetIModelMeshExportsAsyncAction::GetIModelMeshExports(
+    UCesiumITwinConnection* pConnection,
+    const FString& iModelId,
+    int Page) {
+  UCesiumITwinAPIGetIModelMeshExportsAsyncAction* pAsyncAction =
+      NewObject<UCesiumITwinAPIGetIModelMeshExportsAsyncAction>();
+  pAsyncAction->pConnection = pConnection->pConnection;
+  pAsyncAction->page = FMath::Max(Page, 1);
+  pAsyncAction->iModelId = iModelId;
+  return pAsyncAction;
+}
+
+void UCesiumITwinAPIGetIModelMeshExportsAsyncAction::Activate() {
+  if (!this->pConnection) {
+    TArray<FString> Errors;
+    Errors.Push("No connection to iTwin.");
+    OnIModelMeshExportsResult.Broadcast(
+        TArray<UCesiumIModelMeshExport*>(),
+        false,
+        Errors);
+    return;
+  }
+
+  CesiumITwinClient::QueryParameters params;
+  params.top = PageSize;
+  params.skip = PageSize * (this->page - 1);
+
+  this->pConnection->meshExports(TCHAR_TO_UTF8(*this->iModelId), params)
+      .thenInMainThread([this](
+                            CesiumUtility::Result<CesiumITwinClient::PagedList<
+                                CesiumITwinClient::IModelMeshExport>>&&
+                                result) {
+        if (!IsValid(this)) {
+          UE_LOG(
+              LogCesium,
+              Warning,
+              TEXT(
+                  "Get imodel mesh exports finished but get imodel mesh exports async action is no longer valid."));
+          return;
+        }
+
+        if (!result.value) {
+          OnIModelMeshExportsResult.Broadcast(
+              TArray<UCesiumIModelMeshExport*>(),
+              false,
+              errorListToArray(result.errors));
+        } else {
+          TArray<UCesiumIModelMeshExport*> iModels;
+          iModels.Reserve(result.value->size());
+          for (CesiumITwinClient::IModelMeshExport& iModel : *result.value) {
+            UCesiumIModelMeshExport* pIModel =
+                NewObject<UCesiumIModelMeshExport>();
+            pIModel->SetIModelMeshExport(MoveTemp(iModel));
+            iModels.Emplace(pIModel);
+          }
+          OnIModelMeshExportsResult.Broadcast(
+              iModels,
+              result.value->hasNextUrl(),
+              TArray<FString>());
+        }
+      });
+}
+
+UCesiumITwinAPIGetRealityDataAsyncAction*
+UCesiumITwinAPIGetRealityDataAsyncAction::GetITwinRealityData(
+    UCesiumITwinConnection* pConnection,
+    const FString& iTwinId,
+    int Page) {
+  UCesiumITwinAPIGetRealityDataAsyncAction* pAsyncAction =
+      NewObject<UCesiumITwinAPIGetRealityDataAsyncAction>();
+  pAsyncAction->pConnection = pConnection->pConnection;
+  pAsyncAction->page = FMath::Max(Page, 1);
+  pAsyncAction->iTwinId = iTwinId;
+  return pAsyncAction;
+}
+
+void UCesiumITwinAPIGetRealityDataAsyncAction::Activate() {
+  if (!this->pConnection) {
+    TArray<FString> Errors;
+    Errors.Push("No connection to iTwin.");
+    OnITwinRealityDataResult.Broadcast(
+        TArray<UCesiumITwinRealityData*>(),
+        false,
+        Errors);
+    return;
+  }
+
+  CesiumITwinClient::QueryParameters params;
+  params.top = PageSize;
+  params.skip = PageSize * (this->page - 1);
+
+  this->pConnection->realityData(TCHAR_TO_UTF8(*this->iTwinId), params)
+      .thenInMainThread([this](
+                            CesiumUtility::Result<CesiumITwinClient::PagedList<
+                                CesiumITwinClient::ITwinRealityData>>&&
+                                result) {
+        if (!IsValid(this)) {
+          UE_LOG(
+              LogCesium,
+              Warning,
+              TEXT(
+                  "Get reality data finished but get reality data async action is no longer valid."));
+          return;
+        }
+
+        if (!result.value) {
+          OnITwinRealityDataResult.Broadcast(
+              TArray<UCesiumITwinRealityData*>(),
+              false,
+              errorListToArray(result.errors));
+        } else {
+          TArray<UCesiumITwinRealityData*> realityDataObjects;
+          realityDataObjects.Reserve(result.value->size());
+          for (CesiumITwinClient::ITwinRealityData& realityData :
+               *result.value) {
+            UCesiumITwinRealityData* pRealityData =
+                NewObject<UCesiumITwinRealityData>();
+            pRealityData->SetITwinRealityData(MoveTemp(realityData));
+            realityDataObjects.Emplace(pRealityData);
+          }
+          OnITwinRealityDataResult.Broadcast(
+              realityDataObjects,
+              result.value->hasNextUrl(),
+              TArray<FString>());
+        }
+      });
+}
+
+UCesiumITwinAPIListCesiumCuratedContentAsyncAction*
+UCesiumITwinAPIListCesiumCuratedContentAsyncAction::
+    GetCesiumCuratedContentAssets(UCesiumITwinConnection* pConnection) {
+  UCesiumITwinAPIListCesiumCuratedContentAsyncAction* pAsyncAction =
+      NewObject<UCesiumITwinAPIListCesiumCuratedContentAsyncAction>();
+  pAsyncAction->pConnection = pConnection->pConnection;
+  return pAsyncAction;
+}
+
+void UCesiumITwinAPIListCesiumCuratedContentAsyncAction::Activate() {
+  if (!this->pConnection) {
+    TArray<FString> Errors;
+    Errors.Push("No connection to iTwin.");
+    OnListCesiumCuratedContentDelegate.Broadcast(
+        TArray<UCesiumCuratedContentAsset*>(),
+        Errors);
+    return;
+  }
+
+  this->pConnection->cesiumCuratedContent().thenInMainThread(
+      [this](CesiumUtility::Result<std::vector<
+                 CesiumITwinClient::CesiumCuratedContentAsset>>&& result) {
+        if (!IsValid(this)) {
+          UE_LOG(
+              LogCesium,
+              Warning,
+              TEXT(
+                  "Get cesium curated content finished but get cesium curated content async action is no longer valid."));
+          return;
+        }
+
+        if (!result.value) {
+          OnListCesiumCuratedContentDelegate.Broadcast(
+              TArray<UCesiumCuratedContentAsset*>(),
+              errorListToArray(result.errors));
+        } else {
+          TArray<UCesiumCuratedContentAsset*> assets;
+          assets.Reserve(result.value->size());
+          for (CesiumITwinClient::CesiumCuratedContentAsset& asset :
+               *result.value) {
+            UCesiumCuratedContentAsset* pAsset =
+                NewObject<UCesiumCuratedContentAsset>();
+            pAsset->SetCesiumCuratedContentAsset(MoveTemp(asset));
+            assets.Emplace(pAsset);
+          }
+          OnListCesiumCuratedContentDelegate.Broadcast(
+              assets,
+              TArray<FString>());
+        }
+      });
+}