Difference between revisions of "JSON Integration Adapter"

From CDOT Wiki
Jump to: navigation, search
m (Project Phases)
 
(56 intermediate revisions by 3 users not shown)
Line 1: Line 1:
[[category: NexJ Current Projects]]
+
{{Admon/obsolete}}
 +
 
 +
[[category: NexJ Past Projects]]
 
[[category: NexJ Express JSON Message Adapter]]
 
[[category: NexJ Express JSON Message Adapter]]
 
== Project Repository ==
 
 
https://bitbucket.org/b_lim/nexj-express-json-integration-adapter/overview
 
 
 
== Project Goal==
 
== Project Goal==
 
To create an adapter for the NexJ Core similar in methodology and design of existing message adapters (XML, Fixed, CSV etc.) but using the JSON format
 
To create an adapter for the NexJ Core similar in methodology and design of existing message adapters (XML, Fixed, CSV etc.) but using the JSON format
  
===Contributors===
+
Contributors
 
* [[User:Gbatumbya|Grace Batumbya]]
 
* [[User:Gbatumbya|Grace Batumbya]]
 
* [[User:Brianlim  | Brian Lim]]
 
* [[User:Brianlim  | Brian Lim]]
 +
  
 
== Current Status==
 
== Current Status==
 +
* '''Completed''' (February 02, 2012)
  
See https://bitbucket.org/b_lim/nexj-express-json-integration-adapter/changesets for changesets.
 
  
Forked NexJ code and created public repository for others to monitor progress and contribute.
+
== Project Repository ==
 +
BitBucket : https://bitbucket.org/gbatumbya/nexjexpress-jsonintergrationadapter/
 +
<br/>Deprecated: <del>https://bitbucket.org/b_lim/nexj-express-json-integration-adapter/</del>
  
Completed overview of NexJ Integration classes and coding method and class stubs. In process of creating unit tests.
 
  
==Project Phases==
+
== Definitions ==
 +
 
 +
{| class="wikitable" border="1"
 +
|-
 +
! Term
 +
! Description
 +
|-
 +
| Formatter
 +
| Turns data into JSON
 +
|-
 +
| Parser
 +
| Turns JSON into data
 +
|-
 +
| Message
 +
| The metadata to be used when formatting and parsing a message. The grammar. It is a tree-like structure.
 +
|-
 +
| MessageInstance
 +
| The information to be parsed or formatted
 +
|}
 +
 
 +
Because the Integration layer allows a Model to interact with external applications asynchronously, a description / grammar of the data to be exchanged between the two systems is defined using a Message in the Model. 
 +
 
 +
* Formatting is turning internal NexJ representation of a MessageInstance into JSON. The formatter is given a Message (the grammar), MessageInstance (the data), and a pipe. This accomplished by walking the Message tree-like structure while validating the data in the MessageInstance and streaming JSON format to the pipe. If the data in the MessageInstance does not conform to the Message, the formatter throws an exception.
 +
 
 +
* Parsing is turning JSON representation of a MessageInstance into an internal NexJ representation of a MessageInstance. The parser is given a Message (the grammar) and an input stream. First the input stream is parsed for JSON using a JSONParser which returns either an Object or an Array. The formatter walks the Message building the structure of the MessageInstance and adding validated values in the object returned by the JSONParser to the MessageInstance. If the data from the input stream does not match the expected input at any time, the parser throws an exception.
 +
 
 +
 
 +
==== Message Fundamentals ====
 +
Message - Messages can contain values or other messages. The red nodes are messages, the green nodes are values.
 +
 
 +
[[File:NexJExpressMessages.gif|NexJ Express Messages]]
 +
 
 +
Internally, messages are Transfer Objects. To determine if a node is a message, use instanceof on CompositeMessagePartInstance after retrieving the MessagePart. For example,
 +
 
 +
<pre>
 +
