JVC automatisieren

msg = require 'mp.msg'
utils = require 'mp.utils'
require 'mp.options'

local python = "C:\\Users\\User\\AppData\\Local\\Programs\\Python\\Python38\\python.exe"
local jvcscript = "C:\\mpv\\jvc_dyn.py"

local options = {
    -- behavior
    enable = true,          -- enable or disable the functionality of LD
}

read_options(options)

local state = "m0"

function dyn_ctrl(dir)
    local command = {
        python, jvcscript, dir
    }

    local process = mp.command_native({
        name = 'subprocess',
        playback_only = false,
        args = command,
        capture_stdout = false,
        capture_stderr = false,
    })              

    --dyn_state()
    if dir == "0" then
        state = "m0"
    else    
        state = "m2"
    end
    
    --mp.commandv('script-message', 'jvcdyn', state) 
    dyn_state()
end

function dyn_state()
    local command = {
        python, jvcscript, "ldstate"
    }

    local process = mp.command_native({
        name = 'subprocess',
        playback_only = false,
        args = command,
        capture_stdout = true,
        capture_stderr = true,
    })
             
    state = process.stdout:sub(1, -3)         
    
    -- script message for custom OSD/OSC
    mp.commandv('script-message', 'jvcdyn', state) 
    print("state " .. state)
end

function dyn_start()
    dyn_ctrl("2")
end

-- try to disable laser dimming for end credits
function chapter_update()
    if mp.get_property("chapters") ~= nil then
        local total = mp.get_property_number("chapters")
        local chapter = mp.get_property_number("chapter")
        
        if total >= 3 and chapter == (total-1) then
            dyn_stop()
        end
    end
end

-- example function for custom OSD/OSC or L key
function dyn_toggle()
    if state == "m0" then
        dyn_ctrl("2")
    else    
        dyn_ctrl("0")
    end    
end

function dyn_stop()
    if state ~= "m0" then
        dyn_ctrl("0")
    end
end

mp.register_event("file-loaded", dyn_start)
mp.register_event("end-file",dyn_stop)
mp.observe_property("chapter", "number", chapter_update)
-- example function for custom OSD/OSC or use of L (Shift+l)
mp.add_key_binding("L", "jvcdyn_toggle", dyn_toggle)  

import sys
import socket
from enum import Enum
from time import sleep
import datetime

#change to JVC IP
host = "192.168.0.171"

class Commands(Enum):   
    #LD control
    ld_off   = b"\x21\x89\x01\x50\x4D\x44\x43\x30\x0A"
    ld_mode1 = b"\x21\x89\x01\x50\x4D\x44\x43\x31\x0A"
    ld_mode2 = b"\x21\x89\x01\x50\x4D\x44\x43\x32\x0A"
    ld_status = b"\x3F\x89\x01\x50\x4D\x44\x43\x0A"

class LDStates(Enum):
    m0 = b'\x40\x89\x01\x50\x4D\x30\x0A'
    m1 = b'\x40\x89\x01\x50\x4D\x31\x0A'
    m2 = b'\x40\x89\x01\x50\x4D\x32\x0A'


class ACKs(Enum):
    power_ack = b"\x06\x89\x01\x50\x57\x0A"
    input_ack = b"\x06\x89\x01\x49\x50\x0A"
    
class JVCProjector:
    """JVC Projector Control"""

    def __init__(self, host, port=20554, connect_timeout=2):
        self.host = host
        self.port = port
        self.connect_timeout = connect_timeout

    def _send_command(self, operation, ack=None):
        JVC_GREETING = b'PJ_OK'
        JVC_REQ = b'PJREQ'
        JVC_ACK = b'PJACK'
        result = False

        jvc_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        jvc_sock.settimeout(self.connect_timeout)
        jvc_sock.connect((self.host, self.port)) # connect to projector

        # 3 step handshake:
        # Projector sends PJ_OK, client sends PJREQ, projector replies with PJACK
        # first, after connecting, see if we receive PJ_OK. If not, raise exception
        if jvc_sock.recv(len(JVC_GREETING)) != JVC_GREETING:
            raise Exception("Projector did not reply with correct PJ_OK greeting")

        # try sending PJREQ, if there's an error, raise exception
        try:
            jvc_sock.sendall(JVC_REQ)
        except socket.error as e:
            raise Exception("Socket exception when sending PJREQ")

        # see if we receive PJACK, if not, raise exception
        if jvc_sock.recv(len(JVC_ACK)) != JVC_ACK:
            raise Exception("Socket exception on PJACK")

        # 3 step connection is verified, send the command
        jvc_sock.sendall(operation)
        # if we send a command that returns info, the projector will send
        # an ack, followed by the message. Check to see if the ack sent by
        # projector is correct, then return the message.
        if ack:
            ACK = jvc_sock.recv(len(ack))            

            #if ACK == ack:
            message = jvc_sock.recv(1024)
            result = message
            #print(message)

        jvc_sock.close()

        self.last_command_time = datetime.datetime.now()

        return result
        
        
    def dynld_off(self):
        self._send_command(Commands.ld_off.value)
        
    def dynld_mode1(self):
        self._send_command(Commands.ld_mode1.value)        
    
    def dynld_mode2(self):
        self._send_command(Commands.ld_mode2.value)           
        
    def ld_state(self):
        message = self._send_command(Commands.ld_status.value, ack=ACKs.power_ack.value)
        print(LDStates(message).name)        
        
if sys.argv[1] == "0":
    projector = JVCProjector(host)
    projector.dynld_off()
elif sys.argv[1] == "1":
    projector = JVCProjector(host)
    projector.dynld_mode1()
elif sys.argv[1] == "2":
    projector = JVCProjector(host)
    projector.dynld_mode2()
elif sys.argv[1] == "ldstate":
    projector = JVCProjector(host)
    projector.ld_state()