1540 Commits

Author SHA1 Message Date
Kamil Myśliwiec
53e1cc6360 test: fix broken unit transform pattern test 2026-02-20 11:51:45 +01:00
Kamil Myśliwiec
ca7d95a219 fix: transform pattern regression 2026-02-20 11:25:23 +01:00
Kamil Mysliwiec
cd7501b5c8 Merge pull request #16402 from nestjs/fix/pattern-max-depth-keys
fix(microservices): introuduce max pattern depth and object complexity
2026-02-20 10:49:32 +01:00
Kamil Myśliwiec
e099625a33 fix(microservices): introuduce max pattern depth and object complexity 2026-02-20 10:48:05 +01:00
Weixie Cui
3a74946f63 fix: if indexOf return 0 will if will be falsy 2026-02-20 14:00:08 +08:00
Kamil Myśliwiec
5d31df7eb6 chore(release): publish v11.1.14 release 2026-02-17 17:24:39 +01:00
Kamil Mysliwiec
9f55de66ed Merge pull request #16326 from suuuuuuminnnnnn/test/kafka-run-options-forwarding
test(microservices): verify kafka run options forwarding
2026-02-09 13:57:15 +01:00
suuuuuuminnnnnn
e0c40e4a1b test(microservices): verify kafka run options forwarding 2026-02-09 00:35:06 +09:00
Kamil Myśliwiec
8d1c16c1ca chore: update readme 2026-02-03 14:07:38 +01:00
Kamil Myśliwiec
e3a958ac3e chore(release): publish v11.1.13 release 2026-02-03 13:47:36 +01:00
suuuuuuminnnnnn
f5148709ff feat(microservices): support per-handler qos in mqtt 2026-02-03 10:41:51 +09:00
Ricardo
a5be2710ee refactor(microservices): Use options object for JsonSocket constructor
- Replace maxBufferSize parameter with JsonSocketOptions object
- Add JsonSocketOptions interface for better extensibility
- Update ClientTCP and ServerTCP to pass options object
- Update all tests to use new options format

Addresses review feedback from @kamilmysliwiec
2026-01-28 17:12:46 -03:00
Ricardo
5dd0a9ab8c test(microservices): Fix maxBufferSize tests
- Use valid JSON strings in test data
- Account for packet header length in buffer size calculations
- Fix chunked data test to properly accumulate buffer
2026-01-28 15:22:39 -03:00
Ricardo
2c62817436 feat(microservices): Add configurable maxBufferSize option
- Add maxBufferSize option to TcpOptions and TcpClientOptions interfaces
- Modify JsonSocket to accept maxBufferSize as constructor parameter
- Update ClientTCP and ServerTCP to pass maxBufferSize to JsonSocket
- Add comprehensive tests for maxBufferSize functionality
- Maintain backward compatibility with default value (128MB in characters)

Closes #16256
2026-01-28 15:21:04 -03:00
Kamil Myśliwiec
ed8370697d chore: add type cast in nats emitter 2026-01-22 09:34:45 +01:00
Kamil Myśliwiec
96932ad073 chore(release): publish v11.1.12 release 2026-01-15 09:29:44 +01:00
Kamil Myśliwiec
4fdeb0b504 style: address lint issues 2026-01-15 09:25:17 +01:00
Kamil Myśliwiec
e5616c2b92 feat: apply instance decorator to all enhancers 2026-01-14 19:58:10 +01:00
Kamil Myśliwiec
585f55f0e4 chore: revert lerna version 2025-12-29 14:30:25 +01:00
Kamil Myśliwiec
fef323b2c9 chore(release): publish v11.1.11 release 2025-12-29 14:26:08 +01:00
Kamil Myśliwiec
de5e0262d2 chore(@nestjs) publish v11.1.10 release 2025-12-22 09:31:35 +01:00
shash-hq
541ef2ffef fix(microservices): fix grpc stream method return type
Ensure GrpcStreamMethod returns Observable directly instead of wrapping it in a Promise when called locally.

Closes #15953
2025-12-14 21:49:58 +05:30
Kamil Myśliwiec
0c93692bc9 chore: update prettier 2025-12-05 13:35:27 +01:00
Kamil Myśliwiec
0430f3f190 chore: resolve conflicts 2025-12-05 13:31:11 +01:00
Kamil Myśliwiec
5045fea937 chore: update eslint monorepo 2025-12-05 13:29:23 +01:00
Oleh Strokan
62242bcab9 feat(microservices): add keepalive support for server side 2025-11-25 20:04:36 +01:00
Kamil Myśliwiec
64c85527f5 chore(@nestjs) publish v11.1.9 release 2025-11-14 11:18:00 +01:00
Kamil Myśliwiec
68cd545949 chore(@nestjs) publish v11.1.8 release 2025-10-27 10:00:53 +01:00
Kamil Myśliwiec
ee1b347555 chore(@nestjs) publish v11.1.7 release 2025-10-21 10:54:51 +02:00
Kamil Myśliwiec
33d6cb59a6 chore: update readme 2025-10-21 10:54:00 +02:00
Serafim Gerasimov
4fcd068d13 fix(microservices): rmq generated queue name in server
Generated queue name use in the server channel setup process
2025-10-14 21:09:36 +03:00
Serafim Gerasimov
c58da76adf fix(microservices): Prevent unusable queue assertion
The client queue assertion and bind prevent for cases when exchange will be used for send
2025-10-14 01:11:09 +03:00
Serafim Gerasimov
bf59ad2ecc test(microservices): RMQ Client and Server queue bind
Tests for new fanout exchange functional

FIXES: #15746
2025-10-07 22:52:40 +03:00
Serafim Gerasimov
5238114a0e fix(microservices): RMQ Client fanout bind behaviour change
Enforce the client and server to bind the queue to exchange
2025-10-07 22:29:05 +03:00
ghy
68adf92897 fix 2025-09-10 16:07:01 +08:00
ghy
f33aba8938 Update packages/microservices/errors/invalid-tcp-data-reception.exception.ts
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
2025-09-10 15:59:39 +08:00
ghy
9403addd44 fix:lint
lint fix at local
2025-09-06 16:15:52 +08:00
ghy
4f6270fb95 Update invalid-tcp-data-reception.exception.ts
fix..=.=
2025-09-05 15:22:56 +08:00
ghy
4eb049261d fix lint error
Delete "."
2025-09-05 14:55:49 +08:00
ghy
a63c411d92 fix lint error 2025-09-05 14:39:38 +08:00
ghy
0bfd43cdd7 fix: build error 2025-09-05 14:09:36 +08:00
ghy
05f5c3633f fix lint 2025-09-05 14:06:14 +08:00
ghy
edefb30e31 fix: lint error 2025-09-05 14:02:02 +08:00
ghy
7a9dbde30e fix: lint error 2025-09-05 14:01:25 +08:00
ghy
9a6d03bc5c fix build error 2025-09-05 13:51:52 +08:00
ghy
b1af0e65a9 Update server-tcp.ts
typo  format
2025-09-05 11:41:25 +08:00
ghy
7d42cc9d16 Update and rename invalid-tcp-message.exception.ts to invalid-tcp-data-reception.exception.ts
rename InvalidTcpDataReceptionException
2025-09-05 11:40:07 +08:00
ghy
1194c7436f Update server-tcp.ts
type invalid-tcp-data-reception
2025-09-05 11:38:53 +08:00
ghy
df7b5263b7 Update invalid-tcp-message.exception.ts
typo error message
2025-09-05 11:28:59 +08:00
ghy
c023827a24 Create invalid-tcp-message.exception.ts
add file for tcp error message
2025-09-05 10:34:56 +08:00