mirror/i2ME-Legacy
1
0
Fork 0
mirror of https://github.com/mewtek/i2ME-Legacy.git synced 2025-05-13 01:40:23 -05:00
Code Issues Packages Projects Releases Wiki Activity

Add radarCollector task to main.py

Browse Source
This commit is contained in:
April 2022-11-02 22:09:12 -07:00
parent 3c64469b5e
commit b82ad0107b
No known key found for this signature in database
GPG Key ID: 17A9A017FAA4DE5E
1 changed files with 23 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
main.py
View File

@ -3,24 +3,28 @@ from asyncio.log import logger
from asyncore import loop from asyncore import loop
import logging,coloredlogs import logging,coloredlogs
from recordGenerators import Alerts,CurrentObservations,DailyForecast,HourlyForecast,AirportDelays,AirQuality,HeatingAndCooling,PollenForecast,Breathing, AchesAndPains, MosquitoActivity, WateringNeeds, TideForecast from recordGenerators import Alerts,CurrentObservations,DailyForecast,HourlyForecast,AirportDelays,AirQuality,HeatingAndCooling,PollenForecast,Breathing, AchesAndPains, MosquitoActivity, WateringNeeds, TideForecast
from radar import TWCRadarCollector
import os import os
from datetime import datetime
l = logging.getLogger(__name__) l = logging.getLogger(__name__)
coloredlogs.install(logger=l) coloredlogs.install(logger=l)
radarTypes = ['radarmosaic'] # TODO: Fix satrad radar server to generate properly.
# Create dirs and files # Create dirs and files
if not os.path.exists('./.temp/'): if not os.path.exists('.temp/'):
os.makedirs('./.temp/') os.makedirs('.temp/')
if not os.path.exists('./.temp/tiles/'): if not os.path.exists('.temp/tiles/'):
os.makedirs('./.temp/tiles/') os.makedirs('.temp/tiles/')
if not os.path.exists('./.temp/tiles/output/'): if not os.path.exists('.temp/tiles/output/'):
os.makedirs('./.temp/tiles/output/') os.makedirs('.temp/tiles/output/')
if not os.path.exists('./.temp/msgId.txt'): if not os.path.exists('.temp/msgId.txt'):
print("Creating initial msgId file") print("Creating initial msgId file")
with open('./.temp/msgId.txt', "w") as f: with open('.temp/msgId.txt', "w") as f:
f.write("410080515") f.write("410080515")
@ -37,13 +41,6 @@ async def grabAlertsLoop():
Alerts.makeRecord() Alerts.makeRecord()
await asyncio.sleep(60) await asyncio.sleep(60)
# THIS IS BROKEN AT THE MOMENT -- COME BACK LATER.
# async def RadarProcessingLoop():
# while True:
# await TWCRadarProcessor.makeRadarImages()
# await asyncio.sleep(30 * 60)
async def FiveMinUpdaters(): async def FiveMinUpdaters():
while True: while True:
CurrentObservations.makeDataFile() CurrentObservations.makeDataFile()
@ -66,6 +63,17 @@ async def HourUpdaters():
l.debug("Sleeping for an hour...") l.debug("Sleeping for an hour...")
await asyncio.sleep(60 * 60) await asyncio.sleep(60 * 60)
async def radarCollector():
radarUpdateIntervalMinutes = [0, 5, 10, 15, 20, 25, 30, 35, 40, 45, 50, 55]
while True:
# Server takes ~15 - 35 seconds on average to fully generate a frame, use 40 seconds
# to make sure the radar frame is fully good to go
if datetime.now().minute in radarUpdateIntervalMinutes and datetime.now().second == 40:
for type in radarTypes:
await TWCRadarCollector.collect(type)
await asyncio.sleep(30)
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
alertTask = loop.create_task(grabAlertsLoop()) alertTask = loop.create_task(grabAlertsLoop())
CCtask = loop.create_task(FiveMinUpdaters()) CCtask = loop.create_task(FiveMinUpdaters())