public class MyPlugin extends JavaPlugin {
    @Override
    public void onEnable() {
        // Ekonomi servisi sunucuda ne zaman hazır olursa (şimdi veya 5 saniye sonra) tetiklenir:
        RelayAPI.getServiceRegistry().onServiceReady(EconomyService.class, economy -> {
            getLogger().info("Ekonomi sistemi başarıyla bağlandı!");
            getLogger().info("Para Birimi: " + economy.getDefaultCurrency().displayName());
        });
    }
}

// 1. Özel Servis Arayüzü:
public interface DungeonBridge {
    CompletableFuture<Boolean> isDungeonActive(String dungeonId);
    CompletableFuture<Integer> getPlayerDungeonLevel(UUID playerId);
}

// 2. Kendi Eklentinizde Servisi Kaydetme:
RelayAPI.getServiceRegistry().register(
    DungeonBridge.class,
    new MyDungeonBridgeImpl(),
    ServicePriority.HIGH, // Yüksek öncelikle kaydol
    this
);

// 3. Başka Bir Eklentiden Kullanma:
RelayAPI.getServiceRegistry().getProvider(DungeonBridge.class).ifPresent(dungeon -> {
    dungeon.isDungeonActive("ancient_ruins").thenAccept(active -> {
        if (active) getLogger().info("Antik Harabeler zindanı şu anda açık!");
    });
});

@EventHandler
public void onProviderChange(PrimaryProviderChangedEvent event) {
    if (event.getServiceClass().equals(EconomyService.class)) {
        getLogger().warning("Ekonomi sağlayıcısı değişti!");
        getLogger().info("Eski Sağlayıcı Eklenti: " + (event.getOldProvider() != null ? event.getOldProvider().getPlugin().getName() : "Yok"));
        getLogger().info("Yeni Sağlayıcı Eklenti: " + (event.getNewProvider() != null ? event.getNewProvider().getPlugin().getName() : "Yok"));
    }
}

// Paylaşılacak Veri Modeli (Java Record):
public record ClanLevelUpData(String clanName, UUID leaderId, int newLevel) {}

// Yayınlayan Eklenti (Klan Eklentisi):
ClanLevelUpData payload = new ClanLevelUpData("Akıncılar", leader.getUniqueId(), 5);
RelayAPI.getMessenger().publish("clan:levelup", payload, this);

// Dinleyen Eklenti A (Görev Eklentisi):
RelayAPI.getMessenger().subscribe("clan:levelup", ClanLevelUpData.class, this, context -> {
    ClanLevelUpData data = context.getPayload();
    questManager.giveReward(data.leaderId(), 1000);
});

// Dinleyen Eklenti B (Discord / Webhook Eklentisi):
RelayAPI.getMessenger().subscribe("clan:levelup", ClanLevelUpData.class, this, context -> {
    ClanLevelUpData data = context.getPayload();
    discordBot.sendMessage("📢 " + data.clanName() + " klanı " + data.newLevel() + ". seviyeye ulaştı!");
});

// İstek ve Yanıt Modelleri:
public record BidRequest(UUID playerId, BigDecimal bidAmount) {}
public record BidResponse(boolean approved, String failureReason) {}

// Banka Eklentisi (İsteği Yanıtlayan):
RelayAPI.getMessenger().handleRequest("auction:verify_bid", BidRequest.class, this, (ctx, req) -> {
    return bankService.checkAndLockFunds(req.playerId(), req.bidAmount())
        .thenApply(success -> success 
            ? new BidResponse(true, null) 
            : new BidResponse(false, "Yetersiz bakiye!"));
});

// Açık Artırma Eklentisi (Soru Soran):
BidRequest req = new BidRequest(player.getUniqueId(), BigDecimal.valueOf(5000));

// 3 saniye süre tanınır, yanıt gelmezse otomatik iptal edilir:
RelayAPI.getMessenger().request("auction:verify_bid", req, BidResponse.class, Duration.ofSeconds(3))
    .thenAccept(response -> {
        if (response.approved()) {
            player.sendMessage("§aTeklifiniz kabul edildi!");
        } else {
            player.sendMessage("§cTeklif reddedildi: " + response.failureReason());
        }
    })
    .exceptionally(err -> {
        player.sendMessage("§cBanka servisine ulaşılamadı (Zaman aşımı). Teklif iptal edildi.");
        return null;
    });

