Sonos, Alexa, Denon Ultimate Integration

// Design by Waldemar Sakalus - SAKA
// ver 12282017
// App to monitor Sonos status, integrated with Alexa and IFTTT


TCPClient client; //for IFTTT

TCPClient sonos;
byte sonosIP[] = { 192, 168, 1, 111 }; //put your Sonos_IP_address
String sonosResponse;

//IFTTT key
const String keyWaldi = "your IFTTT id";

unsigned long smartDelay = millis();
unsigned long smartCheck = millis();
unsigned long resetTimer = millis();
const unsigned long smartDelayTime = 1000; //1s probing time, how often Sonos is checked whether playing/ stopped
int builtInLED = 7;
String sonosTransportState = "";
String previousState;
byte ledStatus = LOW;

//byte playSonosCheck = LOW;
//byte stopSonosCheck = LOW;

int sonosAmp(String command);

int ampOpto = D2;
int ledOpto = D3;

String masterVolume = "80";
unsigned long volumeDelay = millis();
const unsigned long volumeDelayTime = 60000; //1min probing time, how often current volume on amplifier is checked

void setup()
{
    pinMode(builtInLED, OUTPUT);
    pinMode(ampOpto, INPUT);
    pinMode(ledOpto, OUTPUT);
    checkAmp();
    getSonosStatus();
    sonosTransportState = tryExtractString(readSonosResponse(),"<CurrentTransportState>","</CurrentTransportState>");
    previousState = sonosTransportState;
    
    //Serial1.blockOnOverrun(false);
    Serial1.begin(9600, SERIAL_8N1);
    Particle.function("DenonSerial", controlAmplifier);
    Particle.function("Sonos", controlSonos);
    Particle.variable("MasterVolume", masterVolume);
    
    Serial.begin(9600);
    Serial.println("Connected");
    //Particle.function("Sonos", sonosAmp);
}

void loop() {
    byte ampRead;
    checkAmp();
    getSonosStatus();
    sonosTransportState = tryExtractString(readSonosResponse(),"<CurrentTransportState>","</CurrentTransportState>");
    if (previousState != sonosTransportState) {
        Serial.println(sonosTransportState);
        if (sonosTransportState == "PLAYING") {
            digitalWrite (builtInLED , HIGH );
            delay(2000);
            ampRead = checkAmp();
            if (ampRead == LOW) makerIFTTT(keyWaldi, "SonosOn");
            ledStatus = HIGH;
        }
        else if (sonosTransportState == "PAUSED_PLAYBACK" || sonosTransportState == "STOPPED") {
            digitalWrite (builtInLED , LOW );
            delay(3000); //that's how long it gets for the amplifier to switch up
            ampRead = checkAmp();
            if (ampRead == HIGH ) makerIFTTT(keyWaldi, "SonosOff");
            ledStatus = LOW;
        }
        previousState = sonosTransportState;
    }
    if (volumeDelay < millis()) {
        Serial1.println("MV?"); //check volume
        Serial1.flush();
        volumeDelay = millis() + volumeDelayTime;
    }
    
    sendHeartbeat();
    /*
    if (playSonosCheck == HIGH) {
        playSonos();
        //sonosResponse = readSonosResponse();
        //Serial.println(tryExtractString(sonosResponse,"HTTP/1.1 ","CONTENT-LENGTH:"));
        //Serial.println("playSonosCheck");
        playSonosCheck = LOW;
    }
    if (stopSonosCheck == HIGH) {
        stopSonos();
        //sonosResponse = readSonosResponse();
        //Serial.print(tryExtractString(sonosResponse,"HTTP/1.1 ","CONTENT-LENGTH:"));
        //Serial.println("stopSonosCheck");
        stopSonosCheck = LOW;
    }
    */
    delay(smartDelayTime);
    
    // Reset after 7h of operation
    // ==================================
    if (millis() - resetTimer > 25200000) {
        System.reset();
    }
}

