Either find a way to use the ligmos base listener class, or make the queue concept her

Initial version now done; the gist is (from ligmos): LIGBaseCo

Fix listener about mrfreeze HOT 3 CLOSED

astrobokonon commented on September 26, 2024

Fix listener

from mrfreeze.

Comments (3)

astrobokonon commented on September 26, 2024

Oh. I forgot that this listener is a bit of a hackish mess. This is not going to get done today after all.

MrFreeze/mrfreeze/listener.py

Lines 64 to 84 in 1eb06a9

    
           if tname == 'lig.MrFreeze.cmd': 
        
               schema = self.schemaDict[tname] 
        
               cmddict = parsers.parserCmdPacket(headers, body, 
        
                                                 schema=schema, 
        
                                                 debug=True) 
        
           elif tname.endswith("loisLog"): 
        
               tfields = parsers.parseLOISTemps(headers, body) 
        
               # A little bit of hackish because it's already ugly 
        
               #   I HATE THAT THESE ARE HARDCODED BUT IT'S FASTER 
        
               #   AND MAYBE LOIS WILL GO AWAY SOON SO I CAN DITCH THIS. 
        
               # I couldn't figure out a quick way to get the config 
        
               #   sections into here, but probably could with more effort 
        
               table = "MrFreeze" 
        
               tags = {"Device": "arc-loisgettemp"} 
        
               if 'lemi' in tname.lower(): 
        
                   meas = ["LMI_arc-loisgettemp"] 
        
               elif 'deveny' in tname.lower(): 
        
                   meas = ["DeVeny_arc-loisgettemp"] 
        
               elif 'nasa42' in tname.lower(): 
        
                   meas = ["NASA42_arc-loisgettemp"]

from mrfreeze.

astrobokonon commented on September 26, 2024

One chance might be to define the listener command topic as a "kinda XML" topic that requires further parsing like I did for the PurpleAir parser, but I might have to define a meta-function to call another processing sequence since I only have a place for one bound method to be called. But it might work and it might not be too confusing.

from mrfreeze.

astrobokonon commented on September 26, 2024

Initial version now done; the gist is (from ligmos):

LIGBaseConsumer is a subclass of STOMP's ConnectionListener
queueMaintainer is a subclass of LIGBaseConsumer

and the command/reply topics are passed in as arguments to the initialization of queueMaintainer. The queueMaintainer itself is initialized here in MrFreeze but it's really just a stub with some definitions. Hooray!

from mrfreeze.

Recommend Projects

Fix listener about mrfreeze HOT 3 CLOSED

Comments (3)

Related Issues (16)

Recommend Projects

React

Vue.js

Typescript

TensorFlow

Django

Laravel

D3

Recommend Topics

javascript

web

server

Machine learning

Visualization

Game

Recommend Org

Facebook

Microsoft

Google

Alibaba

D3

Tencent

	if tname == 'lig.MrFreeze.cmd':
	schema = self.schemaDict[tname]
	cmddict = parsers.parserCmdPacket(headers, body,
	schema=schema,
	debug=True)

	elif tname.endswith("loisLog"):
	tfields = parsers.parseLOISTemps(headers, body)
	# A little bit of hackish because it's already ugly
	# I HATE THAT THESE ARE HARDCODED BUT IT'S FASTER
	# AND MAYBE LOIS WILL GO AWAY SOON SO I CAN DITCH THIS.
	# I couldn't figure out a quick way to get the config
	# sections into here, but probably could with more effort
	table = "MrFreeze"
	tags = {"Device": "arc-loisgettemp"}
	if 'lemi' in tname.lower():
	meas = ["LMI_arc-loisgettemp"]
	elif 'deveny' in tname.lower():
	meas = ["DeVeny_arc-loisgettemp"]
	elif 'nasa42' in tname.lower():
	meas = ["NASA42_arc-loisgettemp"]