Merge branch 'main' into furnisettingeditor-pr

packages/communication/src/messages/incoming/IncomingHeader.ts

@@ -181,6 +181,7 @@ export class IncomingHeader
     public static ROOM_RIGHTS_LIST_REMOVE = 1327;
     public static ROOM_RIGHTS_OWNER = 339;
     public static ROOM_ROLLING = 3207;
+    public static WIRED_MOVEMENTS = 3999;
     public static ROOM_SCORE = 482;
     public static ROOM_SETTINGS = 1498;
     public static ROOM_SETTINGS_CHAT = 1191;

packages/communication/src/messages/incoming/room/engine/WiredMovementsEvent.ts

@@ -0,0 +1,16 @@
+import { IMessageEvent } from '@nitrots/api';
+import { MessageEvent } from '@nitrots/events';
+import { WiredMovementsParser } from '../../../parser';
+
+export class WiredMovementsEvent extends MessageEvent implements IMessageEvent
+{
+    constructor(callBack: Function)
+    {
+        super(callBack, WiredMovementsParser);
+    }
+
+    public getParser(): WiredMovementsParser
+    {
+        return this.parser as WiredMovementsParser;
+    }
+}

packages/communication/src/messages/incoming/room/engine/index.ts

@@ -1,3 +1,4 @@
 export * from './FavoriteMembershipUpdateMessageEvent';
 export * from './ObjectsDataUpdateEvent';
 export * from './ObjectsRollingEvent';
+export * from './WiredMovementsEvent';

packages/communication/src/messages/parser/room/engine/WiredMovementsParser.ts

@@ -0,0 +1,240 @@
+import { IMessageDataWrapper, IMessageParser, ObjectRolling } from '@nitrots/api';
+import { Vector3d } from '@nitrots/utils';
+
+function parseLocaleFloat(value: string): number
+{
+    if(!value) return 0;
+
+    return parseFloat(value.replace(',', '.'));
+}
+
+function parseDirection(value: number): number
+{
+    return ((((value % 8) + 8) % 8) * 45);
+}
+
+export class WiredUserMovementData extends ObjectRolling
+{
+    constructor(id: number, location: Vector3d, targetLocation: Vector3d, movementType: string, private _bodyDirection: number, private _headDirection: number, private _duration: number)
+    {
+        super(id, location, targetLocation, movementType);
+    }
+
+    public get bodyDirection(): number
+    {
+        return this._bodyDirection;
+    }
+
+    public get headDirection(): number
+    {
+        return this._headDirection;
+    }
+
+    public get duration(): number
+    {
+        return this._duration;
+    }
+}
+
+export class WiredFurniMovementData extends ObjectRolling
+{
+    constructor(id: number, location: Vector3d, targetLocation: Vector3d, private _rotation: number, private _duration: number)
+    {
+        super(id, location, targetLocation, ObjectRolling.SLIDE);
+    }
+
+    public get rotation(): number
+    {
+        return this._rotation;
+    }
+
+    public get duration(): number
+    {
+        return this._duration;
+    }
+}
+
+export class WiredWallItemMovementData
+{
+    constructor(private _id: number, private _enabled: boolean, private _values: number[])
+    {
+    }
+
+    public get id(): number
+    {
+        return this._id;
+    }
+
+    public get enabled(): boolean
+    {
+        return this._enabled;
+    }
+
+    public get values(): number[]
+    {
+        return this._values;
+    }
+}
+
+export class WiredUserDirectionUpdateData
+{
+    constructor(private _id: number, private _headDirection: number, private _bodyDirection: number)
+    {
+    }
+
+    public get id(): number
+    {
+        return this._id;
+    }
+
+    public get headDirection(): number
+    {
+        return this._headDirection;
+    }
+
+    public get bodyDirection(): number
+    {
+        return this._bodyDirection;
+    }
+}
+
+export class WiredMovementsParser implements IMessageParser
+{
+    private _furniMovements: WiredFurniMovementData[];
+    private _userMovements: WiredUserMovementData[];
+    private _wallItemMovements: WiredWallItemMovementData[];
+    private _userDirectionUpdates: WiredUserDirectionUpdateData[];
+
+    public flush(): boolean
+    {
+        this._furniMovements = [];
+        this._userMovements = [];
+        this._wallItemMovements = [];
+        this._userDirectionUpdates = [];
+
+        return true;
+    }
+
+    public parse(wrapper: IMessageDataWrapper): boolean
+    {
+        if(!wrapper) return false;
+
+        let totalMovements = wrapper.readInt();
+
+        while(totalMovements > 0)
+        {
+            const type = wrapper.readInt();
+
+            switch(type)
+            {
+                case 0:
+                {
+                    const fromX = wrapper.readInt();
+                    const fromY = wrapper.readInt();
+                    const toX = wrapper.readInt();
+                    const toY = wrapper.readInt();
+                    const fromZ = parseLocaleFloat(wrapper.readString());
+                    const toZ = parseLocaleFloat(wrapper.readString());
+                    const id = wrapper.readInt();
+                    const animationType = wrapper.readInt();
+                    const bodyDirection = parseDirection(wrapper.readInt());
+                    const headDirection = parseDirection(wrapper.readInt());
+                    const duration = wrapper.readInt();
+                    const movementType = (animationType === 0) ? ObjectRolling.MOVE : ObjectRolling.SLIDE;
+
+                    this._userMovements.push(new WiredUserMovementData(
+                        id,
+                        new Vector3d(fromX, fromY, fromZ),
+                        new Vector3d(toX, toY, toZ),
+                        movementType,
+                        bodyDirection,
+                        headDirection,
+                        duration));
+                    break;
+                }
+                case 1:
+                {
+                    const fromX = wrapper.readInt();
+                    const fromY = wrapper.readInt();
+                    const toX = wrapper.readInt();
+                    const toY = wrapper.readInt();
+                    const fromZ = parseLocaleFloat(wrapper.readString());
+                    const toZ = parseLocaleFloat(wrapper.readString());
+                    const id = wrapper.readInt();
+                    const rotation = wrapper.readInt();
+                    const duration = wrapper.readInt();
+
+                    this._furniMovements.push(new WiredFurniMovementData(
+                        id,
+                        new Vector3d(fromX, fromY, fromZ),
+                        new Vector3d(toX, toY, toZ),
+                        rotation,
+                        duration));
+                    break;
+                }
+                case 2:
+                {
+                    const id = wrapper.readInt();
+                    const enabled = wrapper.readBoolean();
+                    const values: number[] = [];
+
+                    let index = 0;
+
+                    while(index < 9)
+                    {
+                        values.push(wrapper.readInt());
+                        index++;
+                    }
+
+                    this._wallItemMovements.push(new WiredWallItemMovementData(id, enabled, values));
+                    break;
+                }
+                case 3:
+                {
+                    const id = wrapper.readInt();
+                    const headDirection = parseDirection(wrapper.readInt());
+                    const bodyDirection = parseDirection(wrapper.readInt());
+
+                    this._userDirectionUpdates.push(new WiredUserDirectionUpdateData(id, headDirection, bodyDirection));
+                    break;
+                }
+                default:
+                    return false;
+            }
+
+            totalMovements--;
+        }
+
+        return true;
+    }
+
+    public get itemMovements(): WiredFurniMovementData[]
+    {
+        return this._furniMovements;
+    }
+
+    public get unitMovements(): WiredUserMovementData[]
+    {
+        return this._userMovements;
+    }
+
+    public get furniMovements(): WiredFurniMovementData[]
+    {
+        return this._furniMovements;
+    }
+
+    public get userMovements(): WiredUserMovementData[]
+    {
+        return this._userMovements;
+    }
+
+    public get wallItemMovements(): WiredWallItemMovementData[]
+    {
+        return this._wallItemMovements;
+    }
+
+    public get userDirectionUpdates(): WiredUserDirectionUpdateData[]
+    {
+        return this._userDirectionUpdates;
+    }
+}

packages/communication/src/messages/parser/room/engine/index.ts

@@ -3,3 +3,4 @@ export * from './FavoriteMembershipUpdateMessageParser';
 export * from './ObjectData';
 export * from './ObjectsDataUpdateParser';
 export * from './ObjectsRollingParser';
+export * from './WiredMovementsParser';