diff --git a/packages/restapi/src/lib/pushstream/DataModifier.ts b/packages/restapi/src/lib/pushstream/DataModifier.ts index 3dc62a9c6..efcaf2149 100644 --- a/packages/restapi/src/lib/pushstream/DataModifier.ts +++ b/packages/restapi/src/lib/pushstream/DataModifier.ts @@ -57,7 +57,7 @@ export class DataModifier { ): JoinGroupEvent { const baseEventData: JoinGroupEvent = { origin: data.messageOrigin, - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, chatId: data.chatId, from: data.from, to: data.to, @@ -78,7 +78,7 @@ export class DataModifier { ): LeaveGroupEvent { const baseEventData: LeaveGroupEvent = { origin: data.messageOrigin, - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, chatId: data.chatId, from: data.from, to: data.to, @@ -96,7 +96,7 @@ export class DataModifier { private static mapToRequestEvent(data: any, includeRaw: boolean): any { const eventData: RequestEvent = { origin: data.messageOrigin, - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, chatId: data.chatId, from: data.from, to: data.to, @@ -116,7 +116,7 @@ export class DataModifier { // Whatever the structure of your RemoveEvent, modify accordingly const eventData: RemoveEvent = { origin: data.messageOrigin, - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, chatId: data.chatId, from: data.from, to: data.to, @@ -133,7 +133,7 @@ export class DataModifier { // Whatever the structure of your RemoveEvent, modify accordingly const eventData: RoleEvent = { origin: data.messageOrigin, - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, chatId: data.chatId, from: data.from, to: data.to, @@ -186,7 +186,7 @@ export class DataModifier { const groupEvent: any = { event: eventType, origin: incomingData.messageOrigin, - timestamp: incomingData.timestamp.toString(), + timestamp: incomingData.timestamp, chatId: incomingData.chatId, from: incomingData.from, meta, @@ -233,7 +233,7 @@ export class DataModifier { const messageEvent: MessageEvent = { event: eventType, origin: data.messageOrigin, - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, chatId: data.chatId, // TODO: ChatId not working for w2w from: data.fromCAIP10, to: [data.toCAIP10], // TODO: Assuming 'to' is an array in MessageEvent. Update as necessary. @@ -330,7 +330,7 @@ export class DataModifier { const notificationEvent: NotificationEvent = { event: notificationEventType, origin: origin, - timestamp: data.epoch.toString(), + timestamp: data.epoch, from: data.sender, to: recipients, notifID: data.payload_id.toString(), @@ -496,7 +496,7 @@ export class DataModifier { type BaseEventData = { event: string; origin: string; - timestamp: string; + timestamp: number; spaceId: string; from: string; meta: { @@ -515,7 +515,7 @@ export class DataModifier { const baseEventData: BaseEventData = { event: data.eventType, origin: data.messageOrigin, - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, spaceId: data.spaceId, from: data.spaceCreator, meta: { @@ -541,7 +541,7 @@ export class DataModifier { type BaseEventData = { event: string; origin: string; - timestamp: string; + timestamp: number; spaceId: string; from: string; meta: { @@ -560,7 +560,7 @@ export class DataModifier { const baseEventData: BaseEventData = { event: data.eventType, origin: data.messageOrigin, - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, spaceId: data.spaceId, from: data.spaceCreator, meta: { @@ -585,7 +585,7 @@ export class DataModifier { private static mapToRequestSpaceEvent(data: any, includeRaw: boolean): any { const eventData: SpaceRequestEvent = { origin: data.messageOrigin, - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, spaceId: data.spaceId, from: data.from, to: data.to, @@ -602,7 +602,7 @@ export class DataModifier { type BaseEventData = { event: string; origin: string; - timestamp: any; + timestamp: number; spaceId: any; from: any; to: any[]; @@ -614,7 +614,7 @@ export class DataModifier { const baseEventData: BaseEventData = { event: 'request', origin: data.messageOrigin === 'other' ? 'self' : 'other', - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, spaceId: data.chatId, from: data.fromCAIP10, to: [data.toCAIP10], @@ -633,7 +633,7 @@ export class DataModifier { type BaseEventData = { event: string; origin: string; - timestamp: string; + timestamp: number; spaceId: string; from: string; to: null; @@ -645,7 +645,7 @@ export class DataModifier { const baseEventData: BaseEventData = { event: 'reject', origin: data.messageOrigin === 'other' ? 'other' : 'self', - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, spaceId: data.chatId, from: data.fromCAIP10, to: null, @@ -664,7 +664,7 @@ export class DataModifier { type BaseEventData = { event: string; origin: string; - timestamp: string; + timestamp: number; spaceId: string; from: string; to: null; @@ -675,7 +675,7 @@ export class DataModifier { const eventData: BaseEventData = { origin: data.messageOrigin, - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, spaceId: data.spaceId, from: data.from, to: data.to, @@ -692,7 +692,7 @@ export class DataModifier { type BaseEventData = { event: string; origin: string; - timestamp: string; + timestamp: number; spaceId: string; from: string; to: null; @@ -703,7 +703,7 @@ export class DataModifier { const eventData: BaseEventData = { origin: data.messageOrigin, - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, spaceId: data.spaceId, from: data.from, to: data.to, @@ -720,7 +720,7 @@ export class DataModifier { type BaseEventData = { event: string; origin: string; - timestamp: string; + timestamp: number; spaceId: string; from: string; to: null; @@ -731,7 +731,7 @@ export class DataModifier { const eventData: BaseEventData = { origin: data.messageOrigin, - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, spaceId: data.spaceId, from: data.from, to: data.to, @@ -748,7 +748,7 @@ export class DataModifier { type BaseEventData = { event: string; origin: string; - timestamp: string; + timestamp: number; spaceId: string; from: string; to: null; @@ -759,7 +759,7 @@ export class DataModifier { const eventData: BaseEventData = { origin: data.messageOrigin, - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, spaceId: data.spaceId, from: data.from, to: null, @@ -776,7 +776,7 @@ export class DataModifier { type BaseEventData = { event: string; origin: string; - timestamp: string; + timestamp: number; spaceId: string; from: string; to: null; @@ -787,7 +787,7 @@ export class DataModifier { const eventData: BaseEventData = { origin: data.messageOrigin, - timestamp: data.timestamp.toString(), + timestamp: data.timestamp, spaceId: data.spaceId, from: data.from, to: null, @@ -856,7 +856,7 @@ export class DataModifier { const videoEvent: VideoEvent = { event: videoEventType, origin: origin, - timestamp: data.epoch.toString(), + timestamp: data.epoch, peerInfo, }; diff --git a/packages/restapi/src/lib/pushstream/pushStreamTypes.ts b/packages/restapi/src/lib/pushstream/pushStreamTypes.ts index f9d2dddb6..2019aead0 100644 --- a/packages/restapi/src/lib/pushstream/pushStreamTypes.ts +++ b/packages/restapi/src/lib/pushstream/pushStreamTypes.ts @@ -132,7 +132,7 @@ export interface GroupEventRawData { export interface GroupEventBase { origin: MessageOrigin; - timestamp: string; + timestamp: number chatId: string; from: string; meta: GroupMeta; @@ -151,7 +151,7 @@ export interface UpdateGroupEvent extends GroupEventBase { export interface GroupMemberEventBase { event: GroupEventType | MessageEventType; origin: MessageOrigin; - timestamp: string; + timestamp: number chatId: string; from: string; to: string[]; @@ -185,7 +185,7 @@ export interface RoleEvent extends GroupMemberEventBase { export interface SpaceMemberEventBase { event: SpaceEventType | MessageEventType; origin: MessageOrigin; - timestamp: string; + timestamp: number spaceId: string; from: string; to: string[]; @@ -211,7 +211,7 @@ export interface SpaceRemoveEvent extends SpaceMemberEventBase { export interface MessageEvent { event: MessageEventType; origin: MessageOrigin; - timestamp: string; + timestamp: number chatId: string; from: string; to: string[]; @@ -239,7 +239,7 @@ export type NotificationType = keyof typeof NOTIFICATION.TYPE; export interface NotificationEvent { event: NotificationEventType; origin: 'other' | 'self'; - timestamp: string; + timestamp: number from: string; to: string[]; notifID: string; @@ -298,7 +298,7 @@ export interface MessageRawData { export interface VideoEvent { event: VideoEventType; origin: MessageOrigin; - timestamp: string; + timestamp: number peerInfo: VideoPeerInfo; raw?: GroupEventRawData; }