KMA Weather MCP Server

import sys
import os
import asyncio
from dotenv import load_dotenv

# Ensure import works
current_dir = os.path.dirname(os.path.abspath(__file__))
if current_dir not in sys.path:
    sys.path.insert(0, current_dir)

try:
    from server import fetch_ultra_srt_ncst, get_ultra_short_term_forecast, convert_latlon_to_grid
except ImportError:
    # Fallback if running from root
    sys.path.append(os.path.join(current_dir, "src"))
    from src.server import fetch_ultra_srt_ncst, get_ultra_short_term_forecast, convert_latlon_to_grid

load_dotenv()

async def main():
    # Gangnam-gu Office Coordinates
    lat = 37.5172
    lon = 127.0473
    
    nx, ny = convert_latlon_to_grid(lat, lon)
    print(f"📍 Gangnam-gu ({lat}, {lon}) -> Grid ({nx}, {ny})")
    
    print("\n1️⃣  Fetching Current Weather...")
    try:
        import json
        result_str = await fetch_ultra_srt_ncst(nx, ny)
        data = json.loads(result_str)
        
        try:
            items = data['response']['body']['items']['item']
            weather = {}
            for item in items:
                weather[item['category']] = item['obsrValue']
            
            t1h = float(weather.get('T1H', -999))
            pty = int(weather.get('PTY', 0))
            reh = float(weather.get('REH', 0))
            wsd = float(weather.get('WSD', 0))
            
            pty_map = {0: "없음", 1: "비", 2: "비/눈", 3: "눈", 5: "빗방울", 6: "빗방울/눈날림", 7: "눈날림"}
            pty_str = pty_map.get(pty, str(pty))
            
            print(f"   🌡️ 기온: {t1h} ℃")
            print(f"   💧 습도: {reh} %")
            print(f"   🌬️ 풍속: {wsd} m/s")
            print(f"   ☔ 강수: {pty_str}")
            
            if t1h < 0:
                print("   🥶 결론: 영하권입니다. 매우 춥습니다.")
            elif t1h < 5:
                print("   🧥 결론: 쌀쌀합니다. 두꺼운 외투가 필요합니다.")
            else:
                print("   🙂 결론: 많이 춥지는 않습니다.")

        except (KeyError, ValueError) as e:
             print(f"⚠️ 데이터 파싱 실패: {e}")
             print(f"Raw: {result_str[:200]}...")

    except Exception as e:
        print(f"❌ Error: {e}")

if __name__ == "__main__":
    asyncio.run(main())