AdvancedHttpClient (Demo Project)

Demo

• Live: https://hasan-akbari.github.io/angular-advanced-http-client/

Production‑grade Angular HTTP client that augments HttpClient with caching, inflight de‑duplication, rate limiting, debouncing, queueing/concurrency, batching, retry/backoff, timeout, and logging.

---

Highlights

Capability	What it does
Cache	In‑memory cache with TTL for successful responses
Inflight de‑dup	Merges equivalent requests; shares results via shareReplay
Rate limit & Debounce	Controls call rate and merges rapid bursts
Queue & Concurrency	Sequential or parallel processing with priority and capacity
Batching	Combines payloads and distributes responses via selector
Retry/Backoff	Retries with exponential/linear backoff and fallback
Timeout	Per‑request timeout handling
Logging	Structured logs with optional server shipping

Tip

Use raw: true in tests to disable automatic de‑duplication when you need to observe concurrency precisely.

---

Installation

npm i @hasan-akbari/advanced-http-client

import { AdvancedHttpClientService } from '@hasan-akbari/advanced-http-client';

Quick Start

// Params and headers
import { HttpHeaders, HttpParams } from '@angular/common/http';
const params = new HttpParams().set('_limit', '5').set('_page', '2');
const headers = new HttpHeaders({ 'X-Mode': 'demo' });

http.send<any>('https://jsonplaceholder.typicode.com/posts', undefined, {
  method: 'GET', params, headers
}).subscribe();

// Inflight de‑dup and result sharing
http.get<any>('https://jsonplaceholder.typicode.com/posts/1').subscribe();
http.get<any>('https://jsonplaceholder.typicode.com/posts/1').subscribe();

// Raw mode to bypass de‑dup/shareReplay
http.get<any>('https://jsonplaceholder.typicode.com/posts/1', {}, { raw: true }).subscribe();
http.get<any>('https://jsonplaceholder.typicode.com/posts/1', {}, { raw: true }).subscribe();

---

Options Overview

Option	Type / Example	Description
method	`'GET'	'POST'
params	Plain object	Converted to HttpParams
headers	Plain object	Converted to HttpHeaders
raw	boolean	Bypass de‑dup; every call sends independently
cacheDurationMs	number	TTL for caching successful responses
debounceMs	number	Merge rapid calls; delays send
rateLimitMs	number	Minimum gap between completions on same key
queue	{ enabled, mode, concurrency?, priority }	Sequential/parallel pipeline control
batch	{ enabled, key, size, intervalMs, combine, selector }	Group payloads and split responses
retry	{ attempts, backoff, baseDelayMs, maxDelayMs?, shouldRetry?, fallbackValue }	Resilience configuration
timeoutMs	number	Per‑request timeout
log	{ enabled, level, sendToServer? }	Logging and optional server shipping
debug	boolean	Console debugging alongside logs

Note

Cache is process‑local and not durable. Use a persistent store if you need cross‑session caching.

---

Usage Patterns

// Cache successful responses for 30s
http.get('https://jsonplaceholder.typicode.com/posts/2', {}, { cacheDurationMs: 30000 }).subscribe();

// Debounce rapid calls; Rate‑limit enforces minimum spacing between completions
http.get('https://api.example.com/search', { q: 'ng' }, { debounceMs: 300 }).subscribe();
http.get('https://api.example.com/items', {}, { rateLimitMs: 1000 }).subscribe();

// Sequential queue
http.get('https://api.example.com/todos/1', {}, { queue: { enabled: true, mode: 'sequential', priority: 'normal' } }).subscribe();
http.get('https://api.example.com/todos/2', {}, { queue: { enabled: true, mode: 'sequential', priority: 'normal' } }).subscribe();

// Parallel with concurrency
http.get('https://api.example.com/comments', {}, { raw: true, queue: { enabled: true, mode: 'parallel', concurrency: 2, priority: 'high' } }).subscribe();

// Batching (GET) with combine/selector
const batchOpts = {
  method: 'GET',
  batch: {
    enabled: true,
    key: 'users-batch',
    size: 10,
    intervalMs: 0,
    combine: (arr: any[]) => arr.map(p => p.id),
    selector: (resp: any[], payload: any) => resp.find(u => u.id === payload.id)
  }
} as const;
http.send<any>('https://jsonplaceholder.typicode.com/users', { id: 1 }, batchOpts as any).subscribe();

// Retry with exponential backoff and fallback
http.get('https://jsonplaceholder.typicode.com/posts', {}, {
  retry: {
    attempts: 2,
    backoff: 'exponential',
    baseDelayMs: 50,
    maxDelayMs: 2000,
    shouldRetry: (err) => err.status >= 500,
    fallbackValue: { ok: true }
  }
}).subscribe(v => console.log('Result:', v));

// Timeout and logging
http.get('https://jsonplaceholder.typicode.com/posts', {}, {
  timeoutMs: 10,
  log: { enabled: true, level: 'basic' },
  debug: true
}).subscribe();

---

Compatibility

Angular	RxJS	Node
^17.3.0	^7.8.0	18+ recommended

---

Build & Publish

• Build: npx ng build advanced-http-client
• Publish: cd dist/advanced-http-client && npm publish

---

License

MIT