WIP: HTTP API

core/src/core-plugin-definitions.ts

@@ -11,6 +11,7 @@ export interface PluginRegistry {
   Filesystem: FilesystemPlugin;
   Geolocation: GeolocationPlugin;
   Haptics: HapticsPlugin;
+  Http: HttpPlugin;
   Keyboard: KeyboardPlugin;
   LocalNotifications: LocalNotificationsPlugin;
   Modals: ModalsPlugin;
@@ -904,6 +905,36 @@ export enum HapticsNotificationType {
   ERROR = 'ERROR'
 }
 
+// Http
+
+export interface HttpPlugin {
+  request(options: HttpOptions): Promise<HttpResponse>;
+}
+
+export interface HttpOptions {
+  url: string;
+  method: string;
+  params?: HttpParams;
+  data?: any;
+  headers?: HttpHeaders;
+}
+
+export interface HttpParams {
+  [key:string]: string;
+}
+
+export interface HttpHeaders {
+  [key:string]: string;
+}
+
+export interface HttpResponse {
+  data: any;
+  status: number;
+  headers: HttpHeaders;
+}
+
+// Vibrate
+
 export interface VibrateOptions {
   duration?: number;
 }

example/android/app/src/main/assets/capacitor.config.json

@@ -6,6 +6,9 @@
   "plugins": {
     "SplashScreen": {
       "launchShowDuration": 12345
+    },
+    "LocalNotifications": {
+      "smallIcon": "ic_stat_icon_config_sample"
     }
   }
 }

example/src/app/app.component.ts

