BOSWatch/BW3-Core
1
0
Fork 0
mirror of https://github.com/BOSWatch/BW3-Core.git synced 2026-04-04 22:07:45 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Neue InputSource - LineIn (#38)

Browse source 
* Line-In input Source - code

* bugfix

* Docs

* code cleanup

* cleanup

* code cleanup

* Update docu/docs/config.md

Co-Authored-By: Jan Speller <janspeller1@gmail.com>

* fixes

Co-authored-by: Jan Speller <janspeller1@gmail.com>
This commit is contained in:
kirschbaump 2020-04-20 08:18:29 +02:00 • committed by GitHub
parent 9463bc1eec
commit c2aab648c8
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
4 changed files with 134 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

76
boswatch/inputSource/lineInInput.py Normal file
View file

@ -0,0 +1,76 @@
#!/usr/bin/python
# -*- coding: utf-8 -*-
"""!
____ ____ ______ __ __ __ _____
/ __ )/ __ \/ ___/ | / /___ _/ /______/ /_ |__ /
/ __ / / / /\__ \| | /| / / __ `/ __/ ___/ __ \ /_ <
/ /_/ / /_/ /___/ /| |/ |/ / /_/ / /_/ /__/ / / / ___/ /
/_____/\____//____/ |__/|__/\__,_/\__/\___/_/ /_/ /____/
German BOS Information Script
by Bastian Schroll
@file: lienInInput.py
@date: 18.04.2020
@author: Philipp von Kirschbaum
@description: Input source for line-in with alsa
"""
import logging
from boswatch.utils import paths
from boswatch.processManager import ProcessManager
from boswatch.inputSource.inputBase import InputBase
logging.debug("- %s loaded", __name__)
class LineInInput(InputBase):
"""!Class for the line-in input source"""
def _runThread(self, dataQueue, lineInConfig, decoderConfig):
lineInProc = None
mmProc = None
try:
lineInProc = ProcessManager("arecord")
lineInProc.addArgument("-q ") # supress any other outputs
lineInProc.addArgument("-f S16_LE") # set output format (16bit)
lineInProc.addArgument("-r 22050") # set output sampling rate (22050Hz)
lineInProc.addArgument("-D plughw:" +
str(lineInConfig.get("card", default="1")) +
"," +
str(lineInConfig.get("device", default="0"))) # device id
lineInProc.setStderr(open(paths.LOG_PATH + "asla.log", "a"))
lineInProc.start()
mmProc = ProcessManager(str(lineInConfig.get("mmPath", default="multimon-ng")), textMode=True)
if decoderConfig.get("fms", default=0):
mmProc.addArgument("-a FMSFSK")
if decoderConfig.get("zvei", default=0):
mmProc.addArgument("-a ZVEI1")
if decoderConfig.get("poc512", default=0):
mmProc.addArgument("-a POCSAG512")
if decoderConfig.get("poc1200", default=0):
mmProc.addArgument("-a POCSAG1200")
if decoderConfig.get("poc2400", default=0):
mmProc.addArgument("-a POCSAG2400")
mmProc.addArgument("-f alpha")
mmProc.addArgument("-t raw -")
mmProc.setStdin(lineInProc.stdout)
mmProc.setStderr(open(paths.LOG_PATH + "multimon-ng.log", "a"))
mmProc.start()
logging.info("start decoding")
while self._isRunning:
if not lineInProc.isRunning:
logging.warning("asla was down - try to restart")
lineInProc.start()
elif not mmProc.isRunning:
logging.warning("multimon was down - try to restart")
mmProc.start()
elif lineInProc.isRunning and mmProc.isRunning:
line = mmProc.readline()
if line:
self.addToQueue(line)
except:
logging.exception("error in lineIn input routine")
finally:
mmProc.stop()
lineInProc.stop()