public void buyPremiumSword(Player player) {
    RelayAPI.getEconomy().ifPresent(econ -> {
        UUID uuid = player.getUniqueId();
        
        // 1. "token" adlı özel para birimini bul:
        Currency token = econ.getCurrency("token").orElseThrow();
        BigDecimal price = BigDecimal.valueOf(150); // 150 Token

        // 2. Asenkron bakiye kontrolü ve para çekme:
        econ.withdraw(uuid, price, token, "Marketten Kılıç Satın Alındı")
            .thenAccept(response -> {
                if (response.isSuccess()) {
                    giveSword(player);
                    player.sendMessage("§aKılıç satın alındı! Kalan Token: " + econ.format(response.balanceAfter(), token));
                } else {
                    player.sendMessage("§cİşlem başarısız: " + response.errorMessage());
                }
            });
    });
}

public void handlePayCommand(Player sender, Player target, BigDecimal amount) {
    RelayAPI.getEconomy().ifPresent(econ -> {
        Currency gold = econ.getDefaultCurrency();

        econ.transfer(sender.getUniqueId(), target.getUniqueId(), amount, gold, "Oyuncu /pay Transferi")
            .thenAccept(res -> {
                if (res.isSuccess()) {
                    sender.sendMessage("§a" + target.getName() + " oyuncusuna " + econ.format(amount) + " gönderdiniz.");
                    sender.sendMessage("§7Kalan Bakiyeniz: " + econ.format(res.balanceAfter()));
                    target.sendMessage("§a" + sender.getName() + " size " + econ.format(amount) + " gönderdi!");
                } else {
                    sender.sendMessage("§cTransfer yapılamadı: " + res.errorMessage());
                }
            });
    });
}

public void castDashAbility(Player player) {
    UUID uuid = player.getUniqueId();
    String key = "ability:dash";

    // 1. Kontrol:
    if (RelayAPI.getCooldowns().hasCooldown(uuid, key)) {
        String remaining = RelayAPI.getCooldowns().formatRemaining(uuid, key);
        player.sendActionBar(Component.text("§cDash henüz hazır değil! (" + remaining + ")"));
        return;
    }

    // 2. Yeteneği uygula:
    applyDashEffect(player);

    // 3. 8 saniyelik bekleme başlat ve süre bitince ses efekti çal:
    RelayAPI.getCooldowns().setCooldown(uuid, key, Duration.ofSeconds(8), this, expiredEntry -> {
        player.sendActionBar(Component.text("§a✦ Dash Yeteneği Tekrar Hazır! ✦"));
        player.playSound(player.getLocation(), Sound.ENTITY_EXPERIENCE_ORB_PICKUP, 1f, 1.5f);
    });
}

public void triggerDragonSpawnEvent() {
    String key = "event:ender_dragon";

    if (RelayAPI.getCooldowns().hasGlobalCooldown(key)) {
        String remaining = RelayAPI.getCooldowns().formatGlobalRemaining(key);
        Bukkit.broadcastMessage("§cEjderha etkinliği beklemede! Kalan süre: " + remaining);
        return;
    }

    // Ejderhayı doğur ve 2 saatlik global bekleme başlat:
    spawnEnderDragon();
    RelayAPI.getCooldowns().setGlobalCooldown(key, Duration.ofHours(2), this, entry -> {
        Bukkit.broadcastMessage("§e§lDİKKAT! §r§6Antik Ejderha tapınağı tekrar uyanıyor!");
    });
}

// 1. Ortak Anahtar Tanımı:
public static final DataKey<Boolean> COMBAT_TAG = DataKey.of("combat", "tagged", Boolean.class, false);

// 2. Savaş Eklentisi (Combat Plugin):
@EventHandler
public void onDamage(EntityDamageByEntityEvent event) {
    if (event.getEntity() instanceof Player victim) {
        // 15 saniyelik otomatik silinen savaş etiketi koy:
        RelayAPI.getData().setTemporary(victim.getUniqueId(), COMBAT_TAG, true, Duration.ofSeconds(15), this);
    }
}

