🚀 Flutter ve PocketBase ile Modern Bildirim Sistemi (FCM V1 API)

routerAdd("POST", "/api/duyuru-yap", (c) => {
    // --- 1. AYARLAR ---
    const CLIENT_ID = "BURAYA_CLIENT_ID_GELECEK";
    const CLIENT_SECRET = "BURAYA_CLIENT_SECRET_GELECEK";
    const REFRESH_TOKEN = "BURAYA_REFRESH_TOKEN_GELECEK";
    const PROJECT_ID = "justtalk-XXXX"; // Firebase Proje ID'niz

    try {
        // --- 2. VERİYİ GARANTİLİ OKUMA (v0.23+ Uyumlu) ---
        let title = "Varsayılan Başlık";
        let body = "Varsayılan İçerik";

        try {
            // Ham veriyi okuyup JSON parse ediyoruz (En sağlam yöntem)
            const rawBody = readerToString(c.request.body);
            if (rawBody) {
                const json = JSON.parse(rawBody);
                if (json.title) title = json.title;
                if (json.body) body = json.body;
            }
        } catch (readError) {
            console.log("Veri okuma hatası (Varsayılan kullanılıyor): " + readError);
        }

        console.log("📨 Gönderiliyor: " + title + " - " + body);

        // --- 3. GOOGLE TOKEN AL (Dinamik Yetkilendirme) ---
        const tokenResponse = $http.send({
            url: "https://oauth2.googleapis.com/token",
            method: "POST",
            headers: { "Content-Type": "application/x-www-form-urlencoded" },
            body: "client_id=" + CLIENT_ID + 
                  "&client_secret=" + CLIENT_SECRET + 
                  "&refresh_token=" + REFRESH_TOKEN + 
                  "&grant_type=refresh_token"
        });

        if (tokenResponse.statusCode !== 200) {
            return c.json(500, { error: "Google Token alınamadı", details: tokenResponse.json });
        }
        const accessToken = tokenResponse.json.access_token;

        // --- 4. BİLDİRİMİ GÖNDER (FCM V1 API) ---
        const fcmResponse = $http.send({
            url: "https://fcm.googleapis.com/v1/projects/" + PROJECT_ID + "/messages:send",
            method: "POST",
            headers: {
                "Authorization": "Bearer " + accessToken,
                "Content-Type": "application/json"
            },
            body: JSON.stringify({
                "message": {
                    "topic": "tum_kullanicilar", // Tüm abonelere gönder
                    "notification": {
                        "title": title,
                        "body": body
                    }
                }
            })
        });

        // --- 5. LOGLAMA (DB Kayıt) ---
        if (fcmResponse.statusCode === 200) {
            try {
                const collection = $app.findCollectionByNameOrId("duyurular");
                const record = new Record(collection);
                record.set("baslik", title);
                record.set("icerik", body);
                $app.save(record); // Admin yetkisiyle kaydet
            } catch (dbError) {
                console.log("❌ DB Log Hatası: " + dbError);
            }
        }

        return c.json(fcmResponse.statusCode, fcmResponse.json);

    } catch (err) {
        return c.json(500, { error: "Sunucu içi hata", details: err.toString() });
    }
});

dependencies:
  firebase_core: latest
  firebase_messaging: latest
  http: latest

void main() async {
  WidgetsFlutterBinding.ensureInitialized();
  await Firebase.initializeApp(); // Firebase başlatma
  
  // iOS ve Android için ön plan ayarı
  await FirebaseMessaging.instance.setForegroundNotificationPresentationOptions(
    alert: true, 
    badge: true, 
    sound: true,
  );
  
  // Genel kanala abone ol (Broadcast için şart)
  await FirebaseMessaging.instance.subscribeToTopic('tum_kullanicilar');

  runApp(const MyApp());
}

// admin_notification_page.dart
import 'package:flutter/material.dart';
import 'package:http/http.dart' as http;
import 'dart:convert';

class AdminNotificationPage extends StatefulWidget {
  const AdminNotificationPage({super.key});

  @override
  State<AdminNotificationPage> createState() => _AdminNotificationPageState();
}

class _AdminNotificationPageState extends State<AdminNotificationPage> {
  final _titleController = TextEditingController();
  final _bodyController = TextEditingController();
  bool _isLoading = false;

  Future<void> _bildirimGonder() async {
    setState(() => _isLoading = true);
    try {
      final response = await http.post(
        Uri.parse('https://SIZIN-POCKETBASE-URL.com/api/duyuru-yap'),
        headers: {'Content-Type': 'application/json'},
        body: jsonEncode({
          'title': _titleController.text,
          'body': _bodyController.text,
        }),
      );

      if (response.statusCode == 200) {
        ScaffoldMessenger.of(context).showSnackBar(const SnackBar(content: Text('✅ Gönderildi!')));
      } else {
        throw Exception(response.body);
      }
    } catch (e) {
      ScaffoldMessenger.of(context).showSnackBar(SnackBar(content: Text('Hata: $e')));
    } finally {
      setState(() => _isLoading = false);
    }
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(title: const Text('Admin Panel')),
      body: Padding(
        padding: const EdgeInsets.all(16.0),
        child: Column(
          children: [
            TextField(controller: _titleController, decoration: const InputDecoration(labelText: 'Başlık')),
            const SizedBox(height: 10),
            TextField(controller: _bodyController, decoration: const InputDecoration(labelText: 'Mesaj')),
            const SizedBox(height: 20),
            ElevatedButton(
              onPressed: _isLoading ? null : _bildirimGonder,
              child: _isLoading ? const CircularProgressIndicator() : const Text('HERKESE GÖNDER 🚀'),
            ),
          ],
        ),
      ),
    );
  }
}