change streamInfo lastElement to lastId

th2-net · May 13, 2022 · 3fe0ddc · 3fe0ddc
1 parent f1f223f
commit 3fe0ddc
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/src/helpers/streamInfo.ts b/src/helpers/streamInfo.ts
@@ -16,8 +16,8 @@
 
 import { StreamInfo } from '../models/StreamInfo';
 
-export const extractMessageId = ({ lastElement }: StreamInfo) => {
-	return lastElement;
+export const extractMessageId = ({ lastId }: StreamInfo) => {
+	return `${lastId.streamName}:${lastId.direction.toLowerCase()}:${lastId.index}`;
 };
 
 export const extractMessageIds = (streamInfoList: StreamInfo[]) =>

diff --git a/src/models/StreamInfo.ts b/src/models/StreamInfo.ts
@@ -21,7 +21,11 @@ export type StreamInfo = {
 		name: string;
 		direction: StreamDirection;
 	};
-	lastElement: string;
+	lastId: {
+		streamName: string;
+		direction: string;
+		index: number;
+	};
 };
 
 export type DirectionalStreamInfo = {