26632156910

Committed 29 May 2026 10:28AM UTC coverage: 79.576% (-0.02%) from 79.595%

Build # 26632156910

Build Type

push

github

Committed by

web-flow

Commit Message

feat: add inProgress event action and maxDeliver consumer option (#179)

Co-authored-by: gleip <kuchinsn@lad24.ru>

Coverage Stats

445 of 605 branches covered (73.55%)

Branch coverage included in aggregate %.

5 of 9 new or added lines in 3 files covered. (55.56%)

981 of 1187 relevant lines covered (82.65%)

5.62 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

10.53

/src/Union/JetStreamClient.ts

import {
  ConsumerOpts,
  ConsumerOptsBuilder,
  Consumers,
  JetStreamClient,
  JetStreamManager,
  JetStreamOptions,
  JetStreamPublishOptions,
  JetStreamPullSubscription,
  JetStreamSubscription,
  JsMsg,
  PubAck,
  PullOptions,
  QueuedIterator,
  Streams,
  Views,
} from 'nats';

import { EventEmitter } from 'stream';
import { UnionSubscription } from './Subscription';

export class JetStreamClientBlank implements JetStreamClient {
  views: Views;

  constructor(private emitter: EventEmitter) {}
  apiPrefix: string;
  consumers: Consumers;
  streams: Streams;
  jetstreamManager(checkAPI?: boolean | undefined): Promise<JetStreamManager> {
    throw new Error('Method not implemented.');
  }
  getOptions(): JetStreamOptions {
    throw new Error('Method not implemented.');
  }

  publish(subj: string, data?: Uint8Array, options?: Partial<JetStreamPublishOptions>): Promise<PubAck> {
    throw new Error('Method publish not implemented.');
  }
  pull(stream: string, durable: string, expires?: number): Promise<JsMsg> {
    throw new Error('Method pull not implemented.');
  }
  fetch(stream: string, durable: string, opts?: Partial<PullOptions>): QueuedIterator<JsMsg> {
    throw new Error('Method fetch not implemented.');
  }
  pullSubscribe(
    subject: string,
    opts: ConsumerOptsBuilder | Partial<ConsumerOpts>,
  ): Promise<JetStreamPullSubscription> {
    throw new Error('Method pullSubscribe not implemented.');
  }
  subscribe(subject: string, opts: ConsumerOptsBuilder | Partial<ConsumerOpts>): Promise<JetStreamSubscription> {
    const subscription = new UnionSubscription({ objectMode: true });
    const listener = ({ data }: any) => {
      subscription.write({
        data,
        ack: () => Promise.resolve(),
        nak: () => Promise.resolve(),
        working: () => Promise.resolve(),
      });
    };
    this.emitter.on(subject, listener);

    subscription.on('close', () => {
      this.emitter.off(subject, listener);
    });

    return Promise.resolve(subscription);
  }
}

1	import {
2	ConsumerOpts,
3	ConsumerOptsBuilder,
4	Consumers,
5	JetStreamClient,
6	JetStreamManager,
7	JetStreamOptions,
8	JetStreamPublishOptions,
9	JetStreamPullSubscription,
10	JetStreamSubscription,
11	JsMsg,
12	PubAck,
13	PullOptions,
14	QueuedIterator,
15	Streams,
16	Views,
17	} from 'nats';
18
19	import { EventEmitter } from 'stream';
20	import { UnionSubscription } from './Subscription';	6✔
21
22	export class JetStreamClientBlank implements JetStreamClient {	6✔
23	views: Views;
24
25	constructor(private emitter: EventEmitter) {}	×
26	apiPrefix: string;
27	consumers: Consumers;
28	streams: Streams;
29	jetstreamManager(checkAPI?: boolean \| undefined): Promise<JetStreamManager> {
30	throw new Error('Method not implemented.');	×
31	}
32	getOptions(): JetStreamOptions {
33	throw new Error('Method not implemented.');	×
34	}
35
36	publish(subj: string, data?: Uint8Array, options?: Partial<JetStreamPublishOptions>): Promise<PubAck> {
37	throw new Error('Method publish not implemented.');	×
38	}
39	pull(stream: string, durable: string, expires?: number): Promise<JsMsg> {
40	throw new Error('Method pull not implemented.');	×
41	}
42	fetch(stream: string, durable: string, opts?: Partial<PullOptions>): QueuedIterator<JsMsg> {
43	throw new Error('Method fetch not implemented.');	×
44	}
45	pullSubscribe(
46	subject: string,
47	opts: ConsumerOptsBuilder \| Partial<ConsumerOpts>,
48	): Promise<JetStreamPullSubscription> {
49	throw new Error('Method pullSubscribe not implemented.');	×
50	}
51	subscribe(subject: string, opts: ConsumerOptsBuilder \| Partial<ConsumerOpts>): Promise<JetStreamSubscription> {
52	const subscription = new UnionSubscription({ objectMode: true });	×
53	const listener = ({ data }: any) => {	×
NEW 54	subscription.write({	×
55	data,
NEW 56	ack: () => Promise.resolve(),	×
NEW 57	nak: () => Promise.resolve(),	×
NEW 58	working: () => Promise.resolve(),	×
59	});
60	};
61	this.emitter.on(subject, listener);	×
62
63	subscription.on('close', () => {	×
64	this.emitter.off(subject, listener);	×
65	});
66
67	return Promise.resolve(subscription);	×
68	}
69	}

lad-tech / nsc-toolkit / 26632156910

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous