()
| 7 | var topic = urlHashTopic ? urlHashTopic : "pgomapcatch/chat"; |
| 8 | |
| 9 | function initialiseEventBus(){ |
| 10 | window.client = mqtt.connect('ws://ws.pikabot.org',{ |
| 11 | reconnectPeriod:20*1000 |
| 12 | }); |
| 13 | client.on("connect", function(err,res){ |
| 14 | client.subscribe("pgomapcatch/#"); |
| 15 | client.subscribe("pgochat/chat"); |
| 16 | }) |
| 17 | client.on("disconnect", function(err,res){ |
| 18 | client.unsubscribe("pgomapcatch/#"); |
| 19 | client.unsubscribe("pgochat/chat"); |
| 20 | }) |
| 21 | client.on("message", function (topic, payload) { |
| 22 | //Materialize.toast(payload, 4000); |
| 23 | if (topic === 'pgochat/chat') { |
| 24 | var objx = $.parseJSON(payload); |
| 25 | var message_data = "<b>anonymous" + Math.floor(Math.random()*90000) + "</b>: " + objx.text; |
| 26 | displayChatMessageOnMap(payload); |
| 27 | Materialize.toast(message_data, 5000); |
| 28 | var msg = JSON.parse(payload); |
| 29 | console.info('[CHAT]', '(' + msg.lat + ',' + msg.lng + '): ', msg.text); |
| 30 | } else if (/^pgomapcatch\/all\/catchable/i.test(topic)) { |
| 31 | //@ro: let's grab the message and split that shit. (simple for now, maybe we could just parse the json instead) |
| 32 | var pLoadR = payload.toString(); |
| 33 | var pLoadR2 = pLoadR.split(","); |
| 34 | var olat = pLoadR2[0] |
| 35 | var olong = pLoadR2[1] |
| 36 | |
| 37 | var pokemon_id = parseInt(pLoadR2[2]) |
| 38 | if (pokemon_id>0 && pokemon_id< 160){ |
| 39 | var ico = pLoadR2[2] |
| 40 | var expir = pLoadR2[3] |
| 41 | var pokenick = pLoadR2[4] |
| 42 | var sessid = pLoadR2[2] |
| 43 | var path = "./images/p/" |
| 44 | console.log('icon is '+ico) |
| 45 | var icon = path + "0" + ico.replace(" ","") + ".png" |
| 46 | var icostr = icon.toString(); |
| 47 | displayMessageOnMap(payload, olat, olong, sessid, icostr, expir, pokenick); |
| 48 | console.debug('[CATCHABLE]', pokenick, '(' + olat + ',' + olong + ')'); |
| 49 | } else { |
| 50 | var pokemon_id = parseInt(pLoadR2[3]) |
| 51 | if (pokemon_id>0 && pokemon_id< 160){ |
| 52 | var ico = pLoadR2[3] |
| 53 | var expir = pLoadR2[4] |
| 54 | var pokenick = pLoadR2[5] |
| 55 | var sessid = pLoadR2[5] |
| 56 | var path = "./images/p/" |
| 57 | console.log('icon is '+ico) |
| 58 | var icon = path + "0" + ico.replace(" ","") + ".png" |
| 59 | var icostr = icon.toString(); |
| 60 | displayMessageOnMap(payload, olat, olong, sessid, icostr, expir, pokenick); |
| 61 | console.debug('[CATCHABLE]', pokenick, '(' + olat + ',' + olong + ')'); |
| 62 | } |
| 63 | } |
| 64 | } else { |
| 65 | console.debug(topic); |
| 66 | } |
no test coverage detected