import {isString, isPresent, isBlank} from 'angular2/src/core/facade/lang'; import {makeTypeError} from 'angular2/src/core/facade/exceptions'; import {Injectable} from 'angular2/angular2'; import {RequestOptionsArgs, Connection, ConnectionBackend} from './interfaces'; import {Request} from './static_request'; import {BaseRequestOptions, RequestOptions} from './base_request_options'; import {RequestMethods} from './enums'; function httpRequest(backend: ConnectionBackend, request: Request): any { return backend.createConnection(request).response; } function mergeOptions(defaultOpts, providedOpts, method, url): RequestOptions { var newOptions = defaultOpts; if (isPresent(providedOpts)) { // Hack so Dart can used named parameters newOptions = newOptions.merge(new RequestOptions({ method: providedOpts.method, url: providedOpts.url, search: providedOpts.search, headers: providedOpts.headers, body: providedOpts.body })); } if (isPresent(method)) { return newOptions.merge(new RequestOptions({method: method, url: url})); } else { return newOptions.merge(new RequestOptions({url: url})); } } /** * Performs http requests using `XMLHttpRequest` as the default backend. * * `Http` is available as an injectable class, with methods to perform http requests. Calling * `request` returns an {@link Observable} which will emit a single {@link Response} when a * response is received. * * #Example * * ```typescript * import {Http, HTTP_PROVIDERS} from 'angular2/http'; * @Component({selector: 'http-app', viewProviders: [HTTP_PROVIDERS]}) * @View({templateUrl: 'people.html'}) * class PeopleComponent { * constructor(http: Http) { * http.get('people.json') * // Call map on the response observable to get the parsed people object * .map(res => res.json()) * // Subscribe to the observable to get the parsed people object and attach it to the * // component * .subscribe(people => this.people = people); * } * } * ``` * * * #Example * * ``` * http.get('people.json').observer({next: (value) => this.people = people}); * ``` * * The default construct used to perform requests, `XMLHttpRequest`, is abstracted as a "Backend" ( * {@link XHRBackend} in this case), which could be mocked with dependency injection by replacing * the {@link XHRBackend} provider, as in the following example: * * #Example * * ```typescript * import {MockBackend, BaseRequestOptions, Http} from 'angular2/http'; * var injector = Injector.resolveAndCreate([ * BaseRequestOptions, * MockBackend, * provide(Http, {asFactory: * function(backend, defaultOptions) { * return new Http(backend, defaultOptions); * }, * deps: [MockBackend, BaseRequestOptions]}) * ]); * var http = injector.get(Http); * http.get('request-from-mock-backend.json').subscribe((res:Response) => doSomething(res)); * ``` * **/ @Injectable() export class Http { constructor(protected _backend: ConnectionBackend, protected _defaultOptions: RequestOptions) {} /** * Performs any type of http request. First argument is required, and can either be a url or * a {@link Request} instance. If the first argument is a url, an optional {@link RequestOptions} * object can be provided as the 2nd argument. The options object will be merged with the values * of {@link BaseRequestOptions} before performing the request. */ request(url: string | Request, options?: RequestOptionsArgs): any { var responseObservable: any; if (isString(url)) { responseObservable = httpRequest( this._backend, new Request(mergeOptions(this._defaultOptions, options, RequestMethods.Get, url))); } else if (url instanceof Request) { responseObservable = httpRequest(this._backend, url); } else { throw makeTypeError('First argument must be a url string or Request instance.'); } return responseObservable; } /** * Performs a request with `get` http method. */ get(url: string, options?: RequestOptionsArgs): any { return httpRequest(this._backend, new Request(mergeOptions(this._defaultOptions, options, RequestMethods.Get, url))); } /** * Performs a request with `post` http method. */ post(url: string, body: string, options?: RequestOptionsArgs): any { return httpRequest( this._backend, new Request(mergeOptions(this._defaultOptions.merge(new RequestOptions({body: body})), options, RequestMethods.Post, url))); } /** * Performs a request with `put` http method. */ put(url: string, body: string, options?: RequestOptionsArgs): any { return httpRequest( this._backend, new Request(mergeOptions(this._defaultOptions.merge(new RequestOptions({body: body})), options, RequestMethods.Put, url))); } /** * Performs a request with `delete` http method. */ delete (url: string, options?: RequestOptionsArgs): any { return httpRequest(this._backend, new Request(mergeOptions(this._defaultOptions, options, RequestMethods.Delete, url))); } /** * Performs a request with `patch` http method. */ patch(url: string, body: string, options?: RequestOptionsArgs): any { return httpRequest( this._backend, new Request(mergeOptions(this._defaultOptions.merge(new RequestOptions({body: body})), options, RequestMethods.Patch, url))); } /** * Performs a request with `head` http method. */ head(url: string, options?: RequestOptionsArgs): any { return httpRequest(this._backend, new Request(mergeOptions(this._defaultOptions, options, RequestMethods.Head, url))); } } @Injectable() export class Jsonp extends Http { constructor(backend: ConnectionBackend, defaultOptions: RequestOptions) { super(backend, defaultOptions); } /** * Performs any type of http request. First argument is required, and can either be a url or * a {@link Request} instance. If the first argument is a url, an optional {@link RequestOptions} * object can be provided as the 2nd argument. The options object will be merged with the values * of {@link BaseRequestOptions} before performing the request. */ request(url: string | Request, options?: RequestOptionsArgs): any { var responseObservable: any; if (isString(url)) { url = new Request(mergeOptions(this._defaultOptions, options, RequestMethods.Get, url)); } if (url instanceof Request) { if (url.method !== RequestMethods.Get) { makeTypeError('JSONP requests must use GET request method.'); } responseObservable = httpRequest(this._backend, url); } else { throw makeTypeError('First argument must be a url string or Request instance.'); } return responseObservable; } }