Offline-Sprachsteuerung für VDR und Kodi mit Snips und Fhem

Code:

# currentMediaDevice freigeben, damit es vom VDR aus gesetzt werden kann

# da gibt es auch andere Wege, siehe fhem-wiki zu csrfToken

define WEBapi FHEMWEB 8088 global

attr WEBapi allowfrom 192.168.x.y|127.0.0.1        # ip vom vdr

attr WEBapi csrfToken none



define allowedWEB allowed

attr allowedWEB allowedCommands set

attr allowedWEB allowedDevices currentMediaDevice

attr allowedWEB validFor WEBapi



# MQTT device

define SnipsMQTT MQTT 192.168.x.y:1883            #ip und Port vom snips-raspi



# Snips device

define Snips SNIPS SnipsMQTT Wohnküche

attr Snips IODev SnipsMQTT

attr Snips room Wohnküche

attr Snips shortcuts Welcher Tag ist heute={return "es ist " . qx(date +%A) . " der " . qx(date +%D);;}\

Wieviel Uhr ist es={return "es ist " . qx(date +%R);;}\

Wieviel Uhr haben wir={return "es ist " . qx(date +%R);;}\

Ton aus={MediaAction("mute")}\

Ton an={MediaAction("unmute")}\

lauter={MediaAction("vol+")}\

leiser={MediaAction("vol-")}\

Lautstärke maximum={MediaAction("volmax")}\

Lautstärke maximal={MediaAction("volmax")}\

play={MediaAction("play")}\

pause={MediaAction("pause")}\

stop={MediaAction("stop")}\

vor spulen={MediaAction("FastFwd")}\

zurück spulen={MediaAction("FastRew")}\

vor springen={MediaAction("skip+")}\

zurück springen={MediaAction("skip-")}\

Kanal hoch={MediaAction("Channel+")}\

Kanal runter={MediaAction("Channel-")}\

Letzter Sender={MediaAction("PrevChannel")}\

aufnehmen={MediaAction("record")}\

weiter={MediaAction("next")}\

zurück={MediaAction("prev")}\



attr Snips verbose 5



define ntfy_snips_listening notify Snips:listening_wohnkueche.* {snipsListening($EVTPART1)}



# dummy devices, werden als variablen genutzt

define VDR.Volume dummy

define Kodi.Volume dummy

define currentMediaDevice dummy



# VDR device, ich habe es als WOL-Device definiert, damit kann den VDR auch per Sprache einschalten. Man könnte auch ein dummy-device nehmen.

define VDR WOL 00:11:22:AA:BB:CC 192.168.x.y        # mac und ip vom vdr

attr VDR userattr snipsChannels:textField-long

attr VDR interval 60

attr VDR room Snips,Wohnküche

attr VDR snipsChannels a er de={sendSVDRP("CHAN Das Erste HD")}\

zdf={sendSVDRP("CHAN ZDF HD")}\

vox={sendSVDRP("CHAN VOX")}\

rtl={sendSVDRP("CHAN RTL Television")}\

rtl2={sendSVDRP("CHAN RTL2")}\

sat 1={sendSVDRP("CHAN SAT.1")}\

pro 7={sendSVDRP("CHAN ProSieben")}\

kabel 1={sendSVDRP("CHAN kabel eins")}\

sport 1={sendSVDRP("CHAN SPORT1")}\

eurosport={sendSVDRP("CHAN EUROSPORT 1")}\

Nickelodeon={sendSVDRP("CHAN Nickelodeon/Nicknight")}\

comedy central={sendSVDRP("CHAN VIVA/COMEDY CENTRAL")}\

ntv={sendSVDRP("CHAN ntv")}\

en vier und zwanzig={sendSVDRP("CHAN N24")}\

euronews={sendSVDRP("CHAN euronews (D)")}\

arte={sendSVDRP("CHAN arte HD")}\

Phoenix={sendSVDRP("CHAN Phoenix HD")}\

3Sat={sendSVDRP("CHAN 3Sat HD")}\

ServusTV={sendSVDRP("CHAN ServusTV HD")}\

WDR={sendSVDRP("CHAN WDR Köln HD")}\

SWR={sendSVDRP("CHAN SWR BW HD")}\

ha er={sendSVDRP("CHAN hr-fernsehen HD")}\

beh er={sendSVDRP("CHAN BR Fernsehen Süd HD")}\

en de er={sendSVDRP("CHAN NDR Niedersachsen HD")}\

er beh beh={sendSVDRP("CHAN rbb Berlin")}\

em de er={sendSVDRP("CHAN MDR Sachsen")}\

a er de alpha={sendSVDRP("CHAN ARD-alpha")}\

tagesschau vier und zwanzig={sendSVDRP("CHAN tagesschau24")}\

wann={sendSVDRP("CHAN ONE HD")}\

ZDF_neo={sendSVDRP("CHAN ZDF_neo HD")}\

ZDFinfo={sendSVDRP("CHAN ZDFinfo")}\

KIKA={sendSVDRP("CHAN KIKA HD")}\

er en ef={sendSVDRP("CHAN RNF HD")}\

