split client and server channels

pkg/analysis_server/lib/src/protocol.dart

 // Copyright (c) 2014, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 library protocol;
 
 import 'dart:convert' show JsonDecoder;
 
 /**
  * Instances of the class [Request] represent a request that was received.
@@ skipping 57 matching lines @@
    * pairs.
    */
   factory Request.fromString(String data) {
     try {
       var result = DECODER.convert(data);
       if (result is! Map) {
         return null;
       }
       String id = result[Request.ID];
       String method = result[Request.METHOD];
-      Map<String, Object> params = result[Request.PARAMS];
+      var params = result[Request.PARAMS];
       Request request = new Request(id, method);
-      if (params != null) {
+      if (params is Map) {
         params.forEach((String key, Object value) {
           request.setParameter(key, value);
         });
       }
       return request;
     } catch (exception) {
       return null;
     }
   }
 
@@ skipping 55 matching lines @@
       });
     }
     throw new RequestFailure(new Response.expectedInteger(this, value));
   }
 
   /**
    * Return a table representing the structure of the Json object that will be
    * sent to the client to represent this response.
    */
   Map<String, Object> toJson() {
-    Map jsonObject = new Map();
+    Map<String, Object> jsonObject = new Map<String, Object>();
     jsonObject[ID] = id;
     jsonObject[METHOD] = method;
-    params.forEach((String key, Object value) {
-      jsonObject[key] = value;
-    });
+    if (params.isNotEmpty) {
+      jsonObject[PARAMS] = params;
+    }
     return jsonObject;
   }
 }
 
 /**
  * Instances of the class [Response] represent a response to a request.
  */
 class Response {
   /**
    * The name of the JSON attribute containing the id of the request for which
@@ skipping 82 matching lines @@
     : this(request.id, new RequestError(-6, 'Unknown analysis option: "$optionName"'));
 
   /**
    * Initialize a newly created instance to represent an error condition caused
    * by a [request] that cannot be handled by any known handlers.
    */
   Response.unknownRequest(Request request)
     : this(request.id, new RequestError(-7, 'Unknown request'));
 
   /**
+   * Initialize a newly created instance based upon the given JSON data
+   */
+  factory Response.fromJson(Map<String, Object> json) {
+    try {
+      // TODO process result
+      String id = json[Response.ID];
+      var error = json[Response.ERROR];
+      var result = json[Response.RESULT];
+      Response response;
+      if (error is Map) {
+        response = new Response(id, new RequestError.fromJson(error));
+      } else {
+        response = new Response(id);
+      }
+      if (result is Map) {
+        result.forEach((String key, Object value) {
+          response.setResult(key, value);
+        });
+      }
+      return response;
+    } catch (exception) {
+      return null;
+    }
+  }
+
+  /**
    * Return the value of the result field with the given [name].
    */
   Object getResult(String name) {
     return result[name];
   }
 
   /**
    * Set the value of the result field with the given [name] to the given [value].
    */
   void setResult(String name, Object value) {
     result[name] = value;
   }
 
   /**
    * Return a table representing the structure of the Json object that will be
    * sent to the client to represent this response.
    */
   Map<String, Object> toJson() {
-    Map jsonObject = new Map();
+    Map<String, Object> jsonObject = new Map<String, Object>();
     jsonObject[ID] = id;
     if (error == null) {
       jsonObject[ERROR] = null;
     } else {
       jsonObject[ERROR] = error.toJson();
     }
     if (!result.isEmpty) {
       jsonObject[RESULT] = result;
     }
     return jsonObject;
@@ skipping 99 matching lines @@
    * parameters.
    */
   RequestError.invalidParameters() : this(CODE_INVALID_PARAMS, "Invalid parameters");
 
   /**
    * Initialize a newly created [Error] to indicate an internal error.
    */
   RequestError.internalError() : this(CODE_INTERNAL_ERROR, "Internal error");
 
   /**
+   * Initialize a newly created [Error] from the given JSON.
+   */
+  factory RequestError.fromJson(Map<String, Object> json) {
+    try {
+      int code = json[RequestError.CODE];
+      String message = json[RequestError.MESSAGE];
+      Map<String, Object> data = json[RequestError.DATA];
+      RequestError requestError = new RequestError(code, message);
+      if (data != null) {
+        data.forEach((String key, Object value) {
+          requestError.setData(key, value);
+        });
+      }
+      return requestError;
+    } catch (exception) {
+      return null;
+    }
+  }
+
+  /**
    * Return the value of the data with the given [name], or `null` if there is
    * no such data associated with this error.
    */
   Object getData(String name) => data[name];
 
   /**
    * Set the value of the data with the given [name] to the given [value].
    */
   void setData(String name, Object value) {
     data[name] = value;
   }
 
   /**
    * Return a table representing the structure of the Json object that will be
    * sent to the client to represent this response.
    */
   Map<String, Object> toJson() {
-    Map jsonObject = new Map();
+    Map<String, Object> jsonObject = new Map<String, Object>();
     jsonObject[CODE] = code;
     jsonObject[MESSAGE] = message;
     if (!data.isEmpty) {
       jsonObject[DATA] = data;
     }
     return jsonObject;
   }
 }
 
 /**
@@ skipping 21 matching lines @@
    * A table mapping the names of notification parameters to their values.
    */
   final Map<String, Object> params = new Map<String, Object>();
 
   /**
    * Initialize a newly created [Notification] to have the given [event] name.
    */
   Notification(this.event);
 
   /**
+   * Initialize a newly created instance based upon the given JSON data
+   */
+  factory Notification.fromJson(Map<String, Object> json) {
+    try {
+      String event = json[Notification.EVENT];
+      var params = json[Notification.PARAMS];
+      Notification notification = new Notification(event);
+      if (params is Map) {
+        params.forEach((String key, Object value) {
+          notification.setParameter(key, value);
+        });
+      }
+      return notification;
+    } catch (exception) {
+      return null;
+    }
+  }
+
+  /**
    * Return the value of the parameter with the given [name], or `null` if there
    * is no such parameter associated with this notification.
    */
   Object getParameter(String name) => params[name];
 
   /**
    * Set the value of the parameter with the given [name] to the given [value].
    */
   void setParameter(String name, Object value) {
     params[name] = value;
   }
 
   /**
    * Return a table representing the structure of the Json object that will be
    * sent to the client to represent this response.
    */
   Map<String, Object> toJson() {
-    Map jsonObject = new Map();
+    Map<String, Object> jsonObject = new Map<String, Object>();
     jsonObject[EVENT] = event;
     if (!params.isEmpty) {
       jsonObject[PARAMS] = params;
     }
     return jsonObject;
   }
 }
 
 /**
  * Instances of the class [RequestHandler] implement a handler that can handle
@@ skipping 18 matching lines @@
   /**
    * The response to be returned as a result of the failure.
    */
   final Response response;
 
   /**
    * Initialize a newly created exception to return the given reponse.
    */
   RequestFailure(this.response);
 }