Fritzbox über Echo aufrufen

var md5 = require('md5');
var request = require('request-promise');
var xml2js = require('xml2js');


var sName = null, sKind = null;
var mPhoneKind = {
    "home"    : "home",
    "zuhause" : "home",
    "festnetz": "home",
    "mobile"  : "mobile",
    "mobil"   : "mobile",
    "handy"   : "mobile",
    "work"    : "work",
    "arbeit"  : "work",
    "arbeitsplatz": "work"
}

exports.handler = (event, context, callback) => {

    try {

        // new session   
        if (event.session.new) {
           console.log("NEW SESSION");
        }

        switch (event.request.type) {
            // launch request
            case "LaunchRequest":
               console.log("LAUNCH REQUEST");
               context.succeed(
                 generateResponse(
                     buildSpeechletResponse("Willkommen zur Telefonie", false),
                     {}
                 )
               );
               break;

            // intent request
            case "IntentRequest":
               console.log("INTENT REQUEST");

               switch(event.request.intent.name) {

                  case "AnrufenIntend":


                     if (event.request.intent.slots.Item && event.request.intent.slots.Item.value) {                     
                        sName = event.request.intent.slots.Item.value;                     
                     }

                     if (event.request.intent.slots.name && event.request.intent.slots.name.value) {                     
                        sName = event.request.intent.slots.name.value;                     
                     }   

                     if (event.request.intent.slots.type && event.request.intent.slots.type.value) {                     
                        if (mPhoneKind[event.request.intent.slots.type.value]) {
                            sKind = mPhoneKind[event.request.intent.slots.type.value];
                        }                     
                     }                        


                    console.log("name=" + sName);                        

                     getPhoneBook(0)           
                        .then((oPhoneBook) => {

                            if (oPhoneBook) {

                                var oNumber = getPhoneEntry(oPhoneBook, sName.toLowerCase(), sKind);
                                if (oNumber) {   

                                console.log("name=" + sName + " Nummer=" + oNumber.number);

                                dialFritz(sName, oNumber.number)
                                    .then((sMessage) => {                           
                                        context.succeed(
                                            generateResponse(
                                                buildSpeechletResponse(sMessage, true),
                                                {}
)
)
                                    })
                                    .catch((error) => {
                                        context.fail("Exception: " + error);                           
                                    })  
                                } else {
                                    context.fail("Keine Nummer....");                                                                                                               
                                }
                            } else {
                                context.fail("Keine Telefonbuch....");
                            }                               

                        })
                        .catch((error) => {
                            context.fail("Exception: " + error);                            
                        })  



                    break;                     
               }              
               break;       

            // session ended request
            case "SessionEndedRequest":
               console.log("SESSION ENDED REQUEST");
               break;

            default:
               context.fail("INVALID REQUEST TYPE: ${event.request.type}");       
        }

    } catch(error) {
        context.fail("Exception: ${error}");   
    }   
};

//Helpers
buildSpeechletResponse = (outputText, shouldEndSession) => {
    return {
        shouldEndSession: shouldEndSession,       
        outputSpeech: {
           type: "PlainText",
           text: outputText
        }
    }
};

generateResponse = (speechletResponse, sessionAttributes) => {
    return {
        version: "1.0",
        sessionAttributes: sessionAttributes,
        response: {
            outputSpeech: speechletResponse.outputSpeech,
            shouldEndSession: speechletResponse.shouldEndSession
        }
    }
};



myRequest = (path, method, options, formData, formUrlEncoded) => {
  return new Promise(function (resolve, reject) {
    options.protocol = options.protocol || 'GET';

    // Make sure we have the required options.
    if (!options.server || options.server === '') {
      // We should probably check for more config settings..
      return reject('Missing login config.');
    }

    // add sid to path.
    if (options.sid && !options.sIdIsContainedInFormData) {
      path += '&sid=' + options.sid;
    }

    // Set the options for the request.
    var requestOptions = {
      uri: options.protocol + '://' + options.server + ':' + options.port + path,
      method: method || 'GET',
      resolveWithFullResponse: true,
      rejectUnauthorized: false     
    };

    console.log('uri:' + requestOptions.uri);

    if (formData) {
      requestOptions.formData = formData;
    }

    if (formUrlEncoded) {
      requestOptions.form = formUrlEncoded;
    }         

    // Execute HTTP(S) request.
    request(requestOptions)
    .then((response) => {
      return resolve(response);
    })
    .catch((error) => {
      console.log('Request failed.');
      return reject(error);
    })
  })
}