public void format(TransferObject tobj, Message message, Output out) throws IntegrationException
 +
{
 +
...
 +
CompositeMessagePart root = message.getRoot(); // Gets the root of the message.
 +
Iterator it = root.getPartIterator();
 +
while (it.hasNext())
 +
{
 +
  part = (MessagePart)it.next());
 +
  if (part instanceof CompositeMessagePartInstance)
 +
  {
 +
    // This part is a message
 +
  }
 +
  else if (part instanceof PrimitiveMessagePart)
 +
  {
 +
    // This part is a value
 +
  }
 +
...
 +
}
 +
...
 +
</pre>
  
JSON Integration Adapter Phases
+
NOTE: THE MESSAGE PARAMETER DOES NOT CONTAIN THE MESSAGE VALUES. THE MESSAGE PARAMETER CONTAINS THE MESSAGE METADATA. THE TRANSFER OBJECT CONTAINS THE MESSAGE VALUES WHICH MUST BE VALIDATED AGAINST THE MESSAGE TO ENSURE CORRECT FORMAT.
  
Phase I. Research
+
; MessagePart
 +
:Parts of a message. Messages can contain values or other messages.  NexJ Express has two types of message parts, ''CompositeMessagePart'' and ''PrimitiveMessagePart''.
  
# 1. Complete Fundamentals of NexJ Studio tutorial
+
; CompositeMessagePart
# 2. Complete NexJ Integration tutorial
+
: implementation is CompositeMessagePartInstance . The relationship between CompositeMessagePartInstance and PrimitiveMessagePart with the above picture is as follows - CompositeMessagePartInstance are messages (the red nodes) and PrimitiveMessagePart are values (the green nodes). To determine multiplicity of MessageParts, use isCollection() method of MessagePart. Note that multiplicity of the above screenshot are all '''[0..1]''', that is zero or one instance. Possible node multiplicities:
# 3. Install NexJ Studio Express from source
+
; '''[0..1]''' : zero or one instance (i.e. an optional entry)
 +
; '''[1..1]''' : exactly one instance (i.e. required)
 +
; '''[1..N]''' : collection of at least one, at most N instances
 +
; '''[0..0]''' : collection of zero to infinite instances (displayed as '''[*]''')
 +
; '''[1..0]''' : collection of at least one, possibly unlimited instances
  
Phase II. Planning and Approval
+
; XMLJSONMessageMappingLoader
 +
: Used by the framework to autoload JSONMessagePartMapping for each of the message parts.
  
# 1. Receive general approval for project
+
; JSONMessagePartMapping
# 2. Receive approval for JSON encoding options
+
: Each node in the above picture ''may'' has a corresponding JSONMessagePartMapping. Each node may have its own mapping, with its own values initialized in XMLJSONMessageMappingLoader. In order to get the mapping, first cast MessagePart to a concrete class such as CompositeMessagePartInstance or PrimitiveMessagePart, then use part.getMapping(). The purpose of the mapping is metadata for each node.
# 3. Receive approval for JSON formatting options
 
  
Phase III. Message Formatter
+
; JSONMessageFormatter
 +
: Used to turn messages into JSON format.
  
# 1. Add JSON to .XSD base types
+
; JSONMessageParser
# 2. Create sample JSON .message
+
: Used to turn JSON into a message.
# 3. Parse sample JSON .message with JUnit Test
 
# 4. Create first set of unit tests for Message Formatter
 
# 5. Code Message Formatter first draft
 
# 6. Resolve issues with first set of unit tests
 
# 7. Create second set of unit tests
 
# 8. Resolve issues with second set of unit tests
 
# 9. Refactor and code message formatter
 
 
Phase IV. Message Parser First Draft
 
  
# 1. Discover how to connect JSON RPC parser with Message Parser
+
==== Algorithm ====
# 2. Create first set of trivial unit tests for Message Parser
 
#      3. Code Message Parser skeleton
 
#      4. Pass first set of trivial unit tests
 
#      5. Create second set of unit tests (non-trivial) for Message Parser
 
#      6. Code Message Formatter first draft
 