int controlAmplifier(String command)
{   
    if (command != NULL) {
        if (command == "MVUP" || command == "MVDOWN") {
            int increment = 5;
            int vol = masterVolume.toInt();
            if (masterVolume.length() == 3){
                vol = (vol-5)/10;
            }
            if (command == "MVUP") {
                vol = vol + increment;
                if (vol >= 99 ) vol = 99;
            }
            else if (command == "MVDOWN") {
                vol = vol - increment;
                if (vol <= 0) vol = 0;
            }
            //Function to format the volume with leading zeros
            String s = "000" + String(vol);
            s = s.substring(s.length() - 2);
            masterVolume = s;
            String newCommand = "MV" + masterVolume;
            Serial1.println(newCommand);
        }
        else if (command == "PWON"){
            Serial1.println(command);
            setRadioStation();
            playSonos();            
            Serial1.println("SICD"); //select CD as input, that's where Sonos connected
            Serial1.println("MZON"); //switch on main zone, just in case it was off
        }
        else if (command == "PWSTANDBY"){
            Serial1.println(command);
            stopSonos();            
        }
        else {
            Serial1.println(command);
        }
        return 1;
    }
    else return -1;
}

void serialEvent1()
//Triggered when response received from the Denon amplifer
{       
        String denonResponse = "";
        while (Serial1.available() > 0) { 
            char c = Serial1.read();
            denonResponse += c;
        }
        if (denonResponse.startsWith("MV")) {
            masterVolume = "";
            for (int i=2; i<denonResponse.indexOf("\r"); i++){
                masterVolume += denonResponse.charAt(i);
            }
            Serial.println(masterVolume);
        }
}

int controlSonos(String command)
{
    if (command != NULL) {
        if (command == "Play") playSonos();
        else if (command == "Pause") stopSonos();
        else if (command == "Stop") stopSonos();
        return 1;
    }
    else return -1;
}

/*int sonosAmp(String command)
{
    String sonosResponse;
    if(command == "ON")
    {
        Serial.println("ON received");
        playSonosCheck = HIGH;
        //playSonos();
        //sonosResponse = readSonosResponse();
        //Serial.print(tryExtractString(sonosResponse,"HTTP/1.1 ","CONTENT-LENGTH:"));
    }
    else if(command == "OFF")
    {
        //Serial.println(command);
        Serial.println("OFF received");
        stopSonosCheck = HIGH;
        //stopSonos();
        //sonosResponse = readSonosResponse();
        //Serial.print(tryExtractString(sonosResponse,"HTTP/1.1 ","CONTENT-LENGTH:"));
    }

    if (sonosResponse != NULL) return 1;
    else return -1;
}
*/

String readSonosResponse() {
    unsigned long lastdata = millis();
    String sonosResponse = "";
    while (sonos.connected()  || (millis()-lastdata < 500)) { //500ms timeout
        if (sonos.available()) {
            char c = sonos.read();
            sonosResponse += c;
            lastdata = millis();
        }
    }
    sonos.flush();
    sonos.stop();
    return sonosResponse;
}

void getSonosStatus()
/*
POST http://Sonos_IP_address:1400/MediaRenderer/AVTransport/Control HTTP/1.1
HOST: Sonos_IP_address:1400
SOAPACTION: "urn:schemas-upnp-org:service:AVTransport:1#GetTransportInfo"
CONTENT-TYPE: text/xml; charset="utf-8"
Content-Length: 354

<?xml version="1.0" encoding="utf-8"?>
<s:Envelope s:encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" xmlns:s="http://schemas.xmlsoap.org/soap/envelope/">
   <s:Body>
      <u:GetTransportInfo xmlns:u="urn:schemas-upnp-org:service:AVTransport:1">
      <InstanceID>0</InstanceID>
      </u:GetTransportInfo>
   </s:Body>
</s:Envelope>
*/
{
    if (sonos.connect(sonosIP, 1400))
    {
        String contentSOAP ="<?xml version=\"1.0\" encoding=\"utf-8\"?>";
        contentSOAP += "<s:Envelope s:encodingStyle=\"http://schemas.xmlsoap.org/soap/encoding/\" xmlns:s=\"http://schemas.xmlsoap.org/soap/envelope/\">";
        contentSOAP += "<s:Body>";
        contentSOAP += "<u:GetTransportInfo xmlns:u=\"urn:schemas-upnp-org:service:AVTransport:1\">";
        contentSOAP += "<InstanceID>0</InstanceID>";
        contentSOAP += "</u:GetTransportInfo>";
        contentSOAP += "</s:Body>";
        contentSOAP += "</s:Envelope>";
        
        String post = "POST http://";
        post += sonosText();
        post += ":1400/MediaRenderer/AVTransport/Control HTTP/1.1\r\n";
        post += "HOST: ";
        post += sonosText();
        post += ":1400\r\n";
        post += "SOAPACTION: \"urn:schemas-upnp-org:service:AVTransport:1#GetTransportInfo\"\r\n";
        post += "CONTENT-TYPE: text/xml; charset=\"utf-8\"\r\n";
        post += "Content-Length: ";
        post += contentSOAP.length();
        post += "\r\n\r\n";
        post += contentSOAP;
        post += "\r\n\r\n";

        //Serial.println(post);
        sonos.print(post);

        delay(10);
    }
    else Serial.println("connection failed");
}


