Verify FIXTradingCommunity/fix-simple-binary-encoding#127

Author: donmendelson

v1-0-STANDARD/doc/examples.md

@@ -75,3 +75,11 @@
 | `4f52443030303031` | 379 | BusinesRejectRefId | 0 | 8 | ORD00001 |
 | `06` | 380 | BusinessRejectReason | 8 | 1 | NotAuthorized |
 | `4e6f74206175...` | 58 | Text | 0 | 39 | Not authorized to trade that instrument |
+### Wire format of field encodings
+```
+00 50 d4 89 fe a2 24 13 09 fa 00                : P   $    
+```
+### Interpretation of field encodings
+|Wire format|Field ID|Name|Offset|Length|Interpreted value|
+|-----------|-------:|----|-----:|-----:|-----------------|
+| `0050d489fea2241309fa00` | 60 | TZTimestamp | 0 | 11 | 2013-09-17T02:30 |

v1-0-STANDARD/src/main/java/io/fixprotocol/sbe/examples/ExampleDumper.java

@@ -24,6 +24,7 @@
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.ZoneOffset;
+import java.time.format.DateTimeFormatter;
 import java.util.Arrays;
 import java.util.concurrent.TimeUnit;
 
@@ -52,6 +53,8 @@
 import io.fixprotocol.sbe.examples.messages.QtyEncodingDecoder;
 import io.fixprotocol.sbe.examples.messages.QtyEncodingEncoder;
 import io.fixprotocol.sbe.examples.messages.SideEnum;
+import io.fixprotocol.sbe.examples.messages.TzTimestampDecoder;
+import io.fixprotocol.sbe.examples.messages.TzTimestampEncoder;
 import io.fixprotocol.sbe.util.BufferDumper;
 
 
