lampPipe.py

# Copyright (C) 2020 Hiroki Fujii <hfujii@hisystron.com>

import wx, configparser, re
import namedPipe, globalVars, constants, sys, os, m3uManager, listManager

pipeServer = None

def sendPipe():
    pipeClient = namedPipe.Client(constants.PIPE_NAME)
    while True:
        try:
            pipeClient.connect()
            pipeClient.write(sys.argv[1])
            return
        except namedPipe.PipeServerNotFoundError as e:
            pass
def startPipeServer():
    global pipeServer
    pipeServer = namedPipe.Server(constants.PIPE_NAME)
    pipeServer.setReceiveCallback(onReceive)
    pipeServer.start()

def stopPipeServer():
    global pipeServer
    if pipeServer != None:
        pipeServer.exit()
        pipeServer.close()
        pipeServer = None

def onReceive(msg):
    if os.path.exists(msg):
        if os.path.isdir(msg) or os.path.splitext(msg)[1].lower() == ".url" or os.path.splitext(msg)[1].lower() in globalVars.fileExpansions:
            setting = globalVars.app.config.getstring("player", "fileInterrupt", "play", ("play", "addPlaylist", "addQueue", "addQueueHead"))
            if setting == "play":
                if os.path.splitext(msg)[1].lower() == ".url":
                    try: 
                        configP = configparser.ConfigParser()
                        configP.read(msg)
                        url = configP["InternetShortcut"]["url"]
                        if re.search("^https?://.+\..+/.*$", url)!=None: wx.CallAfter(globalVars.eventProcess.forcePlay, url)
                    except: pass
                elif os.path.isfile(msg): wx.CallAfter(globalVars.eventProcess.forcePlay, msg)
                else: wx.CallAfter(listManager.addItems, [msg], globalVars.app.hMainView.queueView, 0)
            elif setting == "addPlaylist":
                if os.path.isfile(msg): wx.CallAfter(listManager.addItems, [msg], globalVars.app.hMainView.playlistView)
                else: wx.CallAfter(listManager.addItems, [msg], globalVars.app.hMainView.playlistView)
            elif setting == "addQueue":
                if os.path.isfile(msg): wx.CallAfter(listManager.addItems, [msg], globalVars.app.hMainView.queueView)
                else: wx.CallAfter(listManager.addItems, [msg], globalVars.app.hMainView.queueView)
            elif setting == "addQueueHead":
                if os.path.isfile(msg): wx.CallAfter(listManager.addItems, [msg], globalVars.app.hMainView.queueView, 0)
                else: wx.CallAfter(listManager.addItems, [msg], globalVars.app.hMainView.queueView, 0)
        elif os.path.splitext(msg)[1].lower() == ".m3u" or os.path.splitext(msg)[1].lower() == ".m3u8":
            setting = globalVars.app.config.getstring("player", "playlistInterrupt", "open", ("open", "add"))
            if setting == "open": wx.CallAfter(m3uManager.loadM3u, msg, m3uManager.REPLACE)
            elif setting == "add": wx.CallAfter(m3uManager.loadM3u, msg, m3uManager.ADD)