void playSonos()
/*
POST http://Sonos_IP_address:1400/MediaRenderer/AVTransport/Control HTTP/1.1
HOST: Sonos_IP_address:1400
SOAPACTION: "urn:schemas-upnp-org:service:AVTransport:1#Play"
CONTENT-TYPE: text/xml; charset="utf-8"
Content-Length: 354

<?xml version="1.0" encoding="utf-8"?>
<s:Envelope s:encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" xmlns:s="http://schemas.xmlsoap.org/soap/envelope/">
   <s:Body>
      <u:Play xmlns:u="urn:schemas-upnp-org:service:AVTransport:1">
      <InstanceID>0</InstanceID>
      <Speed>1</Speed>
      </u:Play>
   </s:Body>
</s:Envelope>

<?xml version="1.0" encoding="utf-8"?><s:Envelope s:encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" xmlns:s="http://schemas.xmlsoap.org/soap/envelope/"><s:Body><u:Play xmlns:u="urn:schemas-upnp-org:service:AVTransport:1"><InstanceID>0</InstanceID><Speed>1</Speed></u:Play></s:Body></s:Envelope>
*/
{
    if (sonos.connect(sonosIP, 1400))
    {
        String contentSOAP ="<?xml version=\"1.0\" encoding=\"utf-8\"?>";
        contentSOAP += "<s:Envelope s:encodingStyle=\"http://schemas.xmlsoap.org/soap/encoding/\" xmlns:s=\"http://schemas.xmlsoap.org/soap/envelope/\">";
        contentSOAP += "<s:Body>";
        contentSOAP += "<u:Play xmlns:u=\"urn:schemas-upnp-org:service:AVTransport:1\">";
        contentSOAP += "<InstanceID>0</InstanceID>";
        contentSOAP += "<Speed>1</Speed>";
        contentSOAP += "</u:Play>";
        contentSOAP += "</s:Body>";
        contentSOAP += "</s:Envelope>";
        
        String post = "POST http://";
        post += sonosText();
        post += ":1400/MediaRenderer/AVTransport/Control HTTP/1.1\r\n";
        post += "HOST: ";
        post += sonosText();
        post += ":1400\r\n";
        post += "SOAPACTION: \"urn:schemas-upnp-org:service:AVTransport:1#Play\"\r\n";
        post += "CONTENT-TYPE: text/xml; charset=\"utf-8\"\r\n";
        post += "Content-Length: ";
        post += contentSOAP.length();
        post += "\r\n\r\n";
        post += contentSOAP;
        post += "\r\n\r\n";

        //Serial.println(post);
        sonos.print(post);

        delay(10);
    }
    else Serial.println("connection failed");
}

void stopSonos()
/*
POST http://Sonos_IP_address:1400/MediaRenderer/AVTransport/Control HTTP/1.1
HOST: Sonos_IP_address:1400
SOAPACTION: "urn:schemas-upnp-org:service:AVTransport:1#Stop"
CONTENT-TYPE: text/xml; charset="utf-8"
Content-Length: 354

<?xml version="1.0" encoding="utf-8"?>
<s:Envelope s:encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" xmlns:s="http://schemas.xmlsoap.org/soap/envelope/">
   <s:Body>
      <u:Stop xmlns:u="urn:schemas-upnp-org:service:AVTransport:1">
      <InstanceID>0</InstanceID>
      <Speed>1</Speed>
      </u:Stop>
   </s:Body>
</s:Envelope>
*/
{
    if (sonos.connect(sonosIP, 1400))
    {
        String contentSOAP ="<?xml version=\"1.0\" encoding=\"utf-8\"?>";
        contentSOAP += "<s:Envelope s:encodingStyle=\"http://schemas.xmlsoap.org/soap/encoding/\" xmlns:s=\"http://schemas.xmlsoap.org/soap/envelope/\">";
        contentSOAP += "<s:Body>";
        contentSOAP += "<u:Stop xmlns:u=\"urn:schemas-upnp-org:service:AVTransport:1\">";
        contentSOAP += "<InstanceID>0</InstanceID>";
        contentSOAP += "<Speed>1</Speed>";
        contentSOAP += "</u:Stop>";
        contentSOAP += "</s:Body>";
        contentSOAP += "</s:Envelope>";
        
        String post = "POST http://";
        post += sonosText();
        post += ":1400/MediaRenderer/AVTransport/Control HTTP/1.1\r\n";
        post += "HOST: ";
        post += sonosText();
        post += ":1400\r\n";
        post += "SOAPACTION: \"urn:schemas-upnp-org:service:AVTransport:1#Stop\"\r\n";
        post += "CONTENT-TYPE: text/xml; charset=\"utf-8\"\r\n";
        post += "Content-Length: ";
        post += contentSOAP.length();
        post += "\r\n\r\n";
        post += contentSOAP;
        post += "\r\n\r\n";

        //Serial.println(post);
        sonos.print(post);

        delay(10);
    }
    else Serial.println("connection failed");
}

