313 Commits

Author SHA1 Message Date
Alex Dukhnovskiy
9e2d606382 feat(microservices): add multiple grpc packages and proto files to config
before:

grpcOptions: <GrpcOptions>{
    transport: Transport.GRPC,
    options: {
        url: 'url',
        package: 'name.package',
        protoPath: 'alone.proto'
    }
}
after:

grpcOptions: <GrpcOptions>{
    transport: Transport.GRPC,
    options: {
        url: 'url',
        package: ['name.package', 'other.package'],
        protoPath: [
        'one.proto',
        'two.proto',
        'any.proto'
        ]
    }
}
2019-10-03 20:22:19 +03:00
Renovate Bot
32834c1b2e fix(deps): update nest monorepo to v6.8.0 2019-09-30 09:01:06 +00:00
Kamil Myśliwiec
1d27dacb2a feat() add rpc & ws decorators, add rpc context 2019-09-26 12:44:44 +02:00
Renovate Bot
669f31519d fix(deps): update dependency class-validator to v0.10.1 2019-09-25 07:02:09 +00:00
Renovate Bot
4377e40989 fix(deps): update nest monorepo to v6.7.2 2019-09-21 10:48:51 +00:00
Kamil Myśliwiec
645dfd1780 fix(microservices) add subscriptions counter to mqtt and redis 2019-09-21 12:37:04 +02:00
Renovate Bot
f559d009af fix(deps): update nest monorepo to v6.7.1 2019-09-16 11:22:10 +00:00
Renovate Bot
d2cca0cffe chore(deps): update dependency ts-node to v8.4.1 2019-09-16 07:52:53 +00:00
Renovate Bot
0b2e5652ed fix(deps): update dependency typescript to v3.6.3 2019-09-10 21:06:00 +00:00
Kamil Myśliwiec
fbb894a10a refactor() resolve conflicts 2019-09-04 13:12:49 +02:00
Kamil Myśliwiec
7db42a1a2c refactor(microservices) adjust to codebase style 2019-09-04 13:08:31 +02:00
Renovate Bot
450d5f7537 fix(deps): update nest monorepo to v6.6.7 2019-09-04 07:14:10 +00:00
Renovate Bot
8ea9f8ae94 fix(deps): update dependency rxjs to v6.5.3 2019-09-03 22:01:00 +00:00
Kamil Myśliwiec
7f9e110c60 resolve conflicts 2019-09-03 13:30:12 +02:00
Renovate Bot
8cac746b2c fix(deps): update nest monorepo to v6.6.6 2019-09-03 08:18:26 +00:00
Renovate Bot
d357f1edfe fix(deps): update nest monorepo to v6.6.4 2019-09-02 09:42:44 +00:00
Renovate Bot
3c59864847 fix(deps): update nest monorepo to v6.6.3 2019-08-29 09:59:06 +00:00
Michael Kaufman
df90e0dc62 Merge remote-tracking branch 'Nest/master' into 2361-kafka-micoservice-6-6-0
# Conflicts:
#	package-lock.json
2019-08-28 12:36:09 -04:00
Michael Kaufman
4632ba60cf Adds serializer and deserializer logic. 2019-08-28 12:34:49 -04:00
Kamil Myśliwiec
709625e273 Merge branch 'master' of https://github.com/nestjs/nest 2019-08-28 12:50:09 +02:00
Kamil Myśliwiec
37e41d7afe test() mqtt concurrent integration test comment out 2019-08-28 10:05:11 +02:00
Renovate Bot
40234488d6 fix(deps): update nest monorepo to v6.6.0 2019-08-28 07:42:18 +00:00
Michael Kaufman
e39b6468f0 Merge remote-tracking branch 'Nest/6.6.0' into 2361-kafka-micoservice-6-6-0
# Conflicts:
#	package-lock.json
#	packages/microservices/interfaces/index.ts
#	packages/microservices/test/listeners-controller.spec.ts
2019-08-27 09:29:18 -04:00
Kamil Myśliwiec
48fc6473bd ci() add npm install before integration tests and samples
ci() add npm install before integration tests and sampels

ci() add machine option to integraiton tests

ci() setup remote docker for integration tests

ci() add unit tests mixin function

ci() add unit tests mixin function

ci() fix working directory for integration tests

ci() rename unit tests function

ci() use reusable run-unit-tests config

ci() update naming, add coveralls

ci() add alias for unit tests

ci() add aliases (circleci)

ci() remove run command from aliases

ci() fix aliases

ci(): fix restore cache alias

ci() add list containers step to integration tests

