diff --git a/app/.env b/app/.env
index daf92f1..5740621 100644
--- a/app/.env
+++ b/app/.env
@@ -7,11 +7,11 @@ REACT_APP_SERVER_SOCKET_API_BASE_URL=185.100.212.76:8000
# Base URL for the server REST API, used for HTTP requests to the backend server.
REACT_APP_SERVER_REST_API_BASE_URL=185.100.212.76:5000
-REACT_APP_SERVER_REST_API_LOCAL_BASE_URL=192.168.0.102:5000
+# Base URL for the server marketplace, used for market place model blob.
+REACT_APP_SERVER_MARKETPLACE_URL=185.100.212.76:50011
-# Base URL for the server marketplace API.
-# REACT_APP_SERVER_MARKETPLACE_URL=185.100.212.76:50011
-REACT_APP_SERVER_MARKETPLACE_URL=192.168.0.111:3501
+# Base URL for the asset library server, used for asset library images and model blob id.
+REACT_APP_SERVER_ASSET_LIBRARY_URL=192.168.0.111:3501
# base url for IoT socket server
REACT_APP_IOT_SOCKET_SERVER_URL =185.100.212.76:5010
diff --git a/app/src/components/layout/sidebarRight/visualization/data/Data.tsx b/app/src/components/layout/sidebarRight/visualization/data/Data.tsx
index 2c9b5c6..5f501a2 100644
--- a/app/src/components/layout/sidebarRight/visualization/data/Data.tsx
+++ b/app/src/components/layout/sidebarRight/visualization/data/Data.tsx
@@ -118,7 +118,7 @@ const Data = () => {
};
});
};
- console.log("selectedChartId", selectedChartId);
+ // console.log("selectedChartId", selectedChartId);
return (
diff --git a/app/src/components/ui/componets/RealTimeVisulization.tsx b/app/src/components/ui/componets/RealTimeVisulization.tsx
index f6a041a..4ff643b 100644
--- a/app/src/components/ui/componets/RealTimeVisulization.tsx
+++ b/app/src/components/ui/componets/RealTimeVisulization.tsx
@@ -63,7 +63,7 @@ const RealTimeVisulization: React.FC = () => {
const organization = email?.split("@")[1]?.split(".")[0];
try {
const response = await getZone2dData(organization);
- console.log('response: ', response);
+ // console.log('response: ', response);
if (!Array.isArray(response)) {
return;
diff --git a/app/src/modules/builder/geomentries/assets/addAssetModel.ts b/app/src/modules/builder/geomentries/assets/addAssetModel.ts
index 65832f8..a4255bd 100644
--- a/app/src/modules/builder/geomentries/assets/addAssetModel.ts
+++ b/app/src/modules/builder/geomentries/assets/addAssetModel.ts
@@ -60,7 +60,7 @@ async function addAssetModel(
if (intersectPoint.y < 0) {
intersectPoint = new THREE.Vector3(intersectPoint.x, 0, intersectPoint.z);
}
- console.log('selectedItem: ', selectedItem);
+ // console.log('selectedItem: ', selectedItem);
const cachedModel = THREE.Cache.get(selectedItem.id);
if (cachedModel) {
// console.log(`[Cache] Fetching ${selectedItem.name}`);
@@ -145,10 +145,9 @@ async function handleModelLoad(
};
const email = localStorage.getItem("email");
- const organization = email ? email.split("@")[1].split(".")[0] : "default";
+ const organization = email ? email.split("@")[1].split(".")[0] : "";
getAssetEventType(selectedItem.id, organization).then(async (res) => {
- console.log('res: ', res);
if (res.type === "Conveyor") {
const pointUUIDs = res.points.map(() => THREE.MathUtils.generateUUID());
@@ -177,7 +176,7 @@ async function handleModelLoad(
speed: 'Inherit'
};
- console.log('eventData: ', eventData);
+ // console.log('eventData: ', eventData);
newFloorItem.eventData = eventData;
}
@@ -215,6 +214,8 @@ async function handleModelLoad(
eventData: newFloorItem.eventData,
socketId: socket.id
};
+ console.log('data: ', data);
+
socket.emit("v2:model-asset:add", data);
diff --git a/app/src/modules/builder/geomentries/assets/deleteFloorItems.ts b/app/src/modules/builder/geomentries/assets/deleteFloorItems.ts
index 87930dc..3bbe2cc 100644
--- a/app/src/modules/builder/geomentries/assets/deleteFloorItems.ts
+++ b/app/src/modules/builder/geomentries/assets/deleteFloorItems.ts
@@ -2,9 +2,9 @@ import { toast } from 'react-toastify';
import * as THREE from 'three';
import * as Types from "../../../../types/world/worldTypes";
-import { getFloorItems } from '../../../../services/factoryBuilder/assest/floorAsset/getFloorItemsApi';
// import { deleteFloorItem } from '../../../../services/factoryBuilder/assest/floorAsset/deleteFloorItemApi';
import { Socket } from 'socket.io-client';
+import { getFloorAssets } from '../../../../services/factoryBuilder/assest/floorAsset/getFloorItemsApi';
async function DeleteFloorItems(
itemsGroup: Types.RefGroup,
@@ -20,7 +20,7 @@ async function DeleteFloorItems(
const email = localStorage.getItem('email')
const organization = (email!.split("@")[1]).split(".")[0];
- const items = await getFloorItems(organization);
+ const items = await getFloorAssets(organization);
const removedItem = items.find(
(item: { modeluuid: string }) => item.modeluuid === hoveredDeletableFloorItem.current?.uuid
);
@@ -42,7 +42,7 @@ async function DeleteFloorItems(
socketId: socket.id
}
- const response = socket.emit('v1:FloorItems:delete', data)
+ const response = socket.emit('v2:model-asset:delete', data)
if (response) {
const updatedItems = items.filter(
diff --git a/app/src/modules/builder/groups/floorItemsGroup.tsx b/app/src/modules/builder/groups/floorItemsGroup.tsx
index 3b38d01..2f2241e 100644
--- a/app/src/modules/builder/groups/floorItemsGroup.tsx
+++ b/app/src/modules/builder/groups/floorItemsGroup.tsx
@@ -11,7 +11,7 @@ import DeletableHoveredFloorItems from "../geomentries/assets/deletableHoveredFl
import DeleteFloorItems from "../geomentries/assets/deleteFloorItems";
import loadInitialFloorItems from "../../scene/IntialLoad/loadInitialFloorItems";
import addAssetModel from "../geomentries/assets/addAssetModel";
-import { getFloorItems } from "../../../services/factoryBuilder/assest/floorAsset/getFloorItemsApi";
+import { getFloorAssets } from "../../../services/factoryBuilder/assest/floorAsset/getFloorItemsApi";
import useModuleStore from "../../../store/useModuleStore";
// import { retrieveGLTF } from "../../../utils/indexDB/idbUtils";
const assetManagerWorker = new Worker(new URL('../../../services/factoryBuilder/webWorkers/assetManagerWorker.js', import.meta.url));
@@ -59,8 +59,7 @@ const FloorItemsGroup = ({ itemsGroup, hoveredDeletableFloorItem, AttachedObject
}
};
- getFloorItems(organization).then((data) => {
- console.log('data: ', data);
+ getFloorAssets(organization).then((data) => {
const uniqueItems = (data as Types.FloorItems).filter((item, index, self) =>
index === self.findIndex((t) => t.modelfileID === item.modelfileID)
);
@@ -307,8 +306,7 @@ const FloorItemsGroup = ({ itemsGroup, hoveredDeletableFloorItem, AttachedObject
}, [deleteModels, transformMode, controls, selectedItem, state.camera, state.pointer, activeTool, activeModule]);
useEffect(() => {
-
- console.log('floorItems: ', floorItems);
+ // console.log('floorItems: ', floorItems);
}, [floorItems])
useFrame(() => {
diff --git a/app/src/modules/collaboration/collabCams.tsx b/app/src/modules/collaboration/collabCams.tsx
index 5ebe1eb..b15d17d 100644
--- a/app/src/modules/collaboration/collabCams.tsx
+++ b/app/src/modules/collaboration/collabCams.tsx
@@ -32,7 +32,7 @@ const CamModelsGroup = () => {
if (!socket) return;
const organization = email!.split("@")[1].split(".")[0];
- socket.on("userConnectRespones", (data: any) => {
+ socket.on("userConnectResponse", (data: any) => {
if (!groupRef.current) return;
if (data.data.userData.email === email) return;
if (socket.id === data.socketId || organization !== data.organization)
@@ -64,7 +64,11 @@ const CamModelsGroup = () => {
});
});
- socket.on("userDisConnectRespones", (data: any) => {
+ // socket.on("users:online", (data: any) => {
+ // console.log('users online: ', data);
+ // })
+
+ socket.on("userDisConnectResponse", (data: any) => {
if (!groupRef.current) return;
if (socket.id === data.socketId || organization !== data.organization)
return;
@@ -109,6 +113,15 @@ const CamModelsGroup = () => {
};
}, [socket, activeUsers]);
+
+ // useEffect(() => {
+ // console.log(activeUsers);
+ // }, [activeUsers])
+
+ // useEffect(() => {
+ // console.log(models);
+ // }, [models])
+
useFrame(() => {
if (!groupRef.current) return;
Object.keys(models).forEach((uuid) => {
@@ -142,7 +155,7 @@ const CamModelsGroup = () => {
const filteredData = data.cameraDatas.filter(
(camera: any) => camera.userData.email !== email
);
- let a:any = [];
+ let a: any = [];
if (filteredData.length > 0) {
loader.load(camModel, (gltf) => {
const newCams = filteredData.map((cam: any) => {
diff --git a/app/src/modules/collaboration/socketResponses.dev.tsx b/app/src/modules/collaboration/socketResponses.dev.tsx
index 1a5ef83..d17557d 100644
--- a/app/src/modules/collaboration/socketResponses.dev.tsx
+++ b/app/src/modules/collaboration/socketResponses.dev.tsx
@@ -82,14 +82,14 @@ export default function SocketResponses({
})
socket.on('model-asset:response:updates', async (data: any) => {
- console.log('data: ', data);
+ // console.log('data: ', data);
if (socket.id === data.socketId) {
return
}
if (organization !== data.organization) {
return
}
- if (data.message === "flooritem created") {
+ if (data.message === "Model created successfully") {
const loader = new GLTFLoader();
const dracoLoader = new DRACOLoader();
@@ -101,10 +101,61 @@ export default function SocketResponses({
isTempLoader.current = true;
const cachedModel = THREE.Cache.get(data.data.modelname);
let url;
-
if (cachedModel) {
// console.log(`Getting ${data.data.modelname} from cache`);
- url = URL.createObjectURL(cachedModel);
+ const model = cachedModel.scene.clone();
+ model.uuid = data.data.modeluuid;
+ model.userData = { name: data.data.modelname, modelId: data.data.modelFileID };
+ model.position.set(...data.data.position as [number, number, number]);
+ model.rotation.set(data.data.rotation.x, data.data.rotation.y, data.data.rotation.z);
+ model.scale.set(...CONSTANTS.assetConfig.defaultScaleBeforeGsap);
+
+ model.traverse((child: any) => {
+ if (child.isMesh) {
+ // Clone the material to ensure changes are independent
+ // child.material = child.material.clone();
+
+ child.castShadow = true;
+ child.receiveShadow = true;
+ }
+ });
+
+ itemsGroup.current.add(model);
+
+ if (tempLoader.current) {
+ tempLoader.current.material.dispose();
+ tempLoader.current.geometry.dispose();
+ itemsGroup.current.remove(tempLoader.current);
+ tempLoader.current = undefined;
+ }
+
+ const newFloorItem: Types.FloorItemType = {
+ modeluuid: data.data.modeluuid,
+ modelname: data.data.modelname,
+ modelfileID: data.data.modelfileID,
+ position: [...data.data.position as [number, number, number]],
+ rotation: {
+ x: model.rotation.x,
+ y: model.rotation.y,
+ z: model.rotation.z,
+ },
+ isLocked: data.data.isLocked,
+ isVisible: data.data.isVisible,
+ };
+
+ if (data.data.eventData) {
+ newFloorItem.eventData = data.data.eventData;
+ }
+
+ setFloorItems((prevItems: any) => {
+ const updatedItems = [...(prevItems || []), newFloorItem];
+ localStorage.setItem("FloorItems", JSON.stringify(updatedItems));
+ return updatedItems;
+ });
+
+ gsap.to(model.position, { y: data.data.position[1], duration: 1.5, ease: 'power2.out' });
+ gsap.to(model.scale, { x: 1, y: 1, z: 1, duration: 1.5, ease: 'power2.out', onComplete: () => { toast.success("Model Added!") } });
+
} else {
const indexedDBModel = await retrieveGLTF(data.data.modelname);
if (indexedDBModel) {
@@ -118,7 +169,9 @@ export default function SocketResponses({
}
}
- loadModel(url);
+ if (url) {
+ loadModel(url);
+ }
} catch (error) {
console.error('Error fetching asset model:', error);
@@ -168,6 +221,10 @@ export default function SocketResponses({
isVisible: data.data.isVisible,
};
+ if (data.data.eventData) {
+ newFloorItem.eventData = data.data.eventData;
+ }
+
setFloorItems((prevItems: any) => {
const updatedItems = [...(prevItems || []), newFloorItem];
localStorage.setItem("FloorItems", JSON.stringify(updatedItems));
@@ -183,7 +240,7 @@ export default function SocketResponses({
});
}
- } else if (data.message === "flooritems updated") {
+ } else if (data.message === "Model updated successfully") {
itemsGroup.current.children.forEach((item: THREE.Group) => {
if (item.uuid === data.data.modeluuid) {
item.position.set(...data.data.position as [number, number, number]);
@@ -212,14 +269,14 @@ export default function SocketResponses({
}
})
- socket.on('FloorItemsDeleteResponse', (data: any) => {
+ socket.on('model-asset:response:updates', (data: any) => {
if (socket.id === data.socketId) {
return
}
if (organization !== data.organization) {
return
}
- if (data.message === "flooritem deleted") {
+ if (data.message === "Model deleted successfully") {
const deletedUUID = data.data.modeluuid;
let items = JSON.parse(localStorage.getItem("FloorItems")!);
@@ -746,7 +803,6 @@ export default function SocketResponses({
return
}
if (data.message === "zone deleted") {
- console.log('data: ', data);
const updatedZones = zones.filter((zone: any) => zone.zoneId !== data.data.zoneId);
setZones(updatedZones);
@@ -769,7 +825,7 @@ export default function SocketResponses({
return () => {
socket.off('zone:response:updates');
- socket.off('zone:response:updates');
+ socket.off('zone:response:delete');
};
}, [socket, zones, zonePoints])
diff --git a/app/src/modules/scene/IntialLoad/loadInitialFloorItems.ts b/app/src/modules/scene/IntialLoad/loadInitialFloorItems.ts
index 439cbc3..dfff78d 100644
--- a/app/src/modules/scene/IntialLoad/loadInitialFloorItems.ts
+++ b/app/src/modules/scene/IntialLoad/loadInitialFloorItems.ts
@@ -5,9 +5,9 @@ import * as THREE from 'three';
import * as CONSTANTS from '../../../types/world/worldConstants';
import { toast } from 'react-toastify';
import * as Types from "../../../types/world/worldTypes";
-import { getFloorItems } from '../../../services/factoryBuilder/assest/floorAsset/getFloorItemsApi';
import { initializeDB, retrieveGLTF, storeGLTF } from '../../../utils/indexDB/idbUtils';
import { getCamera } from '../../../services/factoryBuilder/camera/getCameraApi';
+import { getFloorAssets } from '../../../services/factoryBuilder/assest/floorAsset/getFloorItemsApi';
async function loadInitialFloorItems(
itemsGroup: Types.RefGroup,
@@ -18,7 +18,7 @@ async function loadInitialFloorItems(
const email = localStorage.getItem('email');
const organization = (email!.split("@")[1]).split(".")[0];
- const items = await getFloorItems(organization);
+ const items = await getFloorAssets(organization);
localStorage.setItem("FloorItems", JSON.stringify(items));
await initializeDB();
@@ -121,18 +121,34 @@ async function loadInitialFloorItems(
});
} else {
// console.log(`Item ${item.modelname} is not near`);
- setFloorItems((prevItems) => [
- ...(prevItems || []),
- {
- modeluuid: item.modeluuid,
- modelname: item.modelname,
- position: item.position,
- rotation: item.rotation,
- modelfileID: item.modelfileID,
- isLocked: item.isLocked,
- isVisible: item.isVisible,
- },
- ]);
+ if (item.eventData) {
+ setFloorItems((prevItems) => [
+ ...(prevItems || []),
+ {
+ modeluuid: item.modeluuid,
+ modelname: item.modelname,
+ position: item.position,
+ rotation: item.rotation,
+ modelfileID: item.modelfileID,
+ isLocked: item.isLocked,
+ isVisible: item.isVisible,
+ // eventData: item.eventData,
+ },
+ ]);
+ } else {
+ setFloorItems((prevItems) => [
+ ...(prevItems || []),
+ {
+ modeluuid: item.modeluuid,
+ modelname: item.modelname,
+ position: item.position,
+ rotation: item.rotation,
+ modelfileID: item.modelfileID,
+ isLocked: item.isLocked,
+ isVisible: item.isVisible,
+ },
+ ]);
+ }
modelsLoaded++;
checkLoadingCompletion(modelsLoaded, modelsToLoad, dracoLoader, () => { });
}
@@ -169,18 +185,35 @@ function processLoadedModel(
itemsGroup?.current?.add(model);
- setFloorItems((prevItems) => [
- ...(prevItems || []),
- {
- modeluuid: item.modeluuid,
- modelname: item.modelname,
- position: item.position,
- rotation: item.rotation,
- modelfileID: item.modelfileID,
- isLocked: item.isLocked,
- isVisible: item.isVisible,
- },
- ]);
+
+ if (item.eventData) {
+ setFloorItems((prevItems) => [
+ ...(prevItems || []),
+ {
+ modeluuid: item.modeluuid,
+ modelname: item.modelname,
+ position: item.position,
+ rotation: item.rotation,
+ modelfileID: item.modelfileID,
+ isLocked: item.isLocked,
+ isVisible: item.isVisible,
+ // eventData: item.eventData,
+ },
+ ]);
+ } else {
+ setFloorItems((prevItems) => [
+ ...(prevItems || []),
+ {
+ modeluuid: item.modeluuid,
+ modelname: item.modelname,
+ position: item.position,
+ rotation: item.rotation,
+ modelfileID: item.modelfileID,
+ isLocked: item.isLocked,
+ isVisible: item.isVisible,
+ },
+ ]);
+ }
gsap.to(model.position, { y: item.position[1], duration: 1.5, ease: 'power2.out' });
gsap.to(model.scale, { x: 1, y: 1, z: 1, duration: 1.5, ease: 'power2.out' });
diff --git a/app/src/modules/scene/controls/selection/copyPasteControls.tsx b/app/src/modules/scene/controls/selection/copyPasteControls.tsx
index 3082462..4628311 100644
--- a/app/src/modules/scene/controls/selection/copyPasteControls.tsx
+++ b/app/src/modules/scene/controls/selection/copyPasteControls.tsx
@@ -180,7 +180,7 @@ const CopyPasteControls = ({ itemsGroupRef, copiedObjects, setCopiedObjects, pas
socketId: socket.id,
};
- socket.emit("v1:FloorItems:set", data);
+ socket.emit("v2:model-asset:add", data);
itemsGroupRef.current.add(obj);
}
diff --git a/app/src/modules/scene/controls/selection/duplicationControls.tsx b/app/src/modules/scene/controls/selection/duplicationControls.tsx
index cbe561a..6b32195 100644
--- a/app/src/modules/scene/controls/selection/duplicationControls.tsx
+++ b/app/src/modules/scene/controls/selection/duplicationControls.tsx
@@ -161,7 +161,7 @@ const DuplicationControls = ({ itemsGroupRef, duplicatedObjects, setDuplicatedOb
socketId: socket.id,
};
- socket.emit("v1:FloorItems:set", data);
+ socket.emit("v2:model-asset:add", data);
itemsGroupRef.current.add(obj);
}
diff --git a/app/src/modules/scene/controls/selection/moveControls.tsx b/app/src/modules/scene/controls/selection/moveControls.tsx
index bbdb3e1..15973d8 100644
--- a/app/src/modules/scene/controls/selection/moveControls.tsx
+++ b/app/src/modules/scene/controls/selection/moveControls.tsx
@@ -209,7 +209,7 @@ function MoveControls({ movedObjects, setMovedObjects, itemsGroupRef, copiedObje
socketId: socket.id,
};
- socket.emit("v1:FloorItems:set", data);
+ socket.emit("v2:model-asset:add", data);
itemsGroupRef.current.add(obj);
}
diff --git a/app/src/modules/scene/controls/selection/rotateControls.tsx b/app/src/modules/scene/controls/selection/rotateControls.tsx
index 6e65839..f8771be 100644
--- a/app/src/modules/scene/controls/selection/rotateControls.tsx
+++ b/app/src/modules/scene/controls/selection/rotateControls.tsx
@@ -212,7 +212,7 @@ function RotateControls({ rotatedObjects, setRotatedObjects, movedObjects, setMo
socketId: socket.id,
};
- socket.emit("v1:FloorItems:set", data);
+ socket.emit("v2:model-asset:add", data);
itemsGroupRef.current.add(obj);
}
diff --git a/app/src/modules/scene/controls/selection/selectionControls.tsx b/app/src/modules/scene/controls/selection/selectionControls.tsx
index 9d5f7ea..8e9ac96 100644
--- a/app/src/modules/scene/controls/selection/selectionControls.tsx
+++ b/app/src/modules/scene/controls/selection/selectionControls.tsx
@@ -222,7 +222,7 @@ const SelectionControls: React.FC = () => {
socketId: socket.id
};
- socket.emit('v1:FloorItems:delete', data);
+ socket.emit('v2:model-asset:delete', data);
selectedMesh.traverse((child: THREE.Object3D) => {
if (child instanceof THREE.Mesh) {
diff --git a/app/src/modules/scene/controls/transformControls.tsx b/app/src/modules/scene/controls/transformControls.tsx
index 7047f35..0f0aaf0 100644
--- a/app/src/modules/scene/controls/transformControls.tsx
+++ b/app/src/modules/scene/controls/transformControls.tsx
@@ -83,7 +83,7 @@ export default function TransformControl() {
socketId: socket.id
}
- socket.emit('v1:FloorItems:set', data);
+ socket.emit('v2:model-asset:add', data);
}
localStorage.setItem("FloorItems", JSON.stringify(updatedItems));
return updatedItems;
diff --git a/app/src/modules/simulation/behaviour/behaviour.tsx b/app/src/modules/simulation/behaviour/behaviour.tsx
index 5075384..d127705 100644
--- a/app/src/modules/simulation/behaviour/behaviour.tsx
+++ b/app/src/modules/simulation/behaviour/behaviour.tsx
@@ -12,14 +12,15 @@ function Behaviour() {
floorItems.forEach((item: Types.FloorItemType) => {
if (item.modelfileID === "672a090f80d91ac979f4d0bd") {
+ console.log('item: ', item);
const point1Position = new THREE.Vector3(0, 0.85, 2.2);
const middlePointPosition = new THREE.Vector3(0, 0.85, 0);
const point2Position = new THREE.Vector3(0, 0.85, -2.2);
-
+
const point1UUID = THREE.MathUtils.generateUUID();
const middlePointUUID = THREE.MathUtils.generateUUID();
const point2UUID = THREE.MathUtils.generateUUID();
-
+
const newPath: Types.ConveyorEventsSchema = {
modeluuid: item.modeluuid,
modelName: item.modelname,
@@ -29,7 +30,7 @@ function Behaviour() {
uuid: point1UUID,
position: [point1Position.x, point1Position.y, point1Position.z],
rotation: [0, 0, 0],
- actions: [{ uuid: THREE.MathUtils.generateUUID(), name: 'Action 1', type: 'Inherit', material: 'Inherit', delay: 'Inherit', spawnInterval: 'Inherit', isUsed: false }],
+ actions: [{ uuid: THREE.MathUtils.generateUUID(), name: 'Action 1', type: 'Inherit', material: 'Inherit', delay: 'Inherit', spawnInterval: 'Inherit', isUsed: true }],
triggers: [],
connections: { source: { pathUUID: item.modeluuid, pointUUID: point1UUID }, targets: [] },
},
@@ -37,7 +38,7 @@ function Behaviour() {
uuid: middlePointUUID,
position: [middlePointPosition.x, middlePointPosition.y, middlePointPosition.z],
rotation: [0, 0, 0],
- actions: [{ uuid: THREE.MathUtils.generateUUID(), name: 'Action 1', type: 'Inherit', material: 'Inherit', delay: 'Inherit', spawnInterval: 'Inherit', isUsed: false }],
+ actions: [{ uuid: THREE.MathUtils.generateUUID(), name: 'Action 1', type: 'Inherit', material: 'Inherit', delay: 'Inherit', spawnInterval: 'Inherit', isUsed: true }],
triggers: [],
connections: { source: { pathUUID: item.modeluuid, pointUUID: middlePointUUID }, targets: [] },
},
@@ -45,13 +46,13 @@ function Behaviour() {
uuid: point2UUID,
position: [point2Position.x, point2Position.y, point2Position.z],
rotation: [0, 0, 0],
- actions: [{ uuid: THREE.MathUtils.generateUUID(), name: 'Action 1', type: 'Inherit', material: 'Inherit', delay: 'Inherit', spawnInterval: 'Inherit', isUsed: false }],
+ actions: [{ uuid: THREE.MathUtils.generateUUID(), name: 'Action 1', type: 'Inherit', material: 'Inherit', delay: 'Inherit', spawnInterval: 'Inherit', isUsed: true }],
triggers: [],
connections: { source: { pathUUID: item.modeluuid, pointUUID: point2UUID }, targets: [] },
},
],
- assetPosition: [...item.position],
- assetRotation: [item.rotation.x, item.rotation.y, item.rotation.z],
+ position: [...item.position],
+ rotation: [item.rotation.x, item.rotation.y, item.rotation.z],
speed: 'Inherit',
};
@@ -71,7 +72,7 @@ function Behaviour() {
connections: { source: { pathUUID: item.modeluuid, pointUUID: pointUUID }, targets: [] },
speed: 2,
},
- assetPosition: [...item.position],
+ position: [...item.position],
};
newPaths.push(newVehiclePath);
diff --git a/app/src/modules/simulation/path/pathCreation.tsx b/app/src/modules/simulation/path/pathCreation.tsx
index 202c7e7..84c3b78 100644
--- a/app/src/modules/simulation/path/pathCreation.tsx
+++ b/app/src/modules/simulation/path/pathCreation.tsx
@@ -171,8 +171,8 @@ function PathCreation({ pathsGroupRef }: { pathsGroupRef: React.MutableRefObject
name={`${path.modeluuid}-event-path`}
key={path.modeluuid}
ref={el => (groupRefs.current[path.modeluuid] = el!)}
- position={path.assetPosition}
- rotation={path.assetRotation}
+ position={path.position}
+ rotation={path.rotation}
onClick={(e) => {
if (isConnecting || eyeDropMode) return;
e.stopPropagation();
@@ -237,7 +237,7 @@ function PathCreation({ pathsGroupRef }: { pathsGroupRef: React.MutableRefObject
name={`${path.modeluuid}-vehicle-path`}
key={path.modeluuid}
ref={el => (groupRefs.current[path.modeluuid] = el!)}
- position={path.assetPosition}
+ position={path.position}
onClick={(e) => {
if (isConnecting || eyeDropMode) return;
e.stopPropagation();
diff --git a/app/src/modules/simulation/process/processAnimator.tsx b/app/src/modules/simulation/process/processAnimator.tsx
new file mode 100644
index 0000000..123ec80
--- /dev/null
+++ b/app/src/modules/simulation/process/processAnimator.tsx
@@ -0,0 +1,416 @@
+import React, { useRef, useState, useEffect, useMemo } from "react";
+import { usePlayButtonStore } from "../../../store/usePlayButtonStore";
+import { GLTFLoader } from "three-stdlib";
+import { useLoader, useFrame } from "@react-three/fiber";
+import * as THREE from "three";
+import { GLTF } from "three-stdlib";
+import boxGltb from "../../../assets/gltf-glb/crate_box.glb";
+
+interface PointAction {
+ uuid: string;
+ name: string;
+ type: "Inherit" | "Spawn" | "Despawn" | "Delay" | "Swap";
+ material: string;
+ delay: string | number;
+ spawnInterval: string | number;
+ isUsed: boolean;
+}
+
+interface ProcessPoint {
+ uuid: string;
+ position: number[];
+ rotation: number[];
+ actions: PointAction[];
+ connections: {
+ source: { pathUUID: string; pointUUID: string };
+ targets: { pathUUID: string; pointUUID: string }[];
+ };
+}
+
+interface ProcessPath {
+ modeluuid: string;
+ modelName: string;
+ points: ProcessPoint[];
+ pathPosition: number[];
+ pathRotation: number[];
+ speed: number;
+}
+
+interface ProcessData {
+ id: string;
+ paths: ProcessPath[];
+ animationPath: { x: number; y: number; z: number }[];
+ pointActions: PointAction[][];
+ speed: number;
+}
+
+interface AnimationState {
+ currentIndex: number;
+ progress: number;
+ isAnimating: boolean;
+ speed: number;
+ isDelaying: boolean;
+ delayStartTime: number;
+ currentDelayDuration: number;
+ delayComplete: boolean;
+ currentPathIndex: number;
+ spawnPoints: Record<
+ string,
+ {
+ position: THREE.Vector3;
+ interval: number;
+ lastSpawnTime: number;
+ }
+ >;
+}
+
+const MAX_SPAWNED_OBJECTS = 20;
+
+const ProcessAnimator: React.FC<{ processes: ProcessData[] }> = ({
+ processes,
+}) => {
+ console.log("processes: ", processes);
+ const gltf = useLoader(GLTFLoader, boxGltb) as GLTF;
+ const { isPlaying, setIsPlaying } = usePlayButtonStore();
+
+ const groupRef = useRef
(null);
+ const meshRef = useRef(null);
+ const [visible, setVisible] = useState(false);
+ const spawnedObjectsRef = useRef([]);
+
+ const materials = useMemo(
+ () => ({
+ Wood: new THREE.MeshStandardMaterial({ color: 0x8b4513 }),
+ Box: new THREE.MeshStandardMaterial({
+ color: 0xcccccc,
+ metalness: 0.8,
+ roughness: 0.2,
+ }),
+ Crate: new THREE.MeshStandardMaterial({
+ color: 0x00aaff,
+ metalness: 0.1,
+ roughness: 0.5,
+ }),
+ Default: new THREE.MeshStandardMaterial({ color: 0x00ff00 }),
+ }),
+ []
+ );
+
+ const [currentMaterial, setCurrentMaterial] = useState(
+ materials.Default
+ );
+
+ const { animationPath, currentProcess } = useMemo(() => {
+ const defaultProcess = {
+ animationPath: [],
+ pointActions: [],
+ speed: 1,
+ paths: [],
+ };
+ const cp = processes?.[0] || defaultProcess;
+ return {
+ animationPath:
+ cp.animationPath?.map((p) => new THREE.Vector3(p.x, p.y, p.z)) || [],
+ currentProcess: cp,
+ };
+ }, [processes]);
+
+ const animationStateRef = useRef({
+ currentIndex: 0,
+ progress: 0,
+ isAnimating: false,
+ speed: currentProcess.speed,
+ isDelaying: false,
+ delayStartTime: 0,
+ currentDelayDuration: 0,
+ delayComplete: false,
+ currentPathIndex: 0,
+ spawnPoints: {},
+ });
+
+ const getPointDataForAnimationIndex = (index: number) => {
+ if (!processes[0]?.paths) return null;
+
+ if (index < 3) {
+ return processes[0].paths[0]?.points[index];
+ } else {
+ const path2Index = index - 3;
+ return processes[0].paths[1]?.points[path2Index];
+ }
+ };
+
+ useEffect(() => {
+ if (isPlaying) {
+ setVisible(true);
+ animationStateRef.current = {
+ currentIndex: 0,
+ progress: 0,
+ isAnimating: true,
+ speed: currentProcess.speed,
+ isDelaying: false,
+ delayStartTime: 0,
+ currentDelayDuration: 0,
+ delayComplete: false,
+ currentPathIndex: 0,
+ spawnPoints: {},
+ };
+
+ // Clear spawned objects
+ if (groupRef.current) {
+ spawnedObjectsRef.current.forEach((obj) => {
+ if (groupRef.current?.children.includes(obj)) {
+ groupRef.current.remove(obj);
+ }
+ if (obj instanceof THREE.Mesh) {
+ obj.material.dispose();
+ }
+ });
+ spawnedObjectsRef.current = [];
+ }
+
+ const currentRef = gltf?.scene ? groupRef.current : meshRef.current;
+ if (currentRef && animationPath.length > 0) {
+ currentRef.position.copy(animationPath[0]);
+ }
+ } else {
+ animationStateRef.current.isAnimating = false;
+ }
+ }, [isPlaying, currentProcess, animationPath]);
+
+ const handleMaterialSwap = (materialType: string) => {
+ const newMaterial =
+ materials[materialType as keyof typeof materials] || materials.Default;
+ setCurrentMaterial(newMaterial);
+
+ spawnedObjectsRef.current.forEach((obj) => {
+ if (obj instanceof THREE.Mesh) {
+ obj.material = newMaterial.clone();
+ }
+ });
+ };
+
+ const hasNonInheritActions = (actions: PointAction[] = []) => {
+ return actions.some((action) => action.isUsed && action.type !== "Inherit");
+ };
+
+ const handlePointActions = (
+ actions: PointAction[] = [],
+ currentTime: number,
+ currentPosition: THREE.Vector3
+ ) => {
+ let shouldStopAnimation = false;
+
+ actions.forEach((action) => {
+ if (!action.isUsed) return;
+
+ switch (action.type) {
+ case "Delay":
+ if (
+ !animationStateRef.current.isDelaying &&
+ !animationStateRef.current.delayComplete
+ ) {
+ const delayDuration =
+ typeof action.delay === "number"
+ ? action.delay
+ : parseFloat(action.delay as string) || 0;
+
+ if (delayDuration > 0) {
+ animationStateRef.current.isDelaying = true;
+ animationStateRef.current.delayStartTime = currentTime;
+ animationStateRef.current.currentDelayDuration = delayDuration;
+ shouldStopAnimation = true;
+ }
+ }
+ break;
+
+ case "Despawn":
+ setVisible(false);
+ setIsPlaying(false);
+ animationStateRef.current.isAnimating = false;
+ shouldStopAnimation = true;
+ break;
+
+ case "Spawn":
+ const spawnInterval =
+ typeof action.spawnInterval === "number"
+ ? action.spawnInterval
+ : parseFloat(action.spawnInterval as string) || 1;
+
+ const positionKey = currentPosition.toArray().join(",");
+
+ animationStateRef.current.spawnPoints[positionKey] = {
+ position: currentPosition.clone(),
+ interval: spawnInterval,
+ lastSpawnTime: currentTime - spawnInterval, // Force immediate spawn
+ };
+ break;
+
+ case "Swap":
+ if (action.material) {
+ handleMaterialSwap(action.material);
+ }
+ break;
+
+ case "Inherit":
+ break;
+ }
+ });
+
+ return shouldStopAnimation;
+ };
+
+ useFrame((state, delta) => {
+ const currentRef = gltf?.scene ? groupRef.current : meshRef.current;
+ if (
+ !currentRef ||
+ !animationStateRef.current.isAnimating ||
+ animationPath.length < 2
+ ) {
+ return;
+ }
+
+ const currentTime = state.clock.getElapsedTime();
+ const path = animationPath;
+ const stateRef = animationStateRef.current;
+
+ if (stateRef.currentIndex === 3 && stateRef.currentPathIndex === 0) {
+ stateRef.currentPathIndex = 1;
+ }
+
+ const currentPointData = getPointDataForAnimationIndex(
+ stateRef.currentIndex
+ );
+
+ if (stateRef.progress === 0 && currentPointData?.actions) {
+ const shouldStop = handlePointActions(
+ currentPointData.actions,
+ currentTime,
+ currentRef.position
+ );
+ if (shouldStop) return;
+ }
+
+ if (stateRef.isDelaying) {
+ if (
+ currentTime - stateRef.delayStartTime >=
+ stateRef.currentDelayDuration
+ ) {
+ stateRef.isDelaying = false;
+ stateRef.delayComplete = true;
+ } else {
+ return;
+ }
+ }
+
+ // Handle spawning - this is the key updated part
+ Object.entries(stateRef.spawnPoints).forEach(([key, spawnPoint]) => {
+ if (currentTime - spawnPoint.lastSpawnTime >= spawnPoint.interval) {
+ spawnPoint.lastSpawnTime = currentTime;
+
+ if (gltf?.scene && groupRef?.current) {
+ const newObject = gltf.scene.clone();
+ newObject.position.copy(spawnPoint.position);
+
+ newObject.traverse((child) => {
+ if (child instanceof THREE.Mesh) {
+ child.material = currentMaterial.clone();
+ }
+ });
+
+ groupRef.current.add(newObject);
+ spawnedObjectsRef.current.push(newObject);
+
+ // Clean up old objects if needed
+ console.log(
+ "spawnedObjectsRef.current.length: ",
+ spawnedObjectsRef.current.length
+ );
+ if (spawnedObjectsRef.current.length > MAX_SPAWNED_OBJECTS) {
+ const oldest = spawnedObjectsRef.current.shift();
+ if (oldest && groupRef.current.children.includes(oldest)) {
+ groupRef.current.remove(oldest);
+ if (oldest instanceof THREE.Mesh) {
+ oldest.material.dispose();
+ }
+ }
+ }
+ }
+ }
+ });
+
+ const nextPointIdx = stateRef.currentIndex + 1;
+ const isLastPoint = nextPointIdx >= path.length;
+
+ if (isLastPoint) {
+ if (currentPointData?.actions) {
+ const shouldStop = !hasNonInheritActions(currentPointData.actions);
+ if (shouldStop) {
+ currentRef.position.copy(path[stateRef.currentIndex]);
+ setIsPlaying(false);
+ stateRef.isAnimating = false;
+ return;
+ }
+ }
+ }
+
+ if (!isLastPoint) {
+ const nextPoint = path[nextPointIdx];
+ const distance = path[stateRef.currentIndex].distanceTo(nextPoint);
+ const movement = stateRef.speed * delta;
+ stateRef.progress += movement / distance;
+
+ if (stateRef.progress >= 1) {
+ stateRef.currentIndex = nextPointIdx;
+ stateRef.progress = 0;
+ stateRef.delayComplete = false;
+ currentRef.position.copy(nextPoint);
+ } else {
+ currentRef.position.lerpVectors(
+ path[stateRef.currentIndex],
+ nextPoint,
+ stateRef.progress
+ );
+ }
+ }
+ });
+
+ useEffect(() => {
+ return () => {
+ if (groupRef.current) {
+ spawnedObjectsRef.current.forEach((obj) => {
+ if (groupRef.current?.children.includes(obj)) {
+ groupRef.current.remove(obj);
+ }
+ if (obj instanceof THREE.Mesh) {
+ obj.material.dispose();
+ }
+ });
+ spawnedObjectsRef.current = [];
+ }
+ };
+ }, []);
+
+ if (!processes || processes.length === 0) {
+ return null;
+ }
+
+ if (!gltf?.scene) {
+ return visible ? (
+
+
+
+ ) : null;
+ }
+
+ return visible ? (
+
+
+
+ ) : null;
+};
+
+export default ProcessAnimator;
diff --git a/app/src/modules/simulation/process/processContainer.tsx b/app/src/modules/simulation/process/processContainer.tsx
new file mode 100644
index 0000000..967376c
--- /dev/null
+++ b/app/src/modules/simulation/process/processContainer.tsx
@@ -0,0 +1,17 @@
+import React, { useState } from "react";
+import ProcessCreator from "./processCreator";
+import ProcessAnimator from "./processAnimator";
+
+const ProcessContainer: React.FC = () => {
+ const [processes, setProcesses] = useState([]);
+
+
+ return (
+ <>
+
+ {processes.length > 0 && }
+ >
+ );
+};
+
+export default ProcessContainer;
diff --git a/app/src/modules/simulation/process/processCreator.tsx b/app/src/modules/simulation/process/processCreator.tsx
new file mode 100644
index 0000000..8e1ed1d
--- /dev/null
+++ b/app/src/modules/simulation/process/processCreator.tsx
@@ -0,0 +1,398 @@
+import React, {
+ useEffect,
+ useMemo,
+ useState,
+ useCallback,
+ useRef,
+} from "react";
+import { useSimulationPaths } from "../../../store/store";
+import * as THREE from "three";
+import { useThree } from "@react-three/fiber";
+import {
+ ConveyorEventsSchema,
+ VehicleEventsSchema,
+} from "../../../types/world/worldTypes";
+
+// Type definitions
+export interface PointAction {
+ uuid: string;
+ name: string;
+ type: string;
+ material: string;
+ delay: number | string;
+ spawnInterval: string | number;
+ isUsed: boolean;
+}
+
+export interface PathPoint {
+ uuid: string;
+ position: [number, number, number];
+ actions: PointAction[];
+ connections: {
+ targets: Array<{ pathUUID: string }>;
+ };
+}
+
+export interface SimulationPath {
+ modeluuid: string;
+ points: PathPoint[];
+ pathPosition: [number, number, number];
+ speed?: number;
+}
+
+export interface Process {
+ id: string;
+ paths: SimulationPath[];
+ animationPath: THREE.Vector3[];
+ pointActions: PointAction[][];
+ speed: number;
+}
+
+interface ProcessCreatorProps {
+ onProcessesCreated: (processes: Process[]) => void;
+}
+
+// Convert event schemas to SimulationPath
+function convertToSimulationPath(
+ path: ConveyorEventsSchema | VehicleEventsSchema
+): SimulationPath {
+ const { modeluuid } = path;
+
+ // Simplified normalizeAction function that preserves exact original properties
+ const normalizeAction = (action: any): PointAction => {
+ return { ...action }; // Return exact copy with no modifications
+ };
+
+ if (path.type === "Conveyor") {
+ return {
+ modeluuid,
+ points: path.points.map((point) => ({
+ uuid: point.uuid,
+ position: point.position,
+ actions: point.actions.map(normalizeAction), // Preserve exact actions
+ connections: {
+ targets: point.connections.targets.map((target) => ({
+ pathUUID: target.pathUUID,
+ })),
+ },
+ })),
+ pathPosition: path.position,
+ speed:
+ typeof path.speed === "string"
+ ? parseFloat(path.speed) || 1
+ : path.speed || 1,
+ };
+ } else {
+ return {
+ modeluuid,
+ points: [
+ {
+ uuid: path.point.uuid,
+ position: path.point.position,
+ actions: Array.isArray(path.point.actions)
+ ? path.point.actions.map(normalizeAction)
+ : [normalizeAction(path.point.actions)],
+ connections: {
+ targets: path.point.connections.targets.map((target) => ({
+ pathUUID: target.pathUUID,
+ })),
+ },
+ },
+ ],
+ pathPosition: path.position,
+ speed: path.point.speed || 1,
+ };
+ }
+}
+
+// Custom shallow comparison for arrays
+const areArraysEqual = (a: any[], b: any[]) => {
+ if (a.length !== b.length) return false;
+ for (let i = 0; i < a.length; i++) {
+ if (a[i] !== b[i]) return false;
+ }
+ return true;
+};
+
+// Helper function to create an empty process
+const createEmptyProcess = (): Process => ({
+ id: `process-${Math.random().toString(36).substring(2, 11)}`,
+ paths: [],
+ animationPath: [],
+ pointActions: [],
+ speed: 1,
+});
+
+// Enhanced connection checking function
+function shouldReverseNextPath(
+ currentPath: SimulationPath,
+ nextPath: SimulationPath
+): boolean {
+ if (nextPath.points.length !== 3) return false;
+
+ const currentLastPoint = currentPath.points[currentPath.points.length - 1];
+ const nextFirstPoint = nextPath.points[0];
+ const nextLastPoint = nextPath.points[nextPath.points.length - 1];
+
+ // Check if current last connects to next last (requires reversal)
+ const connectsToLast = currentLastPoint.connections.targets.some(
+ (target) =>
+ target.pathUUID === nextPath.modeluuid &&
+ nextLastPoint.connections.targets.some(
+ (t) => t.pathUUID === currentPath.modeluuid
+ )
+ );
+
+ // Check if current last connects to next first (no reversal needed)
+ const connectsToFirst = currentLastPoint.connections.targets.some(
+ (target) =>
+ target.pathUUID === nextPath.modeluuid &&
+ nextFirstPoint.connections.targets.some(
+ (t) => t.pathUUID === currentPath.modeluuid
+ )
+ );
+
+ // Only reverse if connected to last point and not to first point
+ return connectsToLast && !connectsToFirst;
+}
+
+// Updated path adjustment function
+function adjustPathPointsOrder(paths: SimulationPath[]): SimulationPath[] {
+ if (paths.length < 2) return paths;
+
+ const adjustedPaths = [...paths];
+
+ for (let i = 0; i < adjustedPaths.length - 1; i++) {
+ const currentPath = adjustedPaths[i];
+ const nextPath = adjustedPaths[i + 1];
+
+ if (shouldReverseNextPath(currentPath, nextPath)) {
+ const reversedPoints = [
+ nextPath.points[2],
+ nextPath.points[1],
+ nextPath.points[0],
+ ];
+
+ adjustedPaths[i + 1] = {
+ ...nextPath,
+ points: reversedPoints,
+ };
+ }
+ }
+
+ return adjustedPaths;
+}
+
+// Main hook for process creation
+export function useProcessCreation() {
+ const { scene } = useThree();
+ const [processes, setProcesses] = useState([]);
+
+ const hasSpawnAction = useCallback((path: SimulationPath): boolean => {
+ return path.points.some((point) =>
+ point.actions.some((action) => action.type.toLowerCase() === "spawn")
+ );
+ }, []);
+
+ const createProcess = useCallback(
+ (paths: SimulationPath[]): Process => {
+ if (!paths || paths.length === 0) {
+ return createEmptyProcess();
+ }
+
+ const animationPath: THREE.Vector3[] = [];
+ const pointActions: PointAction[][] = [];
+ const processSpeed = paths[0]?.speed || 1;
+
+ for (const path of paths) {
+ for (const point of path.points) {
+ const obj = scene.getObjectByProperty("uuid", point.uuid);
+ if (!obj) {
+ console.warn(`Object with UUID ${point.uuid} not found in scene`);
+ continue;
+ }
+
+ const position = obj.getWorldPosition(new THREE.Vector3());
+ animationPath.push(position.clone());
+ pointActions.push(point.actions);
+ }
+ }
+
+ return {
+ id: `process-${Math.random().toString(36).substring(2, 11)}`,
+ paths,
+ animationPath,
+ pointActions,
+ speed: processSpeed,
+ };
+ },
+ [scene]
+ );
+
+ const getAllConnectedPaths = useCallback(
+ (
+ initialPath: SimulationPath,
+ allPaths: SimulationPath[],
+ visited: Set = new Set()
+ ): SimulationPath[] => {
+ const connectedPaths: SimulationPath[] = [];
+ const queue: SimulationPath[] = [initialPath];
+ visited.add(initialPath.modeluuid);
+
+ const pathMap = new Map();
+ allPaths.forEach((path) => pathMap.set(path.modeluuid, path));
+
+ while (queue.length > 0) {
+ const currentPath = queue.shift()!;
+ connectedPaths.push(currentPath);
+
+ // Process outgoing connections
+ for (const point of currentPath.points) {
+ for (const target of point.connections.targets) {
+ if (!visited.has(target.pathUUID)) {
+ const targetPath = pathMap.get(target.pathUUID);
+ if (targetPath) {
+ visited.add(target.pathUUID);
+ queue.push(targetPath);
+ }
+ }
+ }
+ }
+
+ // Process incoming connections
+ for (const [uuid, path] of pathMap) {
+ if (!visited.has(uuid)) {
+ const hasConnectionToCurrent = path.points.some((point) =>
+ point.connections.targets.some(
+ (t) => t.pathUUID === currentPath.modeluuid
+ )
+ );
+ if (hasConnectionToCurrent) {
+ visited.add(uuid);
+ queue.push(path);
+ }
+ }
+ }
+ }
+
+ return connectedPaths;
+ },
+ []
+ );
+
+ const createProcessesFromPaths = useCallback(
+ (paths: SimulationPath[]): Process[] => {
+ if (!paths || paths.length === 0) return [];
+
+ const visited = new Set();
+ const processes: Process[] = [];
+ const pathMap = new Map();
+ paths.forEach((path) => pathMap.set(path.modeluuid, path));
+
+ for (const path of paths) {
+ if (!visited.has(path.modeluuid) && hasSpawnAction(path)) {
+ const connectedPaths = getAllConnectedPaths(path, paths, visited);
+ const adjustedPaths = adjustPathPointsOrder(connectedPaths);
+ const process = createProcess(adjustedPaths);
+ processes.push(process);
+ }
+ }
+
+ return processes;
+ },
+ [createProcess, getAllConnectedPaths, hasSpawnAction]
+ );
+
+ return {
+ processes,
+ createProcessesFromPaths,
+ setProcesses,
+ };
+}
+
+const ProcessCreator: React.FC = React.memo(
+ ({ onProcessesCreated }) => {
+ const { simulationPaths } = useSimulationPaths();
+ const { createProcessesFromPaths } = useProcessCreation();
+ const prevPathsRef = useRef([]);
+ const prevProcessesRef = useRef([]);
+
+ const convertedPaths = useMemo((): SimulationPath[] => {
+ if (!simulationPaths) return [];
+ return simulationPaths.map((path) =>
+ convertToSimulationPath(
+ path as ConveyorEventsSchema | VehicleEventsSchema
+ )
+ );
+ }, [simulationPaths]);
+
+ const pathsDependency = useMemo(() => {
+ if (!convertedPaths) return null;
+ return convertedPaths.map((path) => ({
+ id: path.modeluuid,
+ hasSpawn: path.points.some((p: PathPoint) =>
+ p.actions.some((a: PointAction) => a.type.toLowerCase() === "spawn")
+ ),
+ connections: path.points
+ .flatMap((p: PathPoint) =>
+ p.connections.targets.map((t: { pathUUID: string }) => t.pathUUID)
+ )
+ .join(","),
+ }));
+ }, [convertedPaths]);
+
+ useEffect(() => {
+ if (!convertedPaths || convertedPaths.length === 0) {
+ if (prevProcessesRef.current.length > 0) {
+ onProcessesCreated([]);
+ prevProcessesRef.current = [];
+ }
+ return;
+ }
+
+ if (areArraysEqual(prevPathsRef.current, convertedPaths)) {
+ return;
+ }
+
+ prevPathsRef.current = convertedPaths;
+ const newProcesses = createProcessesFromPaths(convertedPaths);
+
+ // console.log("--- Action Types in Paths ---");
+ // convertedPaths.forEach((path) => {
+ // path.points.forEach((point) => {
+ // point.actions.forEach((action) => {
+ // console.log(
+ // `Path ${path.modeluuid}, Point ${point.uuid}: ${action.type}`
+ // );
+ // });
+ // });
+ // });
+ // console.log("New processes:", newProcesses);
+
+ if (
+ newProcesses.length !== prevProcessesRef.current.length ||
+ !newProcesses.every(
+ (proc, i) =>
+ proc.paths.length === prevProcessesRef.current[i]?.paths.length &&
+ proc.paths.every(
+ (path, j) =>
+ path.modeluuid ===
+ prevProcessesRef.current[i]?.paths[j]?.modeluuid
+ )
+ )
+ ) {
+ onProcessesCreated(newProcesses);
+ // prevProcessesRef.current = newProcesses;
+ }
+ }, [
+ pathsDependency,
+ onProcessesCreated,
+ convertedPaths,
+ createProcessesFromPaths,
+ ]);
+
+ return null;
+ }
+);
+
+export default ProcessCreator;
diff --git a/app/src/modules/simulation/simulation.tsx b/app/src/modules/simulation/simulation.tsx
index 739a92b..0212d50 100644
--- a/app/src/modules/simulation/simulation.tsx
+++ b/app/src/modules/simulation/simulation.tsx
@@ -5,6 +5,7 @@ import Behaviour from './behaviour/behaviour';
import PathCreation from './path/pathCreation';
import PathConnector from './path/pathConnector';
import useModuleStore from '../../store/useModuleStore';
+import ProcessContainer from './process/processContainer';
function Simulation() {
const { activeModule } = useModuleStore();
@@ -13,6 +14,7 @@ function Simulation() {
const [processes, setProcesses] = useState([]);
useEffect(() => {
+ // console.log('simulationPaths: ', simulationPaths);
}, [simulationPaths]);
// useEffect(() => {
@@ -35,6 +37,7 @@ function Simulation() {
<>
+
>
)}
>
diff --git a/app/src/services/factoryBuilder/assest/assets/getCategoryAsset.ts b/app/src/services/factoryBuilder/assest/assets/getCategoryAsset.ts
index 522e54c..a1ac727 100644
--- a/app/src/services/factoryBuilder/assest/assets/getCategoryAsset.ts
+++ b/app/src/services/factoryBuilder/assest/assets/getCategoryAsset.ts
@@ -1,4 +1,4 @@
-let BackEnd_url = `http://${process.env.REACT_APP_SERVER_MARKETPLACE_URL}`;
+let BackEnd_url = `http://${process.env.REACT_APP_SERVER_ASSET_LIBRARY_URL}`;
export const getCategoryAsset = async (categoryName: any) => {
try {
const response = await fetch(
diff --git a/app/src/services/factoryBuilder/assest/floorAsset/getFloorItemsApi.ts b/app/src/services/factoryBuilder/assest/floorAsset/getFloorItemsApi.ts
index efe98fc..7a0290a 100644
--- a/app/src/services/factoryBuilder/assest/floorAsset/getFloorItemsApi.ts
+++ b/app/src/services/factoryBuilder/assest/floorAsset/getFloorItemsApi.ts
@@ -1,8 +1,8 @@
let url_Backend_dwinzo = `http://${process.env.REACT_APP_SERVER_REST_API_BASE_URL}`;
-export const getFloorItems = async (organization: string) => {
+export const getFloorAssets = async (organization: string) => {
try {
- const response = await fetch(`${url_Backend_dwinzo}/api/v1/findfloorItems/${organization}`, {
+ const response = await fetch(`${url_Backend_dwinzo}/api/v2/floorAssets/${organization}`, {
method: "GET",
headers: {
"Content-Type": "application/json",
@@ -10,7 +10,7 @@ export const getFloorItems = async (organization: string) => {
});
if (!response.ok) {
- throw new Error("Failed to get Floor Items");
+ throw new Error("Failed to get assets");
}
const result = await response.json();
diff --git a/app/src/services/factoryBuilder/assest/floorAsset/setFloorItemApi.ts b/app/src/services/factoryBuilder/assest/floorAsset/setFloorItemApi.ts
index f6cd496..75583cc 100644
--- a/app/src/services/factoryBuilder/assest/floorAsset/setFloorItemApi.ts
+++ b/app/src/services/factoryBuilder/assest/floorAsset/setFloorItemApi.ts
@@ -1,4 +1,4 @@
-let url_Backend_dwinzo = `http://${process.env.REACT_APP_TEST}`;
+let url_Backend_dwinzo = `http://${process.env.REACT_APP_SERVER_REST_API_BASE_URL}`;
export const setFloorItemApi = async (
organization: string,
diff --git a/app/src/services/simulation/getAssetEventType.ts b/app/src/services/simulation/getAssetEventType.ts
index a681b12..84433ec 100644
--- a/app/src/services/simulation/getAssetEventType.ts
+++ b/app/src/services/simulation/getAssetEventType.ts
@@ -1,4 +1,4 @@
-let url_Backend_dwinzo = `http://${process.env.REACT_APP_TEST}`;
+let url_Backend_dwinzo = `http://${process.env.REACT_APP_SERVER_REST_API_BASE_URL}`;
export const getAssetEventType = async (modelId: string, organization: string) => {
try {
diff --git a/app/src/types/world/worldTypes.d.ts b/app/src/types/world/worldTypes.d.ts
index 4d10a36..d1ce13f 100644
--- a/app/src/types/world/worldTypes.d.ts
+++ b/app/src/types/world/worldTypes.d.ts
@@ -319,8 +319,8 @@ interface ConveyorEventsSchema {
triggers: { uuid: string; name: string; type: string; isUsed: boolean; bufferTime: number }[] | [];
connections: { source: { pathUUID: string; pointUUID: string }; targets: { pathUUID: string; pointUUID: string }[] };
}[];
- assetPosition: [number, number, number];
- assetRotation: [number, number, number];
+ position: [number, number, number];
+ rotation: [number, number, number];
speed: number | string;
}
@@ -335,5 +335,5 @@ interface VehicleEventsSchema {
connections: { source: { pathUUID: string; pointUUID: string }; targets: { pathUUID: string; pointUUID: string }[] };
speed: number;
};
- assetPosition: [number, number, number];
+ position: [number, number, number];
}
\ No newline at end of file
diff --git a/app/src/utils/theme.ts b/app/src/utils/theme.ts
index 754904b..9395129 100644
--- a/app/src/utils/theme.ts
+++ b/app/src/utils/theme.ts
@@ -18,5 +18,4 @@ export function toggleTheme() {
localStorage.setItem('theme', newTheme);
}
-// Initialize theme on page load
setTheme();