|
|
|
|
@ -6,15 +6,24 @@ import org.w3c.dom.Element;
|
|
|
|
|
import seng302.Data.RaceData;
|
|
|
|
|
import seng302.Mock.Regatta;
|
|
|
|
|
import seng302.Mock.RegattaDataSource;
|
|
|
|
|
import seng302.Exceptions.InvalidBoatDataException;
|
|
|
|
|
import seng302.Exceptions.InvalidRaceDataException;
|
|
|
|
|
import seng302.Exceptions.InvalidRegattaDataException;
|
|
|
|
|
import seng302.Model.Race;
|
|
|
|
|
import seng302.RaceDataSource;
|
|
|
|
|
|
|
|
|
|
import javax.xml.parsers.DocumentBuilder;
|
|
|
|
|
import javax.xml.parsers.DocumentBuilderFactory;
|
|
|
|
|
import javax.xml.parsers.ParserConfigurationException;
|
|
|
|
|
import javax.xml.transform.Transformer;
|
|
|
|
|
import javax.xml.transform.TransformerConfigurationException;
|
|
|
|
|
import javax.xml.transform.TransformerException;
|
|
|
|
|
import javax.xml.transform.TransformerFactory;
|
|
|
|
|
import javax.xml.transform.dom.DOMSource;
|
|
|
|
|
import javax.xml.transform.stream.StreamResult;
|
|
|
|
|
import java.io.IOException;
|
|
|
|
|
import java.io.OutputStream;
|
|
|
|
|
import java.io.StringWriter;
|
|
|
|
|
import java.util.List;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
@ -24,34 +33,50 @@ public class Event {
|
|
|
|
|
|
|
|
|
|
RaceDataSource raceDataSource;
|
|
|
|
|
RegattaDataSource regattaDataSource;
|
|
|
|
|
///The stream to which we send all data.
|
|
|
|
|
private OutputStream outputStream;
|
|
|
|
|
|
|
|
|
|
public Event(RaceDataSource raceData, RegattaDataSource regattaData) {
|
|
|
|
|
public Event(RaceDataSource raceData, RegattaDataSource regattaData, OutputStream outputStream) {
|
|
|
|
|
this.raceDataSource = raceData;
|
|
|
|
|
this.regattaDataSource = regattaData;
|
|
|
|
|
this.outputStream = outputStream;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public void start() {
|
|
|
|
|
public void start()
|
|
|
|
|
{
|
|
|
|
|
System.out.println("\nREGATTA DATA\n");//TEMP REMOVE debug
|
|
|
|
|
sendRegattaData();
|
|
|
|
|
System.out.println("\nRACE DATA\n");//TEMP REMOVE debug
|
|
|
|
|
sendRaceData();
|
|
|
|
|
System.out.println("\nBOAT DATA\n");//TEMP REMOVE debug
|
|
|
|
|
sendBoatData();
|
|
|
|
|
|
|
|
|
|
Race newRace = new Race(raceDataSource, 15);
|
|
|
|
|
System.out.println("RACE STARTING!!\n\n");//TEMP REMOVE debug
|
|
|
|
|
|
|
|
|
|
Race newRace = new Race(raceDataSource, 15, this.outputStream);
|
|
|
|
|
new Thread((newRace)).start();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public void sendRegattaData() {
|
|
|
|
|
try {
|
|
|
|
|
public void sendRegattaData() throws InvalidRegattaDataException {
|
|
|
|
|
|
|
|
|
|
Regatta regatta = regattaDataSource.getRegatta();
|
|
|
|
|
Regatta regatta = regattaDataSource.getRegatta();
|
|
|
|
|
|
|
|
|
|
DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();
|
|
|
|
|
DocumentBuilder docBuilder = docFactory.newDocumentBuilder();
|
|
|
|
|
DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();
|
|
|
|
|
DocumentBuilder docBuilder = null;
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
docBuilder = docFactory.newDocumentBuilder();
|
|
|
|
|
}
|
|
|
|
|
catch (ParserConfigurationException e)
|
|
|
|
|
{
|
|
|
|
|
throw new InvalidRegattaDataException();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//root element
|
|
|
|
|
Document doc = docBuilder.newDocument();
|
|
|
|
|
Element rootElement = doc.createElement("RegattaConfig");
|
|
|
|
|
doc.appendChild(rootElement);
|
|
|
|
|
//root element
|
|
|
|
|
Document doc = docBuilder.newDocument();
|
|
|
|
|
Element rootElement = doc.createElement("RegattaConfig");
|
|
|
|
|
doc.appendChild(rootElement);
|
|
|
|
|
|
|
|
|
|
//regattaID element
|
|
|
|
|
Element regattaID = doc.createElement("RegattaID");
|
|
|
|
|
@ -93,121 +118,199 @@ public class Event {
|
|
|
|
|
magneticVariation.appendChild(doc.createTextNode(Double.toString(regatta.getMagneticVariation())));
|
|
|
|
|
rootElement.appendChild(magneticVariation);
|
|
|
|
|
|
|
|
|
|
TransformerFactory trasformerFactory = TransformerFactory.newInstance();
|
|
|
|
|
Transformer transformer = trasformerFactory.newTransformer();
|
|
|
|
|
DOMSource source = new DOMSource(doc);
|
|
|
|
|
TransformerFactory transformerFactory = TransformerFactory.newInstance();
|
|
|
|
|
Transformer transformer = null;
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
transformer = transformerFactory.newTransformer();
|
|
|
|
|
}
|
|
|
|
|
catch (TransformerConfigurationException e)
|
|
|
|
|
{
|
|
|
|
|
throw new InvalidRegattaDataException();
|
|
|
|
|
}
|
|
|
|
|
DOMSource source = new DOMSource(doc);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//print XML object to check for correctness
|
|
|
|
|
StreamResult result = new StreamResult(System.out);
|
|
|
|
|
//Serialize document.
|
|
|
|
|
StringWriter stringWriter = new StringWriter();
|
|
|
|
|
StreamResult result = new StreamResult(stringWriter);
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
transformer.transform(source,result);
|
|
|
|
|
}
|
|
|
|
|
catch (TransformerException e)
|
|
|
|
|
{
|
|
|
|
|
throw new InvalidRegattaDataException();
|
|
|
|
|
}
|
|
|
|
|
//TODO now we should place in XML message object.
|
|
|
|
|
//TODO now we should serialize xml message object.
|
|
|
|
|
//TODO now we should write serialized xml message over this.outputStream.
|
|
|
|
|
|
|
|
|
|
} catch (Exception e){
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
this.outputStream.write(stringWriter.toString().getBytes());//TEMP currently we output the XML doc, not the serialized message.
|
|
|
|
|
}
|
|
|
|
|
catch (IOException e)
|
|
|
|
|
{
|
|
|
|
|
throw new InvalidRegattaDataException();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public void sendRaceData() {
|
|
|
|
|
public void sendRaceData() throws InvalidRaceDataException
|
|
|
|
|
{
|
|
|
|
|
RaceData raceData = new RaceData(raceDataSource);
|
|
|
|
|
raceData.createXML();
|
|
|
|
|
//Serialize race data to an XML as a string.
|
|
|
|
|
String xmlString = raceData.createXML();
|
|
|
|
|
|
|
|
|
|
//TODO now we should place in XML message object.
|
|
|
|
|
//TODO now we should serialize xml message object.
|
|
|
|
|
//TODO now we should write serialized xml message over this.outputStream.
|
|
|
|
|
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
this.outputStream.write(xmlString.getBytes());//TEMP currently we output the XML doc, not the serialized message.
|
|
|
|
|
}
|
|
|
|
|
catch (IOException e)
|
|
|
|
|
{
|
|
|
|
|
throw new InvalidRaceDataException();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public void sendBoatData() {
|
|
|
|
|
public void sendBoatData() throws InvalidBoatDataException
|
|
|
|
|
{
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
List<BoatInRace> boatData = raceDataSource.getBoats();
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
|
|
DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();
|
|
|
|
|
DocumentBuilder docBuilder = docFactory.newDocumentBuilder();
|
|
|
|
|
|
|
|
|
|
//root element
|
|
|
|
|
Document doc = docBuilder.newDocument();
|
|
|
|
|
Element rootElement = doc.createElement("BoatConfig");
|
|
|
|
|
doc.appendChild(rootElement);
|
|
|
|
|
DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();
|
|
|
|
|
DocumentBuilder docBuilder = null;
|
|
|
|
|
|
|
|
|
|
//Boats element
|
|
|
|
|
Element boats = doc.createElement("Boats");
|
|
|
|
|
rootElement.appendChild(boats);
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
docBuilder = docFactory.newDocumentBuilder();
|
|
|
|
|
}
|
|
|
|
|
catch (ParserConfigurationException e)
|
|
|
|
|
{
|
|
|
|
|
throw new InvalidBoatDataException();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
for (int i=0; i < boatData.size(); i++) {
|
|
|
|
|
//root element
|
|
|
|
|
Document doc = docBuilder.newDocument();
|
|
|
|
|
Element rootElement = doc.createElement("BoatConfig");
|
|
|
|
|
doc.appendChild(rootElement);
|
|
|
|
|
|
|
|
|
|
//Boat element
|
|
|
|
|
Element boat = doc.createElement("Boat");
|
|
|
|
|
//Boats element
|
|
|
|
|
Element boats = doc.createElement("Boats");
|
|
|
|
|
rootElement.appendChild(boats);
|
|
|
|
|
|
|
|
|
|
//Type attribute
|
|
|
|
|
Attr attrType = doc.createAttribute("Type");
|
|
|
|
|
attrType.setValue("Mark");
|
|
|
|
|
boat.setAttributeNode(attrType);
|
|
|
|
|
for (int i=0; i < boatData.size(); i++) {
|
|
|
|
|
|
|
|
|
|
//SourceID attribute
|
|
|
|
|
Attr attrSourceID = doc.createAttribute("SourceID");
|
|
|
|
|
attrSourceID.setValue(Integer.toString(boatData.get(i).getSourceID()));
|
|
|
|
|
boat.setAttributeNode(attrSourceID);
|
|
|
|
|
//Boat element
|
|
|
|
|
Element boat = doc.createElement("Boat");
|
|
|
|
|
|
|
|
|
|
//ShapeID attribute
|
|
|
|
|
Attr attrShapeID = doc.createAttribute("ShapeID");
|
|
|
|
|
attrShapeID.setValue("0");
|
|
|
|
|
boat.setAttributeNode(attrShapeID);
|
|
|
|
|
//Type attribute
|
|
|
|
|
Attr attrType = doc.createAttribute("Type");
|
|
|
|
|
attrType.setValue("Mark");
|
|
|
|
|
boat.setAttributeNode(attrType);
|
|
|
|
|
|
|
|
|
|
//HullNum attribute
|
|
|
|
|
Attr attrHullNum = doc.createAttribute("HullNum");
|
|
|
|
|
attrHullNum.setValue("RG01");
|
|
|
|
|
boat.setAttributeNode(attrHullNum);
|
|
|
|
|
//SourceID attribute
|
|
|
|
|
Attr attrSourceID = doc.createAttribute("SourceID");
|
|
|
|
|
attrSourceID.setValue(Integer.toString(boatData.get(i).getSourceID()));
|
|
|
|
|
boat.setAttributeNode(attrSourceID);
|
|
|
|
|
|
|
|
|
|
//StoweName attribute
|
|
|
|
|
Attr attrStoweName = doc.createAttribute("StoweName");
|
|
|
|
|
attrStoweName.setValue(boatData.get(i).getAbbrev());
|
|
|
|
|
boat.setAttributeNode(attrStoweName);
|
|
|
|
|
//ShapeID attribute
|
|
|
|
|
Attr attrShapeID = doc.createAttribute("ShapeID");
|
|
|
|
|
attrShapeID.setValue("0");
|
|
|
|
|
boat.setAttributeNode(attrShapeID);
|
|
|
|
|
|
|
|
|
|
//ShortName attribute
|
|
|
|
|
Attr attrShortName = doc.createAttribute("ShortName");
|
|
|
|
|
attrShortName.setValue(boatData.get(i).getAbbrev());
|
|
|
|
|
boat.setAttributeNode(attrShortName);
|
|
|
|
|
//HullNum attribute
|
|
|
|
|
Attr attrHullNum = doc.createAttribute("HullNum");
|
|
|
|
|
attrHullNum.setValue("RG01");
|
|
|
|
|
boat.setAttributeNode(attrHullNum);
|
|
|
|
|
|
|
|
|
|
//BoatName attribute
|
|
|
|
|
Attr attrBoatName = doc.createAttribute("BoatName");
|
|
|
|
|
attrBoatName.setValue(boatData.get(i).toString());
|
|
|
|
|
boat.setAttributeNode(attrBoatName);
|
|
|
|
|
//StoweName attribute
|
|
|
|
|
Attr attrStoweName = doc.createAttribute("StoweName");
|
|
|
|
|
attrStoweName.setValue(boatData.get(i).getAbbrev());
|
|
|
|
|
boat.setAttributeNode(attrStoweName);
|
|
|
|
|
|
|
|
|
|
//GPSCoord for element
|
|
|
|
|
Element GPSCoord = doc.createElement("GPSposition");
|
|
|
|
|
//ShortName attribute
|
|
|
|
|
Attr attrShortName = doc.createAttribute("ShortName");
|
|
|
|
|
attrShortName.setValue(boatData.get(i).getAbbrev());
|
|
|
|
|
boat.setAttributeNode(attrShortName);
|
|
|
|
|
|
|
|
|
|
//Z axis attribute
|
|
|
|
|
Attr attrZCoord = doc.createAttribute("Z");
|
|
|
|
|
attrZCoord.setValue("0");
|
|
|
|
|
GPSCoord.setAttributeNode(attrZCoord);
|
|
|
|
|
//BoatName attribute
|
|
|
|
|
Attr attrBoatName = doc.createAttribute("BoatName");
|
|
|
|
|
attrBoatName.setValue(boatData.get(i).toString());
|
|
|
|
|
boat.setAttributeNode(attrBoatName);
|
|
|
|
|
|
|
|
|
|
//Y axis attribute
|
|
|
|
|
Attr attrYCoord = doc.createAttribute("Y");
|
|
|
|
|
attrYCoord.setValue(Double.toString(boatData.get(i).getCurrentPosition().getLatitude()));
|
|
|
|
|
GPSCoord.setAttributeNode(attrYCoord);
|
|
|
|
|
//GPSCoord for element
|
|
|
|
|
Element GPSCoord = doc.createElement("GPSposition");
|
|
|
|
|
|
|
|
|
|
//X axis attribute
|
|
|
|
|
Attr attrXCoord = doc.createAttribute("X");
|
|
|
|
|
attrXCoord.setValue(Double.toString(boatData.get(i).getCurrentPosition().getLongitude()));
|
|
|
|
|
GPSCoord.setAttributeNode(attrXCoord);
|
|
|
|
|
//Z axis attribute
|
|
|
|
|
Attr attrZCoord = doc.createAttribute("Z");
|
|
|
|
|
attrZCoord.setValue("0");
|
|
|
|
|
GPSCoord.setAttributeNode(attrZCoord);
|
|
|
|
|
|
|
|
|
|
//Write GPSCoord to boat
|
|
|
|
|
boat.appendChild(GPSCoord);
|
|
|
|
|
//Y axis attribute
|
|
|
|
|
Attr attrYCoord = doc.createAttribute("Y");
|
|
|
|
|
attrYCoord.setValue(Double.toString(boatData.get(i).getCurrentPosition().getLatitude()));
|
|
|
|
|
GPSCoord.setAttributeNode(attrYCoord);
|
|
|
|
|
|
|
|
|
|
//Write boat to boats
|
|
|
|
|
boats.appendChild(boat);
|
|
|
|
|
//X axis attribute
|
|
|
|
|
Attr attrXCoord = doc.createAttribute("X");
|
|
|
|
|
attrXCoord.setValue(Double.toString(boatData.get(i).getCurrentPosition().getLongitude()));
|
|
|
|
|
GPSCoord.setAttributeNode(attrXCoord);
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
//Write GPSCoord to boat
|
|
|
|
|
boat.appendChild(GPSCoord);
|
|
|
|
|
|
|
|
|
|
TransformerFactory trasformerFactory = TransformerFactory.newInstance();
|
|
|
|
|
Transformer transformer = trasformerFactory.newTransformer();
|
|
|
|
|
DOMSource source = new DOMSource(doc);
|
|
|
|
|
//Write boat to boats
|
|
|
|
|
boats.appendChild(boat);
|
|
|
|
|
|
|
|
|
|
//print XML object to check for correctness
|
|
|
|
|
StreamResult result = new StreamResult(System.out);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
TransformerFactory trasformerFactory = TransformerFactory.newInstance();
|
|
|
|
|
Transformer transformer = null;
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
transformer = trasformerFactory.newTransformer();
|
|
|
|
|
}
|
|
|
|
|
catch (TransformerConfigurationException e)
|
|
|
|
|
{
|
|
|
|
|
throw new InvalidBoatDataException();
|
|
|
|
|
}
|
|
|
|
|
DOMSource source = new DOMSource(doc);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//Serialize document.
|
|
|
|
|
StringWriter stringWriter = new StringWriter();
|
|
|
|
|
StreamResult result = new StreamResult(stringWriter);
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
transformer.transform(source,result);
|
|
|
|
|
}
|
|
|
|
|
catch (TransformerException e)
|
|
|
|
|
{
|
|
|
|
|
throw new InvalidBoatDataException();
|
|
|
|
|
}
|
|
|
|
|
//TODO now we should place in XML message object.
|
|
|
|
|
//TODO now we should serialize xml message object.
|
|
|
|
|
//TODO now we should write serialized xml message over this.outputStream.
|
|
|
|
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
this.outputStream.write(stringWriter.toString().getBytes());//TEMP currently we output the XML doc, not the serialized message.
|
|
|
|
|
}
|
|
|
|
|
catch (IOException e)
|
|
|
|
|
{
|
|
|
|
|
throw new InvalidBoatDataException();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|