Gas Storage REST API

const API_TOKEN = 'YOUR_API_TOKEN';

async function checkGasStorage(country = 'DE') {
  const response = await fetch(
    'https://api.cernion.de/api/gas-storage/country-storage',
    {
      method: 'POST',
      headers: {
        'Authorization': `Bearer ${API_TOKEN}`,
        'Content-Type': 'application/json'
      },
      body: JSON.stringify({
        country,
        includeOperators: true,
        includeFacilities: false
      })
    }
  );
  
  const data = await response.json();
  
  console.log(`\n=== ${data.country} Gas Storage Status ===`);
  console.log(`Date: ${data.date}`);
  console.log(`Fill Level: ${data.fillLevel.percentage}% (${data.fillLevel.status})`);
  console.log(`Storage: ${data.gasInStorage.value.toFixed(0)} / ${data.fullCapacity.value.toFixed(0)} GWh`);
  console.log(`Coverage: ${data.supplySecurityCheck.coverageDays} days\n`);
  
  // EU Mandate Check
  const mandate = data.euMandate;
  console.log('=== EU 90% Mandate ===');
  console.log(`Target: ${mandate.targetFillLevel}% by ${mandate.targetDate}`);
  console.log(`Progress: ${mandate.currentProgress}%`);
  console.log(`Status: ${mandate.status} (${mandate.message})\n`);
  
  // Top 3 Operators
  console.log('=== Top 3 Storage Operators ===');
  data.operators.slice(0, 3).forEach((op, i) => {
    console.log(`${i+1}. ${op.name}: ${op.fillLevel}% (${op.gasInStorage.toFixed(0)} GWh)`);
  });
  
  // Alert if below 70%
  if (data.fillLevel.percentage < 70) {
    console.warn(`\n⚠️ WARNING: Fill level below 70% - Supply risk!`);
  }
  
  return data;
}

// Multi-Country Comparison
async function compareEUStorage() {
  const countries = ['DE', 'FR', 'IT', 'AT', 'NL'];
  const results = await Promise.all(
    countries.map(c => checkGasStorage(c))
  );
  
  console.log('\n=== EU Storage Comparison ===');
  results.forEach(r => {
    console.log(`${r.country}: ${r.fillLevel.percentage}% - ${r.euMandate.status}`);
  });
}

checkGasStorage('DE');

import requests
import pandas as pd
from datetime import datetime, timedelta

API_TOKEN = 'YOUR_API_TOKEN'

class GasStorageMonitor:
    def __init__(self, api_token):
        self.api_token = api_token
        self.base_url = 'https://api.cernion.de/api/gas-storage'
    
    def get_country_storage(self, country='DE', include_operators=True):
        """Fetch gas storage data for a country"""
        response = requests.post(
            f'{self.base_url}/country-storage',
            headers={
                'Authorization': f'Bearer {self.api_token}',
                'Content-Type': 'application/json'
            },
            json={
                'country': country,
                'includeOperators': include_operators
            }
        )
        
        return response.json()
    
    def check_supply_security(self, country='DE'):
        """Analyze supply security status"""
        data = self.get_country_storage(country)
        
        print(f'\n=== {data["country"]} Supply Security ===')
        print(f'Date: {data["date"]}')
        print(f'\nStorage Status:')
        print(f'  Fill Level: {data["fillLevel"]["percentage"]}%')
        print(f'  Gas in Storage: {data["gasInStorage"]["value"]:.0f} GWh')
        print(f'  Full Capacity: {data["fullCapacity"]["value"]:.0f} GWh')
        print(f'  Status: {data["fillLevel"]["status"]}')
        
        print(f'\nFlow Rates:')
        print(f'  Injection: {data["injection"]["dailyRate"]:.1f} GWh/day ({data["injection"]["weeklyTrend"]})')
        print(f'  Withdrawal: {data["withdrawal"]["dailyRate"]:.1f} GWh/day ({data["withdrawal"]["weeklyTrend"]})')
        
        print(f'\nSupply Security:')
        print(f'  Coverage: {data["supplySecurityCheck"]["coverageDays"]} days')
        print(f'  Status: {data["supplySecurityCheck"]["status"]}')
        
        # EU Mandate
        mandate = data['euMandate']
        print(f'\nEU 90% Mandate:')
        print(f'  Target: {mandate["targetFillLevel"]}% by {mandate["targetDate"]}')
        print(f'  Current: {mandate["currentProgress"]}%')
        print(f'  Days Remaining: {mandate["daysRemaining"]}')
        print(f'  Status: {mandate["status"]}')
        
        # Warnings
        if data['fillLevel']['percentage'] < 70:
            print(f'\n⚠️ WARNING: Fill level below 70% - Supply risk!')
        
        if mandate['status'] == 'AT_RISK':
            print(f'\n⚠️ ALERT: EU mandate target at risk!')
        
        return data
    
    def compare_eu_countries(self, countries=['DE', 'FR', 'IT', 'AT', 'NL', 'BE', 'ES']):
        """Compare gas storage across EU countries"""
        results = []
        
        for country in countries:
            try:
                data = self.get_country_storage(country, include_operators=False)
                results.append({
                    'Country': data['country'],
                    'Code': country,
                    'Fill Level %': data['fillLevel']['percentage'],
                    'Storage GWh': data['gasInStorage']['value'],
                    'Coverage Days': data['supplySecurityCheck']['coverageDays'],
                    'EU Mandate Progress': data['euMandate']['currentProgress'],
                    'Status': data['euMandate']['status']
                })
            except Exception as e:
                print(f'Error fetching {country}: {e}')
        
        df = pd.DataFrame(results)
        df = df.sort_values('Fill Level %', ascending=False)
        
        print('\n=== EU Gas Storage Comparison ===')
        print(df.to_string(index=False))
        
        # Critical countries
        critical = df[df['Fill Level %'] < 70]
        if len(critical) > 0:
            print(f'\n⚠️ Countries below 70%:')
            print(critical[['Country', 'Fill Level %', 'Coverage Days']].to_string(index=False))
        
        return df

if __name__ == '__main__':
    monitor = GasStorageMonitor(API_TOKEN)
    
    # Single country check
    monitor.check_supply_security('DE')
    
    # EU comparison
    df = monitor.compare_eu_countries()
    
    # Export
    df.to_csv('eu_gas_storage.csv', index=False)
    print('\nData exported to: eu_gas_storage.csv')