decentralised sync engine
refactor: clean up from old project
-75
-11
src/lib/utils.ts
-11
src/lib/utils.ts
···
1
-
import type { RawData } from "ws";
2
-
3
-
export const rawDataToString = (data: RawData): string => {
4
-
if (Buffer.isBuffer(data)) {
5
-
return data.toString("utf-8");
6
-
}
7
-
if (Array.isArray(data)) {
8
-
return Buffer.concat(data).toString("utf-8");
9
-
}
10
-
return new TextDecoder().decode(data);
11
-
};
-64
src/lib/validators.ts
-64
src/lib/validators.ts
···
1
-
import {
2
-
historyMessageSchema,
3
-
shardMessageSchema,
4
-
websocketMessageSchema,
5
-
} from "@/lib/types/messages";
6
-
import { z } from "zod";
7
-
8
-
export const validateWsMessageString = (data: unknown) => {
9
-
const { success, error, data: message } = z.string().safeParse(data);
10
-
if (!success) {
11
-
console.error("Error decoding websocket message");
12
-
console.error(error);
13
-
return;
14
-
}
15
-
return message;
16
-
};
17
-
18
-
export const validateWsMessageType = (data: unknown) => {
19
-
const {
20
-
success: wsMessageSuccess,
21
-
error: wsMessageError,
22
-
data: wsMessage,
23
-
} = websocketMessageSchema.loose().safeParse(data);
24
-
if (!wsMessageSuccess) {
25
-
console.error(
26
-
"Error parsing websocket message. The data might be the wrong shape.",
27
-
);
28
-
console.error(wsMessageError);
29
-
return;
30
-
}
31
-
return wsMessage;
32
-
};
33
-
34
-
export const validateHistoryMessage = (data: unknown) => {
35
-
const {
36
-
success: historySuccess,
37
-
error: historyError,
38
-
data: history,
39
-
} = historyMessageSchema.safeParse(data);
40
-
if (!historySuccess) {
41
-
console.error(
42
-
"History message schema parsing failed. Did your type drift?",
43
-
);
44
-
console.error(historyError);
45
-
return;
46
-
}
47
-
return history;
48
-
};
49
-
50
-
export const validateNewMessage = (data: unknown) => {
51
-
const {
52
-
success: messageSuccess,
53
-
error: messageError,
54
-
data: message,
55
-
} = shardMessageSchema.safeParse(data);
56
-
if (!messageSuccess) {
57
-
console.error(
58
-
"New message schema parsing failed. Did your type drift?",
59
-
);
60
-
console.error(messageError);
61
-
return;
62
-
}
63
-
return message;
64
-
};