// 3. Işınlanma Eklentisi (Teleport / Spawn Plugin):
public boolean canTeleport(Player player) {
    boolean inCombat = RelayAPI.getData().getOrKeyDefault(player.getUniqueId(), COMBAT_TAG);
    if (inCombat) {
        player.sendMessage("§cSavaş halindeyken ışınlanamazsınız!");
        return false;
    }
    return true;
}

public static final DataKey<Integer> REPUTATION = DataKey.of("rpg", "reputation", Integer.class, 0);

// Değişiklikleri dinle:
RelayAPI.getData().observe(REPUTATION, this, (targetId, key, oldVal, newVal) -> {
    Player player = Bukkit.getPlayer(targetId);
    if (player != null) {
        updatePlayerScoreboard(player, newVal);
        player.sendMessage("§eİtibar puanınız güncellendi: §a" + newVal);
    }
});

public void onVipZoneEnter(Player player) {
    RelayAPI.getPermissions().ifPresent(perms -> {
        UUID uuid = player.getUniqueId();

        // 1. Asenkron rütbe kontrolü (Main thread donmaz):
        perms.inGroup(uuid, "vip").thenAccept(isVip -> {
            if (!isVip) {
                player.sendMessage("§cBu bölgeye sadece VIP üyeler girebilir!");
                teleportBack(player);
                return;
            }

            // 2. Unvanı çekip tebrik et:
            perms.getPrefix(uuid).thenAccept(prefix -> {
                player.sendMessage(prefix + "§aHoş geldiniz, özel VIP ayrıcalıklarınız aktif!");
                player.setAllowFlight(true);
            });
        });
    });
}

public void grantTempFly(Player player) {
    RelayAPI.getPermissions().ifPresent(perms -> {
        // 24 saatlik geçici yetki ver:
        perms.setTemporaryPermission(player.getUniqueId(), "essentials.fly", true, Duration.ofDays(1))
            .thenAccept(result -> {
                if (result.isSuccess()) {
                    player.sendMessage("§aTebrikler! 24 saatlik uçuş yetkisi hesabınıza tanımlandı.");
                }
            });
    });
}

package com.example.combat;

import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.EventPriority;
import org.bukkit.event.Listener;
import org.bukkit.event.entity.EntityDamageByEntityEvent;
import org.vrz.relay.api.RelayAPI;

public class FriendlyFireListener implements Listener {

    @EventHandler(priority = EventPriority.HIGH, ignoreCancelled = true)
    public void onPlayerDamage(EntityDamageByEntityEvent event) {
        if (!(event.getDamager() instanceof Player damager) || !(event.getEntity() instanceof Player victim)) {
            return;
        }

        RelayAPI.getParties().ifPresent(parties -> {
            // isFriendlySync: O(1) lock-free kontrol. Saniyede binlerce vuruşta thread dondurmaz:
            if (parties.isFriendlySync(damager.getUniqueId(), victim.getUniqueId())) {
                event.setCancelled(true);
                damager.sendMessage("§c" + victim.getName() + " takım arkadaşınız! Ona saldıramazsınız.");
            }
        });
    }
}

public void startDungeonRaid(Player leader) {
    RelayAPI.getParties().ifPresent(parties -> {
        parties.getParty(leader.getUniqueId()).thenAccept(optParty -> {
            if (optParty.isEmpty()) {
                leader.sendMessage("§cZindana girmek için bir partiye sahip olmalısınız!");
                return;
            }

            Party party = optParty.get();
            if (!party.isLeader(leader.getUniqueId())) {
                leader.sendMessage("§cSadece parti lideri zindan akınını başlatabilir!");
                return;
            }

            leader.sendMessage("§aZindan kapıları açılıyor! Parti üye sayısı: " + party.getSize());
            for (UUID memberId : party.getMembers()) {
                Player member = Bukkit.getPlayer(memberId);
                if (member != null && member.isOnline()) {
                    teleportToDungeonArena(member);
                    member.sendMessage("§eZindana ışınlandınız! Takım arkadaşlarınızı koruyun.");
                }
            }
        });
    });
}