#      7. Resolve issues with second set of unit tests
 
#      8. Refactor
 
  
Phase V. Integration and Stress Tests
+
format(TransferObject tobj, Message message, Output out)
 +
Algorithm for format method is as follows
 +
# Retrieve the root of the message
 +
# Iterate through each of the parts of the root
 +
## If the part is a CompositeMessagePartInstance, it is a message node
 +
## If the part is a PrimitiveMessagePart, it is a value node
 +
## Validate the part against the MessagePartMapping. Different types of validation must be done if the part is a Composite versus if it is a Primitive.
 +
## If the part is a CompositeMessagePartInstance, recursively call the format method with TransferObject set to the part. Suggested to overload the format method to format(TransferObject tobj, MessagePart message, Output out) and pass in the part, since retrieving a message root with getRoot() will always get the highest root of the message but what you want is the parent.
 +
## If the part is a PrimitiveMessagePart, write the message part to the output.
  
#      1. Test Message Formatter and Message Parser with integration and stress tests
 
#      2. Test through NexJ Studio Express GUI (manual testing)
 
  
Phase VI. Internal Code Review
+
==Project Phases==
  
# 1. Internally review code at CDOT
+
===Phase 1. Research (DONE)===
 +
# Complete Fundamentals of NexJ Studio tutorial
 +
# Complete NexJ Integration tutorial
 +
# Install NexJ Studio Express from source
  
Phase VII. Optimization
+
===Phase 2. Design Proposal (DONE)===
 +
# Receive general approval for project
 +
# Receive approval for JSON encoding options
 +
# Receive approval for JSON formatting options
 +
# [https://docs.google.com/document/d/1wAjG-xSJi227GBPUZtADAROSydIn3KuimoZarqO7xDQ/edit?hl=en_US Final Project Proposal]
  
#       1. Find more code optimizations relevant to Enterprise environments
+
===Phase 3. Create Classes (DONE)===
 +
# JSONMessagePartMapping
 +
# XMLJSONMessageMappingLoader
 +
# JSONMessageFormatter
 +
# JSONMessageParser
 +
# JSONMessageFormatterTest
  
Phase VIII. First Code Review at NexJ
+
===Phase 4. Internal Code Review (DONE)===
 +
# Internally review code at CDOT
  
# 1. Date TBA
+
===Phase 5. Code Review 1 (DONE)===
 +
# August 9, 2011
 +
# Code review took place at NexJ with [[User:Gbatumbya|Grace Batumbya]], [[User:Brianlim  | Brian Lim]] and Andrew Borzenko (NexJ Developer) in attendance.
  
Phase IX. Code Rewrite
+
===Phase 6. Apply Changes from Code Review 1===
 +
# Estimated Duration: 3 Weeks (August 29, 2011)
 +
# [[JSON_Integration_Adapter_Code_Review_1_Changes | Changes to make]]
 +
'''Summary of [[JSON_Integration_Adapter_Code_Review_1_Changes | changes]]'''
 +
# Allowing modes for all Composite message parts, not just the root.
 +
# Refactoring methods to check for != right condition instead of checking for the wrong condition to throw an exception. (whitelist instead of blacklist)
 +
# Formatting all primitives before writing or storing them (e.g. timestamps, decimal numbers.)
 +
# Creating a RootJSONMessagePartMapping extending JSONMessagePartMapping
  
# 1. Rewrite code to conform with NexJ suggestions and
+
===Phase 7. Code Review 2===
 +
* Proposed Date: Week of <del>September 23</del> October 15
  
Phase X. Second Code Review at NexJ
+
===Phase 8. Apply Changes from Code Review 2===
 +
*[[JSON_Integration_Adapter_Code_Review_2_Changes | Changes to make]]
  
# 1. Date TBA
+
===Phase 9. Code Review 3===
 +
* Week of November 14
  
Phase XI. Project Completion
+
===Phase 10. Apply Changes from Code Review 3===
 +
