Merge pull request #95 from noflo/schema_support

Schema support

src/protocol/Component.coffee

@@ -106,6 +106,7 @@ class ComponentProtocol
       inPorts.push
         id: portName
         type: port.getDataType() if port.getDataType
+        schema: port.getSchema() if port.getSchema
         required: port.isRequired() if port.isRequired
         addressable: port.isAddressable() if port.isAddressable
         description: port.getDescription() if port.getDescription
@@ -116,6 +117,7 @@ class ComponentProtocol
       outPorts.push
         id: portName
         type: port.getDataType() if port.getDataType
+        schema: port.getSchema() if port.getSchema
         required: port.isRequired() if port.isRequired
         addressable: port.isAddressable() if port.isAddressable
         description: port.getDescription() if port.getDescription

src/protocol/Network.coffee

@@ -17,6 +17,10 @@ prepareSocketEvent = (event, req) ->
     payload.subgraph = event.subgraph
   if event.group
     payload.group = event.group
+  if event.datatype
+    payload.type = event.datatype
+  if event.schema
+    payload.schema = event.schema
   if typeof event.data isnt 'undefined'
     unless noflo.isBrowser()
       if Buffer.isBuffer event.data
@@ -179,6 +183,8 @@ class NetworkProtocol extends EventEmitter
         when 'data'
           protocolEvent.type = 'data'
           protocolEvent.data = event.data
+          protocolEvent.datatype = event.datatype
+          protocolEvent.schema = event.schema
         when 'closeBracket'
           protocolEvent.type = 'endgroup'
           protocolEvent.group = event.data

src/protocol/Runtime.coffee

@@ -36,6 +36,7 @@ portToPayload = (pub, internal, network, inPort) ->
   # we don't have full component info
   return def unless port
   def.type = port.getDataType()
+  def.schema = port.getSchema() if port.getSchema
   def.description = internal.metadata?.description or port.getDescription()
   def.addressable = port.isAddressable()
   def.required = port.isRequired()