This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch cleanup_fixes
in repository https://gitbox.apache.org/repos/asf/iggy.git
from aa5d0ce4c fixes
add 3b190c14e feat(js): add VSR framing to the Node SDK (#3763)
add 5ca0bbb40 chore(deps): Bump postcss from 8.5.16 to 8.5.23 in /web
(#3762)
add fbaeae1b7 Merge branch 'master' into cleanup_fixes
No new revisions were added by this update.
Summary of changes:
.github/actions/node-npm/pre-merge/action.yml | 76 ++-
.github/actions/utils/server-start/action.yml | 15 +-
.github/config/components.yml | 2 +-
.github/workflows/_test.yml | 15 +-
codecov.yml | 6 +
foreign/node/README.md | 63 +-
foreign/node/package-lock.json | 4 +-
foreign/node/package.json | 8 +-
foreign/node/scripts/check-vsr-protocol.mjs | 340 +++++++++++
foreign/node/src/bdd/raw.ts | 5 +-
foreign/node/src/client/client.config.test.ts | 95 +++
foreign/node/src/client/client.config.ts | 56 ++
foreign/node/src/client/client.connection.test.ts | 455 ++++++++++++++
foreign/node/src/client/client.connection.ts | 362 ++++++++---
foreign/node/src/client/client.frame.test.ts | 160 +++++
foreign/node/src/client/client.frame.ts | 227 +++++++
foreign/node/src/client/client.socket.test.ts | 677 +++++++++++++++++++++
foreign/node/src/client/client.socket.ts | 410 +++++++++++--
foreign/node/src/client/client.ts | 73 +--
foreign/node/src/client/client.type.ts | 24 +-
foreign/node/src/client/index.ts | 1 +
foreign/node/src/e2e/tcp.consumer-group.e2e.ts | 8 +-
foreign/node/src/e2e/tcp.consumer-stream.e2e.ts | 8 +-
foreign/node/src/e2e/tcp.raw.e2e.ts | 38 +-
foreign/node/src/e2e/test-client.utils.ts | 2 +
foreign/node/src/index.ts | 6 +
foreign/node/src/stream/consumer-stream.ts | 9 +-
foreign/node/src/wire/command-set.test.ts | 10 +-
foreign/node/src/wire/command-set.ts | 10 +-
foreign/node/src/wire/command.code.ts | 5 +-
.../src/wire/command.utils.test.ts} | 39 +-
foreign/node/src/wire/command.utils.ts | 8 +-
.../wire/consumer-group/delete-group.command.ts | 19 +-
.../src/wire/consumer-group/get-group.command.ts | 16 +-
.../node/src/wire/consumer-group/group.utils.ts | 7 +
foreign/node/src/wire/consumer-group/index.ts | 1 +
.../src/wire/consumer-group/join-group.command.ts | 19 +-
.../src/wire/consumer-group/leave-group.command.ts | 19 +-
.../wire/consumer-group/sync-group.command.test.ts | 99 +++
.../src/wire/consumer-group/sync-group.command.ts | 67 ++
foreign/node/src/wire/error.code.test.ts | 40 ++
foreign/node/src/wire/error.code.ts | 32 +-
foreign/node/src/wire/error.utils.ts | 22 +-
.../src/wire/message/poll-messages.command.test.ts | 423 +++++++++++++
.../node/src/wire/message/poll-messages.command.ts | 211 ++++++-
foreign/node/src/wire/offset/get-offset.command.ts | 2 +-
foreign/node/src/wire/offset/offset.utils.ts | 4 +-
.../node/src/wire/offset/store-offset.command.ts | 2 +-
.../topic.utils.test.ts} | 60 +-
foreign/node/src/wire/topic/topic.utils.ts | 4 +-
foreign/node/src/wire/vsr/header.test.ts | 99 +++
foreign/node/src/wire/vsr/header.ts | 165 +++++
foreign/node/src/wire/vsr/index.ts | 157 +++++
foreign/node/src/wire/vsr/namespace.test.ts | 342 +++++++++++
foreign/node/src/wire/vsr/namespace.ts | 216 +++++++
foreign/node/src/wire/vsr/operation.test.ts | 107 ++++
foreign/node/src/wire/vsr/operation.ts | 158 +++++
foreign/node/src/wire/vsr/register.test.ts | 93 +++
foreign/node/src/wire/vsr/register.ts | 116 ++++
foreign/node/src/wire/vsr/reply.test.ts | 196 ++++++
foreign/node/src/wire/vsr/reply.ts | 172 ++++++
foreign/node/src/wire/vsr/session.test.ts | 73 +++
foreign/node/src/wire/vsr/session.ts | 117 ++++
foreign/node/src/wire/vsr/vsr.test.ts | 131 ++++
web/package-lock.json | 16 +-
web/package.json | 2 +-
66 files changed, 6053 insertions(+), 371 deletions(-)
create mode 100644 foreign/node/scripts/check-vsr-protocol.mjs
create mode 100644 foreign/node/src/client/client.config.test.ts
create mode 100644 foreign/node/src/client/client.config.ts
create mode 100644 foreign/node/src/client/client.connection.test.ts
create mode 100644 foreign/node/src/client/client.frame.test.ts
create mode 100644 foreign/node/src/client/client.frame.ts
create mode 100644 foreign/node/src/client/client.socket.test.ts
copy foreign/{go/contracts/duration.go => node/src/wire/command.utils.test.ts}
(60%)
create mode 100644
foreign/node/src/wire/consumer-group/sync-group.command.test.ts
create mode 100644 foreign/node/src/wire/consumer-group/sync-group.command.ts
create mode 100644 foreign/node/src/wire/error.code.test.ts
create mode 100644 foreign/node/src/wire/message/poll-messages.command.test.ts
copy foreign/node/src/wire/{token/delete-token.command.test.ts =>
topic/topic.utils.test.ts} (51%)
create mode 100644 foreign/node/src/wire/vsr/header.test.ts
create mode 100644 foreign/node/src/wire/vsr/header.ts
create mode 100644 foreign/node/src/wire/vsr/index.ts
create mode 100644 foreign/node/src/wire/vsr/namespace.test.ts
create mode 100644 foreign/node/src/wire/vsr/namespace.ts
create mode 100644 foreign/node/src/wire/vsr/operation.test.ts
create mode 100644 foreign/node/src/wire/vsr/operation.ts
create mode 100644 foreign/node/src/wire/vsr/register.test.ts
create mode 100644 foreign/node/src/wire/vsr/register.ts
create mode 100644 foreign/node/src/wire/vsr/reply.test.ts
create mode 100644 foreign/node/src/wire/vsr/reply.ts
create mode 100644 foreign/node/src/wire/vsr/session.test.ts
create mode 100644 foreign/node/src/wire/vsr/session.ts
create mode 100644 foreign/node/src/wire/vsr/vsr.test.ts