void setRadioStation()
/*
POST /MediaRenderer/AVTransport/Control HTTP/1.1
HOST: 192.168.1.111:1400
SOAPACTION: "urn:schemas-upnp-org:service:AVTransport:1#SetAVTransportURI"
CONTENT-TYPE: text/xml ; charset="utf-8"
Content-Length: 1029

<?xml version="1.0" encoding="utf-8"?>
<s:Envelope s:encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" xmlns:s="http://schemas.xmlsoap.org/soap/envelope/">
   <s:Body>
      <u:SetAVTransportURI xmlns:u="urn:schemas-upnp-org:service:AVTransport:1">
         <InstanceID>0</InstanceID>
         <CurrentURI>x-sonosapi-stream:s15984?sid=254&amp;flags=8224&amp;sn=0</CurrentURI>
         <CurrentURIMetaData>&lt;DIDL-Lite xmlns:dc="http://purl.org/dc/elements/1.1/" xmlns:upnp="urn:schemas-upnp-org:metadata-1-0/upnp/" xmlns:r="urn:schemas-rinconnetworks-com:metadata-1-0/" xmlns="urn:schemas-upnp-org:metadata-1-0/DIDL-Lite/"&gt;&lt;item id="-1" parentID="-1" restricted="true"&gt;&lt;dc:title&gt;PR3 Trójka&lt;/dc:title&gt;&lt;upnp:class&gt;object.item.audioItem.audioBroadcast&lt;/upnp:class&gt;&lt;desc id="cdudn" nameSpace="urn:schemas-rinconnetworks-com:metadata-1-0/"&gt;SA_RINCON65031_&lt;/desc&gt;&lt;/item&gt;&lt;/DIDL-Lite&gt;</CurrentURIMetaData>
      </u:SetAVTransportURI>
   </s:Body>
</s:Envelope>
*/
{
    if (sonos.connect(sonosIP, 1400))
    {
        String contentSOAP ="<?xml version=\"1.0\" encoding=\"utf-8\"?>";
        contentSOAP += "<s:Envelope s:encodingStyle=\"http://schemas.xmlsoap.org/soap/encoding/\" xmlns:s=\"http://schemas.xmlsoap.org/soap/envelope/\">";
        contentSOAP += "<s:Body>";
        contentSOAP += "<u:SetAVTransportURI xmlns:u=\"urn:schemas-upnp-org:service:AVTransport:1\">";
        contentSOAP += "<InstanceID>0</InstanceID>";
        contentSOAP += "<CurrentURI>x-sonosapi-stream:s15984?sid=254&amp;flags=8224&amp;sn=0</CurrentURI>";
        contentSOAP += "<CurrentURIMetaData>&lt;DIDL-Lite xmlns:dc=\"http://purl.org/dc/elements/1.1/\" xmlns:upnp=\"urn:schemas-upnp-org:metadata-1-0/upnp/\" xmlns:r=\"urn:schemas-rinconnetworks-com:metadata-1-0/\" xmlns=\"urn:schemas-upnp-org:metadata-1-0/DIDL-Lite/\"&gt;&lt;item id=\"-1\" parentID=\"-1\" restricted=\"true\"&gt;&lt;dc:title&gt;PR3 Trójka&lt;/dc:title&gt;&lt;upnp:class&gt;object.item.audioItem.audioBroadcast&lt;/upnp:class&gt;&lt;desc id=\"cdudn\" nameSpace=\"urn:schemas-rinconnetworks-com:metadata-1-0/\"&gt;SA_RINCON65031_&lt;/desc&gt;&lt;/item&gt;&lt;/DIDL-Lite&gt;</CurrentURIMetaData>";
        contentSOAP += "</u:SetAVTransportURI>";
        contentSOAP += "</s:Body>";
        contentSOAP += "</s:Envelope>";
        
        String post = "POST http://";
        post += sonosText();
        post += ":1400/MediaRenderer/AVTransport/Control HTTP/1.1\r\n";
        post += "HOST: ";
        post += sonosText();
        post += ":1400\r\n";
        post += "SOAPACTION: \"urn:schemas-upnp-org:service:AVTransport:1#SetAVTransportURI\"\r\n";
        post += "CONTENT-TYPE: text/xml; charset=\"utf-8\"\r\n";
        post += "Content-Length: ";
        post += contentSOAP.length();
        post += "\r\n\r\n";
        post += contentSOAP;
        post += "\r\n\r\n";

        //Serial.println(post);
        sonos.print(post);

        delay(10);
    }
    else Serial.println("connection failed");
}

