[Phase 4] Integrate links-notation for parsing and serialization

js/.changeset/integrate-links-notation.md

@@ -0,0 +1,16 @@
+---
+'links-queue-js': minor
+---
+
+Integrate links-notation library for parsing and serialization
+
+- Add `links-notation` as a production dependency
+- Add `LinksNotation` class with `parse()` and `stringify()` methods
+- Add `NotationParser` for custom parser configurations
+- Add `NotationStreamParser` for streaming large inputs
+- Add `NotationParseError` for detailed parse error information
+- Add protocol message types (`RequestType`, `ResponseStatus`, `ErrorCode`)
+- Add `Message` and `MessageBuilder` classes for protocol communication
+- Add helper functions for creating request/response messages
+- Full TypeScript type definitions for all new exports
+- Comprehensive unit tests for parsing, serialization, and messages

js/package.json

@@ -63,5 +63,8 @@
       "prettier --write",
       "prettier --check"
     ]
+  },
+  "dependencies": {
+    "links-notation": "^0.13.0"
   }
 }

js/src/index.d.ts

@@ -182,3 +182,47 @@ export {
   QueueHandler,
   QueueSubscription,
 } from './queue/index.d.ts';
+
+// =============================================================================
+// Protocol Exports
+// =============================================================================
+
+export {
+  LinksNotation,
+  NotationParser,
+  NotationStreamParser,
+  NotationParseError,
+  ParseOptions,
+  StringifyOptions,
+  ParserOptions,
+  StreamParserOptions,
+  ParseLocation,
+  StreamParserEvent,
+  StreamParserHandler,
+} from './protocol/notation.d.ts';
+
+export {
+  Message,
+  MessageBuilder,
+  RequestType,
+  ResponseStatus,
+  ErrorCode,
+  RequestTypeValue,
+  ResponseStatusValue,
+  ErrorCodeValue,
+  MessageData,
+  ErrorInfo,
+  EnqueueOptions,
+  createOkResponse,
+  createErrorResponse,
+  createEnqueueRequest,
+  createDequeueRequest,
+  createPeekRequest,
+  createAckRequest,
+  createRejectRequest,
+  createQueryRequest,
+  createGetStatsRequest,
+  createListQueuesRequest,
+  createCreateQueueRequest,
+  createDeleteQueueRequest,
+} from './protocol/messages.d.ts';

js/src/index.js

@@ -181,3 +181,34 @@ export { MemoryLinkStore } from './backends/memory.js';
 // =============================================================================
 
 export { QueueError } from './queue/index.js';
+
+// =============================================================================
+// Protocol Exports
+// =============================================================================
+
+export {
+  LinksNotation,
+  NotationParser,
+  NotationStreamParser,
+  NotationParseError,
+} from './protocol/notation.js';
+
+export {
+  Message,
+  MessageBuilder,
+  RequestType,
+  ResponseStatus,
+  ErrorCode,
+  createOkResponse,
+  createErrorResponse,
+  createEnqueueRequest,
+  createDequeueRequest,
+  createPeekRequest,
+  createAckRequest,
+  createRejectRequest,
+  createQueryRequest,
+  createGetStatsRequest,
+  createListQueuesRequest,
+  createCreateQueueRequest,
+  createDeleteQueueRequest,
+} from './protocol/messages.js';