dart_nats

• Fix heartbeat pings raising an unhandled zone error on every disconnect. The PONG-tracking callback added in 1.3.0 used an expression body, so type inference picked then<int> and the null-returning onError handler could not satisfy FutureOr<int> -- visible on the Dart VM and dart2wasm (dart2js elides the cast).

• Fix heartbeat pings raising an unhandled zone error on every disconnect. The PONG-tracking callback added in 1.3.0 used an expression body, so type inference picked then<int> and the null-returning onError handler could not satisfy FutureOr<int> -- visible on the Dart VM and dart2wasm (dart2js elides the cast).

• Add filtered/keep/seq-bounded stream purge: JsStream.purge()/JetStream.purgeStream() now accept optional filter, keep, and seq parameters ($JS.API.STREAM.PURGE's own options), instead of only supporting an all-or-nothing purge.
• Add ObjectStore.putStream()/getStream() for uploading/downloading objects as a Stream<List<int>>/Stream<Uint8List> without buffering the whole payload in memory, computing the SHA-256 digest incrementally as chunks arrive.
• Fix ObjectStore.put()/putStream() leaving a previous object's chunks orphaned in the backing stream when overwriting an existing name -- the old version's chunks are now purged once the new version is safely written.
• Bump actions/checkout/actions/cache in CI to versions that don't trigger GitHub's Node 20 deprecation warning.

• Add filtered/keep/seq-bounded stream purge: JsStream.purge()/JetStream.purgeStream() now accept optional filter, keep, and seq parameters ($JS.API.STREAM.PURGE's own options), instead of only supporting an all-or-nothing purge.
• Add ObjectStore.putStream()/getStream() for uploading/downloading objects as a Stream<List<int>>/Stream<Uint8List> without buffering the whole payload in memory, computing the SHA-256 digest incrementally as chunks arrive.
• Fix ObjectStore.put()/putStream() leaving a previous object's chunks orphaned in the backing stream when overwriting an existing name -- the old version's chunks are now purged once the new version is safely written.
• Bump actions/checkout/actions/cache in CI to versions that don't trigger GitHub's Node 20 deprecation warning.

• Add consumer pause/resume support (NATS 2.11+): JetStream.pauseConsumer(stream, consumer, pauseUntil) and JetStream.resumeConsumer(stream, consumer), calling $JS.API.CONSUMER.PAUSE. ConsumerInfo also gains paused/pauseUntil fields reflecting the consumer's current pause state.
• Add GitHub Actions CI (test suite against local NATS containers, analyze/format checks, cross-platform analyze jobs, publish dry-run) and automated pub.dev publishing on tagged releases.
• Fix heartbeat pings (pingInterval/maxPingsOut) never confirming a PONG reply actually arrived before counting toward the missed-ping limit, so a connection that was responding perfectly fine still got force-disconnected after maxPingsOut heartbeat ticks. The periodic heartbeat now tracks its PONG the same way Client.ping() does and resets the missed-ping counter on receipt.

• Add consumer pause/resume support (NATS 2.11+): JetStream.pauseConsumer(stream, consumer, pauseUntil) and JetStream.resumeConsumer(stream, consumer), calling $JS.API.CONSUMER.PAUSE. ConsumerInfo also gains paused/pauseUntil fields reflecting the consumer's current pause state.
• Add GitHub Actions CI (test suite against local NATS containers, analyze/format checks, cross-platform analyze jobs, publish dry-run) and automated pub.dev publishing on tagged releases.
• Fix heartbeat pings (pingInterval/maxPingsOut) never confirming a PONG reply actually arrived before counting toward the missed-ping limit, so a connection that was responding perfectly fine still got force-disconnected after maxPingsOut heartbeat ticks. The periodic heartbeat now tracks its PONG the same way Client.ping() does and resets the missed-ping counter on receipt.

• Update package homepage and repository URLs to point to the new dart-nats GitHub organization.

• Fix background reconnection loop getting stuck or stopping prematurely after network loss by evaluating connection and closed states more robustly.
• Fix socket cleanups hanging on zombie connections during abrupt network loss by introducing a soft cleanup with a 2-second timeout window.
• Correct connection callback trigger logic, ensuring onReconnect correctly fires during a reconnection cycle instead of onConnect.
• Many thanks to contributor @JuanCordovaLazo for these crucial reconnect fixes.

• Fix JetStream.listStreams()/listConsumers() silently truncating at the server's page size (256 items) instead of paginating via offset/total — accounts with more streams/consumers than that lost visibility into everything past the first page, with no error or truncation flag.
• Fix Consumer.messages()'s pull loop and OrderedConsumer swallowing every delivery failure into a silent retry loop instead of surfacing it through the stream's addError. For pull consumers specifically, a deleted server-side consumer never actually threw from fetch() — it silently timed out with an empty batch, indistinguishable from a merely idle consumer — so the loop now also confirms the consumer still exists whenever a batch comes back empty.
• Fix KeyValue.watch()/history()/keys() leaking their ephemeral push consumer on every call — the Consumer returned by createConsumer() was discarded and never deleted once the caller cancelled or the call finished. ConsumerConfig also gains an inactiveThreshold field (serialized as inactive_threshold, same convention as idleHeartbeat) so ephemeral consumers can be given a server-side reap window as a safety net.
• Add Message.nakSync()/termSync()/inProgressSync(), awaitable twins of the existing ackSync() for nak()/term()/inProgress(). The originals call pub() without awaiting its own Future<bool>, so a disconnected client still reports success even though the ack/nak/term never reached the server — prefer the *Sync variants when that needs to be known.

• Update README.md with Microservices Framework (ADR-32) and Client Discovery documentation.

• Add heartbeats, clustering, robust reconnection, buffer limits, pull flow control, and NATS Microservices Framework (ADR-32).
• Add client-side service discovery for the ADR-32 Microservices framework, complementing the addService/MicroService hosting side:
  • Client.discoverServices(), getServicesInfo(), and getServicesStats() fan a request out to $SRV.* (optionally scoped to service name and ID) and collect all replies within a bounded timeout window.
  • Adds PingResponse, InfoResponse, EndpointInfo, StatsResponse, and EndpointStatsInfo to parse standard response payloads.
  • Thanks nverbeek for the contribution.

1.1.2

• Fix JetStream.accountInfo() returning all-zero Tier for single-tier accounts by parsing usage fields from the top-level response instead of a nonexistent nested tier key. Also fix Tier.fromJson crash on uint64 sentinel values by reading fields as num. Thanks @nverbeek for the contribution.

• Fix JetStream.accountInfo() returning all-zero Tier for single-tier accounts by parsing usage fields from the top-level response instead of a nonexistent nested tier key. Also fix Tier.fromJson crash on uint64 sentinel values by reading fields as num. Thanks nverbeek for the contribution.

• Fix defect #42: Ensure newInbox always appends a dot suffix (.) to inboxPrefix to conform to hierarchical NATS subject structures (_INBOX.> gateway callout authorization policy).
• Retain backward compatibility: Do not append double dots (..) if the prefix argument already ends with a dot.

• Add JetStream, Key-Value, and Object Store API enhancements and handle-based classes:
  • Introduce JsStream class wrapping JetStream stream operations (info, purge, consumer, createConsumer).
  • Introduce generic Consumer<T> class with fetch (for pull batching) and messages() (stream for push deliver or continuous pull polling in the background).
  • Introduce AccountInfo API mapping JetStream tier resource usage and account details.
  • Add support for numReplicas and maxAge properties in StreamConfig.
  • Support flexible payload publishing using publishPayload<T> on the JetStream class.
• Key-Value Store API updates:
  • Add create and update methods supporting optimistic concurrency control (via PubOpts).
  • Add getRevision to retrieve historical values.
  • Support tracking and emitting key-value entry operations (KeyValueOp like put, delete, and purge).
  • Filter out deleted and purged keys automatically in KeyValue.get().
• Object Store API updates:
  • Introduce ObjectStoreConfig supporting replicas, maxBytes, and ttl.
  • Add addLink and addBucketLink methods to align with standard NATS conventions (aliasing/replacing old putLink and putBucketLink).
  • Update list() to correctly track tombstones and filter deleted object metadata.
  • Add helper methods putBytes and getBytes.
• Performance and refactoring improvements:
  • Optimize NATS protocol parser by replacing dynamic List growth/sublisting with direct byte processing on a manual buffer manager.
  • Clean up and document API definitions, including configuration options, exception models, and platform stubs.

• Add NATS JetStream Support (Stream/Consumer management, Publish/Subscribe, Pull mode with Ack/Nak/Term)
• Add NATS Key-Value (KV) Store (Put, Get, Delete, Purge, Watch)
• Add NATS Object Store (128 KiB chunking, automatic SHA-256 validation)

• Issue resolved when app is in background. Thanks nileshsoni97 for contribution.

• Fix Uint8List and List<int> inconsistency. Thank myxzlpltk for contribution.

• fix Exposing Security Context#31.
• Fix missing headers in request response.

• fix a bug that does not correctly parse headers containing the ':' character. Thank https://github.com/CoryHagerman for contribution.

• fix nkeys decode issue

• Support verbos acknowledge
• Chang pub, pubString to async
• Header support (hpub and hmsg)

• Add nkeys publicKey privateKey functions
• Revamp rqeust
• Custom inbox prefix
• Inbound structure data

• fix #22 error when connect to nats://demo.nats.io

• fix #23 Unsupported operation: Platform._version with WebSocket

• add generic type to client.request()
• fix reconnect issue
• fix retry issue

• fix bug #16 Connect to invalid ws connection does not give error

• fix bug wss: connecting bug

• fix bug #20 larger MSG payloads not always working, check if full payload present in buffer

• TLS support

• fix wss://host:port

• client.connect() support with url schema example ws://host:port or nats://nost:port
• tls:// not support yet
• discontinue client.tcpConnect()
• add nkey authentication
• add jwt authentication

• Update readme

• Support TCP socket as 0.2.x by client.tcpConnect()

• Update package dependencies

• Fix flutter web Nuid() error

• Change transport from socket to WebSock
• Support Flutter Web

• Add user passwor authentication
• Add token authentication
• Convert to Null safety
• Dart SDK version 2.12.0 - 3.0.0
• fix inbox security

• fix request error on second request

• add async support for ping()
• add message.respondString

• async connect
• fix defect message delay when sub receive continuous message

• Improve receive buffer handling

• request/respond function
• change some wording from payload to data

• fix defect

• add inbox to generate unique inbox subject
• add nuid to generate unique id

• add string api client.pubString and message.string
• fix defect: pub sub non ascii
• fix defect: message include \r or \n
• revamp message decoding

• refactor code
• add commend

• publish can be buffered.

• Add readme

• Update readme

• Update sample code

• Update sample code

• Refactor code

• Add change log

• Initial experimental version