*[[JSON_Integration_Adapter_Code_Review_3_Changes | Changes to make]]
  
== Project Repository ==
 
To be determined
 
  
 
== Resources ==
 
== Resources ==
 +
JSON RFC : http://www.ietf.org/rfc/rfc4627.txt<br />
 +
Introduction to NexJ Studio Express : https://www.projects.openhealthtools.org/sf/go/doc1771?nav=1<br />
 
NexJ Developer's Guide<br />
 
NexJ Developer's Guide<br />
NexJ Integration Fundamentals
+
NexJ Integration Fundamentals<br />
 +
Open Health Tools Integration Platform https://www.projects.openhealthtools.org/sf/projects/oht_aip/<br />

Latest revision as of 22:41, 26 January 2014

Important.png
This page may be obsolete.
It contains historical information.

Project Goal

To create an adapter for the NexJ Core similar in methodology and design of existing message adapters (XML, Fixed, CSV etc.) but using the JSON format

Contributors


Current Status

  • Completed (February 02, 2012)


Project Repository

BitBucket : https://bitbucket.org/gbatumbya/nexjexpress-jsonintergrationadapter/
Deprecated: https://bitbucket.org/b_lim/nexj-express-json-integration-adapter/


Definitions

Term Description
Formatter Turns data into JSON
Parser Turns JSON into data
Message The metadata to be used when formatting and parsing a message. The grammar. It is a tree-like structure.
MessageInstance The information to be parsed or formatted

Because the Integration layer allows a Model to interact with external applications asynchronously, a description / grammar of the data to be exchanged between the two systems is defined using a Message in the Model.

  • Formatting is turning internal NexJ representation of a MessageInstance into JSON. The formatter is given a Message (the grammar), MessageInstance (the data), and a pipe. This accomplished by walking the Message tree-like structure while validating the data in the MessageInstance and streaming JSON format to the pipe. If the data in the MessageInstance does not conform to the Message, the formatter throws an exception.
  • Parsing is turning JSON representation of a MessageInstance into an internal NexJ representation of a MessageInstance. The parser is given a Message (the grammar) and an input stream. First the input stream is parsed for JSON using a JSONParser which returns either an Object or an Array. The formatter walks the Message building the structure of the MessageInstance and adding validated values in the object returned by the JSONParser to the MessageInstance. If the data from the input stream does not match the expected input at any time, the parser throws an exception.


Message Fundamentals

Message - Messages can contain values or other messages. The red nodes are messages, the green nodes are values.

NexJ Express Messages

Internally, messages are Transfer Objects. To determine if a node is a message, use instanceof on CompositeMessagePartInstance after retrieving the MessagePart. For example,

public void format(TransferObject tobj, Message message, Output out) throws IntegrationException
{
...
CompositeMessagePart root = message.getRoot(); // Gets the root of the message.
Iterator it = root.getPartIterator();
while (it.hasNext())
{
  part = (MessagePart)it.next());
  if (part instanceof CompositeMessagePartInstance)
  {
    // This part is a message
  }
  else if (part instanceof PrimitiveMessagePart)
  {
    // This part is a value
  }
...
}
...

NOTE: THE MESSAGE PARAMETER DOES NOT CONTAIN THE MESSAGE VALUES. THE MESSAGE PARAMETER CONTAINS THE MESSAGE METADATA. THE TRANSFER OBJECT CONTAINS THE MESSAGE VALUES WHICH MUST BE VALIDATED AGAINST THE MESSAGE TO ENSURE CORRECT FORMAT.

