feat(architecture): add UpdatePassCPJobEntity

pass unit test;

Author: yyc-git

src/run/domain_layer/domain/pipeline/pipeline/entity/jobs/update/UpdatePassCPJobEntity.re

@@ -0,0 +1,29 @@
+let create = () => JobEntity.create("update_pass");
+
+let _updateCommonBufferData = ((commonBuffer, commonBufferData)) => {
+  let sampleCount = PassCPRepo.getSampleCount();
+
+  TypeArrayCPRepoUtils.setUint32_1(0, sampleCount, commonBufferData)
+  ->Result.tap(() => {
+      WebGPUCoreDpRunAPI.unsafeGet().buffer.setSubUint32Data(
+        0,
+        commonBufferData,
+        commonBuffer->UniformBufferVO.value,
+      );
+
+      PassCPRepo.setCommonBufferData((commonBuffer, commonBufferData));
+    });
+};
+
+let _updateAllBufferData = ((commonBuffer, commonBufferData)) => {
+  _updateCommonBufferData((commonBuffer, commonBufferData));
+};
+
+let exec = () => {
+  PassCPRepo.getCommonBufferData()
+  ->OptionSt.get
+  ->Result.bind(((commonBuffer, commonBufferData)) => {
+      _updateAllBufferData((commonBuffer, commonBufferData))
+    })
+  ->WonderBsMost.Most.just;
+};

src/run/domain_layer/domain/pipeline/pipeline/service/JobCPDoService.re

@@ -14,7 +14,7 @@ let _getUpdatePipelineJobs = () => [
     UpdateTextureArrayCPJobEntity.exec,
   ),
   (UpdatePathTracingCPJobEntity.create(), UpdatePathTracingCPJobEntity.exec),
-  // (UpdatePassCPJobEntity.create(), UpdatePassCPJobEntity.exec),
+  (UpdatePassCPJobEntity.create(), UpdatePassCPJobEntity.exec),
 ];
 
 // let _getRenderPipelineJobs = () => [

src/run/domain_layer/repo/CreateCPRepo.re

@@ -16,9 +16,9 @@ let create = () => {
             {name: "start_time", type_: Job},
             {name: "init_webgpu", type_: Job},
             {name: "init_camera", type_: Job},
-            // {name: "init_pass", type_: Job},
-            // {name: "init_pathTracing", type_: Job},
-            // {name: "init_accumulation", type_: Job},
+            {name: "init_pass", type_: Job},
+            {name: "init_pathTracing", type_: Job},
+            {name: "init_accumulation", type_: Job},
           ],
         },
       ],
@@ -34,7 +34,7 @@ let create = () => {
             {name: "update_camera", type_: Job},
             {name: "update_textureArray", type_: Job},
             {name: "update_pathTracing", type_: Job},
-            // {name: "update_pass", type_: Job},
+            {name: "update_pass", type_: Job},
           ],
         },
       ],

test/run/integration/updatePassCPJob_test.re

@@ -0,0 +1,86 @@
+open Wonder_jest;
+
+let _ =
+  describe("test update_pass job", () => {
+    open Expect;
+    open Expect.Operators;
+    open Sinon;
+
+    let sandbox = getSandboxDefaultVal();
+
+    beforeEach(() => {
+      sandbox := createSandbox();
+      TestCPTool.init(
+        ~sandbox,
+        ~updatePipelineData={
+          name: "update",
+          firstGroup: "frame",
+          groups: [
+            {
+              name: "frame",
+              link: Concat,
+              elements: [{name: "update_pass", type_: Job}],
+            },
+          ],
+        },
+        (),
+      );
+    });
+    afterEach(() => restoreSandbox(refJsObjToSandbox(sandbox^)));
+
+    describe("update common buffer data", () => {
+      let _prepare = () => {
+        let device = WebGPUDependencyTool.createDeviceObject();
+        WebGPUCPTool.setDevice(device);
+        let window = WebGPUDependencyTool.createWindowObject();
+        WebGPUCPTool.setWindow(window);
+
+        PassCPTool.buildAndSetAllBufferData(window, device);
+      };
+
+      testPromise("set sample count to buffer data", () => {
+        let _ = _prepare();
+        let sampleCount = 2;
+        DirectorCPTool.prepare(~sampleCount, ());
+
+        DirectorCPTool.initAndUpdate(
+          ~handleSuccessFunc=
+            () => {
+              let (_, typeArr) = PassCPTool.getCommonBufferData();
+
+              typeArr->Js.Typed_array.Uint32Array.unsafe_get(0)->expect
+              == sampleCount;
+            },
+          (),
+        );
+      });
+      testPromise("set buffer's data", () => {
+        let _ = _prepare();
+        let setSubUint32DataStubData =
+          createEmptyStub(refJsObjToSandbox(sandbox^))
+          ->SinonTool.createThreeArgsEmptyStubData;
+        WebGPUDependencyTool.build(
+          ~sandbox,
+          ~setSubUint32Data=setSubUint32DataStubData->SinonTool.getDpFunc,
+          (),
+        )
+        ->WebGPUDependencyTool.set;
+        DirectorCPTool.initAndUpdate(
+          ~handleSuccessFunc=
+            () => {
+              let (buffer, typeArr) = PassCPTool.getCommonBufferData();
+
+              setSubUint32DataStubData
+              ->SinonTool.getStub
+              ->expect
+              ->SinonTool.toCalledWith((
+                  0,
+                  typeArr,
+                  buffer->UniformBufferVO.value,
+                ));
+            },
+          (),
+        );
+      });
+    });
+  });