void makerIFTTT (String keyIFTTT, String eventIFTTT){
   if (client.connect("maker.ifttt.com", 80))
    {
        String post = "GET /trigger/";
        post += eventIFTTT;
        post += "/with/key/";
        post += keyIFTTT;
        post += " HTTP/1.1\r\n";
        post += "Cache-Control: no-cache\r\n";
        post += "User-Agent: Spark/1.0\r\n";
        post += "Content-Length: 0\r\n";
        post += "Connection: close\r\n";
        post += "Host: maker.ifttt.com\r\n\r\n";
        client.print(post);

        delay(10);
    } 
    if (!client.connected()) client.stop();
}

void triggerIFTTT (String eventIFTTT, String keyIFTTT, String eventText)
{
   if (client.connect("maker.ifttt.com", 80))
    {
        String contentJSON = "\{\"value1\":\"";
        contentJSON += eventText;
        contentJSON += "\"\}";
        
        String post = "POST /trigger/";
        post += eventIFTTT;
        post += "/with/key/";
        post += keyIFTTT;
        post += " HTTP/1.1\r\n";
        post += "Cache-Control: no-cache\r\n";
        post += "User-Agent: Spark/1.0\r\n";
        post += "Connection: close\r\n";
        post += "Host: maker.ifttt.com\r\n";
        post += "Content-Type: application/json\r\n";
        post += "Content-Length: ";
        post += contentJSON.length();


        post += "\r\n\r\n";
        post += contentJSON;
        post += "\r\n\r\n";
        
        Serial.println(post);
        client.print(post);

        delay(10);
    }
    if (!client.connected()) client.stop();
}

String sonosText(){
    String addressIP = "";
    for (int i = 0; i < 4; i++) {
        addressIP += sonosIP[i];
        if (i < 3) {
            addressIP += ".";
        }
    }
    return addressIP;
}


void sendHeartbeat() {
    //send a short heartbeat, so visible through the built in LED that the device is not hanging
    byte tempLED = LOW;
    for (int i = 0; i < 5; i++) {
        digitalWrite(builtInLED, tempLED); // Write LED high/low
        tempLED = (tempLED == HIGH) ? LOW : HIGH;
        delay(30);
    }
    digitalWrite(builtInLED, ledStatus); //restore the LED status
}

byte checkAmp () {
    byte ampRead = digitalRead(ampOpto);
    if (ampRead) {
        digitalWrite(ledOpto, HIGH);
        return LOW;
    }
    else {
        digitalWrite(ledOpto, LOW);
        return HIGH;
    }
    //Serial.println(ampRead);
}

// Returns any text found between a start and end string inside 'str'
// example: startfooend  -> returns foo
// credit to an example on particle.io
String tryExtractString(String str, const char* start, const char* end) {
    if (str == NULL) {
        return "";
    }

    int idx = str.indexOf(start);
    if (idx < 0) {
        return "";
    }

    int endIdx = str.indexOf(end);
    if (endIdx < 0) {
        return "";
    }

    return str.substring(idx + strlen(start), endIdx);
}