Subversion Repositories HomeAutomation

Rev

Rev 2098 | Rev 2153 | Go to most recent revision | Blame | Compare with Previous | Last modification | View Log | SVN | RSS feed

  1.  
  2. Sensor_ModuleNames    = [ "DS18x20", "FOST02", "BusVoltage", "SimpleDTMF", "DHT11" ];
  3. Sensor_Intervals      = function() { return [ 1, 5, 10, 15, 20 ]; };
  4. Sensor_Aliases        = function() { return Module_GetAliasNames(Sensor_ModuleNames); };
  5. Sensor_AvailableIds   = function() { return Module_GetAvailableIds(Sensor_ModuleNames); };
  6.  
  7. function Sensor_SetReportInterval(alias_name, interval)
  8. {
  9.     if (arguments.length < 2)
  10.     {
  11.         Log("\033[31mNot enough parameters given.\033[0m\n");
  12.         return false;
  13.     }
  14.  
  15.     var aliases_data = Module_ResolveAlias(alias_name, Sensor_ModuleNames);
  16.     var found = false;
  17.  
  18.     for (var name in aliases_data)
  19.     {
  20.         var variables = {"Time"     : interval };
  21.         if (Module_SendMessage(aliases_data[name]["module_name"], aliases_data[name]["module_id"], "Report_Interval", variables))
  22.         {
  23.             Log("\033[32mCommand sent successfully to " + name + ".\033[0m\n");
  24.         }
  25.         else
  26.         {
  27.             Log("\033[31mFailed to send command to " + name + ".\033[0m\n");
  28.         }
  29.  
  30.         found = true;
  31.     }
  32.  
  33.     if (!found)
  34.     {
  35.         Log("\033[31mNo aliases by the name " + alias_name + " were applicable for this command.\033[0m\n");
  36.         return false;
  37.     }
  38.  
  39.     return true;
  40. }
  41. Console_RegisterCommand(Sensor_SetReportInterval, function(arg_index, args) { return Console_StandardAutocomplete(arg_index, args, Sensor_Aliases(), Sensor_Intervals()); });
  42.  
  43. Sensor_OnNewPhonenumberFunctions = [];
  44.  
  45. function Sensor_RegisterToNewPhonenumber(alias_name, callback)
  46. {
  47.   if (!Sensor_OnNewPhonenumberFunctions[alias_name])
  48.   {
  49.     Sensor_OnNewPhonenumberFunctions[alias_name] = [];
  50.   }
  51.  
  52.   Sensor_OnNewPhonenumberFunctions[alias_name].push(callback);
  53. }
  54.  
  55. function Sensor_OnMessage(module_name, module_id, command, variables)
  56. {
  57.   if (in_array(Sensor_ModuleNames, module_name))
  58.   {
  59.     var aliases_data = Module_LookupAliases({
  60.       "module_name" : module_name,
  61.       "module_id"   : module_id,
  62.       "group"       : false
  63.     });
  64.  
  65.     switch (command)
  66.     {
  67.       case "Phonenumber":
  68.       {
  69.         for (var alias_name in aliases_data)
  70.         {
  71.           var number = variables["Number"];
  72.           var incommingCall = true;
  73.           var checkName = true;
  74.  
  75.           Log("received from DTMF:\"" + number + "\"");
  76.  
  77.           if (variables["Number"].length >= 6)
  78.           {
  79.             /* A seems to mean it is an incomming call! */
  80.             if (number.charAt(0) === 'A' || number.charAt(0) === 'D')
  81.             {
  82.               incommingCall = true;
  83.  
  84.               /* Remove leading A */
  85.               number = number.substring(1);
  86.             }
  87.             else /* Outgoing call */
  88.             {
  89.               incommingCall = false;
  90.             }
  91.  
  92.             /* A number can have a trailing C */
  93.             var endIndex = number.indexOf('C');
  94.  
  95.             if (endIndex !== -1)
  96.             {
  97.               /* Remove trailing C */
  98.               number = number.substring(0, endIndex);
  99.             }
  100.           }
  101.           else if (number == "B00C")
  102.           {
  103.             /* Unknown number */
  104.             number = "Unknown";
  105.             incommingCall = true;
  106.             checkName = false;
  107.           }
  108.           else if (number == "B10C")
  109.           {
  110.             /* Secret/protected number */
  111.             number = "Protected";
  112.             incommingCall = true;
  113.             checkName = false;
  114.           }
  115.           else
  116.           {
  117.             Log("DTMF decoded number is to short, number: \"" + number + "\", length: " + number.length);
  118.             return;
  119.           }
  120.  
  121.  
  122.           /* Store number and direction in last values */
  123.           var lastValue = {};
  124.           var lastValueString = Storage_GetParameter("LastValues", alias_name);
  125.  
  126.           if (lastValueString)
  127.           {
  128.             lastValue = JSON.parse(lastValueString);
  129.           }
  130.  
  131.           var timestamp = get_time();
  132.  
  133.           lastValue["Phonenumber"] = { "value" : number, "timestamp" : timestamp };
  134.           lastValue["Direction"] = { "value" : incommingCall ? "in" : "out", "timestamp" : timestamp };
  135.  
  136.           Storage_SetParameter("LastValues", alias_name, JSON.stringify(lastValue));
  137.  
  138.  
  139.           /* Store number in phone call history */
  140.           var newValue = { "number" : number, "direction" : incommingCall ? "in" : "out", "module" : alias_name, "names" : [], "timestamp" : timestamp };
  141.  
  142.           Storage_SetParameter("PhoneCalls", timestamp, JSON.stringify(newValue));
  143.  
  144.  
  145.           /* Log the number */
  146.           Log("New number: " + number + ", direction: " + (incommingCall ? "in" : "out"));
  147.  
  148.  
  149.           /* Lookup name */
  150.           if (checkName)
  151.           {
  152.             Sensor_StoreNumberInPhonebook(number, timestamp);
  153.           }
  154.  
  155.  
  156.           /* Call any potential subscribers */
  157.           if (Sensor_OnNewPhonenumberFunctions[alias_name])
  158.           {
  159.             for (var n in Sensor_OnNewPhonenumberFunctions[alias_name])
  160.             {
  161.               /* Call callback with arguments number, direction */
  162.               Sensor_OnNewPhonenumberFunctions[alias_name][n](alias_name, number, incommingCall ? "in" : "out");
  163.             }
  164.           }
  165.         }
  166.         break;
  167.       }
  168.       case "Voltage":
  169.       case "Temperature_Celsius":
  170.       {
  171.         if ((module_name == "DS18x20") && (variables["Value"] == 85))
  172.         {
  173.           Log("\033[31mDS18x20: Temperature conversion error: " + module_name + ":" + module_id + ", SensorId=" + variables["SensorId"] + "\033[0m");
  174.           break;
  175.         }
  176.       }
  177.       case "Humidity_Percent":
  178.       {
  179.         for (var alias_name in aliases_data)
  180.         {
  181.           if (aliases_data[alias_name]["specific"]["SensorId"] != variables["SensorId"])
  182.           {
  183.             continue;
  184.           }
  185.  
  186.           var last_value = {};
  187.           var last_value_string = Storage_GetParameter("LastValues", alias_name);
  188.  
  189.           if (last_value_string)
  190.           {
  191.             last_value = eval("(" + last_value_string + ")");
  192.           }
  193.  
  194.           last_value[command] = { "value" : variables["Value"], "timestamp" : get_time() };
  195.  
  196.           Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));
  197.         }
  198.  
  199.         break;
  200.       }
  201.     }
  202.   }
  203. }
  204. Module_RegisterToOnMessage("all", Sensor_OnMessage);
  205.  
  206. function Sensor_StoreNumberInPhonebook(number, timestamp)
  207. {
  208.   var phonebookNumbers = Storage_GetJsonParamter("PhoneBook", number)
  209.  
  210.   if (!phonebookNumbers)
  211.   {
  212.     if (number.charAt(0) != '0')
  213.     {
  214.       if (typeof sensorDefaultPhoneAreaCode === 'undefined')
  215.       {
  216.         Log("\033[31mOnlinePhonebook: please add sensorDefaultPhoneAreaCode = yourAreaCode to autostart.js, defaulting to 031\033[0m\n");
  217.         number = "031" + number;
  218.       }
  219.       else
  220.       {
  221.           number = sensorDefaultPhoneAreaCode + number;
  222.       }
  223.     }
  224.  
  225.     phonebookNumbers = [];
  226.  
  227.     url = "wap.eniro.se/query?search_word=" + number + "&what=mobwp";
  228.     //Log("\033[31mURL: http://"+url+"\033[0m\n");
  229.  
  230.     Http_Request(url, function(socket_id, result, header, content_data)
  231.     {
  232.       //Log("\033[31mOnlinePhonebook-eniro: result was: " + result + "\033[0m\n");
  233.       //Log("\033[31mOnlinePhonebook-eniro: content was: " + content_data + "\033[0m\n");
  234.  
  235.       if (result.indexOf("200 OK") != -1)
  236.       {
  237.  
  238.         var lines = content_data.split("\n");
  239.  
  240.         var endString = "<anchor>Tillbaka<prev/></anchor>";
  241.         var nameStartString = "<td class=\"hTd2\">";
  242.         var nameEndString = "</table>";
  243.  
  244.         for (var n = 1; n < lines.length; n++)
  245.         {
  246.           var line = lines[n].trim("\n");
  247.  
  248.           if (line.indexOf(endString) != -1)
  249.           {
  250.             break;
  251.           }
  252.  
  253.           if (line.indexOf(nameStartString) != -1)
  254.           {
  255.             line = lines[n + 1].trim("\n");
  256.             splitted = line.split("b>");
  257.  
  258.             phonebookNumbers.push(splitted[1].substr(0, splitted[1].length - 2));
  259.             break;
  260.           }
  261.         }
  262.  
  263.         //Log("\033[31mOnlinePhonebook: Line: " + lines[1] + "\033[0m\n");
  264.         //Log("\033[31mOnlinePhonebook: Line: " + lines[2] + "\033[0m\n");
  265.         //Log("\033[31mOnlinePhonebook: Line: " + lines[3] + "\033[0m\n");
  266.         if (phonebookNumbers.length > 0)
  267.         {
  268.           Storage_SetJsonParameter("PhoneBook", number, phonebookNumbers);
  269.  
  270.           Sensor_UpdateNameInPhonecalls(timestamp, phonebookNumbers);
  271.  
  272.           //CAll all listeners!
  273.           //....
  274.  
  275.           Log("\033[31mOnlinePhonebook-eniro: Found: " + JSON.stringify(phonebookNumbers) + "\033[0m\n");
  276.         }
  277.       }
  278.       else
  279.       {
  280.         Log("\033[31mOnlinePhonebook-eniro: Failed to do name lookup, result was: " + result + "\033[0m\n");
  281.       }
  282.  
  283.       if (phonebookNumbers.length == 0)
  284.       {
  285.         if (typeof sensorRKSEEK_API !== 'undefined')
  286.         {
  287.           url = "rkseek.oblivioncreations.se/?client="+sensorRKSEEK_API+"&n=" + number + "&out=text";
  288.           Log("\033[31mURL: http://"+url+"\033[0m\n");
  289.  
  290.           Http_Request(url, function(socket_id, result, header, content_data)
  291.           {
  292.             phonebookNumbers = [];
  293.  
  294.             if (result.indexOf("200 OK") != -1)
  295.             {
  296.               //Log("\033[31mOnlinePhonebook: result was: " + content_data + "\033[0m\n");
  297.               var lines = content_data.split("\n");
  298.               //Log("\033[31mOnlinePhonebook: Line: " + lines[1] + "\033[0m\n");
  299.               //Log("\033[31mOnlinePhonebook: Line: " + lines[2] + "\033[0m\n");
  300.               //Log("\033[31mOnlinePhonebook: Line: " + lines[3] + "\033[0m\n");
  301.               if (lines[2].length > 0)
  302.               {
  303.                 phonebookNumbers = [ lines[2] ]; // TODO Is this really correct?!
  304.                 Storage_SetJsonParameter("PhoneBook", number, phonebookNumbers);
  305.                
  306.                 Sensor_UpdateNameInPhonecalls(timestamp, phonebookNumbers);
  307.                
  308.                 Log("\033[31mOnlinePhonebook-rseek: Found: " + JSON.stringify(phonebookNumbers) + "\033[0m\n");
  309.               }
  310.             }
  311.             else
  312.             {
  313.               Log("\033[31mOnlinePhonebook-rseek: Failed to do name lookup, result was: " + result + "\033[0m\n");
  314.             }
  315.           });
  316.         }
  317.       }
  318.     });
  319.         /*
  320.         Http_Request("wap.hitta.se/default.aspx?Who=" + number + "&Where=&PageAction=White",
  321.             function(socket_id, result, header, content_data) {
  322.                 var persons = new Array();
  323.                 if (result.indexOf("200 OK") != -1)
  324.                 {
  325.                     var endString = "<anchor>Tillbaka<prev/></anchor>";
  326.                     var nameStartString = " title=\"Link\">";
  327.                     var nameEndString = "</a>";
  328.  
  329.                     var lines = content_data.split("<br/>");
  330.  
  331.                     for (var n = 1; n < lines.length; n++)
  332.                     {
  333.                         var line = lines[n].trim(" \n");
  334.  
  335.                         if (line.indexOf(endString) != -1)
  336.                         {
  337.                             break;
  338.                         }
  339.                         var pos = line.indexOf(nameStartString + (persons.length+1) + ".");
  340.  
  341.                         if (pos != -1)
  342.                         {
  343.                             pos += nameStartString.length + 2
  344.                             persons[persons.length] = line.substr(pos, line.length-pos-nameEndString.length).html_entity_decode().replace("  ", " ");
  345.                         }
  346.                     }
  347.                     if (persons.length > 0) {
  348.                         Storage_SetJsonParameter("PhoneBook", number, persons);
  349.  
  350.                         //CAll all listeners!
  351.                         //....
  352.  
  353.                         Log("\033[31mOnlinePhonebook: Found: " + JSON.stringify(persons) + "\033[0m\n");
  354.                     }
  355.                 }
  356.                 else
  357.                 {
  358.                     Log("\033[31mOnlinePhonebook: Failed to do name lookup, result was: " + result + "\033[0m\n");
  359.                 }
  360.             }
  361.         );
  362.         */
  363.  
  364.   }
  365.   else
  366.   {
  367.     //Log("Number already stored\n");
  368.  
  369.     Sensor_UpdateNameInPhonecalls(timestamp, phonebookNumbers);
  370.   }
  371. }
  372. Console_RegisterCommand(Sensor_StoreNumberInPhonebook, function(arg_index, args) { return Console_StandardAutocomplete(arg_index, args); });
  373.  
  374. function Sensor_UpdateNameInPhonecalls(timestamp, numbers)
  375. {
  376.   if (numbers.length > 0)
  377.   {
  378.     var lastValueString = Storage_GetParameter("PhoneCalls", timestamp);
  379.  
  380.     if (lastValueString)
  381.     {
  382.       var lastValue = JSON.parse(lastValueString);
  383.  
  384.       lastValue.names = numbers;
  385.  
  386.       Storage_SetParameter("PhoneCalls", timestamp, JSON.stringify(lastValue));
  387.     }
  388.   }
  389. }
  390.  
  391.