{

this.mapRef = map;

this.isMobile = _IsPlatformMobile();

this.mks = null; // marker manager

this.failures = 0;

this.fail_max = (86400 * 365) / 600;

this.last_tx = 0;

this.enabled = true;

this.int_up = null;

this.dev_test = false;

this.Init();

{

this.Init_DevTestMode();

this.Init_IngestMarkers();

//this.InitMarkersAsync();

this.SetEnabled(true);

//this.InitConnectionWatchdog();

{

var dev_test_str = _GetParam("dev_test");

if (dev_test_str != null && dev_test_str.length > 0)

{

this.dev_test = parseInt(dev_test_str) == 1;

if (this.dev_test)

{

console.log("IngestViewer: dev_test mode temporarily set from querystring. To return to normal (production) view, reload the page without dev_test=1 in the querystring.");

}//if

}//if

{

//var rs = IngestIcon.RenderStyle.DoubleTriangle;

this.mks = new IngestMarkers(this.mapRef, window.devicePixelRatio, this.isMobile, "opc_pm02_5");//, rs);

{

//var pre = window.location.href.substring(0,5) == "https" ? "https://" : "http://";

//var url = pre + "safecast.org/tilemap/test2/ingest-test.json";

var url = this.GetJsonUrl();

this.GetJSONAsync(url);

{

setTimeout(function() {

this.ConnectionWatchdog();

}.bind(this), 10 * 60 * 1000);

{

return !this.dev_test ? "https://s3-us-west-2.amazonaws.com/safecastdata-us-west-2/ingest/prd/json/view24h.json"

: "https://s3-us-west-2.amazonaws.com/safecastdata-us-west-2/ingest/prd/json/view24h_devtest.json";

{

if (Date.now() - this.last_tx > 20 * 60 * 1000)

{

console.log("IngestViewer.prototype.ConnectionWatchdog: >20 mins since last connection attempt, restarting connection...");

this.InitMarkersAsync();

}//if

setTimeout(function() {

this.ConnectionWatchdog();

}.bind(this), 10 * 60 * 1000);

{

// 2016-08-14 ND: Fix for not being able to disable via UI due to timer polling.

// This keeps timers running, but simply does a no-op.

/*

var ss_now = "" + (parseInt(Date.now() * 0.001));

var url_nocache = url + "?t=" + ss_now;

var cb = function(response, userData)

{

var success = response != null && response.length > 0;

if (success)

{

var obj = null;

try

{

obj = JSON.parse(response);

}

catch (err)

{

console.log("IngestViewer: JSON parsing exception.");

}

if (obj != null)

{

// 2016-08-14 ND: Recheck enabled status due to HTTP GET latency, to make sure

// markers are not being added against user's preference.

if (this.enabled)

{

this.mks.AddSensorDataFromJson(obj);

this.mks.AddMarkersToMap();

}//if

}//if

else

{

success = false;

this.failures = this.failures + 1;

}//else

}//if

else

{

this.failures = this.failures + 1;

}//else

if (!success)

{

console.log("IngestViewer.GetJSONAsync: Error getting sensors from URL: %s", url);

}//if

var after_ms = (success ? 60 : 600) * 1000; // 1 min normally, 10 mins on failure

/*

}.bind(this);

_GetAsync_HTTP(url_nocache, null, null, cb, null);

{

if (v && this.int_up == null)

{

this.AddGmapsListeners();

var fx = function()

{

this.InitMarkersAsync();

}.bind(this);

fx();

this.int_up = setInterval(fx, 5 * 60 * 1000);

}//if

else if (!v && this.int_up != null)

{

clearInterval(this.int_up);

this.int_up = null;

this.RemoveAllMarkersFromMapAndPurgeData();

this.ClearGmapsListeners();

}//else

this.enabled = v;

{

var req = new XMLHttpRequest();

req.open("GET", url, true);

if (responseType != null)

{

if (responseType == "text\/plain; charset=x-user-defined")

{

req.overrideMimeType(responseType);

}//if

else

{

req.responseType = responseType; //"arraybuffer", "blob", "document", "json", and "text"

}//else

}//if

req.onreadystatechange = function () // why was this ==== ?

{

if (req.readyState === 4 && req.status == 200 && req.response != null)

{

if (responseHeader != null)

{

fxCallback(req.getResponseHeader(responseHeader), userData);

}//if

else

{

fxCallback(req.response, userData);

}//else

}//if

else if (req.readyState === 4)

{

// This attemps to trap Chrome's ERR_NETWORK_CHANGED

// and other network failures which cause the updates to stop.

console.log("IngestViewer _GetAsync_HTTP: req.readyState == 4, req.status == %d. Retrying.", req.status);

fxCallback(null, userData);

}//else if

};

req.send(null);

{

name = name.replace(/[\[]/, "\\\[").replace(/[\]]/, "\\\]");

var regexS = "[\\?&]" + name + "=([^&#]*)";

var regex = new RegExp(regexS);

var results = regex.exec(window.location.href);

return results == null ? "" : results[1];

{

var check = false;

var ovr_str = _GetParam("mobile");

if (ovr_str != null && ovr_str.length > 0)

{

check = parseInt(ovr_str) == 1;

}//if

else

{

(function(a,b){if(/(android|bb\d+|meego).+mobile|avantgo|bada\/|blackberry|blazer|compal|elaine|fennec|hiptop|iemobile|ip(hone|od)|iris|kindle|lge |maemo|midp|mmp|mobile.+firefox|netfront|opera m(ob|in)i|palm( os)?|phone|p(ixi|re)\/|plucker|pocket|psp|series(4|6)0|symbian|treo|up\.(browser|link)|vodafone|wap|windows ce|xda|xiino/i.test(a)||/1207|6310|6590|3gso|4thp|50[1-6]i|770s|802s|a wa|abac|ac(er|oo|s\-)|ai(ko|rn)|al(av|ca|co)|amoi|an(ex|ny|yw)|aptu|ar(ch|go)|as(te|us)|attw|au(di|\-m|r |s )|avan|be(ck|ll|nq)|bi(lb|rd)|bl(ac|az)|br(e|v)w|bumb|bw\-(n|u)|c55\/|capi|ccwa|cdm\-|cell|chtm|cldc|cmd\-|co(mp|nd)|craw|da(it|ll|ng)|dbte|dc\-s|devi|dica|dmob|do(c|p)o|ds(12|\-d)|el(49|ai)|em(l2|ul)|er(ic|k0)|esl8|ez([4-7]0|os|wa|ze)|fetc|fly(\-|_)|g1 u|g560|gene|gf\-5|g\-mo|go(\.w|od)|gr(ad|un)|haie|hcit|hd\-(m|p|t)|hei\-|hi(pt|ta)|hp( i|ip)|hs\-c|ht(c(\-| |_|a|g|p|s|t)|tp)|hu(aw|tc)|i\-(20|go|ma)|i230|iac( |\-|\/)|ibro|idea|ig01|ikom|im1k|inno|ipaq|iris|ja(t|v)a|jbro|jemu|jigs|kddi|keji|kgt( |\/)|klon|kpt |kwc\-|kyo(c|k)|le(no|xi)|lg( g|\/(k|l|u)|50|54|\-[a-w])|libw|lynx|m1\-w|m3ga|m50\/|ma(te|ui|xo)|mc(01|21|ca)|m\-cr|me(rc|ri)|mi(o8|oa|ts)|mmef|mo(01|02|bi|de|do|t(\-| |o|v)|zz)|mt(50|p1|v )|mwbp|mywa|n10[0-2]|n20[2-3]|n30(0|2)|n50(0|2|5)|n7(0(0|1)|10)|ne((c|m)\-|on|tf|wf|wg|wt)|nok(6|i)|nzph|o2im|op(ti|wv)|oran|owg1|p800|pan(a|d|t)|pdxg|pg(13|\-([1-8]|c))|phil|pire|pl(ay|uc)|pn\-2|po(ck|rt|se)|prox|psio|pt\-g|qa\-a|qc(07|12|21|32|60|\-[2-7]|i\-)|qtek|r380|r600|raks|rim9|ro(ve|zo)|s55\/|sa(ge|ma|mm|ms|ny|va)|sc(01|h\-|oo|p\-)|sdk\/|se(c(\-|0|1)|47|mc|nd|ri)|sgh\-|shar|sie(\-|m)|sk\-0|sl(45|id)|sm(al|ar|b3|it|t5)|so(ft|ny)|sp(01|h\-|v\-|v )|sy(01|mb)|t2(18|50)|t6(00|10|18)|ta(gt|lk)|tcl\-|tdg\-|tel(i|m)|tim\-|t\-mo|to(pl|sh)|ts(70|m\-|m3|m5)|tx\-9|up(\.b|g1|si)|utst|v400|v750|veri|vi(rg|te)|vk(40|5[0-3]|\-v)|vm40|voda|vulc|vx(52|53|60|61|70|80|81|83|85|98)|w3c(\-| )|webc|whit|wi(g |nc|nw)|wmlb|wonu|x700|yas\-|your|zeto|zte|android|ipad|playbook|silk\-/i.test(a.substr(0,4)))check = true})(navigator.userAgent||navigator.vendor||window.opera);

if (!check) check = navigator.userAgent.match(/iPad/i);

if (!check) check = navigator.userAgent.match(/Android/i);

if (!check) check = navigator.userAgent.indexOf("iPad") > 0;

if (!check) check = navigator.userAgent.indexOf("Android") > 0;

}//else

return check;

{

this.SortedWords = null;

this._WordsInit();

{

// If the length isn't precisely 2048, this won't work

if (IngestWords.Words2048.length != 2048)

{

return "not-2048";

}

number >>>= 0;

// Break the 32-bit uint down into 3 parts

var left = (number >> 22) & 0x000003ff;

var middle = (number >> 11) & 0x000007ff;

var right = number & 0x000007ff;

// Generate the string

return IngestWords.Words2048[left] + "-" + IngestWords.Words2048[middle] + "-" + IngestWords.Words2048[right];

{

var result = 0 >>> 0;

var word = what.split("-");

if (word.length != 3)

{

// See if this is just a simple device ID

var i64 = parseInt(what);

if (!isNan(i64))

{

return { ok:true, x:i64 };

}//if

return { ok:false, x:0 };

}//if

var a;

a = this._WordToNumber(word[0]);

var left = a.x;

if (!a.ok)

{

return { ok:false, x:0 };

}//if

a = this._WordToNumber(word[1]);

var middle = a.x;

if (!a.ok)

{

return { ok:false, x:0 };

}//if

a = this._WordToNumber(word[2]);

var right = a.x;

if (!a.ok)

{

return { ok:false, x:0 };

}//if

result |= ((left )>>>0) << 22;

result |= ((middle)>>>0) << 11;

result |= ((right )>>>0);

return { ok:true, x:result };

{

var idx = 2049;

for (var i=0; i<this.SortedWords.length; i++)

{

if (IngestWords.Words2048[this.SortedWords[i]] >= what)

{

idx = i;

break;

}//if

}//for

if (idx < 2048 && IngestWords.Words2048[this.SortedWords[idx]] == what)

{

return { ok:true, x:this.SortedWords[idx] };

}//if

return { ok:false, x:0 };

{

// Init the index array

this.SortedWords = new Uint32Array(2048);

for (var i=0; i<2048; i++)

{

this.SortedWords[i] = i;

}//for

// Sort the array

this.SortedWords = _SortWords(this.SortedWords, IngestWords.Words2048);

{

src = src.sort(function(a, b)

{

return ref[a] > ref[b] ? 1

: ref[a] < ref[b] ? -1

: 0;

});

return src;