MessagePart
Parts of a message. Messages can contain values or other messages. NexJ Express has two types of message parts, CompositeMessagePart and PrimitiveMessagePart.
CompositeMessagePart
implementation is CompositeMessagePartInstance . The relationship between CompositeMessagePartInstance and PrimitiveMessagePart with the above picture is as follows - CompositeMessagePartInstance are messages (the red nodes) and PrimitiveMessagePart are values (the green nodes). To determine multiplicity of MessageParts, use isCollection() method of MessagePart. Note that multiplicity of the above screenshot are all [0..1], that is zero or one instance. Possible node multiplicities:
[0..1] 
zero or one instance (i.e. an optional entry)
[1..1] 
exactly one instance (i.e. required)
[1..N] 
collection of at least one, at most N instances
[0..0] 
collection of zero to infinite instances (displayed as [*])
[1..0] 
collection of at least one, possibly unlimited instances
XMLJSONMessageMappingLoader
Used by the framework to autoload JSONMessagePartMapping for each of the message parts.
JSONMessagePartMapping
Each node in the above picture may has a corresponding JSONMessagePartMapping. Each node may have its own mapping, with its own values initialized in XMLJSONMessageMappingLoader. In order to get the mapping, first cast MessagePart to a concrete class such as CompositeMessagePartInstance or PrimitiveMessagePart, then use part.getMapping(). The purpose of the mapping is metadata for each node.
JSONMessageFormatter
Used to turn messages into JSON format.
JSONMessageParser
Used to turn JSON into a message.

Algorithm

format(TransferObject tobj, Message message, Output out) Algorithm for format method is as follows

  1. Retrieve the root of the message
  2. Iterate through each of the parts of the root
    1. If the part is a CompositeMessagePartInstance, it is a message node
    2. If the part is a PrimitiveMessagePart, it is a value node
    3. Validate the part against the MessagePartMapping. Different types of validation must be done if the part is a Composite versus if it is a Primitive.
    4. If the part is a CompositeMessagePartInstance, recursively call the format method with TransferObject set to the part. Suggested to overload the format method to format(TransferObject tobj, MessagePart message, Output out) and pass in the part, since retrieving a message root with getRoot() will always get the highest root of the message but what you want is the parent.
    5. If the part is a PrimitiveMessagePart, write the message part to the output.


Project Phases

Phase 1. Research (DONE)

  1. Complete Fundamentals of NexJ Studio tutorial
  2. Complete NexJ Integration tutorial
  3. Install NexJ Studio Express from source

Phase 2. Design Proposal (DONE)

  1. Receive general approval for project
  2. Receive approval for JSON encoding options
  3. Receive approval for JSON formatting options
  4. Final Project Proposal

Phase 3. Create Classes (DONE)

  1. JSONMessagePartMapping
  2. XMLJSONMessageMappingLoader
  3. JSONMessageFormatter
  4. JSONMessageParser
  5. JSONMessageFormatterTest

Phase 4. Internal Code Review (DONE)

  1. Internally review code at CDOT

Phase 5. Code Review 1 (DONE)

  1. August 9, 2011
  2. Code review took place at NexJ with Grace Batumbya, Brian Lim and Andrew Borzenko (NexJ Developer) in attendance.

Phase 6. Apply Changes from Code Review 1

  1. Estimated Duration: 3 Weeks (August 29, 2011)
  2. Changes to make

Summary of changes

  1. Allowing modes for all Composite message parts, not just the root.
  2. Refactoring methods to check for != right condition instead of checking for the wrong condition to throw an exception. (whitelist instead of blacklist)
  3. Formatting all primitives before writing or storing them (e.g. timestamps, decimal numbers.)
  4. Creating a RootJSONMessagePartMapping extending JSONMessagePartMapping

Phase 7. Code Review 2

  • Proposed Date: Week of September 23 October 15

Phase 8. Apply Changes from Code Review 2

Phase 9. Code Review 3

  • Week of November 14

Phase 10. Apply Changes from Code Review 3


Resources

JSON RFC : http://www.ietf.org/rfc/rfc4627.txt
Introduction to NexJ Studio Express : https://www.projects.openhealthtools.org/sf/go/doc1771?nav=1
NexJ Developer's Guide
NexJ Integration Fundamentals
Open Health Tools Integration Platform https://www.projects.openhealthtools.org/sf/projects/oht_aip/