Refactor TypeGuard implementation and tests; remove unused TypeGuard and update RedisGuard error handling

Author: SevenWaysDP

src/infra/redis/guards/index.ts

@@ -1,2 +1 @@
 export { RedisGuard } from './redis.guard.js';
-export { TypeGuard } from './type.guard.js';

src/infra/redis/guards/redis.guard.ts

@@ -1,5 +1,5 @@
+import { TypeGuard } from '../../../shared/guard/type.guard.js';
 import { XItem, XItems } from '../interfaces/index.js';
-import { TypeGuard } from './type.guard.js';
 
 export class RedisGuard {
 	public static isXItem(value: unknown): value is XItem {
@@ -19,7 +19,7 @@ export class RedisGuard {
 
 	public static checkXItem(value: unknown): XItem {
 		if (!this.isXItem(value)) {
-			throw new Error('Value is not a XItem.');
+			throw new TypeError('Value is not a XItem.');
 		}
 
 		return value;
@@ -35,7 +35,7 @@ export class RedisGuard {
 
 	public static checkXItems(value: unknown): XItems {
 		if (!this.isXItems(value)) {
-			throw new Error('One of the values is not an xItem.');
+			throw new TypeError('One of the values is not an xItem.');
 		}
 
 		return value;

src/infra/redis/guards/type.guard.spec.ts

@@ -1,4 +1,3 @@
-export { TypeGuard } from './guards/type.guard.js';
 export {
 	RedisAdapter,
 	StreamMessageReply,

src/infra/redis/guards/type.guard.ts

@@ -1,4 +1,5 @@
-import { RedisGuard, TypeGuard } from './guards/index.js';
+import { TypeGuard } from '../../shared/guard/type.guard.js';
+import { RedisGuard } from './guards/index.js';
 import {
 	Compact,
 	DocName,
@@ -17,7 +18,7 @@ export function mapToXAutoClaimResponse(value: unknown): XAutoClaimResponse {
 		return { nextId: '', messages: null };
 	}
 
-	const unknownArray = TypeGuard.checkUnknownArrayWithElements(value);
+	const unknownArray = TypeGuard.checkArrayWithElements(value);
 	const xItems = RedisGuard.checkXItems(unknownArray[1]);
 	const redisKey = TypeGuard.isString(unknownArray[0])
 		? TypeGuard.checkString(unknownArray[0])
@@ -49,10 +50,10 @@ export function mapToStreamMessagesReply(streamReply: XReadBufferReply | unknown
 		return [];
 	}
 
-	const unknownArray = TypeGuard.checkUnknownArrayWithElements(streamReply);
+	const unknownArray = TypeGuard.checkArrayWithElements(streamReply);
 
 	const result = unknownArray.map((entry) => {
-		const entryArray = TypeGuard.checkUnknownArrayWithElements(entry);
+		const entryArray = TypeGuard.checkArrayWithElements(entry);
 		const key = TypeGuard.checkBuffer(entryArray[0]);
 		const messages = RedisGuard.checkXItems(entryArray[1]);
 

src/infra/redis/index.ts

@@ -1,6 +1,7 @@
 import { RedisKey } from 'ioredis';
 import { array, map } from 'lib0';
-import { StreamMessageReply, StreamMessagesReply, TypeGuard } from '../../infra/redis/index.js';
+import { StreamMessageReply, StreamMessagesReply } from '../../infra/redis/index.js';
+import { TypeGuard } from '../../shared/guard/type.guard.js';
 import { YRedisMessage } from './interfaces/stream-message.js';
 
 /* This file contains the implementation of the functions,