observable-json-rest-api-client

Send HTTP requests to JSON REST Web services; receive responses as RxJS Observables.

This package can send HTTP requests of type POST, GET, PUT, and DELETE; these types correspond to the CRUD operations (create, read, update, and delete) of a REST Web service. Any data sent is JSON, and attempts are made to parse any data received as JSON.

This package's API is:

    request(httpMethod, urlString, requestData, verbose = false)
    post(urlString, requestData, verbose = false)
    get(urlString, verbose = false)
    put(urlString, requestData, verbose = false)
    delete(urlString, verbose = false)

post(), get(), put(), and delete() are merely convenience functions that call request() with a specific httpMethod.

Each function returns an RxJS Observable that yields an object with the following fields:

• statusCode : The HTTP status code from the response from the server
• statusMessage : The HTTP status message from the response from the server
• rawResponseBody : The raw body from the response from the server
• jsonResponseBody : The body from the response from the server after it has been parsed as JSON. This field is only present if the response body was successfully parsed as JSON.
• jsonParseError : The error, if any, that was encountered during the parsing of the response body as JSON.

Example 1: POST:

const engine = require('observable-json-rest-api-client');
 
const postData = {
    field1: 'abc',
    field2: 123
};
 
engine.post('https://httpbin.org/post', postData).subscribe(
    result => {
        console.log('POST: Result:', result);
        console.log('POST: Response body as JSON:', result.jsonResponseBody);
        console.log('POST: Posted data:', result.jsonResponseBody.data);
    },
    error => {
        console.error('POST: Error:', error);
    },
    () => {
        console.log('POST: Done.');
    }
);

Example 2: GET:

const engine = require('observable-json-rest-api-client');
 
engine.get('https://httpbin.org/uuid').subscribe(
    result => {
        console.log('GET: result:', result);
        console.log(`GET: HTTP response status: ${result.statusCode} ${result.statusMessage}`);
        console.log('GET: Response body as JSON:', result.jsonResponseBody);
        console.log('GET: UUID:', result.jsonResponseBody.uuid);
        console.log('GET: typeof UUID:', typeof result.jsonResponseBody.uuid);
    },
    error => {
        console.error('GET: Error:', error);
    },
    () => {
        console.log('GET: Done.');
    }
);

License

MIT