getSessionId = (options) => {
  return new Promise(function (resolve, reject) {
    // sid vorhanden ?
    if (options.sid) {
      return resolve(options.sid);
    }

    // Bereite GET zur sid Ermittlung vor
    myRequest('/login_sid.lua', 'GET', options)

    // Errechne sid aus Challange
    .then((response) => {

      var challenge = response.body.match('<Challenge>(.*?)</Challenge>')[1];

      var uc2buffer = new Buffer(challenge + '-' + options.password, "ucs2");
      var challengeResponse = challenge + '-' + md5(uc2buffer);

      var path = '/login_sid.lua?username=' + options.username + '&response=' + challengeResponse;

      return myRequest(path, 'GET', options);
    })

    // Check the response.
    .then((response) => {
      if (response.statusCode !== 200) {
        return reject("Status !== 200");
      }
      return response;
    })

    // lese sid
    .then((response) => {
      var sessionId = response.body.match('<SID>(.*?)</SID>')[1];

      if (sessionId === '0000000000000000') {
        return reject('Could not login to Fritz!Box. Invalid login?');
      }

      return resolve(sessionId);
    })

    .catch((error) => {
      //console.log('getSessionId failed.' + error);
      return reject(error);
    })
  });
}


dialFritz = (sName, phoneNumber) => {

  var options = getLoginOptions();

  return new Promise(function (resolve, reject) {
    getSessionId(options)
    .then((sid) => {
      options.sid = sid;
      var path = '/fon_num/fonbook_list.lua?xhr=1&dial=' + phoneNumber;

      return myRequest(path, 'GET', options);
    })

    .then((response) => {
      if (!JSON.parse(response.body).err) {
        return resolve(sName + ' wird angerufen. Klingelton zeigt an, wenn die Verbindung hergestellt ist.');
      }
      return reject('Fehler bei Wahl.....');
    })

    .catch((error) => {
      console.log('dialNumber failed.');
      return reject(error);
    })
  });
}


xmlToJson = (xml) => {
  return new Promise(function (resolve, reject) {
    xml2js.parseString(xml, (error, result) => {
      if (error) return reject(error);
      return resolve(result);
    })
  })
};


getPhoneBook = (phoneBookId) => {

  var options = getLoginOptions();   

  return new Promise(function (resolve, reject) {
    getSessionId(options)
    .then((sid) => {
      options.sid = sid;
      options.sIdIsContainedInFormData = true;
      var formData = {
        sid: options.sid,
        PhonebookId: phoneBookId,
        PhonebookExportName: 'Phonebook',
        PhonebookExport: ''
      }
      return myRequest('/cgi-bin/firmwarecfg', 'POST', options, formData)
    })

    .then((response) => {
      if (response.statusCode !== 200) {
        return reject(response);
      }
      return response;
    })

    .then((response) => {

      var oJson = xmlToJson(response.body);
      //console.log("response: " + oJson);

      return resolve(oJson);
    })

    .catch((error) => {
      console.log('getPhonebook failed.' + error);
      return reject(error);
    })
  })
};


getPhoneEntry = function(oBook, sName, sKind){

    var i, oPhoneEntry = null, nIdx=0;
    oBook.phonebooks.phonebook[0].contact.some( function(oEntry) {
        var sPhoneName = oEntry.person[0].realName[0].toLowerCase();
        //console.log("sPhoneName="+ sPhoneName);

        if (sPhoneName.indexOf(sName) >= 0) {
            oPhoneEntry = oEntry;

            if (sKind) {
                for (i = 0; i < oPhoneEntry.telephony[0].number.length; i++) {
                    if (oPhoneEntry.telephony[0].number.$.type === sKind) {
                        nIdx = i;
                        break;
                    }
                }
            }
            return true;
        }   

        return false;        
    });


    if (oPhoneEntry) {
        //console.log("oPhoneEntry: <" + JSON.stringify(oPhoneEntry.telephony[0].number[0]._));       
        return {
            number: oPhoneEntry.telephony[0].number[nIdx]._
        };
    }

    return null;
};    

getLoginOptions = function(){

    return {
        username: 'XXX',
        password: 'XXX',
        server: 'XXX.myfritz.net',
        port: '...433',
        protocol: 'https'     
    };
}


getPhoneBook(0)   
        .then((oPhoneBook) => {
            var sName = "XXX";
            var sKind = mPhoneKind["handy"];
            var oNumber = getPhoneEntry(oPhoneBook, sName, sKind);

            if (oNumber) {
                console.log("name=" + sName + " Nummer=" + oNumber.number);


                dialFritz(sName, oNumber.number)
                    .then((sMessage) => {                           
                        console.log(sMessage);
                    })
                    .catch((error) => {
                        console.log("Exception: ${error}");                          
                    })                           

            }
        })
        .catch((error) => {
            console.log(error)                          
        });