en vier und zwanzig Doku={sendSVDRP("CHAN N24 Doku")}\

kabel eins Doku={sendSVDRP("CHAN kabel eins Doku")}\

de max={sendSVDRP("CHAN DMAX")}\

Sat.1 Gold={sendSVDRP("CHAN Sat.1 Gold")}\

sechs={sendSVDRP("CHAN SIXX")}\

Pro 7 max={sendSVDRP("CHAN ProSieben MAXX")}\

Nitro={sendSVDRP("CHAN Nitro")}\

RTLplus={sendSVDRP("CHAN RTLplus")}\

Welt der Wunder={sendSVDRP("CHAN Welt der Wunder")}\

Super RTL={sendSVDRP("CHAN Super RTL")}\

TOGGO={sendSVDRP("CHAN TOGGO plus")}\

Disney={sendSVDRP("CHAN Disney SD")}\

Tele 5={sendSVDRP("CHAN Tele 5")}\



attr VDR snipsMapping GetOnOff:currentVal=currentMediaDevice:state,valueOn=VDR\

SetOnOff:cmdOn=on,cmdOff={sendSVDRP("hitk power")}\

SetNumeric:currentVal={getVdrVolume()},cmd={setVdrVolume($VALUE)},minVal=0,maxVal=255,step=50,type=Lautstärke\

MediaControls:cmdPlay={sendSVDRP("hitk play")},cmdPause={sendSVDRP("hitk pause")},cmdStop={sendSVDRP("hitk stop")},cmdFwd={sendSVDRP("hitk FastFwd")},cmdBack={sendSVDRP("hitk FastRew")}

attr VDR snipsName Fernseher,vau de er

attr VDR snipsRoom Wohnküche

attr VDR useUdpBroadcast 192.168.x.255            # broadcast-ip

attr VDR webCmd :





# Kodi device

define Kodi KODI 192.168.x.y tcp            # ip von Kodi/vdr

attr Kodi room Snips,Wohnküche

attr Kodi snipsMapping GetOnOff:currentVal=currentMediaDevice:state,valueOn=Kodi\

SetOnOff:cmdOn={fhem("trigger VDR_Kodi Kodi");;return "Ok.";;},cmdOff={fhem("trigger VDR_Kodi VDR");;return "Ok.";;}\

SetNumeric:currentVal=volume,cmd={fhem("set Kodi volume " . $VALUE);fhem('set Kodi.Volume -1');},minVal=0,maxVal=100,step=20,type=Lautstärke\

MediaControls:cmdPlay=play,cmdPause=pause,cmdStop=stop,cmdFwd=next,cmdBack=prev

attr Kodi snipsName Kodi

attr Kodi snipsRoom Wohnküche

attr Kodi updateInterval 60



# device um zwischen VDR und Kodi umzuschalten, um es in der fhem-GUI anzuzeigen und um es programmatisch zu triggern

define VDR_Kodi dummy

attr VDR_Kodi alias Kodi / VDR

attr VDR_Kodi devStateIcon {'<div></div>'}

attr VDR_Kodi room Wohnküche

attr VDR_Kodi webCmd Kodi:VDR



# ip vom vdr

define Kodi_An notify VDR_Kodi.Kodi { GetFileFromURL("http://192.168.x.y/index.php?xbmc=start");; fhem("set currentMediaDevice Kodi");; }

define VDR_An notify VDR_Kodi.VDR  { GetFileFromURL("http://192.168.x.y/index.php?xbmc=stop");; fhem("set currentMediaDevice VDR");; }

Code:

sub sendSVDRP($;$) {

    my ($data, $closeSocket) = @_;

    $closeSocket //= 1;

    

    use IO::Socket::INET;

    

    my $ip = InternalVal("VDR","IP","");

    my $port = 6419;

    

    if ($ip) {

        my $socket = new IO::Socket::INET (

            PeerHost => $ip,

            PeerPort => $port,

            Proto => 'tcp',

        ) or die "ERROR in Socket Creation : $!\n";



        # send command

        Log 1,("sending SVDRP: " . $data);

        $socket->send($data . "\r\n");

        $socket->send("quit\r\n");



        if ($closeSocket)

        {

            Log 1,("closing socket");

            $socket->close();

        }

        else

        {

            Log 1,("returning socket");

            return $socket;

        }

    }

    else {

        Log 1,("no vdr-ip found");

    }

}



sub setVdrVolume($) {

    my ($vol) = @_;

    

    my $new = $vol - 5;

    if ($new < 0) { $new = 0; }

    

    my $cmd = "volu " . $new . "\r\n hitk volume" . ($vol == 0 ? "-" : "+");

    sendSVDRP($cmd);

    

    fhem('set VDR.Volume -1');

}



