mpackdb

1.1 KB

1. import { pack, unpack } from 'msgpackr';
3. /**
4. * Serialize object to MessagePack with 4-byte length prefix
5. * Format: [4-byte LE size][MessagePack data]
6. */
7. export function serialize(obj) {
8. const msgpackData = pack(obj);
9. const totalSize = 4 + msgpackData.length;
10. const buffer = Buffer.allocUnsafe(totalSize);
12. // Write 4-byte length prefix (little-endian)
13. buffer.writeInt32LE(totalSize, 0);
15. // Copy MessagePack data after the length prefix
16. msgpackData.copy(buffer, 4);
18. return buffer;
19. }
21. /**
22. * Deserialize MessagePack data (expects data WITHOUT length prefix)
23. */
24. export function deserialize(buffer) {
25. return unpack(buffer);
26. }
28. /**
29. * Read size from buffer (first 4 bytes)
30. */
31. export function readSize(buffer) {
32. return buffer.readInt32LE(0);
33. }
35. /**
36. * Sortable unique ID generator: 9-char base36 timestamp + 3-char base36 random
37. */
38. export function uuid() {
39. const t = Date.now().toString(36).padStart(9, '0');
40. const r = Math.random().toString(36).slice(2, 5).padStart(3, '0');
41. return t + r;
42. }
44. export const PrimaryKeyType = {
45. NUMBER: 0,
46. UUID: 1,
47. STRING: 2,
48. };
50. export const IndexType = {
51. LEXICAL: 0,
52. NUMERIC: 1,
53. };