@@ -9,7 +9,7 @@ import { Plugins } from '@capacitor/core';
 export class MyApp {
   @ViewChild(Nav) nav: Nav;
 
-  rootPage = 'AppPage';
+  rootPage = 'HttpPage';
 
   PLUGINS = [
     { name: 'App', page: 'AppPage' },
@@ -22,6 +22,7 @@ export class MyApp {
     { name: 'Filesystem', page: 'FilesystemPage' },
     { name: 'Geolocation', page: 'GeolocationPage' },
     { name: 'Haptics', page: 'HapticsPage' },
+    { name: 'Http', page: 'HttpPage' },
     { name: 'Keyboard', page: 'KeyboardPage' },
     { name: 'LocalNotifications', page: 'LocalNotificationsPage' },
     { name: 'Modals', page: 'ModalsPage' },

example/src/pages/http/http.html

@@ -0,0 +1,26 @@
+<!--
+  Generated template for the KeyboardPage page.
+
+  See http://ionicframework.com/docs/components/#navigation for more info on
+  Ionic pages and navigation.
+-->
+<ion-header>
+
+  <ion-navbar>
+    <ion-title>Http</ion-title>
+  </ion-navbar>
+
+</ion-header>
+
+
+<ion-content padding no-bounce>
+  <button (click)="get()" ion-button>GET</button>
+  <button (click)="head()" ion-button>HEAD</button>
+  <button (click)="delete()" ion-button>DELETE</button>
+  <button (click)="patch()" ion-button>PATCH</button>
+  <button (click)="post()" ion-button>POST</button>
+  <button (click)="put()" ion-button>PUT</button>
+
+  <h4>Output</h4>
+  <ion-textarea [value]="output" placeholder="Ouput"></ion-textarea>
+</ion-content>

example/src/pages/http/http.module.ts

@@ -0,0 +1,13 @@
+import { NgModule } from '@angular/core';
+import { IonicPageModule } from 'ionic-angular';
+import { HttpPage } from './http';
+
+@NgModule({
+  declarations: [
+    HttpPage,
+  ],
+  imports: [
+    IonicPageModule.forChild(HttpPage),
+  ],
+})
+export class HttpPageModule { }

example/src/pages/http/http.scss

@@ -0,0 +1,6 @@
+ion-textarea {
+  border: 1px solid #eee;
+  textarea {
+    height: 500px;
+  }
+}

example/src/pages/http/http.ts

@@ -0,0 +1,72 @@
+import { Component } from '@angular/core';
+import { IonicPage, NavController, NavParams, LoadingController, Loading } from 'ionic-angular';
+
+import { Plugins } from '@capacitor/core';
+
+/**
+ * Generated class for the KeyboardPage page.
+ *
+ * See https://ionicframework.com/docs/components/#navigation for more info on
+ * Ionic pages and navigation.
+ */
+
+@IonicPage()
+@Component({
+  selector: 'page-http',
+  templateUrl: 'http.html',
+})
+export class HttpPage {
+  url: string = 'https://jsonplaceholder.typicode.com';
+  output: string = '';
+
+  loading: Loading;
+
+  constructor(public navCtrl: NavController, public navParams: NavParams, public loadingCtrl: LoadingController) {
+  }
+
+  ionViewDidLoad() {
+    console.log('ionViewDidLoad KeyboardPage');
+  }
+
+  async get() {
+    this.output = '';
+
+    this.loading = this.loadingCtrl.create({
+      content: 'Requesting...'
+    });
+    this.loading.present();
+    const ret = await Plugins.Http.request({
+      method: 'GET',
+      url: `${this.url}/posts/1`
+    });
+    console.log('Got ret', ret);
+    this.loading.dismiss();
+
+    this.output = JSON.stringify(ret, null, 2);
+  }
+
+  delete =  () => this.mutate('/posts/1', 'DELETE', { title: 'foo', body: 'bar', userId: 1 });
+  patch =   () => this.mutate('/posts/1', 'PATCH', { title: 'foo', body: 'bar', userId: 1 });
+  post =    () => this.mutate('/posts', 'POST', { title: 'foo', body: 'bar', userId: 1 });
+  put =     () => this.mutate('/posts/1', 'PUT', { title: 'foo', body: 'bar', userId: 1 });
+
+  async mutate(path, method, data = {}) {
+    this.output = '';
+    this.loading = this.loadingCtrl.create({
+      content: 'Requesting...'
+    });
+    this.loading.present();
+    const ret = await Plugins.Http.request({
+      url: `${this.url}${path}`,
+      method: method,
+      headers: {
+        'content-type': 'application/json'
+      },
+      data
+    });
+    console.log('Got ret', ret);
+    this.loading.dismiss();
+    this.output = JSON.stringify(ret, null, 2);
+  }
+
+}

ios/Capacitor/Capacitor/Plugins/DefaultPlugins.m

@@ -73,6 +73,10 @@
   CAP_PLUGIN_METHOD(vibrate, CAPPluginReturnNone);
 )
 
+CAP_PLUGIN(CAPHttpPlugin, "Http",
+  CAP_PLUGIN_METHOD(request, CAPPluginReturnPromise);
+)
+
 CAP_PLUGIN(CAPKeyboard, "Keyboard",
   CAP_PLUGIN_METHOD(show, CAPPluginReturnPromise);
   CAP_PLUGIN_METHOD(hide, CAPPluginReturnPromise);

ios/Capacitor/Capacitor/Plugins/Http.swift

@@ -0,0 +1,140 @@
+import Foundation
+import AudioToolbox
+
+@objc(CAPHttpPlugin)
+public class CAPHttpPlugin: CAPPlugin {
+
+  @objc public func request(_ call: CAPPluginCall) {
+    guard let urlValue = call.getString("url") else {
+      return call.reject("Must provide a URL")
+    }
+    guard let method = call.getString("method") else {
+      return call.reject("Must provide a method. One of GET, DELETE, HEAD PATCH, POST, or PUT")
+    }
+
+    guard let url = URL(string: urlValue) else {
+      return call.reject("Invalid URL")
+    }
+
+    switch method {
+    case "GET", "HEAD":
+      get(call, url, method)
+    case "DELETE", "PATCH", "POST", "PUT":
+      mutate(call, url, method)
+    default:
+      call.reject("Unknown method")
+    }
+  }
+
+  // Handle GET operations
+  func get(_ call: CAPPluginCall, _ url: URL, _ method: String) {
+    var request = URLRequest(url: url)
+    request.httpMethod = method
+    let task = URLSession.shared.dataTask(with: request) { (data, response, error) in
+      if error != nil {
+        print("Error on GET", data, response, error)
+        call.reject("Error", error, [:])
+        return
+      }
+
+      let res = response as! HTTPURLResponse
+
+      call.resolve(self.buildResponse(data, res))
+    }
+
+    task.resume()
+  }
+
+  // Handle mutation operations: DELETE, PATCH, POST, and PUT
+  func mutate(_ call: CAPPluginCall, _ url: URL, _ method: String) {
+    let data = call.getObject("data")
+
+    var request = URLRequest(url: url)
+    request.httpMethod = method
+
+    let headers = (call.getObject("headers") ?? [:]) as [String:Any]
+
+    let contentType = getRequestHeader(headers, "Content-Type") as? String
+
+    if data != nil && contentType != nil {
+      do {
+        try setRequestData(request, data!, contentType!)
+      } catch let e {
+        call.reject("Unable to set request data", e)
+        return
+      }
+    }
+
+    let task = URLSession.shared.dataTask(with: request) { (data, response, error) in
+      if error != nil {
+        print("Error on mutate  ", data, response, error)
+        call.reject("Error", error, [:])
+        return
+      }
+
+      let res = response as! HTTPURLResponse
+
+      call.resolve(self.buildResponse(data, res))
+    }
+
+    task.resume()
+  }
+
+  func buildResponse(_ data: Data?, _ response: HTTPURLResponse) -> [String:Any] {
+
+    var ret = [:] as [String:Any]
+
+    ret["status"] = response.statusCode
+    ret["headers"] = response.allHeaderFields
+
+    let contentType = response.allHeaderFields["Content-Type"] as? String
+
+    if data != nil && contentType != nil && contentType!.contains("application/json") {
+      if let json = try? JSONSerialization.jsonObject(with: data!, options: .mutableContainers) as? [String: Any] {
+        print("Got json")
+        print(json)
+          // handle json...
+        ret["data"] = json
+      }
+    }
+    // TODO: Handle other response content types, including binary
+    /*
+    else {
+      ret["data"] =
+    }*/
+
+    return ret
+  }
+
+  func getRequestHeader(_ headers: [String:Any], _ header: String) -> Any? {
+    var normalizedHeaders = [:] as [String:Any]
+    headers.keys.forEach { (key) in
+      normalizedHeaders[key.lowercased()] = headers[key]
+    }
+    return normalizedHeaders[header.lowercased()]
+  }
+
+  func setRequestData(_ request: URLRequest, _ data: [String:Any], _ contentType: String) throws {
+    if contentType.contains("application/json") {
+      try setRequestDataJson(request, data)
+    } else if contentType.contains("application/x-www-form-urlencoded") {
+      setRequestDataFormUrlEncoded(request, data)
+    } else if contentType.contains("multipart/form-data") {
+      setRequestDataMultipartFormData(request, data)
+    }
+  }
+
+  func setRequestDataJson(_ request: URLRequest, _ data: [String:Any]) throws {
+    var req = request
+    let jsonData = try JSONSerialization.data(withJSONObject: data)
+    req.httpBody = jsonData
+  }
+
+  func setRequestDataFormUrlEncoded(_ request: URLRequest, _ data: [String:Any]) {
+
+  }
+
+  func setRequestDataMultipartFormData(_ request: URLRequest, _ data: [String:Any]) {
+
+  }
+}