app.py

import time
import requests
import threading
from firetracker import FireTracker
from flask import Flask, request
from twilio.twiml.messaging_response import MessagingResponse
from datetime import datetime, timedelta
from pytz import timezone

app = Flask(__name__)

LISTEN_ADDRESS = '209.94.59.175'
LISTEN_PORT = 5000
# LISTEN_ADDRESS = '0.0.0.0'
# LISTEN_PORT = 8080


err_text = 'Sorry, an error occurred while generating the fire report.\nPlease try again later.'

fire_reports = {
    'PCT': err_text,
    'CT': err_text,
    'PNT': err_text,
    'AZT': err_text,
    'CDT': err_text
}

trail_names = {
    'PCT': 'PCT',
    'Pacific Crest Trail': 'PCT',
    'CT': 'CT',
    'Colorado Trail': 'CT',
    'PNT': 'PNT',
    'Pacific Northwest Trail': 'PNT',
    'AZT': 'AZT',
    'Arizona Trail': 'AZT',
    'CDT': 'CDT',
    'Continental Divide Trail': 'CDT'
}

def call_api():
    api_url = 'https://services3.arcgis.com/T4QMspbfLg3qTGWY/arcgis/rest/services/WFIGS_Interagency_Perimeters_Current/FeatureServer/0/query?where=1%3D1&outFields=*&returnGeometry=true&f=json'
    while True:
        try:
            response = requests.get(api_url)
            response.raise_for_status()
            data = response.json()
            return data['features']
        except (requests.exceptions.RequestException, ValueError, KeyError) as e:
            print(f"Error retrieving data: {e}")
            print("Retrying in 1 hour...")
            time.sleep(60 * 60)

def retrieve_reports():
    while True:
        current_fires = call_api()
        for trail in fire_reports.keys():
            tracker = FireTracker(trail, current_fires)
            success = tracker.create_SMS()
            if success:
                fire_reports[trail] = tracker.text
                print(f'{trail} generated')
            else:
                fire_reports[trail] = err_text
            del tracker
        time.sleep(60 * 60) # wait one hour before retrieving new reports

@app.route('/test', methods=['GET'])
def test():
    return 'testing'

@app.route('/sms', methods=['POST'])
def sms_reply():
    resp = MessagingResponse()
    message = request.form.get('Body', '').strip()
    match = False
    for name in trail_names.keys():
        if name.lower() in message.lower():
            match = trail_names[name]
            break
    if match:
        resp.message(fire_reports[match])
    else:
        resp.message('Sorry, we could not find a supported trail name in your message.\nPlease enter one of the following: PCT, CT, AZT, PNT, or CDT\nMore trails are forthcoming!')
    return str(resp)

ongoing_thread = threading.Thread(target=retrieve_reports)
ongoing_thread.start()
app.run(host=LISTEN_ADDRESS, port=LISTEN_PORT, threaded=True, debug=False)