blob: 5f1c746d23d39322faa91bc82f5a368ca8f10dde [file] [log] [blame]
Wentao Shangc0311e52012-12-03 10:38:23 -08001/**
Jeff Thompson5b265a72012-11-12 01:13:08 -08002 * @author: Meki Cherkaoui, Jeff Thompson, Wentao Shang
Jeff Thompson745026e2012-10-13 12:49:20 -07003 * See COPYING for copyright and distribution information.
4 * This class represents the top-level object for communicating with an NDN host.
5 */
Meki Cherkaoui8f173612012-06-06 01:05:40 -07006
Jeff Thompson3c263812012-12-01 17:20:28 -08007var LOG = 0;
Jeff Thompson5b265a72012-11-12 01:13:08 -08008
Jeff Thompsone06b31e2012-09-30 17:19:19 -07009/**
Jeff Thompson5b265a72012-11-12 01:13:08 -080010 * settings is an associative array with the following defaults:
11 * {
Jeff Thompson5b265a72012-11-12 01:13:08 -080012 * getTransport: function() { return new WebSocketTransport(); }
Jeff Thompsond3a80dc2012-12-16 17:52:43 -080013 * getHostAndPort: transport.defaultGetHostAndPort,
Jeff Thompsond771b122013-01-26 19:04:41 -080014 * host: null, // If null, use getHostAndPort when connecting.
Jeff Thompsond3a80dc2012-12-16 17:52:43 -080015 * port: 9696,
Wentao Shangc0311e52012-12-03 10:38:23 -080016 * onopen: function() { if (LOG > 3) console.log("NDN connection established."); }
17 * onclose: function() { if (LOG > 3) console.log("NDN connection closed."); }
Jeff Thompson5b265a72012-11-12 01:13:08 -080018 * }
Jeff Thompsond3a80dc2012-12-16 17:52:43 -080019 *
20 * getHostAndPort is a function, on each call it returns a new { host: host, port: port } or
21 * null if there are no more hosts.
Jeff Thompsone06b31e2012-09-30 17:19:19 -070022 */
Jeff Thompson5b265a72012-11-12 01:13:08 -080023var NDN = function NDN(settings) {
24 settings = (settings || {});
Jeff Thompson5b265a72012-11-12 01:13:08 -080025 var getTransport = (settings.getTransport || function() { return new WebSocketTransport(); });
Wentao Shang0e291c82012-12-02 23:36:29 -080026 this.transport = getTransport();
Jeff Thompsond3a80dc2012-12-16 17:52:43 -080027 this.getHostAndPort = (settings.getHostAndPort || this.transport.defaultGetHostAndPort);
Jeff Thompsond771b122013-01-26 19:04:41 -080028 this.host = (settings.host !== undefined ? settings.host : null);
Jeff Thompsond3a80dc2012-12-16 17:52:43 -080029 this.port = (settings.port || 9696);
Wentao Shang0e291c82012-12-02 23:36:29 -080030 this.readyStatus = NDN.UNOPEN;
Wentao Shangd4607392013-01-24 23:08:49 -080031 this.verify = (settings.verify !== undefined ? settings.verify : true);
Wentao Shang0e291c82012-12-02 23:36:29 -080032 // Event handler
Wentao Shangc0311e52012-12-03 10:38:23 -080033 this.onopen = (settings.onopen || function() { if (LOG > 3) console.log("NDN connection established."); });
34 this.onclose = (settings.onclose || function() { if (LOG > 3) console.log("NDN connection closed."); });
Jeff Thompson75771cb2013-01-20 23:27:38 -080035 this.ccndid = null;
Meki Cherkaoui8f173612012-06-06 01:05:40 -070036};
37
Wentao Shang0e291c82012-12-02 23:36:29 -080038NDN.UNOPEN = 0; // created but not opened yet
39NDN.OPENED = 1; // connection to ccnd opened
40NDN.CLOSED = 2; // connection to ccnd closed
Jeff Thompson5b265a72012-11-12 01:13:08 -080041
Wentao Shangb42483a2013-01-03 15:32:32 -080042NDN.ccndIdFetcher = new Name('/%C1.M.S.localhost/%C1.M.SRV/ccnd/KEY');
Jeff Thompson5b265a72012-11-12 01:13:08 -080043
Wentao Shangb42483a2013-01-03 15:32:32 -080044NDN.prototype.createRoute = function(host, port) {
Meki Cherkaoui8f173612012-06-06 01:05:40 -070045 this.host=host;
46 this.port=port;
Wentao Shangb42483a2013-01-03 15:32:32 -080047};
Meki Cherkaoui8f173612012-06-06 01:05:40 -070048
Wentao Shang82854bd2012-12-27 14:14:41 -080049
50NDN.KeyStore = new Array();
51
Wentao Shangb5d0c3e2012-12-30 11:12:03 -080052var KeyStoreEntry = function KeyStoreEntry(name, rsa, time) {
Wentao Shang82854bd2012-12-27 14:14:41 -080053 this.keyName = name; // KeyName
Wentao Shang82854bd2012-12-27 14:14:41 -080054 this.rsaKey = rsa; // RSA key
Wentao Shangb5d0c3e2012-12-30 11:12:03 -080055 this.timeStamp = time; // Time Stamp
56};
57
58NDN.addKeyEntry = function(/* KeyStoreEntry */ keyEntry) {
59 var result = NDN.getKeyByName(keyEntry.keyName);
60 if (result == null)
61 NDN.KeyStore.push(keyEntry);
62 else
63 result = keyEntry;
Wentao Shang82854bd2012-12-27 14:14:41 -080064};
65
66NDN.getKeyByName = function(/* KeyName */ name) {
67 var result = null;
68
69 for (var i = 0; i < NDN.KeyStore.length; i++) {
Wentao Shangb42483a2013-01-03 15:32:32 -080070 if (NDN.KeyStore[i].keyName.contentName.match(name.contentName)) {
Wentao Shang82854bd2012-12-27 14:14:41 -080071 if (result == null ||
72 NDN.KeyStore[i].keyName.contentName.components.length > result.keyName.contentName.components.length)
73 result = NDN.KeyStore[i];
74 }
75 }
76
77 return result;
78};
79
Jeff Thompsonbe85be62012-12-13 22:32:01 -080080// For fetching data
81NDN.PITTable = new Array();
82
83var PITEntry = function PITEntry(interest, closure) {
84 this.interest = interest; // Interest
85 this.closure = closure; // Closure
Wentao Shangfcb16262013-01-20 14:42:46 -080086 this.timerID = -1; // Timer ID
Jeff Thompsonbe85be62012-12-13 22:32:01 -080087};
88
89// Return the longest entry from NDN.PITTable that matches name.
90NDN.getEntryForExpressedInterest = function(/*Name*/ name) {
91 // TODO: handle multiple matches? Maybe not from registerPrefix because multiple ContentObject
92 // could be sent for one Interest?
93 var result = null;
94
95 for (var i = 0; i < NDN.PITTable.length; i++) {
96 if (NDN.PITTable[i].interest.matches_name(name)) {
97 if (result == null ||
98 NDN.PITTable[i].interest.name.components.length > result.interest.name.components.length)
99 result = NDN.PITTable[i];
100 }
101 }
102
103 return result;
104};
105
Jeff Thompson75771cb2013-01-20 23:27:38 -0800106// For publishing data
107NDN.CSTable = new Array();
108
109var CSEntry = function CSEntry(name, closure) {
110 this.name = name; // String
111 this.closure = closure; // Closure
112};
113
114function getEntryForRegisteredPrefix(name) {
115 for (var i = 0; i < NDN.CSTable.length; i++) {
116 if (NDN.CSTable[i].name.match(name) != null)
117 return NDN.CSTable[i];
118 }
119 return null;
120}
121
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800122/*
123 * Return a function that selects a host at random from hostList and returns { host: host, port: port }.
124 * If no more hosts remain, return null.
125 */
126NDN.makeShuffledGetHostAndPort = function(hostList, port) {
127 // Make a copy.
128 hostList = hostList.slice(0, hostList.length);
129 DataUtils.shuffle(hostList);
130
131 return function() {
132 if (hostList.length == 0)
133 return null;
134
135 return { host: hostList.splice(0, 1)[0], port: port };
136 };
137};
138
Jeff Thompson34419762012-10-15 22:24:12 -0700139/** Encode name as an Interest. If template is not null, use its attributes.
140 * Send the interest to host:port, read the entire response and call
141 * closure.upcall(Closure.UPCALL_CONTENT (or Closure.UPCALL_CONTENT_UNVERIFIED),
Jeff Thompson97f27432012-10-16 00:28:03 -0700142 * new UpcallInfo(this, interest, 0, contentObject)).
Jeff Thompson34419762012-10-15 22:24:12 -0700143 */
144NDN.prototype.expressInterest = function(
145 // Name
146 name,
147 // Closure
148 closure,
149 // Interest
150 template) {
Jeff Thompson5b265a72012-11-12 01:13:08 -0800151 var interest = new Interest(name);
Jeff Thompson34419762012-10-15 22:24:12 -0700152 if (template != null) {
Jeff Thompson4404ab52012-10-21 10:29:48 -0700153 interest.minSuffixComponents = template.minSuffixComponents;
154 interest.maxSuffixComponents = template.maxSuffixComponents;
155 interest.publisherPublicKeyDigest = template.publisherPublicKeyDigest;
156 interest.exclude = template.exclude;
157 interest.childSelector = template.childSelector;
158 interest.answerOriginKind = template.answerOriginKind;
159 interest.scope = template.scope;
160 interest.interestLifetime = template.interestLifetime;
Jeff Thompson34419762012-10-15 22:24:12 -0700161 }
162 else
Jeff Thompson42806a12012-12-29 18:19:39 -0800163 interest.interestLifetime = 4000; // default interest timeout value in milliseconds.
Jeff Thompson34419762012-10-15 22:24:12 -0700164
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800165 if (this.host == null || this.port == null) {
166 if (this.getHostAndPort == null)
167 console.log('ERROR: host OR port NOT SET');
Jeff Thompsona5668d52013-01-26 16:23:27 -0800168 else {
169 var thisNDN = this;
170 this.connectAndExecute
171 (function() { thisNDN.transport.expressInterest(thisNDN, interest, closure); });
172 }
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800173 }
174 else
175 this.transport.expressInterest(this, interest, closure);
176};
Jeff Thompson5b265a72012-11-12 01:13:08 -0800177
Jeff Thompson537ce142013-01-26 20:02:48 -0800178/*
179 * Do the work of expressInterest once we know we are connected. Set the PITTable and call
180 * this.transport.send to send the interest.
181 */
182NDN.prototype.expressInterestHelper = function(interest, closure) {
183 //TODO: check local content store first
184 if (closure != null) {
185 var pitEntry = new PITEntry(interest, closure);
186 // TODO: This needs to be a single thread-safe transaction on a global object.
187 NDN.PITTable.push(pitEntry);
188 closure.pitEntry = pitEntry;
189 }
190
191 // Set interest timer
192 var thisNDN = this;
193 if (closure != null) {
194 pitEntry.timerID = setTimeout(function() {
195 if (LOG > 3) console.log("Interest time out.");
196
197 // Remove PIT entry from NDN.PITTable.
198 // TODO: Make this a thread-safe operation on the global PITTable.
199 var index = NDN.PITTable.indexOf(pitEntry);
200 //console.log(NDN.PITTable);
201 if (index >= 0)
202 NDN.PITTable.splice(index, 1);
203 //console.log(NDN.PITTable);
204 //console.log(pitEntry.interest.name.getName());
205
206 // Raise closure callback
207 closure.upcall(Closure.UPCALL_INTEREST_TIMED_OUT, new UpcallInfo(thisNDN, interest, 0, null));
208 }, interest.interestLifetime); // interestLifetime is in milliseconds.
209 //console.log(closure.timerID);
210 }
211
212 this.transport.send(encodeToBinaryInterest(interest));
213};
214
Jeff Thompson5b265a72012-11-12 01:13:08 -0800215NDN.prototype.registerPrefix = function(name, closure, flag) {
Jeff Thompsond771b122013-01-26 19:04:41 -0800216 var thisNDN = this;
217 var onConnected = function() {
218 if (thisNDN.ccndid == null) {
219 // Fetch ccndid first, then register.
220 var interest = new Interest(NDN.ccndIdFetcher);
221 interest.interestLifetime = 4000; // milliseconds
222 if (LOG>3) console.log('Expressing interest for ccndid from ccnd.');
223 thisNDN.transport.expressInterest
224 (thisNDN, interest, new NDN.FetchCcndidClosure(thisNDN, name, closure, flag));
225 }
226 else
227 thisNDN.registerPrefixHelper(name, closure, flag);
228 };
Jeff Thompson75771cb2013-01-20 23:27:38 -0800229
Jeff Thompsond771b122013-01-26 19:04:41 -0800230 if (this.host == null || this.port == null) {
231 if (this.getHostAndPort == null)
232 console.log('ERROR: host OR port NOT SET');
233 else
234 this.connectAndExecute(onConnected);
235 }
236 else
237 onConnected();
238};
239
240/*
241 * This is a closure to receive the ContentObject for NDN.ccndIdFetcher and call
242 * registerPrefixHelper(name, callerClosure, flag).
243 */
244NDN.FetchCcndidClosure = function FetchCcndidClosure(ndn, name, callerClosure, flag) {
245 // Inherit from Closure.
246 Closure.call(this);
247
248 this.ndn = ndn;
249 this.name = name;
250 this.callerClosure = callerClosure;
251 this.flag = flag;
252};
253
254NDN.FetchCcndidClosure.prototype.upcall = function(kind, upcallInfo) {
255 if (kind == Closure.UPCALL_INTEREST_TIMED_OUT) {
256 console.log("Timeout while requesting the ccndid. Cannot registerPrefix for " +
257 this.name.to_uri() + " .");
258 return Closure.RESULT_OK;
259 }
260 if (!(kind == Closure.UPCALL_CONTENT ||
261 kind == Closure.UPCALL_CONTENT_UNVERIFIED))
262 // The upcall is not for us.
263 return Closure.RESULT_ERR;
264
265 var co = upcallInfo.contentObject;
266 if (!co.signedInfo || !co.signedInfo.publisher
267 || !co.signedInfo.publisher.publisherPublicKeyDigest)
268 console.log
269 ("ContentObject doesn't have a publisherPublicKeyDigest. Cannot set ccndid and registerPrefix for "
270 + this.name.to_uri() + " .");
271 else {
272 if (LOG>3) console.log('Got ccndid from ccnd.');
273 this.ndn.ccndid = co.signedInfo.publisher.publisherPublicKeyDigest;
274 if (LOG>3) console.log(this.ndn.ccndid);
275
276 this.ndn.registerPrefixHelper(this.name, this.callerClosure, this.flag);
Jeff Thompson75771cb2013-01-20 23:27:38 -0800277 }
Jeff Thompsond771b122013-01-26 19:04:41 -0800278
279 return Closure.RESULT_OK;
280};
281
Jeff Thompson537ce142013-01-26 20:02:48 -0800282/*
283 * Do the work of registerPrefix once we know we are connected with a ccndid.
284 */
Jeff Thompsond771b122013-01-26 19:04:41 -0800285NDN.prototype.registerPrefixHelper = function(name, closure, flag) {
Jeff Thompson75771cb2013-01-20 23:27:38 -0800286 var fe = new ForwardingEntry('selfreg', name, null, null, 3, 2147483647);
287 var bytes = encodeForwardingEntry(fe);
288
289 var si = new SignedInfo();
290 si.setFields();
291
292 var co = new ContentObject(new Name(), si, bytes, new Signature());
293 co.sign();
294 var coBinary = encodeToBinaryContentObject(co);
295
296 //var nodename = unescape('%00%88%E2%F4%9C%91%16%16%D6%21%8E%A0c%95%A5%A6r%11%E0%A0%82%89%A6%A9%85%AB%D6%E2%065%DB%AF');
297 var nodename = this.ccndid;
298 var interestName = new Name(['ccnx', nodename, 'selfreg', coBinary]);
299
300 var interest = new Interest(interestName);
301 interest.scope = 1;
302 if (LOG > 3) console.log('Send Interest registration packet.');
303
304 var csEntry = new CSEntry(name.getName(), closure);
305 NDN.CSTable.push(csEntry);
306
307 this.transport.send(encodeToBinaryInterest(interest));
Jeff Thompson75771cb2013-01-20 23:27:38 -0800308};
309
310/*
311 * This is called when an entire binary XML element is received, such as a ContentObject or Interest.
312 * Look up in the PITTable and call the closure callback.
313 */
314NDN.prototype.onReceivedElement = function(element) {
Jeff Thompsona46083c2013-01-20 23:55:21 -0800315 if (LOG>3) console.log('Complete element received. Length ' + element.length + '. Start decoding.');
Jeff Thompson75771cb2013-01-20 23:27:38 -0800316 var decoder = new BinaryXMLDecoder(element);
317 // Dispatch according to packet type
318 if (decoder.peekStartElement(CCNProtocolDTags.Interest)) { // Interest packet
319 if (LOG > 3) console.log('Interest packet received.');
320
321 var interest = new Interest();
322 interest.from_ccnb(decoder);
323 if (LOG > 3) console.log(interest);
324 var nameStr = escape(interest.name.getName());
325 if (LOG > 3) console.log(nameStr);
326
327 var entry = getEntryForRegisteredPrefix(nameStr);
328 if (entry != null) {
329 //console.log(entry);
330 var info = new UpcallInfo(this, interest, 0, null);
331 var ret = entry.closure.upcall(Closure.UPCALL_INTEREST, info);
332 if (ret == Closure.RESULT_INTEREST_CONSUMED && info.contentObject != null)
333 this.transport.send(encodeToBinaryContentObject(info.contentObject));
334 }
335 } else if (decoder.peekStartElement(CCNProtocolDTags.ContentObject)) { // Content packet
336 if (LOG > 3) console.log('ContentObject packet received.');
337
338 var co = new ContentObject();
339 co.from_ccnb(decoder);
340
Jeff Thompsond771b122013-01-26 19:04:41 -0800341 var pitEntry = NDN.getEntryForExpressedInterest(co.name);
342 if (pitEntry != null) {
343 //console.log(pitEntry);
344 // Remove PIT entry from NDN.PITTable
345 var index = NDN.PITTable.indexOf(pitEntry);
346 if (index >= 0)
347 NDN.PITTable.splice(index, 1);
Jeff Thompson75771cb2013-01-20 23:27:38 -0800348
Jeff Thompsond771b122013-01-26 19:04:41 -0800349 var currentClosure = pitEntry.closure;
Jeff Thompson75771cb2013-01-20 23:27:38 -0800350
Jeff Thompsond771b122013-01-26 19:04:41 -0800351 // Cancel interest timer
352 clearTimeout(pitEntry.timerID);
353 //console.log("Clear interest timer");
354 //console.log(currentClosure.timerID);
355
356 if (this.verify == false) {
357 // Pass content up without verifying the signature
358 currentClosure.upcall(Closure.UPCALL_CONTENT_UNVERIFIED, new UpcallInfo(this, null, 0, co));
359 return;
Jeff Thompson75771cb2013-01-20 23:27:38 -0800360 }
Wentao Shangd4607392013-01-24 23:08:49 -0800361
Jeff Thompsond771b122013-01-26 19:04:41 -0800362 // Key verification
363
364 // Recursive key fetching & verification closure
365 var KeyFetchClosure = function KeyFetchClosure(content, closure, key, sig, wit) {
366 this.contentObject = content; // unverified content object
367 this.closure = closure; // closure corresponding to the contentObject
368 this.keyName = key; // name of current key to be fetched
369 this.sigHex = sig; // hex signature string to be verified
370 this.witness = wit;
371
372 Closure.call(this);
373 };
374
375 var thisNDN = this;
376 KeyFetchClosure.prototype.upcall = function(kind, upcallInfo) {
377 if (kind == Closure.UPCALL_INTEREST_TIMED_OUT) {
378 console.log("In KeyFetchClosure.upcall: interest time out.");
379 console.log(this.keyName.contentName.getName());
380 } else if (kind == Closure.UPCALL_CONTENT) {
381 //console.log("In KeyFetchClosure.upcall: signature verification passed");
382
383 var rsakey = decodeSubjectPublicKeyInfo(upcallInfo.contentObject.content);
384 var verified = rsakey.verifyByteArray(this.contentObject.rawSignatureData, this.witness, this.sigHex);
385
386 var flag = (verified == true) ? Closure.UPCALL_CONTENT : Closure.UPCALL_CONTENT_BAD;
387 //console.log("raise encapsulated closure");
388 this.closure.upcall(flag, new UpcallInfo(thisNDN, null, 0, this.contentObject));
389
390 // Store key in cache
391 var keyEntry = new KeyStoreEntry(keylocator.keyName, rsakey, new Date().getTime());
392 NDN.addKeyEntry(keyEntry);
393 //console.log(NDN.KeyStore);
394 } else if (kind == Closure.UPCALL_CONTENT_BAD) {
395 console.log("In KeyFetchClosure.upcall: signature verification failed");
Wentao Shangd4607392013-01-24 23:08:49 -0800396 }
Jeff Thompsond771b122013-01-26 19:04:41 -0800397 };
Jeff Thompson75771cb2013-01-20 23:27:38 -0800398
Jeff Thompsond771b122013-01-26 19:04:41 -0800399 if (co.signedInfo && co.signedInfo.locator && co.signature) {
400 if (LOG > 3) console.log("Key verification...");
401 var sigHex = DataUtils.toHex(co.signature.signature).toLowerCase();
Jeff Thompson75771cb2013-01-20 23:27:38 -0800402
Jeff Thompsond771b122013-01-26 19:04:41 -0800403 var wit = null;
404 if (co.signature.Witness != null) {
405 wit = new Witness();
406 wit.decode(co.signature.Witness);
407 }
Jeff Thompson75771cb2013-01-20 23:27:38 -0800408
Jeff Thompsond771b122013-01-26 19:04:41 -0800409 var keylocator = co.signedInfo.locator;
410 if (keylocator.type == KeyLocatorType.KEYNAME) {
411 if (LOG > 3) console.log("KeyLocator contains KEYNAME");
412 //var keyname = keylocator.keyName.contentName.getName();
413 //console.log(nameStr);
414 //console.log(keyname);
Jeff Thompson75771cb2013-01-20 23:27:38 -0800415
Jeff Thompsond771b122013-01-26 19:04:41 -0800416 if (keylocator.keyName.contentName.match(co.name)) {
417 if (LOG > 3) console.log("Content is key itself");
Jeff Thompson75771cb2013-01-20 23:27:38 -0800418
Jeff Thompsond771b122013-01-26 19:04:41 -0800419 var rsakey = decodeSubjectPublicKeyInfo(co.content);
420 var verified = rsakey.verifyByteArray(co.rawSignatureData, wit, sigHex);
421 var flag = (verified == true) ? Closure.UPCALL_CONTENT : Closure.UPCALL_CONTENT_BAD;
422
423 currentClosure.upcall(flag, new UpcallInfo(this, null, 0, co));
424
425 // SWT: We don't need to store key here since the same key will be
426 // stored again in the closure.
427 //var keyEntry = new KeyStoreEntry(keylocator.keyName, rsakey, new Date().getTime());
428 //NDN.addKeyEntry(keyEntry);
429 //console.log(NDN.KeyStore);
430 } else {
431 // Check local key store
432 var keyEntry = NDN.getKeyByName(keylocator.keyName);
433 if (keyEntry) {
434 // Key found, verify now
435 if (LOG > 3) console.log("Local key cache hit");
436 var rsakey = keyEntry.rsaKey;
Jeff Thompson75771cb2013-01-20 23:27:38 -0800437 var verified = rsakey.verifyByteArray(co.rawSignatureData, wit, sigHex);
438 var flag = (verified == true) ? Closure.UPCALL_CONTENT : Closure.UPCALL_CONTENT_BAD;
Jeff Thompson75771cb2013-01-20 23:27:38 -0800439
Jeff Thompsond771b122013-01-26 19:04:41 -0800440 // Raise callback
441 currentClosure.upcall(flag, new UpcallInfo(this, null, 0, co));
442 } else {
443 // Not found, fetch now
444 if (LOG > 3) console.log("Fetch key according to keylocator");
445 var nextClosure = new KeyFetchClosure(co, currentClosure, keylocator.keyName, sigHex, wit);
446 this.expressInterest(keylocator.keyName.contentName.getPrefix(4), nextClosure);
Jeff Thompson75771cb2013-01-20 23:27:38 -0800447 }
Jeff Thompson75771cb2013-01-20 23:27:38 -0800448 }
Jeff Thompsond771b122013-01-26 19:04:41 -0800449 } else if (keylocator.type == KeyLocatorType.KEY) {
450 if (LOG > 3) console.log("Keylocator contains KEY");
451
452 var rsakey = decodeSubjectPublicKeyInfo(co.signedInfo.locator.publicKey);
453 var verified = rsakey.verifyByteArray(co.rawSignatureData, wit, sigHex);
454
455 var flag = (verified == true) ? Closure.UPCALL_CONTENT : Closure.UPCALL_CONTENT_BAD;
456 // Raise callback
457 currentClosure.upcall(Closure.UPCALL_CONTENT, new UpcallInfo(this, null, 0, co));
458
459 // Since KeyLocator does not contain key name for this key,
460 // we have no way to store it as a key entry in KeyStore.
461 } else {
462 var cert = keylocator.certificate;
463 console.log("KeyLocator contains CERT");
464 console.log(cert);
465
466 // TODO: verify certificate
Jeff Thompson75771cb2013-01-20 23:27:38 -0800467 }
468 }
469 }
470 } else
471 console.log('Incoming packet is not Interest or ContentObject. Discard now.');
Wentao Shangb42483a2013-01-03 15:32:32 -0800472};
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800473
474/*
475 * Assume this.getHostAndPort is not null. This is called when this.host is null or its host
Jeff Thompsona5668d52013-01-26 16:23:27 -0800476 * is not alive. Get a host and port, connect, then execute onConnected().
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800477 */
Jeff Thompsona5668d52013-01-26 16:23:27 -0800478NDN.prototype.connectAndExecute = function(onConnected) {
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800479 var hostAndPort = this.getHostAndPort();
480 if (hostAndPort == null) {
481 console.log('ERROR: No more hosts from getHostAndPort');
482 this.host = null;
483 return;
484 }
485
486 if (hostAndPort.host == this.host && hostAndPort.port == this.port) {
487 console.log('ERROR: The host returned by getHostAndPort is not alive: ' +
488 this.host + ":" + this.port);
489 return;
490 }
491
492 this.host = hostAndPort.host;
493 this.port = hostAndPort.port;
Jeff Thompsona5668d52013-01-26 16:23:27 -0800494 if (LOG>3) console.log("Connect: trying host from getHostAndPort: " + this.host);
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800495
Jeff Thompson75771cb2013-01-20 23:27:38 -0800496 // Fetch any content.
497 var interest = new Interest(new Name("/"));
Jeff Thompson42806a12012-12-29 18:19:39 -0800498 interest.interestLifetime = 4000; // milliseconds
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800499
500 var thisNDN = this;
501 var timerID = setTimeout(function() {
Jeff Thompsona5668d52013-01-26 16:23:27 -0800502 if (LOG>3) console.log("Connect: timeout waiting for host " + thisNDN.host);
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800503 // Try again.
Jeff Thompsona5668d52013-01-26 16:23:27 -0800504 thisNDN.connectAndExecute(onConnected);
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800505 }, 3000);
506
507 this.transport.expressInterest
Jeff Thompsona5668d52013-01-26 16:23:27 -0800508 (this, interest, new NDN.ConnectClosure(this, onConnected, timerID));
Wentao Shangb42483a2013-01-03 15:32:32 -0800509};
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800510
Jeff Thompsona5668d52013-01-26 16:23:27 -0800511NDN.ConnectClosure = function ConnectClosure(ndn, onConnected, timerID) {
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800512 // Inherit from Closure.
513 Closure.call(this);
514
515 this.ndn = ndn;
Jeff Thompsona5668d52013-01-26 16:23:27 -0800516 this.onConnected = onConnected;
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800517 this.timerID = timerID;
518};
519
520NDN.ConnectClosure.prototype.upcall = function(kind, upcallInfo) {
521 if (!(kind == Closure.UPCALL_CONTENT ||
Jeff Thompson75771cb2013-01-20 23:27:38 -0800522 kind == Closure.UPCALL_CONTENT_UNVERIFIED))
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800523 // The upcall is not for us.
524 return Closure.RESULT_ERR;
525
Jeff Thompsona5668d52013-01-26 16:23:27 -0800526 // The host is alive, so cancel the timeout and continue with onConnected().
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800527 clearTimeout(this.timerID);
Jeff Thompsond771b122013-01-26 19:04:41 -0800528
529 // Call NDN.onopen after success
530 this.ndn.readyStatus = NDN.OPENED;
531 this.ndn.onopen();
532
Jeff Thompsona5668d52013-01-26 16:23:27 -0800533 this.onConnected();
Jeff Thompsond3a80dc2012-12-16 17:52:43 -0800534
535 return Closure.RESULT_OK;
536};
537
Jeff Thompson75771cb2013-01-20 23:27:38 -0800538/*
539 * A BinaryXmlElementReader lets you call onReceivedData multiple times which uses a
540 * BinaryXMLStructureDecoder to detect the end of a binary XML element and calls
541 * elementListener.onReceivedElement(element) with the element.
542 * This handles the case where a single call to onReceivedData may contain multiple elements.
543 */
544var BinaryXmlElementReader = function BinaryXmlElementReader(elementListener) {
545 this.elementListener = elementListener;
546 this.dataParts = [];
547 this.structureDecoder = new BinaryXMLStructureDecoder();
548};
549
550BinaryXmlElementReader.prototype.onReceivedData = function(/* Uint8Array */ rawData) {
Jeff Thompson75771cb2013-01-20 23:27:38 -0800551 // Process multiple objects in the data.
552 while(true) {
553 // Scan the input to check if a whole ccnb object has been read.
554 this.structureDecoder.seek(0);
555 if (this.structureDecoder.findElementEnd(rawData)) {
556 // Got the remainder of an object. Report to the caller.
557 this.dataParts.push(rawData.subarray(0, this.structureDecoder.offset));
Jeff Thompson0790af82013-01-26 19:54:27 -0800558 var element = DataUtils.concatArrays(this.dataParts);
559 this.dataParts = [];
560 try {
561 this.elementListener.onReceivedElement(element);
562 } catch (ex) {
563 console.log("BinaryXmlElementReader: ignoring exception from onReceivedElement: " + ex);
564 }
Jeff Thompson75771cb2013-01-20 23:27:38 -0800565
566 // Need to read a new object.
567 rawData = rawData.subarray(this.structureDecoder.offset, rawData.length);
Jeff Thompson75771cb2013-01-20 23:27:38 -0800568 this.structureDecoder = new BinaryXMLStructureDecoder();
569 if (rawData.length == 0)
570 // No more data in the packet.
571 return;
572
573 // else loop back to decode.
574 }
575 else {
576 // Save for a later call to concatArrays so that we only copy data once.
577 this.dataParts.push(rawData);
Jeff Thompsona46083c2013-01-20 23:55:21 -0800578 if (LOG>3) console.log('Incomplete packet received. Length ' + rawData.length + '. Wait for more input.');
Jeff Thompson75771cb2013-01-20 23:27:38 -0800579 return;
580 }
581 }
582}