@@ -111,9 +114,6 @@ public class ExampleDumper {
    */
   public static final String MARKDOWN_TABLE_ROW_END = "|";
 
-  private final MessageHeaderDecoder mhDecoder = new MessageHeaderDecoder();
-
-
   /**
    * Output all examples
    * 
@@ -132,6 +132,7 @@ public static void main(String[] args)
     dumper.dumpAll(stream);
   }
 
+
   private static String wireFormat(byte[] bytes, int offset, int width) {
     StringWriter writer = new StringWriter();
     for (int index = 0; index < width; index++) {
@@ -143,11 +144,13 @@ private static String wireFormat(byte[] bytes, int offset, int width) {
   }
 
   private String blockBegin = MARKDOWN_BLOCK_BEGIN;
+
   private String blockEnd = MARKDOWN_BLOCK_END;
   private String headingBegin = MARKDOWN_HEADING_BEGIN;
   private String headingEnd = MARKDOWN_HEADING_END;
   private String literalBegin = MARKDOWN_LITERAL_BEGIN;
   private String literalEnd = MARKDOWN_LITERAL_END;
+  private final MessageHeaderDecoder mhDecoder = new MessageHeaderDecoder();
   private String tableColumnDelim = MARKDOWN_TABLE_COLUMN_DELIM;
   private String tableRowBegin = MARKDOWN_TABLE_ROW_BEGIN;
   private String tableRowEnd = MARKDOWN_TABLE_ROW_END;
@@ -177,6 +180,13 @@ public void dumpAll(PrintStream out) throws UnsupportedEncodingException {
     dump(bytes, size, out);
     heading("Interpretation", out);
     interpretBusinessMessageReject(bytes, size, out);
+    
+    Arrays.fill(bytes, (byte) 0);
+    size = encodeFieldEncodings(bytes);
+    heading("Wire format of field encodings", out);
+    dump(bytes, size, out);
+    heading("Interpretation of field encodings", out);
+    interpretFieldEncodings(bytes, size, out);
   }
 
   public int encodeBusinessMessageReject(byte bytes[]) throws UnsupportedEncodingException {
@@ -258,6 +268,24 @@ public int encodeExecutionReport(byte[] bytes) throws UnsupportedEncodingExcepti
     return offset;
   }
 
+  public int encodeFieldEncodings(byte[] bytes) {
+    TzTimestampEncoder tzEncoder = new TzTimestampEncoder();
+    MutableDirectBuffer buffer = new UnsafeBuffer(bytes);
+    int offset = 0;
+    tzEncoder.wrap(buffer, offset);
+    LocalDateTime dateTime = LocalDateTime.of(2013, 9, 17, 8, 30);
+    long time = TimeUnit.SECONDS.toNanos(dateTime.toEpochSecond(ZoneOffset.UTC));   
+    tzEncoder.time(time);
+    short unit = 9; // nanoseconds
+    tzEncoder.unit(unit);
+    byte timezoneHour = -6;
+    tzEncoder.timezoneHour(timezoneHour);
+    short timezoneMinute = 0;
+    tzEncoder.timezoneMinute(timezoneMinute);
+    offset += tzEncoder.encodedLength();
+    return offset;
+  }
+
   public int encodeOrderMsg(byte bytes[]) throws UnsupportedEncodingException {
     SofhFrameEncoder sofhEncoder = new SofhFrameEncoder();
     MessageHeaderEncoder mhEncoder = new MessageHeaderEncoder();
@@ -472,6 +500,26 @@ public void interpretExecutionReport(byte[] bytes, int size, PrintStream out) {
 
   }
 
+  public void interpretFieldEncodings(byte[] bytes, int size, PrintStream out) {
+    DirectBuffer buffer = new UnsafeBuffer(bytes);
+    interpretTableHeader(out);
+    int offset = 0;
+    TzTimestampDecoder tzDecoder = new TzTimestampDecoder();
+    tzDecoder.wrap(buffer, offset);
+    long time = tzDecoder.time();
+    byte hours = tzDecoder.timezoneHour();
+    short minutes = tzDecoder.timezoneMinute();
+    long epochSeconds = TimeUnit.NANOSECONDS.toSeconds(time);
+    int nanoOfSecond = (int) (time % 1000000000L);
+    LocalDateTime localDateTime = LocalDateTime.ofEpochSecond(epochSeconds, nanoOfSecond , ZoneOffset.ofHoursMinutes(hours, minutes));
+    interpretRow(
+        wireFormat(bytes, offset,
+            tzDecoder.encodedLength()),
+        NewOrderSingleDecoder.transactTimeId(), "TZTimestamp",
+        offset,
+        tzDecoder.encodedLength(), localDateTime.toString(), out);
+  }
+
   public void interpretOrderMsg(byte[] bytes, int size, PrintStream out) {
     DirectBuffer buffer = new UnsafeBuffer(bytes);
     interpretTableHeader(out);
@@ -598,6 +646,10 @@ private String decimalToString(long mantissa, int exponent) {
     }
   }
 
+  private void heading(String text, PrintStream out) {
+    out.format("%s%s%s\n", headingBegin, text, headingEnd);
+  }
+
   private int interpretFramingHeader(byte[] bytes, PrintStream out, DirectBuffer buffer, int offset) {
     SofhFrameDecoder sofhDecoder = new SofhFrameDecoder();
     sofhDecoder.wrap(buffer, offset);
@@ -650,10 +702,6 @@ private int interpretMessageHeader(byte[] bytes, PrintStream out) {
     return mhDecoder.offset() + mhDecoder.encodedLength();
   }
 
-  private void heading(String text, PrintStream out) {
-    out.format("%s%s%s\n", headingBegin, text, headingEnd);
-  }
-
   private void interpretRow(String wireFormat, int fieldId, String name, int offset, int length,
       String interpreted, PrintStream out) {
     out.format("%s %s%s%s %s %s %s %s %s %d %s %d %s %s %s\n", tableRowBegin, literalBegin,

v1-0-STANDARD/src/main/resources/Examples.xml

@@ -37,6 +37,13 @@ xsi:schemaLocation="http://fixprotocol.io/2016/sbe sbe.xsd">
 			<type name="mantissa" primitiveType="int32"/>
 			<type name="exponent" presence="constant" primitiveType="int8">0</type>
 		</composite>
+		<composite name="tzTimestamp" semanticType="TZTimestamp">
+		    <type name="time" primitiveType="uint64" />
+		    <type name="unit" primitiveType="uint8" />
+		    <!-- Sign of timezone offset is on hour subfield -->
+		    <type name="timezoneHour" primitiveType="int8" minValue="-12" maxValue="14" />
+		    <type name="timezoneMinute" primitiveType="uint8" maxValue="59" />
+		</composite>
 		<enum name="businessRejectReasonEnum" encodingType="intEnumEncoding">
 			<validValue name="Other">0</validValue>
 			<validValue name="UnknownID">1</validValue>
@@ -108,4 +115,7 @@ xsi:schemaLocation="http://fixprotocol.io/2016/sbe sbe.xsd">
 		<field name="Price" id="44" type="optionalDecimalEncoding" offset="38" semanticType="Price"/>
 		<field name="StopPx" id="99" type="optionalDecimalEncoding" offset="46" semanticType="Price"/>
 	</sbe:message>
+	<sbe:message name="FieldEncodings" id="999">
+		<field name="TzTimestamp" id="999" type="tzTimestamp"/>
+	</sbe:message>
 </sbe:messageSchema>

v2-0-RC2/src/main/resources/Examples.xml

@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
-<sbe:messageSchema xmlns:sbe="http://fixprotocol.io/2017/sbe" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" package="Examples" id="91" version="0" byteOrder="littleEndian" xsi:schemaLocation="http://fixprotocol.io/2017/sbe ../../../../../fix-simple-binary-encoding/v2-0-RC2/resources/xsd/sbe-2.0rc2.xsd">
+<sbe:messageSchema xmlns:sbe="http://fixprotocol.io/2017/sbe" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" package="Examples" id="91" version="0" byteOrder="littleEndian" xsi:schemaLocation="http://fixprotocol.io/2017/sbe sbe-2.0rc2.xsd">
 	<types>
 		<type name="date" primitiveType="uint16"/>
 		<type name="enumEncoding" primitiveType="char"/>