43 Commits

Author SHA1 Message Date
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
d606466b37 Merge branch 'master' into 11.0.0 2024-11-27 12:03:56 +01:00
Kamil Myśliwiec
96e3e79acc fix(grpc): schedule messages forwarding after the current event loop 2024-11-27 11:50:50 +01:00
Kamil Myśliwiec
d27628aafa chore: resolve conflicts 2024-11-27 09:55:20 +01:00
Kamil Myśliwiec
10fdf16c47 build: use strict null checks part 1 2024-11-26 12:46:59 +01:00
Kamil Myśliwiec
236b633a76 style: address integration tests lint errors 2024-11-26 09:39:20 +01:00
Kamil Myśliwiec
b65c41c5a8 fix: use proxy, drain buffer before execution 2024-11-20 10:21:10 +01:00
Philip Mantrov
8dcc5cb98f feat(microservices): Added invalid-grpc-message-decorator.exception.ts 2023-08-01 11:48:22 +03:00
Ben Teichman
fd070b82c3 feat: allow microserivce event or message extras to be extended 2023-04-04 12:46:37 -04:00
Tony133
0df4dcafa2 chore(microservices): mark facing apis public in microservices 2023-02-09 10:33:27 +01:00
Kamil Myśliwiec
e3e3ef5cc5 chore(): resolve conflicts 2022-05-17 13:16:46 +02:00
Xavier Zhou
4539568030 feat(microservices): allow to set custom transport to decorators 2022-03-17 09:22:23 +08:00
Michał Dzik
5e52a7e85e chore: align message pattern to event pattern 2022-03-08 21:16:37 +01:00
Michał Dzik
0fe67d5f90 chore: alignments after review 2022-03-07 21:18:56 +01:00
Michał Dzik
48dca4ee22 chore: align event pattern 2022-03-04 14:19:02 +01:00
Michał Dzik
4ae2ef54d4 feat(microservices): add support for multiple message pattern decorator 2022-02-19 22:16:49 +01:00
Eugene Korshenko
a0f148df3b chore(microservices): correct argument naming on pattern decorators 2022-01-24 21:17:47 +02:00
Eugene Korshenko
95643fc40a chore(): import shared utils from a proper location 2022-01-17 23:58:17 +02:00
Eugene Korshenko
27a1321bda refactor(microservices): utilize shared utils at pattern decorators 2022-01-17 23:51:22 +02:00
Eugene Korshenko
d1e6e9b587 feat(microservices): add overloads for pattern decorators 2022-01-17 23:33:08 +02:00
Eugene Korshenko
26e9ed63bf feat(microservices): add extras param to pattern decorators
Add optional "extras" parameter for MessagePattern and
EventPattern decorators. Allow embedding extra params into
each message handler method and improve an experience of
creating custom microservice transports
2022-01-16 22:11:16 +02:00
Kamil Myśliwiec
e9024fe7e7 feat(microservices): support property extraction in payload decorator 2021-02-01 16:04:46 +01:00
alex
e2c8f74f19 feat(microservices): move getTransportId functions to public variable transportId and make it optional 2020-05-16 15:22:15 +03:00
alex
0845dab3a3 feat(microservices): Add ability for pass transport to MessagePattern 2020-05-10 02:30:16 +03:00
Kamil Myśliwiec
e8da23cd12 refactor(): minor style improvements 2020-03-03 09:13:25 +01:00
Kamil Myśliwiec
7309ba4bdf chore(): remove lint from lint-staged 2020-01-26 12:17:23 +01:00
Kamil Myśliwiec
5143fc61d4 fix(microservices): fix broken unit tests (exception filter) 2019-11-08 10:52:48 +01:00
Kamil Myśliwiec
489d3299c0 format() run prettier, update format script 2019-10-04 09:08:27 +02:00
Kamil Mysliwiec
f6452959ec Merge pull request #3085 from nestjs/renovate/sequelize-5.x
fix(deps): update dependency sequelize to v5.19.2
2019-10-02 21:46:53 +02:00
Kamil Myśliwiec
1d27dacb2a feat() add rpc & ws decorators, add rpc context 2019-09-26 12:44:44 +02:00
Michael Kaufman
bba86dcac2 Removes @MessageRequest decorator in favor of subscribeToResponseOf() method. 2019-08-26 08:52:50 -04:00
Michael Kaufman
32f04ec382 Adds tests for the client proxy request map. 2019-08-22 15:06:32 -04:00
Michael Kaufman
c376018dc9 Adds MessageRequest decorator to define topic for client consumer subscriptions. 2019-08-19 13:56:39 -04:00
Michael Kaufman
c6123e790f Cleans up extraneous code and cleans up the tests. 2019-08-12 18:30:24 -04:00
Michael Kaufman
16dbe21d40 Initial work on the design and implementation. 2019-07-23 15:13:40 -04:00
Michael Kaufman
110a34b79f Working on Kafka Events. 2019-06-26 09:59:58 -04:00
Kamil Myśliwiec
769d7559d0 test(): add missing unit tests, resolve conflicts 2019-03-31 17:11:50 +02:00
Anton Repin
a1d23d6af8 Pattern decorators updated to have new naming and additional decorator
- GrpcStream now renamed to GrpcStreamMethod
- Grpc call passthrough now GrpcStreamCall
2019-03-10 23:31:51 -07:00
Anton Repin
5721aab084 GRPC patterns expanded with Streaming annotation
- GRPC Method added with definition of streaming parameter for mapping it to appropriate service
- GRPC Stream annotation added
- Commentary added
2019-02-13 13:02:14 -08:00
Kamil Myśliwiec
4f767080bf feature() add external context, microservices event patterns 2019-01-04 16:59:11 +01:00
Kamil Myśliwiec
1cac0a99fd feature: more typings, refactor 2018-11-28 23:08:27 +01:00
Kamil Myśliwiec
bf02e984ac Merge branch 'refactor_remove_reflect_metadata' of https://github.com/jbpionnier/nest into jbpionnier-refactor_remove_reflect_metadata 2018-10-17 21:33:41 +02:00
Kamil Myśliwiec
b2f3dfe0b3 refactor(microservices) move utils to decorators dir, use not stringified 2018-10-06 14:31:09 +02:00