sub getVdrVolume() {

    my ($line, $search, $pos);

    my $doLoop = 1;

    my $vol = ReadingsVal("VDR.Volume", "state", -1);



    if ($vol == -1)

    {

        my $socket = sendSVDRP("volu", 0);



        while ($doLoop)

        {

            $line = $socket->getline();

            if (defined $line && length($line) > 0)

            {

                Log 1,(trim($line));



                if (substr($line, 0, 3) eq "221") { $doLoop = 0; }



                if (substr($line, 0, 3) eq "250")

                {

                    $search = "Audio volume is";

                    $pos = index($line, $search);

                    if ($pos != -1)

                    {

                        $vol = int(trim(substr($line, $pos + length($search))));

                        $doLoop = 0;

                    }

                }

            }

        }



        Log 1,("closing socket");

        $socket->close();

    }

    

    return $vol;

}





sub snipsListening($) {

    my ($event) = @_;



    my $currentDev = ReadingsVal("currentMediaDevice", "state", "");

    Log 1,("snipsListening: event: " . $event . ", currentDev: " . $currentDev);



    my $vol = -1;



    if ($currentDev)

    {

        if ($event eq "1")

        {

            # snips hört zu...



            if ($currentDev eq "VDR")

            {

                $vol = getVdrVolume();

                Log 1,("snipsListening, VDR, event=1: " . $vol);

                if ($vol > -1)

                {

                    fhem('set VDR.Volume ' . $vol);

                    sendSVDRP("volu " . int($vol / 2));

                }

            }

            elsif ($currentDev eq "Kodi")

            {

                $vol = ReadingsVal("Kodi", "volume", -1);

                Log 1,("snipsListening, Kodi, event=1: " . $vol);

                if ($vol > -1)

                {

                    fhem('set Kodi.Volume ' . $vol);

                    fhem('set Kodi volume ' . int($vol / 2));

                }

            }

        }

        elsif ($event eq "0")

        {

            # snips hört nicht mehr zu



            $currentDev = ReadingsVal("currentMediaDevice", "state", "");

            $vol = ReadingsVal($currentDev . ".Volume", "state", -1);

            Log 1,("snipsListening: event=0: " . $vol);

            if ($vol > -1)

            {

                if ($currentDev eq "VDR")

                {

                    sendSVDRP("volu " . $vol);

                }

                elsif ($currentDev eq "Kodi")

                {

                    fhem('set Kodi volume ' . $vol);

                }

                fhem('set ' . $currentDev . '.Volume -1');

            }

        }

    }

}





sub MediaAction($) {

    my ($action) = @_;



    use Switch;



    my $currentDev = ReadingsVal("currentMediaDevice", "state", "");



    Log 1,("MediaAction: action=$action, currentDev=$currentDev");



    if ($currentDev)

    {

        if ($currentDev eq "VDR")

        {

            switch ($action)

            {

                case ["play", "pause", "stop", "FastFwd", "FastRew", "Channel+", "Channel-", "PrevChannel", "record", "next", "prev"]

                {

                    my $cmd = "hitk " . $action;

                    sendSVDRP($cmd);

                }

                case ["vol+", "vol-", "volmax"]

                {

                    my $vol = -1;

                    

                    if ($action eq "volmax")

                    {

                        $vol = 255;

                    }

                    else

                    {

                        $vol = getNewVolume($action, $currentDev, 50, 0, 255);

                    }

                    

                    if ($vol > -1)

                    {

                        setVdrVolume($vol);

                    }

                }

                case ["mute"]

                {

                    sendSVDRP("volu " . ReadingsVal("VDR.Volume", "state", -1) . "\r\n hitk mute");

                    fhem('set VDR.Volume -1');

                }

                case ["unmute"]

                {

                    sendSVDRP("hitk mute");

                }

                case ["skip+"]

                {

                    sendSVDRP("hitk yellow");

                }

                case ["skip-"]

                {

                    sendSVDRP("hitk green");

                }

            }

        }

        elsif ($currentDev eq "Kodi")

        {

            switch ($action)

            {

                case ["play", "pause", "stop", "next", "prev"]

                {

                    fhem('set Kodi ' . $action);

                }

                case ["vol+", "vol-", "volmax"]

                {

                    my $vol = -1;

                    

                    if ($action eq "volmax")

                    {

                        $vol = 100;

                    }

                    else

                    {

                        $vol = getNewVolume($action, $currentDev, 20, 0, 100);

                    }

                    

                    if ($vol > -1)

                    {

                        fhem('set Kodi volume ' . $vol);

                        fhem('set Kodi.Volume -1');

                    }

                }

                case ["mute", "unmute"]

                {

                    fhem('set Kodi mute');

                }

                case ["skip+"]

                {

                    fhem("set Kodi exec stepforward");

                    fhem("set Kodi exec stepforward");

                }

                case ["skip-"]

                {

                    fhem("set Kodi exec stepback");

                    fhem("set Kodi exec stepback");

                }

            }

        }

    }

    

    return "Ok.";

}





sub getNewVolume($$$$$) {

    my ($action, $dev, $delta, $min, $max) = @_;



    my $vol = ReadingsVal($dev . ".Volume", "state", -1);

    if ($vol > -1)

    {

        if ($action eq "vol-") { $delta *= -1; }

        $vol += $delta;

        if ($vol < $min) { $vol = $min; }

        if ($vol > $max) { $vol = $max; }

    }

    return $vol;

}