integration() bind urls and hosts to 0.0.0.0

ci() add waiting for mysql task

ci() hotfix, move tasks order (integration)

ci() wait for mysql - change hostname, increase sleep time

ci() add sleep after docker-compose up (integration)

ci() add sleep after docker-compose up fix (seconds)

ci() switch to machine mode (integration tests)

ci() use nvm to switch default node version

ci() hotfix, wrong indentation (integration tests)

ci() add ls-remove (nvm) and node version check

ci() fix install npm task

ci() wip use nvm to run integration tests

ci() remove NPM upgrade task
2019-08-26 21:23:53 +02:00
Michael Kaufman
bba86dcac2 Removes @MessageRequest decorator in favor of subscribeToResponseOf() method. 2019-08-26 08:52:50 -04:00
Michael Kaufman
dcbeb59596 Implements @Hexenon server tests after botched merge. 2019-08-22 17:01:46 -04:00
Michael Kaufman
e2ac748458 Revert "Merge pull request #2 from Hexenon/2361-kafka-microservice"
This reverts commit ebefabdbda, reversing
changes made to 836698317c.
2019-08-22 16:55:28 -04:00
Hexenon
f25eadf86d refactor from async.parallel to Promise.all for concurrent tests. 2019-08-22 11:57:21 -06:00
Hexenon
710d00e369 Merge branch '2361-kafka-microservice' of https://github.com/mkaufmaner/nest into 2361-kafka-microservice
# Conflicts:
#	integration/microservices/e2e/sum-kafka.spec.ts
#	packages/microservices/test/server/server-kafka.spec.ts
2019-08-22 11:56:27 -06:00
Hexenon
3ed6d3bffa refactor from async.parallel to Promise.all for concurrent tests. 2019-08-22 11:53:31 -06:00
Michael Kaufman
d3ed627199 Adds integration tests for messaging pattern. 2019-08-22 12:33:16 -04:00
Hexenon
dc020161b3 test for Messaging and Kafka Serializer 2019-08-21 19:31:00 -06:00
Hexenon
aa2e8f9ae9 add tests for bindEvent empty messageHandlers. 2019-08-21 13:22:40 -06:00
Hexenon
3273f9f784 add tests for close and listen for kafka server. 2019-08-20 19:22:50 -06:00
Hexenon
b5d8965c5e add tests for @MessageRequests for complex data types. 2019-08-20 18:22:22 -06:00
Michael Kaufman
ad44931eb3 Removes unused key in integration test for Kafka. 2019-08-19 22:01:34 -04:00
Michael Kaufman
4bba628ae9 Adds generic serialization which won't require users to implement custom serializations between microservices. 2019-08-19 19:13:19 -04:00
Michael Kaufman
4480a7c3a1 Formatting and general fixes for tests. 2019-08-19 15:48:16 -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
05fc85dae5 Needs work for but messaging pattern is sorta there. 2019-08-15 19:55:43 -04:00
Michael Kaufman
3e5a30d116 Started work on the implementation on the kafka message pattern. 2019-08-15 13:39:03 -04:00
Michael Kaufman
c70f3fe7f0 Merge remote-tracking branch 'Nest/master' into 2361-kafka-microservice
# Conflicts:
#	package-lock.json
#	package.json
2019-08-13 13:45:48 -04:00
Renovate Bot
d3df1ce269 fix(deps): update dependency class-validator to v0.10.0 2019-08-13 09:03:41 +00:00
Michael Kaufman
cc5ea08c47 Update the timeout on the async messages. 2019-08-12 19:45:27 -04:00
Michael Kaufman
2c582c88d1 Puts kafka application start into it block to wait for leader election on the topics. 2019-08-12 19:34:50 -04:00
Michael Kaufman
41c8b39ca5 Properly dereferences the kafka server client and consumer upon close and fixes the test for kafka. 2019-08-12 19:17:54 -04:00
Michael Kaufman
c6123e790f Cleans up extraneous code and cleans up the tests. 2019-08-12 18:30:24 -04:00
Michael Kaufman
151e2025bb Event pattern producer and consumer initially working. Serialization still needs design. 2019-08-12 13:32:51 -04:00
Michael Kaufman
4fc5c893b8 Merge remote-tracking branch 'Nest/master' into 2361-kafka-microservice
# Conflicts:
#	integration/docker-compose.yml
#	package-lock.json
#	package.json
2019-07-31 10:09:52 -04:00
Kamil Myśliwiec
2038b45d04 test(): add retries to unit and integration tests 2019-07-30 09:10:13 +02:00