feat(asset): add loadImages api

add test cases;

(refactor: move SinonCPTool to test/construct/tool/ and rename it to SinonTool)

.cz-config.js

@@ -20,6 +20,7 @@ module.exports = {
       { name: "transform" },
       { name: "geometry" },
       { name: "pipeline" },
+      { name: "asset" },
       { name: "dependency" },
       { name: "cloud-picture" },
   ],

src/construct/application_layer/asset/AssetApService.re

@@ -0,0 +1,3 @@
+let loadImages = imageDataList => {
+  LoadImageDoService.loadImages(imageDataList);
+};

src/construct/application_layer/dependency/NetworkDpApService.re

@@ -0,0 +1,3 @@
+let set = dp => {
+  DpContainer.setNetworkDp(dp);
+};

src/construct/domain_layer/dependency/container/DpContainer.re

@@ -5,18 +5,17 @@ type t = {
   mutable time: option(ITimeDp.time),
   mutable webgpuCore: option(IWebGPUCoreDp.webgpuCore),
   mutable webgpuRayTracing: option(IWebGPURayTracingDp.webgpuRayTracing),
-  // mutable network: option(INetworkDp.network),
+  mutable network: option(INetworkDp.network),
 };
 
 let dpContainer = {
   otherConfig: None,
   poConfig: None,
   repo: None,
   time: None,
-
   webgpuCore: None,
   webgpuRayTracing: None,
-  // network: None,
+  network: None,
 };
 
 let unsafeGetOtherConfigDp = () => {
@@ -87,6 +86,10 @@ let unsafeGetTimeRepoDp = () => {
   _unsafeGetRepoDp().timeRepo;
 };
 
+let unsafeGetImageRepoDp = () => {
+  _unsafeGetRepoDp().imageRepo;
+};
+
 let setRepoDp = dp => {
   dpContainer.repo = dp->Some;
 
@@ -123,12 +126,12 @@ let setWebGPURayTracingDp = dp => {
   ();
 };
 
-// let unsafeGetNetworkDp = () => {
-//   dpContainer.network->OptionSt.unsafeGet;
-// };
+let unsafeGetNetworkDp = () => {
+  dpContainer.network->OptionSt.unsafeGet;
+};
 
-// let setNetworkDp = dp => {
-//   dpContainer.network = dp->Some;
+let setNetworkDp = dp => {
+  dpContainer.network = dp->Some;
 
-//   ();
-// };
+  ();
+};

src/construct/domain_layer/dependency/interface/INetworkDp.re

@@ -0,0 +1,6 @@
+type path = string;
+
+type network = {
+  readImageFile:
+    path => Result.t2(WonderBsMost.Most.stream(ImagePOType.data)),
+};

src/construct/domain_layer/dependency/interface/IRepoDp.re

@@ -166,6 +166,11 @@ type timeRepo = {
   start: TimePOType.time => unit,
 };
 
+type imageRepo = {
+  getData: ImagePOType.id => Js.Nullable.t(ImagePOType.data),
+  setData: (ImagePOType.id, ImagePOType.data) => unit,
+};
+
 type repo = {
   sceneRepo,
   gameObjectRepo,
@@ -178,4 +183,5 @@ type repo = {
   globalTempRepo,
   pipelineRepo,
   timeRepo,
+  imageRepo,
 };

src/construct/domain_layer/dependency/interface/po/ImagePOType.re

@@ -0,0 +1,7 @@
+type id = string;
+
+type data = {
+  width: int,
+  height: int,
+  data: Js.Typed_array.Uint8Array.t,
+};

src/construct/domain_layer/domain/asset/image/service/LoadImageDoService.re

@@ -0,0 +1,20 @@
+open WonderBsMost.Most;
+
+let loadImages = imageDataList => {
+  imageDataList
+  ->ListSt.traverseResultM(((id, path)) => {
+      DpContainer.unsafeGetNetworkDp().readImageFile(path)
+      ->Result.mapSuccess(stream => {
+          stream->tap(
+                    imageData => {
+                      DpContainer.unsafeGetImageRepoDp().setData(
+                        id,
+                        imageData,
+                      )
+                    },
+                    _,
+                  )
+        })
+    })
+  ->Result.mapSuccess(streamList => {streamList->ListSt.toArray->mergeArray});
+};

src/construct/external_layer/api/run/dependency/NetworkDpRunAPI.re

@@ -0,0 +1,3 @@
+let set = (dp: INetworkDp.network) => {
+  NetworkDpApService.set(dp);
+};

src/construct/external_layer/api/run/domain/AssetRunAPI.re

@@ -0,0 +1,3 @@
+let loadImages = imageDataList => {
+  AssetApService.loadImages(imageDataList);
+};

src/run/cloud_picture/application_layer/AssetCPApService.re

@@ -0,0 +1,3 @@
+let loadImages = imageDataArr => {
+  AssetRunAPI.loadImages(imageDataArr->ListSt.fromArray);
+};

src/run/cloud_picture/application_layer/DirectorCPApService.re

@@ -154,6 +154,10 @@ let _injectDependencies = () => {
       start: TimeCPRepoDp.start,
       getElapsed: TimeCPRepoDp.getElapsed,
     },
+    imageRepo: {
+      getData: ImageCPRepoDp.getData,
+      setData: ImageCPRepoDp.setData,
+    },
   });
 
   POConfigDpRunAPI.set({

src/run/cloud_picture/domain_layer/repo/CreateCPRepo.re

@@ -146,4 +146,7 @@ let create = () => {
     staticBindGroupData: None,
     pipeline: None,
   },
+  image: {
+    dataMap: ImmutableHashMap.createEmpty(),
+  },
 };

src/run/cloud_picture/external_layer/api/AssetCPAPI.re

@@ -0,0 +1,3 @@
+let loadImages = imageDataArr => {
+  AssetCPApService.loadImages(imageDataArr);
+};

src/run/cloud_picture/external_layer/api/dependency/NetworkDpCPAPI.re

@@ -0,0 +1,3 @@
+let set = dp => {
+  NetworkDpRunAPI.set(dp);
+};

src/run/cloud_picture/infrastructure_layer/data/container/CPRepo.re

@@ -207,3 +207,15 @@ let setAccumulationPass = accumulationPass => {
 
   {...po, accumulationPass}->CPContainerManager.setPO;
 };
+
+let getImage = () => {
+  let po = CPContainerManager.getPO();
+
+  po.image;
+};
+
+let setImage = image => {
+  let po = CPContainerManager.getPO();
+
+  {...po, image}->CPContainerManager.setPO;
+};

src/run/cloud_picture/infrastructure_layer/data/po/CPPOType.re

@@ -17,4 +17,5 @@ type po = {
   pass: PassCPPOType.pass,
   pathTracingPass: PathTracingPassCPPOType.pathTracingPass,
   accumulationPass: AccumulationPassCPPOType.accumulationPass,
+  image: ImageCPPOType.image,
 };

src/run/cloud_picture/infrastructure_layer/data/po/asset/ImageCPPOType.re

@@ -0,0 +1,3 @@
+type image = {
+  dataMap: ImmutableHashMap.t(ImagePOType.id, ImagePOType.data),
+};

src/run/cloud_picture/infrastructure_layer/dependency/repo/asset/ImageCPRepoDp.re

@@ -0,0 +1,14 @@
+open ImageCPPOType;
+
+let setData = (id, data) => {
+  let {dataMap} as po = CPRepo.getImage();
+
+  CPRepo.setImage({
+    ...CPRepo.getImage(),
+    dataMap: dataMap->ImmutableHashMap.set(id, data),
+  });
+};
+
+let getData = id => {
+  CPRepo.getImage().dataMap->ImmutableHashMap.getNullable(id);
+};

test/construct/tool/DependencyTool.re

@@ -1,5 +1,16 @@
+open Sinon;
+
 let injectAllDependencies = (~isDebug=true, ()) => {
   DirectorCPApService._injectDependencies();
 
   OtherConfigDpCPAPI.set({getIsDebug: () => isDebug});
-};
+};
+
+let injectNetworkDp =
+    (
+      ~sandbox,
+      ~readImageFile=createEmptyStub(refJsObjToSandbox(sandbox^)),
+      (),
+    ) => {
+  NetworkDpRunAPI.set({readImageFile: readImageFile});
+};