| /** |
| * @author: Jeff Thompson |
| * See COPYING for copyright and distribution information. |
| * This class represents Interest Objects |
| */ |
| |
| /** |
| * A BinaryXmlWireFormat implements the WireFormat interface for encoding and decoding in binary XML. |
| * @constructor |
| */ |
| var BinaryXmlWireFormat = function BinaryXmlWireFormat() { |
| }; |
| |
| /** |
| * Encode the interest and return a Uint8Array. |
| * @param {Interest} interest |
| * @returns {UInt8Array} |
| */ |
| BinaryXmlWireFormat.prototype.encodeInterest = function(interest) { |
| var encoder = new BinaryXMLEncoder(); |
| BinaryXmlWireFormat.encodeInterest(interest, encoder); |
| return encoder.getReducedOstream(); |
| }; |
| |
| /** |
| * Decode the input and put the result in interest. |
| * @param {Interest} interest |
| * @param {Uint8Array} input |
| */ |
| BinaryXmlWireFormat.prototype.decodeInterest = function(interest, input) { |
| var decoder = new BinaryXMLDecoder(input); |
| BinaryXmlWireFormat.decodeInterest(interest, decoder); |
| }; |
| |
| /** |
| * Encode the contentObject and return a Uint8Array. |
| * @param {ContentObject} contentObject |
| * @returns {Uint8Array} |
| */ |
| BinaryXmlWireFormat.prototype.encodeContentObject = function(contentObject) { |
| var encoder = new BinaryXMLEncoder(); |
| BinaryXmlWireFormat.encodeContentObject(contentObject, encoder); |
| return encoder.getReducedOstream(); |
| }; |
| |
| /** |
| * Decode the input and put the result in contentObject. |
| * @param {ContentObject} contentObject |
| * @param {Uint8Array} input |
| */ |
| BinaryXmlWireFormat.prototype.decodeContentObject = function(contentObject, input) { |
| var decoder = new BinaryXMLDecoder(input); |
| BinaryXmlWireFormat.decodeContentObject(contentObject, decoder); |
| }; |
| |
| // Default object. |
| BinaryXmlWireFormat.instance = new BinaryXmlWireFormat(); |
| |
| /** |
| * Encode the interest by calling the operations on the encoder. |
| * @param {Interest} interest |
| * @param {BinaryXMLEncoder} encoder |
| */ |
| BinaryXmlWireFormat.encodeInterest = function(interest, encoder) { |
| encoder.writeStartElement(CCNProtocolDTags.Interest); |
| |
| interest.name.to_ccnb(encoder); |
| |
| if (null != interest.minSuffixComponents) |
| encoder.writeElement(CCNProtocolDTags.MinSuffixComponents, interest.minSuffixComponents); |
| |
| if (null != interest.maxSuffixComponents) |
| encoder.writeElement(CCNProtocolDTags.MaxSuffixComponents, interest.maxSuffixComponents); |
| |
| if (null != interest.publisherPublicKeyDigest) |
| interest.publisherPublicKeyDigest.to_ccnb(encoder); |
| |
| if (null != interest.exclude) |
| interest.exclude.to_ccnb(encoder); |
| |
| if (null != interest.childSelector) |
| encoder.writeElement(CCNProtocolDTags.ChildSelector, interest.childSelector); |
| |
| if (interest.DEFAULT_ANSWER_ORIGIN_KIND != interest.answerOriginKind && interest.answerOriginKind!=null) |
| encoder.writeElement(CCNProtocolDTags.AnswerOriginKind, interest.answerOriginKind); |
| |
| if (null != interest.scope) |
| encoder.writeElement(CCNProtocolDTags.Scope, interest.scope); |
| |
| if (null != interest.interestLifetime) |
| encoder.writeElement(CCNProtocolDTags.InterestLifetime, |
| DataUtils.nonNegativeIntToBigEndian((interest.interestLifetime / 1000.0) * 4096)); |
| |
| if (null != interest.nonce) |
| encoder.writeElement(CCNProtocolDTags.Nonce, interest.nonce); |
| |
| encoder.writeEndElement(); |
| }; |
| |
| /** |
| * Use the decoder to place the result in interest. |
| * @param {Interest} interest |
| * @param {BinaryXMLDecoder} decoder |
| */ |
| BinaryXmlWireFormat.decodeInterest = function(interest, decoder) { |
| decoder.readStartElement(CCNProtocolDTags.Interest); |
| |
| interest.name = new Name(); |
| interest.name.from_ccnb(decoder); |
| |
| if (decoder.peekStartElement(CCNProtocolDTags.MinSuffixComponents)) |
| interest.minSuffixComponents = decoder.readIntegerElement(CCNProtocolDTags.MinSuffixComponents); |
| else |
| interest.minSuffixComponents = null; |
| |
| if (decoder.peekStartElement(CCNProtocolDTags.MaxSuffixComponents)) |
| interest.maxSuffixComponents = decoder.readIntegerElement(CCNProtocolDTags.MaxSuffixComponents); |
| else |
| interest.maxSuffixComponents = null; |
| |
| if (decoder.peekStartElement(CCNProtocolDTags.PublisherPublicKeyDigest)) { |
| interest.publisherPublicKeyDigest = new PublisherPublicKeyDigest(); |
| interest.publisherPublicKeyDigest.from_ccnb(decoder); |
| } |
| else |
| interest.publisherPublicKeyDigest = null; |
| |
| if (decoder.peekStartElement(CCNProtocolDTags.Exclude)) { |
| interest.exclude = new Exclude(); |
| interest.exclude.from_ccnb(decoder); |
| } |
| else |
| interest.exclude = null; |
| |
| if (decoder.peekStartElement(CCNProtocolDTags.ChildSelector)) |
| interest.childSelector = decoder.readIntegerElement(CCNProtocolDTags.ChildSelector); |
| else |
| interest.childSelector = null; |
| |
| if (decoder.peekStartElement(CCNProtocolDTags.AnswerOriginKind)) |
| interest.answerOriginKind = decoder.readIntegerElement(CCNProtocolDTags.AnswerOriginKind); |
| else |
| interest.answerOriginKind = null; |
| |
| if (decoder.peekStartElement(CCNProtocolDTags.Scope)) |
| interest.scope = decoder.readIntegerElement(CCNProtocolDTags.Scope); |
| else |
| interest.scope = null; |
| |
| if (decoder.peekStartElement(CCNProtocolDTags.InterestLifetime)) |
| interest.interestLifetime = 1000.0 * DataUtils.bigEndianToUnsignedInt |
| (decoder.readBinaryElement(CCNProtocolDTags.InterestLifetime)) / 4096; |
| else |
| interest.interestLifetime = null; |
| |
| if (decoder.peekStartElement(CCNProtocolDTags.Nonce)) |
| interest.nonce = decoder.readBinaryElement(CCNProtocolDTags.Nonce); |
| else |
| interest.nonce = null; |
| |
| decoder.readEndElement(); |
| }; |
| |
| /** |
| * Encode the contentObject by calling the operations on the encoder. |
| * @param {ContentObject} contentObject |
| * @param {BinaryXMLEncoder} encoder |
| */ |
| BinaryXmlWireFormat.encodeContentObject = function(contentObject, encoder) { |
| //TODO verify name, SignedInfo and Signature is present |
| encoder.writeStartElement(contentObject.getElementLabel()); |
| |
| if (null != contentObject.signature) |
| contentObject.signature.to_ccnb(encoder); |
| |
| contentObject.startSIG = encoder.offset; |
| |
| if (null != contentObject.name) |
| contentObject.name.to_ccnb(encoder); |
| |
| if (null != contentObject.signedInfo) |
| contentObject.signedInfo.to_ccnb(encoder); |
| |
| encoder.writeElement(CCNProtocolDTags.Content, contentObject.content); |
| |
| contentObject.endSIG = encoder.offset; |
| |
| encoder.writeEndElement(); |
| |
| contentObject.saveRawData(encoder.ostream); |
| }; |
| |
| /** |
| * Use the decoder to place the result in contentObject. |
| * @param {ContentObject} contentObject |
| * @param {BinaryXMLDecoder} decoder |
| */ |
| BinaryXmlWireFormat.decodeContentObject = function(contentObject, decoder) { |
| // TODO VALIDATE THAT ALL FIELDS EXCEPT SIGNATURE ARE PRESENT |
| decoder.readStartElement(contentObject.getElementLabel()); |
| |
| if( decoder.peekStartElement(CCNProtocolDTags.Signature) ){ |
| contentObject.signature = new Signature(); |
| contentObject.signature.from_ccnb(decoder); |
| } |
| else |
| contentObject.signature = null; |
| |
| contentObject.startSIG = decoder.offset; |
| |
| contentObject.name = new Name(); |
| contentObject.name.from_ccnb(decoder); |
| |
| if( decoder.peekStartElement(CCNProtocolDTags.SignedInfo) ){ |
| contentObject.signedInfo = new SignedInfo(); |
| contentObject.signedInfo.from_ccnb(decoder); |
| } |
| else |
| contentObject.signedInfo = null; |
| |
| contentObject.content = decoder.readBinaryElement(CCNProtocolDTags.Content, null, true); |
| |
| contentObject.endSIG = decoder.offset; |
| |
| decoder.readEndElement(); |
| |
| contentObject.saveRawData(decoder.input); |
| }; |