backend.when_save.dosave() - Code Metrics - dfoderick/fullcycle - Measure and Improve Code Quality continuously with Scrutinizer

backend.when_save.dosave() A
last analyzed 2018-11-13 23:52 UTC

↳ Parent: backend.when_save

Complexity

Conditions

Size

Total Lines	10
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	3
eloc	9
nop	1
dl	0
loc	10
rs	9.95
c	0
b	0
f	0

'''save full cycle data'''
from helpers.queuehelper import QueueName, QueueEntries
from domain.mining import Pool, Miner
from backend.fcmapp import Component

COMPONENTSAVE = Component('fullcycle')

def when_save(channel, method, properties, body):
    '''event handler when log event is raised'''
    try:
        print("[{0}] Received save message".format(COMPONENTSAVE.app.now()))
        msg = COMPONENTSAVE.app.messagedecode_configuration(body)
        entries = dosave(msg)
        COMPONENTSAVE.app.enqueue(entries)

    except Exception as ex:
        COMPONENTSAVE.app.logexception(ex)

def dosave(msg):
    entries = QueueEntries()
    if msg.entity == 'miner':
        miner = saveminer(msg)
        entries.add(QueueName.Q_MONITORMINER, COMPONENTSAVE.app.messageencode(miner))
        entries.add(QueueName.Q_PROVISION, COMPONENTSAVE.app.messageencode(miner))

    if msg.entity == 'pool':
        savepool(msg)
    return entries

def saveminer(msg):
    #add or update miner
    miner = Miner.create(msg.values)
    COMPONENTSAVE.app.save_miner(miner)
    return miner

def savepool(msg):
    #save the new named pool
    pool = Pool.create(msg.values)
    COMPONENTSAVE.app.pools.save_pool(pool)
    return pool

def main():
    COMPONENTSAVE.listeningqueue = COMPONENTSAVE.app.subscribe(QueueName.Q_SAVE, when_save)
    COMPONENTSAVE.app.listen(COMPONENTSAVE.listeningqueue)

if __name__ == "__main__":
    main()


1			'''save full cycle data'''
2			from helpers.queuehelper import QueueName, QueueEntries
3			from domain.mining import Pool, Miner
4			from backend.fcmapp import Component
5
6			COMPONENTSAVE = Component('fullcycle')
7
8			def when_save(channel, method, properties, body):
9			'''event handler when log event is raised'''
10			try:
11			print("[{0}] Received save message".format(COMPONENTSAVE.app.now()))
12			msg = COMPONENTSAVE.app.messagedecode_configuration(body)
13			entries = dosave(msg)
14			COMPONENTSAVE.app.enqueue(entries)
15
16			except Exception as ex:
17			COMPONENTSAVE.app.logexception(ex)
18
19			def dosave(msg):
20			entries = QueueEntries()
21			if msg.entity == 'miner':
22			miner = saveminer(msg)
23			entries.add(QueueName.Q_MONITORMINER, COMPONENTSAVE.app.messageencode(miner))
24			entries.add(QueueName.Q_PROVISION, COMPONENTSAVE.app.messageencode(miner))
25
26			if msg.entity == 'pool':
27			savepool(msg)
28			return entries
29
30			def saveminer(msg):
31			#add or update miner
32			miner = Miner.create(msg.values)
33			COMPONENTSAVE.app.save_miner(miner)
34			return miner
35
36			def savepool(msg):
37			#save the new named pool
38			pool = Pool.create(msg.values)
39			COMPONENTSAVE.app.pools.save_pool(pool)
40			return pool
41
42			def main():
43			COMPONENTSAVE.listeningqueue = COMPONENTSAVE.app.subscribe(QueueName.Q_SAVE, when_save)
44			COMPONENTSAVE.app.listen(COMPONENTSAVE.listeningqueue)
45
46			if __name__ == "__main__":
47			main()
48

dfoderick / fullcycle

backend.when_save.dosave() A last analyzed 2018-11-13 23:52 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

backend.when_save.dosave() A
last analyzed 2018-11-13 23:52 UTC