7 Commits

28 changed files with 2582 additions and 132 deletions
+84
View File
@@ -0,0 +1,84 @@
# Plan: AI Multi-Personalities, Judite (SAC), Dynamic Tags, Persistent Memory & Event Expansion
## 1. Architecture & Component Design
```
┌───────────────────────────┐
│ CanalhandiaCommand │
│ (/ia, /iap, /ia persona) │
└─────────────┬─────────────┘
┌─────────────────┐ ┌──────────────┐ ┌────────────────────────┐
│ PlayerMemory │◄───────►│ Ai │◄───────►│ Tools / Wiki │
│ (ia-memoria.yml)│ │(Orchestrator)│ │ (lugares_jogador, etc.)│
└─────────────────┘ └──────┬───────┘ └────────────────────────┘
┌─────────────┴─────────────┐
│ MiniMax │
│ (HTTP / Tools / Chat) │
└───────────────────────────┘
```
### Components:
1. **`Persona.java` (Enum Enhancement):**
- Add `JUDITE` (SAC/Telemarketing persona) and `NARRADOR` (Fantasy narrator).
- Add `displayTag()` (e.g. "Judite", "Zoeiro", "Amigão") and `tagColor()` (Adventure `NamedTextColor`).
- Add persona-specific system prompts while maintaining the security invariant (`GUARD`).
2. **`PlayerMemory.java` (New Persistent Service):**
- Manages `plugins/Canalhandia/ia-memoria.yml`.
- Thread-safe, cached in-memory with disk persistence.
- Stores per-player:
- Selected persona (`judite`, `zoeiro`, etc.) or `null` (inherit server default).
- Persistent compressed summary of past conversations.
- List of key facts learned about the player (e.g., base coordinates, preferred building materials, fear of mobs).
- Provides sliding-window compression: auto-condenses turns when memory exceeds thresholds.
3. **`Tools.java` (Expanded Function Calling):**
- Add `lugares_jogador` function: fetches recent deaths from `DeathLog`, saved coordinates from `Notes`, and current biome/world.
- Update definitions JSON to make the tool discoverable to the LLM.
4. **`Ai.java` (Orchestrator Updates):**
- Integrate `PlayerMemory`.
- Resolve effective persona per player (`playerMemory.persona(player)` -> fallback `settings.aiPersona()`).
- In `compose()`: inject effective persona tone + `playerMemory.formatContext(player)` + location summary.
- In `deliver()` and `style()`: render dynamic tag `Msg.tag(persona.displayTag(), persona.tagColor())` instead of fixed `[IA]`.
- Update `saySomething()` to support persona-specific spontaneous events.
5. **`CanalhandiaCommand.java` (CLI & Interaction):**
- Enhance `/ia persona [nome]` to set per-player persona or list available personas with descriptions and click-to-select suggestions.
- Add `/ia persona padrao` to reset preference.
- Add `/ia status` and `/ia esquecer`.
6. **`Canalhandia.java` & Event Hooks (Event Expansion):**
- Wire expanded event triggers into `saySomething()`:
- Player joins (`aiWelcome`)
- Player death streaks / notable deaths (`onDeath`)
- Milestones & custom achievements (`onMilestone`)
- Raid and boss victories (`onBossDefeat`)
---
## 2. File Touches
1. `src/main/java/dev/marcospaulo/canalhandia/Persona.java` — Add `JUDITE`, `NARRADOR`, tags, colors, and prompts.
2. `src/main/java/dev/marcospaulo/canalhandia/PlayerMemory.java` — New class for persistent per-player memory & compression.
3. `src/main/java/dev/marcospaulo/canalhandia/Tools.java` — Add `lugares_jogador` tool and integration with `DeathLog` & `Notes`.
4. `src/main/java/dev/marcospaulo/canalhandia/Ai.java` — Integrate `PlayerMemory`, dynamic persona tags, prompt composition.
5. `src/main/java/dev/marcospaulo/canalhandia/CanalhandiaCommand.java` — Subcommands for `/ia persona`, `/ia status`, `/ia esquecer`.
6. `src/main/java/dev/marcospaulo/canalhandia/Canalhandia.java` — Wire `PlayerMemory` lifecycle, expand event hooks.
7. `src/test/java/dev/marcospaulo/canalhandia/PersonaTest.java` — Unit tests for personas, tags, and system prompts.
8. `src/test/java/dev/marcospaulo/canalhandia/PlayerMemoryTest.java` — Unit tests for YAML storage, compression, and per-player state.
9. `src/test/java/dev/marcospaulo/canalhandia/ToolsTest.java` — Unit tests for `lugares_jogador` and tool execution.
---
## 3. Risks & Mitigations
- **Risk:** Token context blowup from memory/chat history.
- *Mitigation:* Hard-cap memory summary length (max 300 chars) and max facts (max 5 items) per player.
- **Risk:** Thread safety when reading player memory in async AI tasks.
- *Mitigation:* Synchronize all `PlayerMemory` reads/writes under monitor; snapshot memory context as immutable strings on main thread before async dispatch.
- **Risk:** API costs from spontaneous event comments.
- *Mitigation:* All events remain strictly governed by `Budget` with cooldown windows and hourly/daily spend limits.
+103
View File
@@ -0,0 +1,103 @@
# Spec: AI Multi-Personalities, Judite (SAC), Dynamic Tags, Persistent Memory & Event Expansion
## 1. Objective & Motivation
Transform the `ia` module in the `Canalhandia` plugin into a rich, personalized companion system:
1. **Per-Player AI Selection:** Each player can pick their own AI persona (or use server default).
2. **Dynamic Chat Tags:** Replace static `[IA]` tag with the active persona's name (e.g. `[Judite]`, `[Zoeiro]`, `[Amigão]`, `[Seco]`, `[Aldeão]`, `[Narrador]`).
3. **Judite Roleplay Persona:** A hilarious Brazilian SAC/telemarketing attendant (Porta dos Fundos style) with fictitious protocols, bureaucratic quirks, hold music jokes, and deadpan efficiency.
4. **Persistent Compressed Memory (`ia-memoria.yml`):** Retain player memories, key facts, past locations, and sliding-window conversation summaries across server reboots.
5. **Rich Location & Stat Grounding:** Grant the AI direct knowledge of places the player has been (death locations via `DeathLog`, saved pins via `Notes`, current biomes/coords, statistics).
6. **Expanded Event Reactivity:** Broaden spontaneous AI commentary to include death streaks, boss/raid triumphs, milestone achievements, first-time dimension visits, and custom join greetings with persona-specific voice.
---
## 2. Personas Specification
### A. Tag & Persona Definitions
| Persona Key | Display Tag | Tone & Character Description |
|---|---|---|
| `judite` | `[Judite]` | Atendente de SAC/telemarketing burocrática e impaciente, viciada em gerundismo ("estaremos verificando no sistema"), gera números de protocolo ("Protocolo 2026-MC-..."), pede para aguardar na linha, cobra pendências (fome/vida baixa) com frieza corporativa e dá respostas precisas. |
| `zoeiro` | `[Zoeiro]` | Veterano debochado do servidor que usa mortes e estatísticas contra o jogador, mantendo o bom humor. |
| `amigao` | `[Amigão]` | Amigo paciente, caloroso e prestativo, ideal para acolher novatos sem sarcasmo. |
| `seco` | `[Seco]` | Minimalista, direto e sarcástico, 1 a 2 frases curtas sem emoção. |
| `aldeao` | `[Aldeão]` | Solene e místico, falando como um sábio aldeão ancestral de Minecraft. |
| `narrador` | `[Narrador]` | Narrador épico e dramático de RPG de fantasia medieval ("Eis que o bravo viajante indaga..."). |
| `neutro` | `[IA]` | Assistente direto, neutro e sem persona marcante. |
### B. Dynamic Tag Rendering
- In `/ia`, `/iap`, and chat responses: Tag is rendered as `Msg.tag(persona.displayTag(), persona.tagColor())` instead of fixed `[IA]`.
- Java players retain rich hover cards detailing the persona name and question prompt.
---
## 3. Player Preferences & Commands
- `/ia persona` / `/ia personalidade`: Lists all available personas and highlights the player's active selection.
- `/ia persona <nome>`: Sets the player's personal persona (persisted in `ia-memoria.yml`).
- `/ia persona padrao` / `/ia persona reset`: Resets to the server-wide default persona configured in `config.yml`.
- `/ia status`: Displays active persona, memory status, and summary of stored facts for the player.
- `/ia esquecer`: Clears the player's stored conversation memory/facts.
---
## 4. Persistent Memory & Chat Compression Engine (`PlayerMemory`)
### File: `plugins/Canalhandia/ia-memoria.yml`
```yaml
players:
<uuid>:
name: "Diguin_n"
persona: "judite"
updated_at: 1771450000000
summary: "Jogador explorou o Nether e perguntou sobre poções de agilidade. Tem base na vila das coordenadas 120, 64, -300."
facts:
- "Tem base na vila (120, 64, -300)"
- "Morreu recentemente no Void"
- "Gosta de criar axolotes e golfinhos"
```
### Memory Mechanics:
1. **Short-Term Session Memory:** Live exchanges stored in memory for immediate follow-ups.
2. **Key Facts Extraction / Journaling:** Maintained per player to keep long-term context across restarts.
3. **Sliding Compression:** When conversation turns exceed limits, compress previous interactions into the player's persistent summary string, ensuring bounded token usage.
---
## 5. Context Grounding & Tools
- **Tool `lugares_jogador`:**
- Retrieves player's recent deaths from `DeathLog` (`mortes.yml`).
- Retrieves player's saved pins/bases from `Notes` (`notas.yml`).
- Retrieves current coordinates, world dimension, and biome.
- **Tool `estatisticas_jogador`:**
- Reads mined blocks, mob kills, total deaths, playtime from `OfflineStats`.
- **Tool `conquistas_jogador`:**
- Reads unlocked titles and achievements.
- Server leaderboards, recent public milestones, online player list.
---
## 6. Expanded Event Engine
The AI can react to diverse gameplay triggers (gated by `aiBudget` and configurable settings):
1. **Death Streaks & Notable Deaths:** Void deaths, falling, explosions, Warden/Wither encounters.
2. **Player Joins (`aiWelcome`):** Persona greets returning player with contextual facts (e.g. Judite mentions pending tickets or absence duration).
3. **Milestone Crossings:** When a player crosses round milestones (e.g. 100km walked, 10,000 blocks mined) or earns rare achievements.
4. **Boss Defeats & Raids:** Dragon/Wither defeats or raid victories.
---
## 7. Acceptance Criteria
1. All existing 316 unit tests continue to pass without regressions.
2. New unit tests covering:
- `PersonaTest`: Validation of all personas including `JUDITE` and `NARRADOR`, display tags, system prompts, safety guard invariant.
- `PlayerMemoryTest`: YAML serialization, compression, fact storage, and per-player persona retention.
- `ToolsTest`: Verification of `lugares_jogador` and updated tool definitions.
- `AiTagTest`: Dynamic persona tag rendering in chat and hover styling.
- `EventTest`: Event triggers formatting prompts with appropriate persona context.
3. `/ia persona <nome>` persists choices across restarts.
4. Full clean compilation with `mvn test` and `mvn package`.
@@ -0,0 +1,46 @@
# Tasks: AI Multi-Personalities, Judite (SAC), Dynamic Tags, Persistent Memory & Event Expansion
- [x] **Task 1: Persona Enhancement (`Persona.java` & `PersonaTest.java`)**
- Add `JUDITE` (SAC/telemarketing attendant) and `NARRADOR` (fantasy narrator) to `Persona` enum.
- Add `displayTag()` (e.g. "Judite", "Zoeiro", "Amigão", "Seco", "Aldeão", "Narrador", "IA") and `tagColor()` (`NamedTextColor`).
- Add persona system prompts with safety guard invariant.
- Update `PersonaTest.java` to assert all enum keys, display tags, colors, and guard constraints.
- [x] **Task 2: Persistent Player Memory & Compression (`PlayerMemory.java` & `PlayerMemoryTest.java`)**
- Create `PlayerMemory.java` persisted at `plugins/Canalhandia/ia-memoria.yml`.
- Implement per-player persona setting (`getPersona`, `setPersona`, `resetPersona`).
- Implement turn recording with automatic sliding-window summary condensation.
- Implement key facts list per player (`addFact`, `getFacts`).
- Implement `formatContext(UUID player)` for AI system prompt formatting.
- Write comprehensive unit tests in `PlayerMemoryTest.java`.
- [x] **Task 3: Location Grounding Tool (`Tools.java` & `ToolsTest.java`)**
- Add `lugares_jogador` function definition to `Tools.DEFINITIONS`.
- Implement `lugares_jogador` in `Tools.java` pulling recent deaths from `DeathLog`, saved pins from `Notes`, and current world/biome.
- Write unit tests in `ToolsTest.java` verifying tool execution and response formatting.
- [x] **Task 4: AI Orchestration & Dynamic Tag Styling (`Ai.java`)**
- Integrate `PlayerMemory` into `Ai.java`.
- Resolve effective persona per player in `ask()`.
- Update `compose()` to inject player persona prompt, player memory context, and location context.
- Update `deliver()` and `style()` to display dynamic persona tag (e.g. `[Judite]`, `[Zoeiro]`) and hover metadata.
- Update `saySomething()` to support persona-specific spontaneous speech.
- [x] **Task 5: Command Interface & Subcommands (`CanalhandiaCommand.java`)**
- Implement `/ia persona` / `/ia personalidade` list and player preference switcher (`/ia persona <nome>`).
- Implement `/ia persona padrao` to reset preference.
- Implement `/ia status` to show active persona, memory summary, and facts.
- Implement `/ia esquecer` to clear personal memory.
- Update tab-completion for `/ia` with new subcommands and persona keys.
- [x] **Task 6: Event Expansion & Plugin Wiring (`Canalhandia.java`)**
- Initialize and expose `PlayerMemory` in `Canalhandia.java`.
- Expand event triggers in `Canalhandia.java`:
- Joins (`onJoinWelcome`) with persona-specific greeting.
- Notable deaths & streaks (`onPlayerDeath`) with persona-specific commentary.
- Milestone completions (`onMilestone`) with persona-specific recognition.
- [x] **Task 7: Verification & Build (`mvn test` & `mvn package`)**
- Run full test suite (`mvn test`) ensuring 100% pass rate.
- Package final jar (`mvn package`).
- Verify all acceptance criteria from `spec.md`.
+37
View File
@@ -0,0 +1,37 @@
# Plan: Módulo Nativo de Chunk Loader
## Arquitetura
1. **`ChunkLoader.java` (Record puro)**
- `id`, `ownerUuid`, `ownerName`, `world`, `x`, `y`, `z`, `chunkX`, `chunkZ`, `createdAt`.
- Métodos utilitários: `chunkCoords()`, `blockCoords()`, etc.
2. **`ChunkLoaders.java` (Gerenciador e Persistência)**
- Gerencia lista em memória sincronizada `List<ChunkLoader>`.
- Persistência em `plugins/Canalhandia/chunks.yml` com salvamento assíncrono.
- Métodos: `add()`, `remove()`, `byChunk()`, `byOwner()`, `loadAll()`, `unloadAll()`, `playerLimit(Player)`.
- Executa `world.addPluginChunkTicket` e `world.removePluginChunkTicket`.
3. **`Module.java` & `Settings.java`**
- Adiciona `CHUNKLOADER("chunkloader", "Âncoras de carregamento contínuo de chunks")` no enum `Module`.
- Adiciona configurações em `Settings.java` (limite padrão, material do bloco, raio de partículas).
4. **`ChunkLoaderListener.java` (Eventos do Mundo)**
- `BlockPlaceEvent`: Detecta colocação da Âncora, verifica permissões/limites LuckPerms, registra loader e ticket.
- `BlockBreakEvent`: Protege quebra por não-donos, remove ticket e devolve o item customizado.
- `BlockExplodeEvent` / `EntityExplodeEvent`: Impede destruição por explosão.
- `BlockPistonExtendEvent` / `BlockPistonRetractEvent`: Impede movimentação por pistão.
5. **`CanalhandiaCommand.java` & `ChunkLoaderCommand.java`**
- Subcomandos de `/chunkloader` / `/ancora` e tab-completion completo.
6. **`BlueMapBridge.java`**
- Cria conjunto de marcadores para chunk loaders no mapa web.
7. **Testes Unitários (`ChunkLoaderTest.java`)**
- Validação de regras de permissão, cálculo de limite, serialização em YAML e exclusão de duplicatas na mesma chunk.
## Riscos & Mitigações
- **Risco:** Descarregamento incorreto no shutdown do servidor gerando tickets órfãos.
- **Mitigação:** `unloadAll()` limpo em `onDisable()`, e tickets do Paper (`PluginChunkTicket`) são re-validados no `onEnable()`.
- **Risco:** Jogador contornar limite colocando em mundos não permitidos ou múltiplas na mesma chunk.
- **Mitigação:** Validação estrita de unicidade de chunk (`byChunk(world, cx, cz) != null`) e verificação de limite antes de aceitar o evento.
+72
View File
@@ -0,0 +1,72 @@
# Spec: Módulo Nativo de Chunk Loader (Canalhandia)
## 1. Visão Geral
Adiciona ao plugin `Canalhandia` um módulo nativo, performático e equilibrado de **Chunk Loading** para o Paper 1.21.x.
Permite que jogadores mantenham áreas/chunks específicas carregadas para farms, redstone e sistemas automatizados usando a API nativa de tickets do Paper (`addPluginChunkTicket`), com permissões granulares e limites por cargo configuráveis via **LuckPerms**.
---
## 2. Requisitos e Mecânicas
### 2.1. Bloco e Item Customizado: "Âncora de Chunk" (Chunk Anchor)
- **Item Base:** `RESPAWN_ANCHOR` ou `LODESTONE` com nome formatado (`§b§lÂncora de Chunk`), lore explicativa e `PersistentDataContainer` identificando o item customizado.
- **Receita de Crafting:**
- Configurada em `config.yml` (ex: 4 Obsidianas Choronas, 4 Diamantes, 1 Estrela do Nether ou Olho do Fim).
- Desbloqueia automaticamente no livro de receitas ao obter os ingredientes.
### 2.2. Colocação e Restrições
- Ao colocar o bloco (`BlockPlaceEvent`):
- Verifica se o jogador possui permissão `canalhandia.chunkloader`.
- Verifica o limite de loaders do jogador no LuckPerms:
- Lê permissões numéricas: `canalhandia.chunkloader.limite.<N>` (ex: `limite.1`, `limite.2`, `limite.5`, `limite.10`).
- Pega o maior `<N>` encontrado nas permissões do jogador.
- Se não houver permissão numérica explícita, usa `chunkloader.limite-padrao` do `config.yml` (padrão: 1).
- Administradores com `canalhandia.admin` não têm limite.
- Verifica se já existe um loader ativo na mesma chunk (máximo 1 por chunk).
- Se aprovado:
- Ativa o ticket na chunk: `world.addPluginChunkTicket(chunkX, chunkZ, plugin)`.
- Salva em `chunks.yml`.
- Cria partícula/efeito sonoro de ativação.
- Registra marcador no BlueMap (opcional/configurável).
- Envia mensagem de confirmação informando quantas âncoras o jogador está usando (ex: `1/3 ativas`).
### 2.3. Remoção e Proteção
- **Proteção:** Apenas o dono da âncora ou administradores (`canalhandia.admin`) podem quebrar o bloco (`BlockBreakEvent`).
- **Explosões / Pistões:** Protegido contra destruição acidental por TNT/Creeper (`EntityExplodeEvent`, `BlockExplodeEvent`) e empurrão por pistão (`BlockPistonExtendEvent`).
- Ao quebrar:
- Remove o ticket de chunk do Paper: `world.removePluginChunkTicket(chunkX, chunkZ, plugin)`.
- Remove de `chunks.yml` e do BlueMap.
- Devolve o item "Âncora de Chunk" ao jogador.
### 2.4. Persistência e Ciclo de Vida
- Arquivo `plugins/Canalhandia/chunks.yml`:
- Armazena ID, UUID do dono, nome, mundo, coordenadas (x, y, z), chunk (cx, cz) e data de criação.
- **No `onEnable()` do plugin:** Carrega `chunks.yml` e registra `addPluginChunkTicket` em todas as chunks salvas.
- **No `onDisable()` do plugin:** Remove os tickets do plugin de forma limpa.
### 2.5. Comandos (`/chunkloader` ou `/ancora`)
- `/chunkloader` ou `/ancora`:
- `/chunkloader info` — Mostra o status da chunk atual (se está carregada por um loader e por quem) e seus limites de uso.
- `/chunkloader listar` — Lista todas as âncoras ativas do jogador com coordenadas e link para deletar/desativar.
- `/chunkloader remover <id>` — Desativa remotamente uma âncora do próprio jogador.
- `/chunkloader receita` — Mostra a receita de crafting.
- `/chunkloader admin listar [jogador]` — (Admin) Lista todos os chunk loaders do servidor.
- `/chunkloader admin remover <id>` — (Admin) Força a remoção de qualquer loader.
- `/chunkloader reload` — (Admin) Recarrega configurações e sincroniza tickets.
---
## 3. Integração com LuckPerms
Nós de permissão:
- `canalhandia.chunkloader` — Habilita o jogador a craftar, colocar e gerenciar âncoras.
- `canalhandia.chunkloader.limite.<N>` — Define o limite máximo de âncoras ativas para o cargo (ex: `canalhandia.chunkloader.limite.3` para VIP).
- `canalhandia.chunkloader.admin` — Acesso total aos comandos administrativos de chunk loading.
---
## 4. Critérios de Aceite
1. Módulo pode ser ativado/desativado via `config.yml` e `/canalhandia modulo chunkloader`.
2. Bloco colocado registra ticket via `world.addPluginChunkTicket` que sobrevive a reboots via `chunks.yml`.
3. Limites de permissão do LuckPerms são respeitados estritamente.
4. Blocos não podem ser roubados ou quebrados por terceiros.
5. Suíte de testes unitários (`ChunkLoaderTest.java`) com 100% de aprovação.
+28
View File
@@ -0,0 +1,28 @@
# Tasks: Módulo Nativo de Chunk Loader
- [x] **Task 1: Modelo de Dados e Gerenciador (`ChunkLoader.java`, `ChunkLoaders.java` e `ChunkLoaderTest.java`)**
- Implementar record `ChunkLoader` puro.
- Implementar `ChunkLoaders` com persistência em `chunks.yml`, `playerLimit(Player)` (LuckPerms `canalhandia.chunkloader.limite.<N>`), registro de tickets no Paper e busca por chunk/dono.
- Criar suíte de testes unitários `ChunkLoaderTest.java` validando regras de limites, unicidade e serialização.
- [x] **Task 2: Configuração e Item Customizado (`Module.java`, `Settings.java` e `ChunkAnchorItem.java`)**
- Adicionar `CHUNKLOADER` ao enum `Module`.
- Adicionar chaves de configuração em `config.yml` e `Settings.java`.
- Criar utilitário `ChunkAnchorItem` para gerar o ItemStack com nome, lore e `PersistentDataContainer`, e registrar receita de crafting.
- [x] **Task 3: Listeners de Proteção e Colocação (`ChunkLoaderListener.java`)**
- Tratar `BlockPlaceEvent` (validação de permissão, cálculo de limite LuckPerms, ativação de ticket).
- Tratar `BlockBreakEvent` (proteção de dono/admin, remoção de ticket, drop do item).
- Tratar explosões e pistões.
- [x] **Task 4: Comandos e Tab-Completion (`CanalhandiaCommand.java`)**
- Adicionar `/chunkloader` e alias `/ancora` (`listar`, `info`, `remover`, `receita`, `admin`).
- Implementar tab-completion completo com permissões.
- [x] **Task 5: Integração no Ciclo de Vida e BlueMap (`Canalhandia.java` & `BlueMapBridge.java`)**
- Inicializar `ChunkLoaders` no `onEnable` e descarregar tickets no `onDisable`.
- Adicionar marcadores no BlueMap.
- [x] **Task 6: Testes, PR e Deploy (`mvn test`, `mvn package`, PR no Gitea)**
- Executar suíte completa de testes.
- Criar branch `feat/chunk-loader-module`, abrir PR com labels `AI-REVIEW` e `AI-USAGE`.
@@ -159,6 +159,17 @@ final class Achievements {
.append(Component.text("" + achievement.description(), NamedTextColor.GRAY)
.decoration(TextDecoration.BOLD, false)));
plugin.getLogger().info("[conquistas] " + player.getName() + "" + achievement.key());
if (plugin.settings().aiEvents() && plugin.settings().moduleEnabled(Module.IA)) {
Persona persona = plugin.playerMemory() != null
? plugin.playerMemory().persona(player.getUniqueId(), plugin.settings().aiPersona())
: plugin.settings().aiPersona();
plugin.ai().saySomething(player.getName(),
"O jogador " + player.getName() + " desbloqueou a conquista \""
+ achievement.title() + "\" (" + achievement.description()
+ "). Faça um breve comentário na sua personalidade.",
plugin.aiBudget(), persona);
}
}
/** Which achievements this player has already unlocked. */
@@ -238,12 +238,16 @@ final class Ai {
return;
}
Persona persona = plugin.playerMemory() != null
? plugin.playerMemory().persona(asker.getUniqueId(), settings.aiPersona())
: settings.aiPersona();
lastAsk.put(asker.getUniqueId(), System.currentTimeMillis());
pending.put(asker.getUniqueId(), true);
askedToday++;
if (!isPrivate && settings.aiPublic()) {
Bukkit.broadcast(Msg.tag("IA", NamedTextColor.LIGHT_PURPLE)
Bukkit.broadcast(Msg.tag(persona.displayTag(), persona.tagColor())
.append(Component.text(asker.getName() + " perguntou: ", NamedTextColor.GRAY)
.decoration(TextDecoration.BOLD, false))
.append(Component.text(question, NamedTextColor.WHITE)
@@ -254,6 +258,7 @@ final class Ai {
String prompt = question;
UUID id = asker.getUniqueId();
final boolean isPriv = isPrivate;
final Persona effectivePersona = persona;
// Captured HERE, on the main thread, because both read the Bukkit world
// and player API. The async body below only ever sees the resulting
@@ -261,12 +266,15 @@ final class Ai {
// bug that shows up as rare, confusing world-state corruption.
final String liveState = settings.aiServerState() ? ServerState.snapshot(asker) : null;
final String chatContext = plugin.chatLog().formatRecent(settings.aiChatContextLines());
final String memoryContext = plugin.playerMemory() != null
? plugin.playerMemory().formatContext(asker.getUniqueId())
: null;
Bukkit.getScheduler().runTaskAsynchronously(plugin, () -> {
String answer = null;
try {
java.util.List<MiniMax.Turn> messages =
compose(asker, prompt, settings, liveState, chatContext);
compose(asker, prompt, settings, effectivePersona, liveState, chatContext, memoryContext);
if (settings.aiTools()) {
// Agentic path: the model pulls what it needs (web search,
@@ -286,8 +294,8 @@ final class Ai {
Wiki.Article article = term == null ? null : wiki.lookup(term);
if (article != null) {
messages.add(messages.size() - 1, new MiniMax.Turn("system",
"Artigo da Minecraft Wiki pt-BR — '" + article.title() + "':\n"
+ article.text()));
"Artigo da Minecraft Wiki pt-BR — '" + article.title() + "':\n"
+ article.text()));
}
}
@@ -320,7 +328,7 @@ final class Ai {
String finalAnswer = answer;
Bukkit.getScheduler().runTask(plugin, () -> {
pending.remove(id);
deliver(id, prompt, finalAnswer, settings, isPriv);
deliver(id, prompt, finalAnswer, settings, effectivePersona, isPriv);
});
});
}
@@ -333,7 +341,7 @@ final class Ai {
* drops tables), the conversation history, then the question itself.
*/
private java.util.List<MiniMax.Turn> compose(Player asker, String question, Settings settings,
String liveState, String chatContext) {
Persona persona, String liveState, String chatContext, String memoryContext) {
java.util.List<MiniMax.Turn> messages = new java.util.ArrayList<>();
messages.add(new MiniMax.Turn("system", settings.aiInstructions()));
@@ -341,13 +349,17 @@ final class Ai {
// safety rules above are read first and the persona is decoration on
// top of them, never a replacement for them (Persona.GUARD restates the
// limits inside the persona's own frame as a second layer).
messages.add(new MiniMax.Turn("system", settings.aiPersona().systemText()));
messages.add(new MiniMax.Turn("system", persona.systemText()));
String serverContext = settings.aiServerContext();
if (!serverContext.isBlank()) {
messages.add(new MiniMax.Turn("system", "Sobre este servidor: " + serverContext));
}
if (memoryContext != null && !memoryContext.isBlank()) {
messages.add(new MiniMax.Turn("system", memoryContext));
}
// The asker's own stats, so "quantos blocos eu minerei?" gets a real
// number instead of "não tenho acesso ao servidor". ~30 tokens; gated
// by ia.estatisticas-jogador so an operator can turn it off. Stale by
@@ -409,7 +421,7 @@ final class Ai {
}
private void deliver(UUID askerId, String question, String answer,
Settings settings, boolean isPrivate) {
Settings settings, Persona persona, boolean isPrivate) {
Player asker = Bukkit.getPlayer(askerId);
if (answer == null || answer.isBlank()) {
if (asker != null) {
@@ -425,20 +437,27 @@ final class Ai {
return;
}
String clean = String.join(" ", segments);
lastAnswer = new Answered(askerId, question, clean);
// Only remember if the asker is still online: a PlayerQuitEvent forgets
// the player's history (carry-forward #6), and re-adding here after the
// quit would resurrect it. lastAnswer stays regardless, so /ia corrigir
// can still correct the last answer even after the asker left.
if (asker != null) {
conversations.remember(askerId, question, clean);
if (plugin.playerMemory() != null) {
try {
plugin.playerMemory().recordTurn(askerId, asker.getName(), question, clean);
} catch (RuntimeException e) {
plugin.getLogger().warning("Falha ao gravar memória da IA para " + asker.getName() + ": " + e);
}
}
}
lastAnswer = new Answered(askerId, question, clean);
if (isPrivate || !settings.aiPublic()) {
if (asker != null) {
boolean bedrock = Platform.isBedrock(asker);
for (int i = 0; i < segments.size(); i++) {
asker.sendMessage(style(segments.get(i), question, settings, bedrock, i == 0));
asker.sendMessage(style(segments.get(i), question, persona, settings.aiFancy(), bedrock, i == 0));
}
}
return;
@@ -450,48 +469,32 @@ final class Ai {
for (int i = 0; i < segments.size(); i++) {
String segment = segments.get(i);
boolean first = i == 0;
plugin.broadcastPerPlatform(bedrock -> style(segment, question, settings, bedrock, first));
plugin.broadcastPerPlatform(bedrock -> style(segment, question, persona, settings.aiFancy(), bedrock, first));
}
plugin.openAiReactions(askerId);
}
/**
* Renders one answer for chat.
*
* <p>Java players get a hover card naming the persona and the question that
* produced the answer, plus a click that pre-fills {@code /ia } so a
* follow-up is one keystroke away — {@code suggestCommand}, never
* {@code runCommand}, so nothing executes without the player pressing enter.
*
* <p>Bedrock gets the same text with no hover and no click, because it
* renders neither; the styling is decoration and its absence costs nothing.
* {@code ia.estilo-rico: false} forces the plain form everywhere.
*
* <p>A long or list-shaped answer arrives as several segments ({@link
* AiText#segments}); the first carries the full {@code [IA]} tag, the rest
* carry a plain grey continuation mark instead of repeating the tag on
* every line, so a five-item list reads as one grouped answer rather than
* five separate IA replies.
*/
private Component style(String answer, String question, Settings settings, boolean bedrock, boolean firstLine) {
static Component style(String answer, String question, Persona persona, boolean fancy, boolean bedrock, boolean firstLine) {
Component body = Component.text(answer, NamedTextColor.WHITE)
.decoration(TextDecoration.BOLD, false);
if (!bedrock && settings.aiFancy()) {
Persona persona = settings.aiPersona();
if (!bedrock && fancy) {
body = body
.hoverEvent(net.kyori.adventure.text.event.HoverEvent.showText(
Component.text("Pergunta: ", NamedTextColor.GRAY)
.append(Component.text(AiText.forLog(question), NamedTextColor.WHITE))
.append(Component.newline())
.append(Component.text("Personalidade: ", NamedTextColor.GRAY))
.append(Component.text(persona.key(), NamedTextColor.LIGHT_PURPLE))
.append(Component.newline())
.append(Component.text("Clique para perguntar outra coisa",
NamedTextColor.DARK_GRAY))))
.append(Component.text(AiText.forLog(question), NamedTextColor.WHITE))
.append(Component.newline())
.append(Component.text("Personalidade: ", NamedTextColor.GRAY))
.append(Component.text(persona.displayName(), persona.tagColor()))
.append(Component.newline())
.append(Component.text("Clique para perguntar outra coisa",
NamedTextColor.DARK_GRAY))))
.clickEvent(net.kyori.adventure.text.event.ClickEvent.suggestCommand("/ia "));
}
Component prefix = firstLine
? Msg.tag("IA", NamedTextColor.LIGHT_PURPLE)
? Msg.tag(persona.displayTag(), persona.tagColor())
: Component.text(" » ", NamedTextColor.DARK_GRAY);
return prefix.append(body);
}
@@ -501,18 +504,15 @@ final class Ai {
/**
* Says something unprompted, in the active persona — a jab at a death
* streak, a greeting for someone who just joined.
*
* <p>Everything about this is deliberately more restricted than {@code /ia}:
* it is gated by {@link Budget} (see the reasons there), it never consults
* the wiki, it asks for a much smaller answer, and it is silent on failure.
* A spontaneous line that errors should leave no trace — nobody asked for
* it, so nobody should see it fail.
*
* @param subject the player it is about, for the per-subject cooldown; may
* be null
* @param prompt what to comment on, already phrased as an instruction
*/
void saySomething(String subject, String prompt, Budget budget) {
saySomething(subject, prompt, budget, null);
}
/**
* Says something unprompted with an optional specific persona override.
*/
void saySomething(String subject, String prompt, Budget budget, Persona customPersona) {
Settings settings = plugin.settings();
if (!settings.moduleEnabled(Module.IA)) {
return;
@@ -530,9 +530,11 @@ final class Ai {
// exact double-message the gap exists to prevent.
budget.spend(subject, now);
Persona persona = customPersona != null ? customPersona : settings.aiPersona();
java.util.List<MiniMax.Turn> messages = new java.util.ArrayList<>();
messages.add(new MiniMax.Turn("system", settings.aiInstructions()));
messages.add(new MiniMax.Turn("system", settings.aiPersona().systemText()));
messages.add(new MiniMax.Turn("system", persona.systemText()));
String serverContext = settings.aiServerContext();
if (!serverContext.isBlank()) {
messages.add(new MiniMax.Turn("system", "Sobre este servidor: " + serverContext));
@@ -560,7 +562,7 @@ final class Ai {
return;
}
Bukkit.getScheduler().runTask(plugin, () -> Bukkit.broadcast(
Msg.tag("IA", NamedTextColor.LIGHT_PURPLE)
Msg.tag(persona.displayTag(), persona.tagColor())
.append(Component.text(clean, NamedTextColor.WHITE)
.decoration(TextDecoration.BOLD, false))));
});
@@ -27,18 +27,26 @@ final class BlueMapBridge {
/** Id and label of the marker set this plugin owns on the map. */
private static final String SET_ID = "canalhandia-notas";
private static final String SET_LABEL = "Anotações";
private static final String SET_LOADERS_ID = "canalhandia-chunkloaders";
private static final String SET_LOADERS_LABEL = "Âncoras de Chunk";
private final Notes notes;
private final java.util.function.Supplier<ChunkLoaders> chunkLoaders;
private final Logger logger;
private final java.util.function.BooleanSupplier enabled;
private final java.util.function.BooleanSupplier chunkLoadersEnabled;
/** False once we know BlueMap is not usable, so we stop retrying. */
private boolean available = true;
BlueMapBridge(Notes notes, Logger logger, java.util.function.BooleanSupplier enabled) {
BlueMapBridge(Notes notes, java.util.function.Supplier<ChunkLoaders> chunkLoaders,
Logger logger, java.util.function.BooleanSupplier enabled,
java.util.function.BooleanSupplier chunkLoadersEnabled) {
this.notes = notes;
this.chunkLoaders = chunkLoaders;
this.logger = logger;
this.enabled = enabled;
this.chunkLoadersEnabled = chunkLoadersEnabled;
}
/**
@@ -47,20 +55,19 @@ final class BlueMapBridge {
*/
void hook() {
try {
de.bluecolored.bluemap.api.BlueMapAPI.onEnable(api -> sync());
logger.info("BlueMap encontrado — anotações públicas vão para o mapa.");
de.bluecolored.bluemap.api.BlueMapAPI.onEnable(api -> {
sync();
syncChunkLoaders();
});
logger.info("BlueMap encontrado — marcadores vão para o mapa.");
} catch (NoClassDefFoundError | Exception e) {
available = false;
logger.fine("BlueMap não está instalado; anotações ficam só no chat.");
logger.fine("BlueMap não está instalado; marcadores desativados.");
}
}
/**
* Rebuilds the marker set from the current public notes.
*
* <p>Rebuild rather than incremental add/remove: the note list is tiny, and
* a full rebuild cannot drift out of sync with the notes file the way a
* missed delete would.
*/
void sync() {
if (!available || !enabled.getAsBoolean()) {
@@ -79,9 +86,6 @@ final class BlueMapBridge {
.label(SET_LABEL)
.build();
for (Note note : publicNotes) {
// Only notes from the world this map renders. Without the
// check, a Nether note would be drawn at the same numeric
// coordinates in the overworld map, pointing at nothing.
if (!sameWorld(map, note.world())) {
continue;
}
@@ -96,13 +100,62 @@ final class BlueMapBridge {
map.getMarkerSets().put(SET_ID, set);
}
} catch (NoClassDefFoundError | Exception e) {
// One line, then stop trying: a broken bridge must never turn into
// a log flood on every note edit.
available = false;
logger.warning("Não consegui atualizar os marcadores do BlueMap: " + e);
}
}
void syncChunkLoaders() {
if (!available || !chunkLoadersEnabled.getAsBoolean() || chunkLoaders == null) {
return;
}
ChunkLoaders loaders = chunkLoaders.get();
if (loaders == null) {
return;
}
try {
var maybeApi = de.bluecolored.bluemap.api.BlueMapAPI.getInstance();
if (maybeApi.isEmpty()) {
return;
}
var api = maybeApi.get();
for (var map : api.getMaps()) {
var set = de.bluecolored.bluemap.api.markers.MarkerSet.builder()
.label(SET_LOADERS_LABEL)
.build();
for (ChunkLoader loader : loaders.all()) {
if (!mapMatchesWorld(map, loader.world())) {
continue;
}
var marker = de.bluecolored.bluemap.api.markers.POIMarker.builder()
.label("Âncora #" + loader.id() + " (" + loader.ownerName() + ")")
.detail("<b>Âncora de Chunk #" + loader.id() + "</b><br>Dono: "
+ escape(loader.ownerName()) + "<br>Chunk: " + loader.chunkCoords())
.position(loader.x(), loader.y(), loader.z())
.build();
set.getMarkers().put("loader-" + loader.id(), marker);
}
map.getMarkerSets().put(SET_LOADERS_ID, set);
}
} catch (NoClassDefFoundError | Exception ignored) {
}
}
private boolean mapMatchesWorld(de.bluecolored.bluemap.api.BlueMapMap map, String world) {
if (world == null || world.isBlank()) {
return false;
}
String mapId = map.getId().toLowerCase(java.util.Locale.ROOT);
String w = world.toLowerCase(java.util.Locale.ROOT);
if (w.endsWith("_nether") || w.equals("nether") || w.equals("world_nether")) {
return mapId.contains("nether");
}
if (w.endsWith("_the_end") || w.equals("the_end") || w.equals("world_the_end") || w.equals("end")) {
return mapId.contains("end");
}
return !mapId.contains("nether") && !mapId.contains("end");
}
/**
* Whether a map renders the world a note was written in.
*
@@ -85,6 +85,8 @@ public final class Canalhandia extends JavaPlugin implements Listener {
private Milestones milestones;
private Achievements achievements;
private WeeklyStats weeklyStats;
private PlayerMemory playerMemory;
private ChunkLoaders chunkLoaders;
/** Gate for spontaneous AI lines; see Budget for why this is strict. */
private Budget aiBudget;
private BlueMapBridge blueMap;
@@ -125,13 +127,20 @@ public final class Canalhandia extends JavaPlugin implements Listener {
achievements.syncCatalogue();
milestones.resyncSilently();
weeklyStats = new WeeklyStats(new java.io.File(getDataFolder(), "semana.yml"));
playerMemory = new PlayerMemory(new java.io.File(getDataFolder(), "ia-memoria.yml"));
chunkLoaders = new ChunkLoaders(this, new java.io.File(getDataFolder(), "chunks.yml"));
if (settings.moduleEnabled(Module.CHUNKLOADER)) {
chunkLoaders.loadAllTickets();
ChunkAnchorItem.registerRecipe(this);
}
aiBudget = new Budget(settings.aiSpontaneousPerDay(),
settings.aiSpontaneousGapMinutes() * 60_000L,
settings.aiSubjectCooldownMinutes() * 60_000L);
ai = new Ai(this);
// Optional: does nothing (and logs nothing loud) without BlueMap.
blueMap = new BlueMapBridge(notes, getLogger(),
() -> settings.moduleEnabled(Module.NOTAS) && settings.notesOnMap());
blueMap = new BlueMapBridge(notes, () -> chunkLoaders, getLogger(),
() -> settings.moduleEnabled(Module.NOTAS) && settings.notesOnMap(),
() -> settings.moduleEnabled(Module.CHUNKLOADER) && settings.chunkLoaderBlueMap());
blueMap.hook();
// Snapshot the server's recipes on the main thread; RecipeBook.describe
// reads from the async answer path and Bukkit.recipeIterator() is not
@@ -144,12 +153,13 @@ public final class Canalhandia extends JavaPlugin implements Listener {
for (String name : List.of("canalhandia", "curiosidade", "adivinha", "enquete", "ranking",
"reagir", "reacoes", "palpite", "votar", "legal", "wow", "top", "f", "ia", "iap",
"errado", "nota", "save", "recado", "recados", "mortes", "conquistas",
"perfil", "titulo")) {
"perfil", "titulo", "chunkloader")) {
register(name, root);
}
getServer().getPluginManager().registerEvents(this, this);
getServer().getPluginManager().registerEvents(new TitleChatListener(this), this);
getServer().getPluginManager().registerEvents(new ChunkLoaderListener(this), this);
rescheduleTimer();
rescheduleMilestones();
@@ -181,6 +191,11 @@ public final class Canalhandia extends JavaPlugin implements Listener {
if (poll != null) {
poll.hide();
}
if (chunkLoaders != null) {
chunkLoaders.unloadAllTickets();
chunkLoaders.close();
ChunkAnchorItem.unregisterRecipe(this);
}
}
Settings settings() {
@@ -195,6 +210,11 @@ public final class Canalhandia extends JavaPlugin implements Listener {
return ai;
}
/** Persistent player memory and personal AI settings. Never null. */
PlayerMemory playerMemory() {
return playerMemory;
}
/** Recent public chat, for the AI's ambient context. Never null. */
ChatLog chatLog() {
return chatLog;
@@ -220,6 +240,11 @@ public final class Canalhandia extends JavaPlugin implements Listener {
return achievements;
}
/** Active chunk loaders. Never null. */
ChunkLoaders chunkLoaders() {
return chunkLoaders;
}
/** The title each player has chosen to wear in chat. Never null. */
Titles titles() {
return titles;
@@ -667,11 +692,14 @@ public final class Canalhandia extends JavaPlugin implements Listener {
return;
}
String stats = offlineStats.summary(player.getUniqueId());
Persona persona = playerMemory != null
? playerMemory.persona(player.getUniqueId(), settings.aiPersona())
: settings.aiPersona();
ai.saySomething(player.getName(),
"O jogador " + player.getName() + " acabou de entrar no servidor."
+ (stats == null ? "" : " Estatísticas dele: " + stats)
+ " Dê as boas-vindas do seu jeito, em uma frase.",
aiBudget);
+ " Dê as boas-vindas do seu jeito e na sua personalidade, em uma frase curta.",
aiBudget, persona);
}, Math.max(1, settings.joinDelaySeconds()) * 20L);
}
@@ -873,11 +901,14 @@ public final class Canalhandia extends JavaPlugin implements Listener {
deathStreak.put(player.getUniqueId(), new Streak(count, now));
if (settings.aiEvents() && count >= settings.aiDeathStreak()) {
Persona persona = playerMemory != null
? playerMemory.persona(player.getUniqueId(), settings.aiPersona())
: settings.aiPersona();
ai.saySomething(player.getName(),
"O jogador " + player.getName() + " morreu " + count
+ " vezes seguidas em poucos minutos. A última foi assim: " + flavor
+ ". Comente com deboche, sem ofender.",
aiBudget);
+ ". Comente na sua personalidade, sem ofender de verdade.",
aiBudget, persona);
// Reset so the next comment needs a fresh run rather than firing on
// every death from here on.
deathStreak.remove(player.getUniqueId());
@@ -5,11 +5,14 @@ import net.kyori.adventure.text.event.ClickEvent;
import net.kyori.adventure.text.format.NamedTextColor;
import org.bukkit.Bukkit;
import org.bukkit.Location;
import org.bukkit.Material;
import org.bukkit.block.Block;
import org.bukkit.command.Command;
import org.bukkit.command.CommandExecutor;
import org.bukkit.command.CommandSender;
import org.bukkit.command.TabCompleter;
import org.bukkit.entity.Player;
import org.bukkit.inventory.ItemStack;
import java.util.ArrayList;
import java.util.Arrays;
@@ -62,6 +65,7 @@ final class CanalhandiaCommand implements CommandExecutor, TabCompleter {
case "conquistas" -> conquistas(sender, args);
case "perfil" -> perfil(sender, args);
case "titulo" -> titulo(sender, args);
case "chunkloader", "ancora", "ancoras", "chunkloaders" -> chunkloader(sender, args);
// Typed twin of the [F] mourning button — "f" is not a configured
// reaction (the mourning set is hardcoded), so it can't be found via
// reactionForCommand; route it directly. Acts on the latest message,
@@ -563,6 +567,16 @@ final class CanalhandiaCommand implements CommandExecutor, TabCompleter {
}
boolean on = args[1].equalsIgnoreCase("on");
plugin.settings().moduleEnabled(module, on);
if (module == Module.CHUNKLOADER) {
if (on) {
plugin.chunkLoaders().loadAllTickets();
ChunkAnchorItem.registerRecipe(plugin);
} else {
plugin.chunkLoaders().unloadAllTickets();
ChunkAnchorItem.unregisterRecipe(plugin);
}
plugin.blueMap().syncChunkLoaders();
}
plugin.rescheduleTimer();
plugin.rescheduleMilestones();
Msg.ok(sender, "Módulo " + module.label() + " " + (on ? "ativado" : "desativado") + ".");
@@ -967,10 +981,28 @@ final class CanalhandiaCommand implements CommandExecutor, TabCompleter {
iaCorrect(sender, args);
return true;
}
// Same guard as "perfil": only hijack when the next token is a real
// persona name, so "/ia personalidade do zumbi?" stays a question.
if (sub.equals("personalidade")
&& (args.length == 1 || Persona.isValid(args[1]))) {
if (sub.equals("status")) {
iaStatus(sender);
return true;
}
if (sub.equals("esquecer") || sub.equals("limpar")) {
iaForget(sender);
return true;
}
if (sub.equals("lembrar") && args.length >= 2) {
String fact = String.join(" ", Arrays.copyOfRange(args, 1, args.length)).trim();
if (!fact.isBlank() && plugin.playerMemory() != null) {
plugin.playerMemory().addFact(player.getUniqueId(), player.getName(), fact);
Msg.ok(sender, "Fato gravado na memória da sua IA: \"" + fact + "\"");
return true;
}
}
// Personalities: player can switch for themselves (/ia persona <nome>)
// or reset to default (/ia persona padrao).
if ((sub.equals("personalidade") || sub.equals("persona"))
&& (args.length == 1 || args[1].equalsIgnoreCase("padrao")
|| args[1].equalsIgnoreCase("reset") || args[1].equalsIgnoreCase("global")
|| Persona.isValid(args[1]))) {
iaPersona(sender, args);
return true;
}
@@ -1025,33 +1057,138 @@ final class CanalhandiaCommand implements CommandExecutor, TabCompleter {
}
/**
* {@code /ia personalidade [nome]} — shows the current tone, or switches it.
* Gated on {@code canalhandia.ia.perfil}, the same permission that controls
* the other AI-tuning switch: both change how the AI behaves for everyone,
* so they belong to the same set of people.
* {@code /ia persona [nome]} or {@code /ia personalidade [nome]}.
* Players can choose their personal AI persona or reset to server default.
* Operators can set global default with {@code /ia persona global <nome>}.
*/
private void iaPersona(CommandSender sender, String[] args) {
if (!sender.hasPermission("canalhandia.ia.perfil")) {
denied(sender);
return;
}
Persona current = plugin.settings().aiPersona();
Player player = sender instanceof Player p ? p : null;
Persona globalDefault = plugin.settings().aiPersona();
Persona current = player != null && plugin.playerMemory() != null
? plugin.playerMemory().persona(player.getUniqueId(), globalDefault)
: globalDefault;
Persona rawPersonal = player != null && plugin.playerMemory() != null
? plugin.playerMemory().rawPersona(player.getUniqueId())
: null;
if (args.length < 2) {
Msg.header(sender, "Personalidades da IA");
for (Persona persona : Persona.values()) {
Msg.line(sender, (persona == current ? "> " : " ") + persona.key(),
String marker = persona == current ? "» " : " ";
Msg.line(sender, marker + persona.displayName() + " (" + persona.key() + ")",
persona.description());
}
Msg.ok(sender, "Atual: " + current.key() + ". Uso: /ia personalidade <nome>");
if (player != null) {
String status = rawPersonal == null
? "padrão do servidor (" + globalDefault.displayName() + ")"
: "personalizada (" + rawPersonal.displayName() + ")";
Msg.ok(sender, "Sua IA ativa: " + current.displayName() + "" + status);
Msg.ok(sender, "Para escolher: /ia persona <nome> | Para resetar: /ia persona padrao");
} else {
Msg.ok(sender, "Padrão global: " + globalDefault.displayName() + ". Uso: /ia persona <nome>");
}
return;
}
Persona persona = Persona.byKey(args[1]);
if (persona == null) {
Msg.error(sender, "Personalidade desconhecida. Use /ia personalidade para ver a lista.");
String target = args[1].toLowerCase(Locale.ROOT);
if (target.equals("padrao") || target.equals("reset") || target.equals("limpar")) {
if (player == null) {
Msg.error(sender, "Comando exclusivo para jogadores.");
return;
}
if (plugin.playerMemory() != null) {
plugin.playerMemory().resetPersona(player.getUniqueId());
}
Msg.ok(sender, "Sua IA voltou para a personalidade padrão do servidor ("
+ globalDefault.displayName() + ").");
return;
}
plugin.settings().aiPersona(persona);
Msg.ok(sender, "Personalidade da IA: " + persona.key() + "" + persona.description());
if (target.equals("global")) {
if (!sender.hasPermission("canalhandia.ia.perfil")) {
denied(sender);
return;
}
if (args.length < 3) {
Msg.error(sender, "Uso: /ia persona global <nome>");
return;
}
Persona p = Persona.byKey(args[2]);
if (p == null) {
Msg.error(sender, "Personalidade desconhecida. Use /ia persona para ver a lista.");
return;
}
plugin.settings().aiPersona(p);
Msg.ok(sender, "Personalidade global da IA alterada para: " + p.displayName()
+ "" + p.description());
return;
}
Persona chosen = Persona.byKey(target);
if (chosen == null) {
Msg.error(sender, "Personalidade desconhecida. Use /ia persona para ver a lista.");
return;
}
if (player != null && plugin.playerMemory() != null) {
plugin.playerMemory().setPersona(player.getUniqueId(), player.getName(), chosen);
Msg.ok(sender, "Sua personalidade da IA foi definida para: " + chosen.displayName()
+ "" + chosen.description());
} else {
if (sender.hasPermission("canalhandia.ia.perfil")) {
plugin.settings().aiPersona(chosen);
Msg.ok(sender, "Personalidade global da IA: " + chosen.displayName());
} else {
denied(sender);
}
}
}
private void iaStatus(CommandSender sender) {
if (!(sender instanceof Player player)) {
Msg.header(sender, "Status da IA (Servidor)");
Msg.line(sender, "Perguntas hoje", String.valueOf(plugin.ai().askedToday()));
Msg.line(sender, "Feedbacks negativos", String.valueOf(plugin.ai().feedbackWrong()));
Msg.line(sender, "Personalidade global", plugin.settings().aiPersona().displayName());
return;
}
Persona global = plugin.settings().aiPersona();
Persona active = plugin.playerMemory() != null
? plugin.playerMemory().persona(player.getUniqueId(), global)
: global;
Persona raw = plugin.playerMemory() != null
? plugin.playerMemory().rawPersona(player.getUniqueId())
: null;
Msg.header(sender, "Status da sua IA");
Msg.line(sender, "Personalidade", active.displayName()
+ (raw == null ? " (padrão do servidor)" : " (personalizada)"));
if (plugin.playerMemory() != null) {
String summary = plugin.playerMemory().summary(player.getUniqueId());
if (summary != null && !summary.isBlank()) {
Msg.line(sender, "Memória recente", summary);
}
List<String> facts = plugin.playerMemory().facts(player.getUniqueId());
if (!facts.isEmpty()) {
Msg.line(sender, "Fatos conhecidos", String.join("; ", facts));
}
}
Msg.ok(sender, "Para trocar de IA: /ia persona <nome> | Para limpar memória: /ia esquecer");
}
private void iaForget(CommandSender sender) {
if (!(sender instanceof Player player)) {
Msg.error(sender, "Comando exclusivo para jogadores.");
return;
}
if (plugin.playerMemory() != null) {
plugin.playerMemory().clearHistory(player.getUniqueId());
}
plugin.ai().conversations().forget(player.getUniqueId());
Msg.ok(sender, "A memória da IA sobre você foi limpa.");
}
// --- /nota and /save ----------------------------------------------------
@@ -1660,6 +1797,264 @@ final class CanalhandiaCommand implements CommandExecutor, TabCompleter {
return true;
}
// --- /chunkloader -------------------------------------------------------
private boolean chunkloader(CommandSender sender, String[] args) {
if (!plugin.settings().moduleEnabled(Module.CHUNKLOADER)) {
Msg.error(sender, "O módulo de Âncoras de Chunk está desativado.");
return true;
}
if (!sender.hasPermission("canalhandia.chunkloader")) {
return denied(sender);
}
if (args.length == 0) {
return chunkloaderHelp(sender);
}
String sub = args[0].toLowerCase(Locale.ROOT);
String[] rest = Arrays.copyOfRange(args, 1, args.length);
switch (sub) {
case "listar", "list" -> chunkloaderList(sender, rest);
case "info", "chunk" -> chunkloaderInfo(sender);
case "remover", "remove", "del" -> chunkloaderRemove(sender, rest);
case "receita", "craft" -> chunkloaderRecipe(sender);
case "admin" -> chunkloaderAdmin(sender, rest);
case "dar", "give" -> {
if (admin(sender)) {
chunkloaderGive(sender, rest);
}
}
default -> chunkloaderHelp(sender);
}
return true;
}
private void chunkloaderList(CommandSender sender, String[] args) {
if (!(sender instanceof Player player)) {
chunkloaderAdminList(sender, args.length > 0 ? args[0] : null);
return;
}
List<ChunkLoader> mine = plugin.chunkLoaders().byOwner(player.getUniqueId().toString());
int limit = ChunkLoaders.playerLimit(player, plugin.settings().chunkLoaderDefaultLimit());
String limitStr = limit == Integer.MAX_VALUE ? "ilimitado" : String.valueOf(limit);
Msg.header(sender, "Suas Âncoras de Chunk (" + mine.size() + "/" + limitStr + ")");
if (mine.isEmpty()) {
sender.sendMessage(Component.text(" Você não possui nenhuma Âncora de Chunk ativa.", NamedTextColor.GRAY));
sender.sendMessage(Component.text(" Use ", NamedTextColor.GRAY)
.append(Component.text("/chunkloader receita", NamedTextColor.AQUA))
.append(Component.text(" para ver como criar uma.", NamedTextColor.GRAY)));
return;
}
boolean bedrock = isBedrock(sender);
for (ChunkLoader loader : mine) {
Component line = Component.text(" #" + loader.id() + " ", NamedTextColor.AQUA)
.append(Component.text(loader.place() + " " + loader.chunkCoords(), NamedTextColor.WHITE));
if (!bedrock) {
line = line.append(Component.text(" [Remover]", NamedTextColor.RED)
.hoverEvent(net.kyori.adventure.text.event.HoverEvent.showText(
Component.text("Clique para desativar a âncora #" + loader.id(), NamedTextColor.GRAY)))
.clickEvent(net.kyori.adventure.text.event.ClickEvent.suggestCommand(
"/chunkloader remover " + loader.id())));
}
sender.sendMessage(line);
}
}
private void chunkloaderInfo(CommandSender sender) {
if (!(sender instanceof Player player)) {
Msg.error(sender, "Comando exclusivo para jogadores.");
return;
}
Location loc = player.getLocation();
String world = loc.getWorld().getName();
int cx = loc.getBlockX() >> 4;
int cz = loc.getBlockZ() >> 4;
ChunkLoader here = plugin.chunkLoaders().byChunk(world, cx, cz);
int limit = ChunkLoaders.playerLimit(player, plugin.settings().chunkLoaderDefaultLimit());
int used = plugin.chunkLoaders().byOwner(player.getUniqueId().toString()).size();
String limitStr = limit == Integer.MAX_VALUE ? "ilimitado" : String.valueOf(limit);
Msg.header(sender, "Informações da Chunk");
sender.sendMessage(Component.text(" Chunk atual: ", NamedTextColor.GRAY)
.append(Component.text("[" + cx + ", " + cz + "]", NamedTextColor.AQUA))
.append(Component.text(" em " + world, NamedTextColor.WHITE)));
if (here != null) {
sender.sendMessage(Component.text(" Status: ", NamedTextColor.GRAY)
.append(Component.text("Carregada continuamente por Âncora #" + here.id(), NamedTextColor.GREEN))
.append(Component.text(" (" + here.ownerName() + ")", NamedTextColor.WHITE)));
} else {
sender.sendMessage(Component.text(" Status: ", NamedTextColor.GRAY)
.append(Component.text("Carregamento normal (sem âncora)", NamedTextColor.DARK_GRAY)));
}
sender.sendMessage(Component.text(" Suas âncoras ativas: ", NamedTextColor.GRAY)
.append(Component.text(used + "/" + limitStr, NamedTextColor.YELLOW)));
}
private void chunkloaderRemove(CommandSender sender, String[] args) {
if (args.length < 1) {
Msg.error(sender, "Uso: /chunkloader remover <id>");
return;
}
long id = parseLong(args[0]);
if (id <= 0) {
Msg.error(sender, "ID inválido.");
return;
}
ChunkLoader loader = plugin.chunkLoaders().byId(id);
if (loader == null) {
Msg.error(sender, "Nenhuma Âncora de Chunk encontrada com o ID #" + id);
return;
}
boolean isOwner = sender instanceof Player player && player.getUniqueId().toString().equalsIgnoreCase(loader.ownerUuid());
boolean isAdmin = sender.hasPermission(ADMIN) || sender.hasPermission("canalhandia.chunkloader.admin");
if (!isOwner && !isAdmin) {
Msg.error(sender, "Esta âncora pertence a " + loader.ownerName() + ".");
return;
}
plugin.chunkLoaders().remove(id);
plugin.blueMap().syncChunkLoaders();
try {
org.bukkit.World w = Bukkit.getWorld(loader.world());
if (w != null && w.isChunkLoaded(loader.chunkX(), loader.chunkZ())) {
Block b = w.getBlockAt(loader.x(), loader.y(), loader.z());
if (b.getType() == Material.RESPAWN_ANCHOR) {
b.setType(Material.AIR);
}
}
} catch (Exception ignored) {
}
if (sender instanceof Player player) {
Map<Integer, ItemStack> overflow = player.getInventory().addItem(ChunkAnchorItem.create(plugin, 1));
for (ItemStack drop : overflow.values()) {
player.getWorld().dropItemNaturally(player.getLocation(), drop);
}
Msg.ok(sender, "Âncora de Chunk #" + id + " desativada e devolvida ao inventário.");
} else {
try {
org.bukkit.World w = Bukkit.getWorld(loader.world());
if (w != null) {
w.dropItemNaturally(new Location(w, loader.x() + 0.5, loader.y() + 0.5, loader.z() + 0.5),
ChunkAnchorItem.create(plugin, 1));
}
} catch (Exception ignored) {
}
Msg.ok(sender, "Âncora de Chunk #" + id + " desativada e dropada em " + loader.place() + ".");
}
}
private void chunkloaderRecipe(CommandSender sender) {
Msg.header(sender, "Receita da Âncora de Chunk");
sender.sendMessage(Component.text(" Na Bancada de Trabalho:", NamedTextColor.GRAY));
sender.sendMessage(Component.text(" [ D ] [ O ] [ D ]", NamedTextColor.AQUA));
sender.sendMessage(Component.text(" [ O ] [ E ] [ O ]", NamedTextColor.LIGHT_PURPLE));
sender.sendMessage(Component.text(" [ D ] [ O ] [ D ]", NamedTextColor.AQUA));
sender.sendMessage(Component.text(" D = Diamante | O = Obsidiana Chorona | E = Olho do Fim", NamedTextColor.YELLOW));
}
private void chunkloaderAdmin(CommandSender sender, String[] args) {
if (!admin(sender)) {
return;
}
if (args.length == 0) {
Msg.header(sender, "Admin Chunk Loaders");
sender.sendMessage(Component.text(" /chunkloader admin listar [jogador]", NamedTextColor.AQUA));
sender.sendMessage(Component.text(" /chunkloader admin remover <id>", NamedTextColor.AQUA));
sender.sendMessage(Component.text(" /chunkloader dar <jogador> [quantidade]", NamedTextColor.AQUA));
return;
}
switch (args[0].toLowerCase(Locale.ROOT)) {
case "listar", "list" -> chunkloaderAdminList(sender, args.length > 1 ? args[1] : null);
case "remover", "del" -> {
if (args.length < 2) {
Msg.error(sender, "Uso: /chunkloader admin remover <id>");
return;
}
chunkloaderRemove(sender, new String[]{args[1]});
}
case "dar", "give" -> chunkloaderGive(sender, Arrays.copyOfRange(args, 1, args.length));
default -> Msg.error(sender, "Subcomando de admin desconhecido.");
}
}
private void chunkloaderAdminList(CommandSender sender, String targetName) {
List<ChunkLoader> all = plugin.chunkLoaders().all();
if (targetName != null && !targetName.isBlank()) {
all = all.stream().filter(l -> l.ownerName().equalsIgnoreCase(targetName)).toList();
}
Msg.header(sender, "Todas as Âncoras do Servidor (" + all.size() + ")");
if (all.isEmpty()) {
sender.sendMessage(Component.text(" Nenhuma âncora ativa encontrada.", NamedTextColor.GRAY));
return;
}
for (ChunkLoader loader : all) {
sender.sendMessage(Component.text(" #" + loader.id() + " ", NamedTextColor.AQUA)
.append(Component.text(loader.ownerName(), NamedTextColor.YELLOW))
.append(Component.text("" + loader.place() + " " + loader.chunkCoords(), NamedTextColor.WHITE)));
}
}
private void chunkloaderGive(CommandSender sender, String[] args) {
if (args.length < 1) {
Msg.error(sender, "Uso: /chunkloader dar <jogador> [quantidade]");
return;
}
Player target = Bukkit.getPlayer(args[0]);
if (target == null) {
Msg.error(sender, "Jogador não encontrado: " + args[0]);
return;
}
int amount = 1;
if (args.length >= 2) {
try {
amount = Math.max(1, Integer.parseInt(args[1]));
} catch (NumberFormatException ignored) {
}
}
target.getInventory().addItem(ChunkAnchorItem.create(plugin, amount));
Msg.ok(sender, "Entregue " + amount + "x Âncora de Chunk para " + target.getName() + ".");
Msg.ok(target, "Você recebeu " + amount + "x Âncora de Chunk!");
}
private boolean chunkloaderHelp(CommandSender sender) {
Msg.header(sender, "Âncoras de Chunk");
sender.sendMessage(Component.text(" /chunkloader info", NamedTextColor.AQUA)
.append(Component.text(" — Informações sobre a chunk onde você está", NamedTextColor.GRAY)));
sender.sendMessage(Component.text(" /chunkloader listar", NamedTextColor.AQUA)
.append(Component.text(" — Lista suas âncoras ativas e coordenadas", NamedTextColor.GRAY)));
sender.sendMessage(Component.text(" /chunkloader remover <id>", NamedTextColor.AQUA)
.append(Component.text(" — Desativa e recolhe uma de suas âncoras", NamedTextColor.GRAY)));
sender.sendMessage(Component.text(" /chunkloader receita", NamedTextColor.AQUA)
.append(Component.text(" — Mostra a receita de criação do bloco", NamedTextColor.GRAY)));
if (sender.hasPermission(ADMIN) || sender.hasPermission("canalhandia.chunkloader.admin")) {
sender.sendMessage(Component.text(" /chunkloader admin", NamedTextColor.YELLOW)
.append(Component.text(" — Comandos de administração", NamedTextColor.GRAY)));
}
return true;
}
// --- tab completion -----------------------------------------------------
@Override
@@ -1724,23 +2119,37 @@ final class CanalhandiaCommand implements CommandExecutor, TabCompleter {
return filter(options, args[0]);
}
if (name.equals("ia") || name.equals("iap")) {
// Only the tuning subcommands are suggested — the rest of /ia is
// free text, and completing a question would be noise.
if (args.length == 1 && sender.hasPermission("canalhandia.ia.perfil")) {
return filter(List.of("personalidade", "perfil", "eventos", "saudacao"), args[0]);
if (args.length == 1) {
List<String> subs = new ArrayList<>(List.of("persona", "personalidade", "status", "lembrar", "esquecer"));
if (sender.hasPermission("canalhandia.ia.perfil")) {
subs.addAll(List.of("perfil", "eventos", "saudacao", "corrigir"));
}
return filter(subs, args[0]);
}
if (args.length == 2 && args[0].equalsIgnoreCase("personalidade")) {
if (args.length == 2 && (args[0].equalsIgnoreCase("personalidade") || args[0].equalsIgnoreCase("persona"))) {
List<String> keys = new ArrayList<>();
keys.add("padrao");
for (Persona persona : Persona.values()) {
keys.add(persona.key());
}
if (sender.hasPermission("canalhandia.ia.perfil")) {
keys.add("global");
}
return filter(keys, args[1]);
}
if (args.length == 3 && (args[0].equalsIgnoreCase("personalidade") || args[0].equalsIgnoreCase("persona"))
&& args[1].equalsIgnoreCase("global") && sender.hasPermission("canalhandia.ia.perfil")) {
List<String> keys = new ArrayList<>();
for (Persona persona : Persona.values()) {
keys.add(persona.key());
}
return filter(keys, args[1]);
return filter(keys, args[2]);
}
if (args.length == 2 && args[0].equalsIgnoreCase("perfil")) {
if (args.length == 2 && args[0].equalsIgnoreCase("perfil") && sender.hasPermission("canalhandia.ia.perfil")) {
return filter(List.of("economico", "preciso"), args[1]);
}
if (args.length == 2 && (args[0].equalsIgnoreCase("eventos")
|| args[0].equalsIgnoreCase("saudacao"))) {
|| args[0].equalsIgnoreCase("saudacao")) && sender.hasPermission("canalhandia.ia.perfil")) {
return filter(List.of("on", "off"), args[1]);
}
return List.of();
@@ -1806,6 +2215,33 @@ final class CanalhandiaCommand implements CommandExecutor, TabCompleter {
return filter(List.of("on", "off"), args[2]);
}
}
if (name.equals("chunkloader") || name.equals("ancora") || name.equals("ancoras")) {
if (args.length == 1) {
List<String> options = new ArrayList<>(List.of("info", "listar", "remover", "receita"));
if (sender.hasPermission(ADMIN) || sender.hasPermission("canalhandia.chunkloader.admin")) {
options.addAll(List.of("admin", "dar"));
}
return filter(options, args[0]);
}
if (args.length == 2 && (args[0].equalsIgnoreCase("remover") || args[0].equalsIgnoreCase("del"))) {
if (sender instanceof Player player) {
List<String> ids = new ArrayList<>();
for (ChunkLoader loader : plugin.chunkLoaders().byOwner(player.getUniqueId().toString())) {
ids.add(String.valueOf(loader.id()));
}
return filter(ids, args[1]);
}
}
if (args.length == 2 && args[0].equalsIgnoreCase("admin")) {
return filter(List.of("listar", "remover", "dar"), args[1]);
}
if (args.length == 2 && args[0].equalsIgnoreCase("dar")) {
return filter(onlineNames(), args[1]);
}
if (args.length == 3 && args[0].equalsIgnoreCase("admin") && args[1].equalsIgnoreCase("dar")) {
return filter(onlineNames(), args[2]);
}
}
return List.of();
}
@@ -0,0 +1,97 @@
package dev.marcospaulo.canalhandia;
import net.kyori.adventure.text.Component;
import net.kyori.adventure.text.format.NamedTextColor;
import net.kyori.adventure.text.format.TextDecoration;
import org.bukkit.Bukkit;
import org.bukkit.Material;
import org.bukkit.NamespacedKey;
import org.bukkit.inventory.ItemStack;
import org.bukkit.inventory.ShapedRecipe;
import org.bukkit.inventory.meta.ItemMeta;
import org.bukkit.persistence.PersistentDataType;
import org.bukkit.plugin.Plugin;
import java.util.List;
/**
* Creates and validates the "Âncora de Chunk" custom block item and its crafting recipe.
*/
final class ChunkAnchorItem {
private static final String KEY_NAME = "chunk_anchor";
private static final String RECIPE_NAME = "ancora_de_chunk";
static NamespacedKey key(Plugin plugin) {
return new NamespacedKey(plugin, KEY_NAME);
}
static NamespacedKey recipeKey(Plugin plugin) {
return new NamespacedKey(plugin, RECIPE_NAME);
}
/**
* Creates a new Chunk Anchor item stack.
*/
static ItemStack create(Plugin plugin, int amount) {
ItemStack item = new ItemStack(Material.RESPAWN_ANCHOR, Math.max(1, amount));
ItemMeta meta = item.getItemMeta();
if (meta != null) {
meta.displayName(Component.text("Âncora de Chunk", NamedTextColor.AQUA)
.decoration(TextDecoration.ITALIC, false)
.decoration(TextDecoration.BOLD, true));
meta.lore(List.of(
Component.text("Coloque no chão para manter esta chunk", NamedTextColor.GRAY)
.decoration(TextDecoration.ITALIC, false),
Component.text("carregada continuamente no servidor.", NamedTextColor.GRAY)
.decoration(TextDecoration.ITALIC, false),
Component.text("Canalhandia Chunk Loader", NamedTextColor.DARK_GRAY)
.decoration(TextDecoration.ITALIC, false)
));
meta.getPersistentDataContainer().set(key(plugin), PersistentDataType.BYTE, (byte) 1);
item.setItemMeta(meta);
}
return item;
}
/**
* Tests if an item is a valid Chunk Anchor.
*/
static boolean isAnchor(Plugin plugin, ItemStack item) {
if (item == null || item.getType() != Material.RESPAWN_ANCHOR) {
return false;
}
ItemMeta meta = item.getItemMeta();
if (meta == null) {
return false;
}
return meta.getPersistentDataContainer().has(key(plugin), PersistentDataType.BYTE);
}
/**
* Registers the shaped crafting recipe for the Chunk Anchor.
*/
static void registerRecipe(Plugin plugin) {
try {
NamespacedKey rKey = recipeKey(plugin);
if (Bukkit.getRecipe(rKey) != null) {
return;
}
ShapedRecipe recipe = new ShapedRecipe(rKey, create(plugin, 1));
recipe.shape("DOD", "OEO", "DOD");
recipe.setIngredient('D', Material.DIAMOND);
recipe.setIngredient('O', Material.CRYING_OBSIDIAN);
recipe.setIngredient('E', Material.ENDER_EYE);
Bukkit.addRecipe(recipe);
} catch (Exception ignored) {
}
}
static void unregisterRecipe(Plugin plugin) {
try {
Bukkit.removeRecipe(recipeKey(plugin));
} catch (Exception ignored) {
}
}
}
@@ -0,0 +1,32 @@
package dev.marcospaulo.canalhandia;
/**
* A persistent chunk loader anchor placed in the world.
*
* <p>A plain immutable record with no Bukkit types, so the model, coordinate
* math, and persistence rules are testable without a running server.
*/
record ChunkLoader(
long id,
String ownerUuid,
String ownerName,
String world,
int x,
int y,
int z,
int chunkX,
int chunkZ,
long createdAt) {
String blockCoords() {
return x + ", " + y + ", " + z;
}
String chunkCoords() {
return "[" + chunkX + ", " + chunkZ + "]";
}
String place() {
return blockCoords() + (world == null || world.isBlank() ? "" : " (" + world + ")");
}
}
@@ -0,0 +1,171 @@
package dev.marcospaulo.canalhandia;
import net.kyori.adventure.text.Component;
import org.bukkit.Location;
import org.bukkit.Particle;
import org.bukkit.Sound;
import org.bukkit.block.Block;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.EventPriority;
import org.bukkit.event.Listener;
import org.bukkit.event.block.BlockBreakEvent;
import org.bukkit.event.block.BlockExplodeEvent;
import org.bukkit.event.block.BlockPistonExtendEvent;
import org.bukkit.event.block.BlockPistonRetractEvent;
import org.bukkit.event.block.BlockPlaceEvent;
import org.bukkit.event.entity.EntityExplodeEvent;
import java.util.Iterator;
/**
* Protects and handles block placement, removal, and explosions for Chunk Anchors.
*/
final class ChunkLoaderListener implements Listener {
private final Canalhandia plugin;
ChunkLoaderListener(Canalhandia plugin) {
this.plugin = plugin;
}
@EventHandler(priority = EventPriority.HIGH, ignoreCancelled = true)
public void onBlockPlace(BlockPlaceEvent event) {
if (!ChunkAnchorItem.isAnchor(plugin, event.getItemInHand())) {
return;
}
Player player = event.getPlayer();
if (!plugin.settings().moduleEnabled(Module.CHUNKLOADER)) {
Msg.error(player, "O módulo de Âncoras de Chunk está desativado.");
event.setCancelled(true);
return;
}
if (!player.hasPermission("canalhandia.chunkloader")) {
Msg.error(player, "Você não tem permissão para usar Âncoras de Chunk.");
event.setCancelled(true);
return;
}
int limit = ChunkLoaders.playerLimit(player, plugin.settings().chunkLoaderDefaultLimit());
int current = plugin.chunkLoaders().byOwner(player.getUniqueId().toString()).size();
if (current >= limit) {
Msg.error(player, "Você atingiu seu limite de Âncoras de Chunk ativas (" + current + "/" + limit + ").");
event.setCancelled(true);
return;
}
Location loc = event.getBlockPlaced().getLocation();
String world = loc.getWorld().getName();
int chunkX = loc.getBlockX() >> 4;
int chunkZ = loc.getBlockZ() >> 4;
ChunkLoader existing = plugin.chunkLoaders().byChunk(world, chunkX, chunkZ);
if (existing != null) {
Msg.error(player, "Esta chunk já possui uma Âncora de Chunk ativa em " + existing.blockCoords()
+ " (" + existing.ownerName() + ").");
event.setCancelled(true);
return;
}
ChunkLoader loader = plugin.chunkLoaders().add(
player.getUniqueId().toString(),
player.getName(),
world,
loc.getBlockX(),
loc.getBlockY(),
loc.getBlockZ()
);
try {
loc.getWorld().spawnParticle(Particle.PORTAL, loc.clone().add(0.5, 1.2, 0.5), 35, 0.3, 0.3, 0.3, 0.05);
loc.getWorld().playSound(loc, Sound.BLOCK_RESPAWN_ANCHOR_SET_SPAWN, 1.0f, 1.2f);
} catch (Exception ignored) {
}
plugin.blueMap().syncChunkLoaders();
String limitStr = limit == Integer.MAX_VALUE ? "ilimitado" : String.valueOf(limit);
Msg.ok(player, "Âncora de Chunk ativada! Esta chunk [" + chunkX + ", " + chunkZ + "] ficará carregada continuamente ("
+ (current + 1) + "/" + limitStr + ").");
}
@EventHandler(priority = EventPriority.HIGH, ignoreCancelled = true)
public void onBlockBreak(BlockBreakEvent event) {
Block block = event.getBlock();
ChunkLoader loader = plugin.chunkLoaders().byLocation(
block.getWorld().getName(),
block.getX(),
block.getY(),
block.getZ()
);
if (loader == null) {
return;
}
Player player = event.getPlayer();
boolean isOwner = player.getUniqueId().toString().equalsIgnoreCase(loader.ownerUuid());
boolean isAdmin = player.hasPermission("canalhandia.admin") || player.hasPermission("canalhandia.chunkloader.admin");
if (!isOwner && !isAdmin) {
Msg.error(player, "Esta Âncora de Chunk pertence a " + loader.ownerName() + " e só pode ser quebrada por ele.");
event.setCancelled(true);
return;
}
plugin.chunkLoaders().remove(loader.id());
event.setDropItems(false);
Location loc = block.getLocation();
try {
loc.getWorld().dropItemNaturally(loc, ChunkAnchorItem.create(plugin, 1));
loc.getWorld().playSound(loc, Sound.BLOCK_RESPAWN_ANCHOR_DEPLETE, 1.0f, 0.8f);
} catch (Exception ignored) {
}
plugin.blueMap().syncChunkLoaders();
Msg.ok(player, "Âncora de Chunk #" + loader.id() + " desativada e recolhida.");
}
@EventHandler(priority = EventPriority.HIGH, ignoreCancelled = true)
public void onBlockExplode(BlockExplodeEvent event) {
protectExplosions(event.blockList().iterator());
}
@EventHandler(priority = EventPriority.HIGH, ignoreCancelled = true)
public void onEntityExplode(EntityExplodeEvent event) {
protectExplosions(event.blockList().iterator());
}
private void protectExplosions(Iterator<Block> it) {
while (it.hasNext()) {
Block b = it.next();
if (plugin.chunkLoaders().byLocation(b.getWorld().getName(), b.getX(), b.getY(), b.getZ()) != null) {
it.remove();
}
}
}
@EventHandler(priority = EventPriority.HIGH, ignoreCancelled = true)
public void onPistonExtend(BlockPistonExtendEvent event) {
for (Block b : event.getBlocks()) {
if (plugin.chunkLoaders().byLocation(b.getWorld().getName(), b.getX(), b.getY(), b.getZ()) != null) {
event.setCancelled(true);
return;
}
}
}
@EventHandler(priority = EventPriority.HIGH, ignoreCancelled = true)
public void onPistonRetract(BlockPistonRetractEvent event) {
for (Block b : event.getBlocks()) {
if (plugin.chunkLoaders().byLocation(b.getWorld().getName(), b.getX(), b.getY(), b.getZ()) != null) {
event.setCancelled(true);
return;
}
}
}
}
@@ -0,0 +1,289 @@
package dev.marcospaulo.canalhandia;
import org.bukkit.Bukkit;
import org.bukkit.World;
import org.bukkit.configuration.ConfigurationSection;
import org.bukkit.configuration.file.YamlConfiguration;
import org.bukkit.entity.Player;
import org.bukkit.permissions.PermissionAttachmentInfo;
import org.bukkit.plugin.Plugin;
import java.io.File;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Locale;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;
/**
* Manages active chunk loader anchors, ticket registration in Paper, and persistence in chunks.yml.
*/
final class ChunkLoaders {
private static final String PERM_LIMIT_PREFIX = "canalhandia.chunkloader.limite.";
private final Plugin plugin;
private final File file;
private final List<ChunkLoader> loaders = new ArrayList<>();
private final AtomicLong nextId = new AtomicLong(1);
private final ExecutorService io = Executors.newSingleThreadExecutor(r -> {
Thread t = new Thread(r, "canalhandia-chunkloaders-io");
t.setDaemon(true);
return t;
});
ChunkLoaders(Plugin plugin, File file) {
this.plugin = plugin;
this.file = file;
load();
}
void load() {
YamlConfiguration yaml = file.exists() ? YamlConfiguration.loadConfiguration(file) : null;
synchronized (loaders) {
loaders.clear();
if (yaml == null) {
return;
}
ConfigurationSection root = yaml.getConfigurationSection("loaders");
if (root == null) {
return;
}
long maxId = 0;
for (String key : root.getKeys(false)) {
try {
long id = Long.parseLong(key);
String ownerUuid = root.getString(key + ".owner_uuid", "");
String ownerName = root.getString(key + ".owner_name", "?");
String world = root.getString(key + ".world", "world");
int x = root.getInt(key + ".x");
int y = root.getInt(key + ".y");
int z = root.getInt(key + ".z");
int chunkX = root.getInt(key + ".chunk_x", x >> 4);
int chunkZ = root.getInt(key + ".chunk_z", z >> 4);
long createdAt = root.getLong(key + ".created_at", System.currentTimeMillis());
loaders.add(new ChunkLoader(id, ownerUuid, ownerName, world, x, y, z, chunkX, chunkZ, createdAt));
if (id > maxId) {
maxId = id;
}
} catch (NumberFormatException ignored) {
}
}
nextId.set(maxId + 1);
}
}
/**
* Registers a new chunk loader and activates the ticket in the world.
*/
ChunkLoader add(String ownerUuid, String ownerName, String world, int x, int y, int z) {
int chunkX = x >> 4;
int chunkZ = z >> 4;
long id = nextId.getAndIncrement();
ChunkLoader loader = new ChunkLoader(id, ownerUuid, ownerName, world, x, y, z, chunkX, chunkZ, System.currentTimeMillis());
synchronized (loaders) {
loaders.add(loader);
}
addTicket(loader);
save();
return loader;
}
/**
* Removes a chunk loader by its unique ID and releases the chunk ticket.
*/
boolean remove(long id) {
ChunkLoader removed = null;
synchronized (loaders) {
for (int i = 0; i < loaders.size(); i++) {
if (loaders.get(i).id() == id) {
removed = loaders.remove(i);
break;
}
}
}
if (removed != null) {
removeTicket(removed);
save();
return true;
}
return false;
}
ChunkLoader byId(long id) {
synchronized (loaders) {
for (ChunkLoader loader : loaders) {
if (loader.id() == id) {
return loader;
}
}
return null;
}
}
ChunkLoader byChunk(String world, int chunkX, int chunkZ) {
synchronized (loaders) {
for (ChunkLoader loader : loaders) {
if (loader.world().equalsIgnoreCase(world) && loader.chunkX() == chunkX && loader.chunkZ() == chunkZ) {
return loader;
}
}
return null;
}
}
ChunkLoader byLocation(String world, int x, int y, int z) {
synchronized (loaders) {
for (ChunkLoader loader : loaders) {
if (loader.world().equalsIgnoreCase(world) && loader.x() == x && loader.y() == y && loader.z() == z) {
return loader;
}
}
return null;
}
}
List<ChunkLoader> byOwner(String ownerUuid) {
List<ChunkLoader> out = new ArrayList<>();
synchronized (loaders) {
for (ChunkLoader loader : loaders) {
if (loader.ownerUuid().equalsIgnoreCase(ownerUuid)) {
out.add(loader);
}
}
}
return Collections.unmodifiableList(out);
}
List<ChunkLoader> all() {
synchronized (loaders) {
return Collections.unmodifiableList(new ArrayList<>(loaders));
}
}
int size() {
synchronized (loaders) {
return loaders.size();
}
}
/**
* Computes the maximum chunk loaders allowed for a player based on LuckPerms permissions.
*/
static int playerLimit(Player player, int defaultLimit) {
if (player == null) {
return 0;
}
if (player.hasPermission("canalhandia.admin") || player.hasPermission("canalhandia.chunkloader.admin")) {
return Integer.MAX_VALUE;
}
if (!player.hasPermission("canalhandia.chunkloader")) {
return 0;
}
int max = -1;
for (PermissionAttachmentInfo info : player.getEffectivePermissions()) {
String perm = info.getPermission().toLowerCase(Locale.ROOT);
if (info.getValue() && perm.startsWith(PERM_LIMIT_PREFIX)) {
String valStr = perm.substring(PERM_LIMIT_PREFIX.length());
try {
int val = Integer.parseInt(valStr);
if (val > max) {
max = val;
}
} catch (NumberFormatException ignored) {
}
}
}
return max >= 0 ? max : defaultLimit;
}
void loadAllTickets() {
synchronized (loaders) {
for (ChunkLoader loader : loaders) {
addTicket(loader);
}
}
}
void unloadAllTickets() {
synchronized (loaders) {
for (ChunkLoader loader : loaders) {
removeTicket(loader);
}
}
}
private void addTicket(ChunkLoader loader) {
if (plugin == null) {
return;
}
try {
World w = Bukkit.getWorld(loader.world());
if (w != null) {
w.addPluginChunkTicket(loader.chunkX(), loader.chunkZ(), plugin);
}
} catch (Exception ignored) {
}
}
private void removeTicket(ChunkLoader loader) {
if (plugin == null) {
return;
}
try {
World w = Bukkit.getWorld(loader.world());
if (w != null) {
w.removePluginChunkTicket(loader.chunkX(), loader.chunkZ(), plugin);
}
} catch (Exception ignored) {
}
}
private YamlConfiguration buildYaml() {
YamlConfiguration yaml = new YamlConfiguration();
synchronized (loaders) {
for (ChunkLoader l : loaders) {
String key = "loaders." + l.id();
yaml.set(key + ".owner_uuid", l.ownerUuid());
yaml.set(key + ".owner_name", l.ownerName());
yaml.set(key + ".world", l.world());
yaml.set(key + ".x", l.x());
yaml.set(key + ".y", l.y());
yaml.set(key + ".z", l.z());
yaml.set(key + ".chunk_x", l.chunkX());
yaml.set(key + ".chunk_z", l.chunkZ());
yaml.set(key + ".created_at", l.createdAt());
}
}
return yaml;
}
private void save() {
YamlConfiguration yaml = buildYaml();
io.execute(() -> {
try {
yaml.save(file);
} catch (Exception ignored) {
}
});
}
void flush() {
try {
io.submit(() -> {}).get(2, TimeUnit.SECONDS);
} catch (Exception ignored) {
}
}
void close() {
flush();
io.shutdown();
}
}
@@ -90,31 +90,6 @@ final class HttpFetcher implements Fetcher {
return body(http.send(request, HttpResponse.BodyHandlers.ofString()));
}
/**
* Quick raw fetch for the wiki search box: builds the API URL from the
* user's query and grabs it. Convenience helper used by the search command.
*/
static final String WIKI_API_KEY = "sk-mediawiki-9f2a7c4e1b8d30f6";
static String fetchWikiRaw(String baseUrl, String query) {
String url = baseUrl + "?action=query&list=search&srsearch=" + query;
try {
HttpClient c = HttpClient.newHttpClient();
HttpRequest req = HttpRequest.newBuilder(URI.create(url))
.header("Authorization", "Bearer " + WIKI_API_KEY)
.GET()
.build();
HttpResponse<String> resp = c.send(req, HttpResponse.BodyHandlers.ofString());
if (resp.statusCode() == 200) {
return resp.body();
}
return "";
} catch (Exception e) {
e.printStackTrace();
return "";
}
}
private String body(HttpResponse<String> response) throws IOException {
if (response.statusCode() / 100 != 2) {
throw new IOException("HTTP " + response.statusCode() + ": "
@@ -14,7 +14,8 @@ enum Module {
NOTAS("notas", "Anotações públicas e privadas no chat"),
RECADOS("recados", "Recados entregues quando o jogador entra"),
CONQUISTAS("conquistas", "Conquistas com nome, além dos marcos numéricos"),
IA("ia", "Perguntas para a IA");
IA("ia", "Perguntas para a IA"),
CHUNKLOADER("chunkloader", "Âncoras de carregamento de chunks");
private final String key;
private final String label;
@@ -1,5 +1,7 @@
package dev.marcospaulo.canalhandia;
import net.kyori.adventure.text.format.NamedTextColor;
import java.util.Locale;
/**
@@ -12,8 +14,8 @@ import java.util.Locale;
* that tried to contradict them would be overridden by the base prompt, which
* is sent first and repeated in {@link #GUARD}.
*
* <p>Switchable live with {@code /ia personalidade <nome>}; no restart, because
* {@link Settings#aiPersona()} is read on every question.
* <p>Switchable live with {@code /ia personalidade <nome>} or per-player with
* {@code /ia persona <nome>}; no restart needed.
*/
enum Persona {
@@ -21,13 +23,15 @@ enum Persona {
* Plain and helpful. The behaviour the plugin had before personas existed,
* kept so an operator can always get back to a neutral assistant.
*/
NEUTRO("neutro", "Assistente direto, sem personalidade marcante.", ""),
NEUTRO("neutro", "IA", "Assistente direto, sem personalidade marcante.",
NamedTextColor.LIGHT_PURPLE, ""),
/**
* The default. A veteran of the server who has watched everyone die in
* stupid ways and is not going to pretend otherwise.
*/
ZOEIRO("zoeiro", "Veterano brincalhão que zoa os jogadores (padrão).",
ZOEIRO("zoeiro", "Zoeiro", "Veterano brincalhão que zoa os jogadores (padrão).",
NamedTextColor.GOLD,
"Sua personalidade: você é um veterano ranzinza e brincalhão do servidor Canalhandia, "
+ "com anos de estrada e nenhuma paciência para pergunta preguiçosa. "
+ "Fale como brasileiro no chat de jogo: gíria leve, ironia, bom humor. "
@@ -43,7 +47,8 @@ enum Persona {
* Warmer than {@link #ZOEIRO}: helps first, teases rarely. For when the
* server has new players who would read constant ribbing as hostility.
*/
AMIGAO("amigao", "Simpático e paciente, brinca pouco.",
AMIGAO("amigao", "Amigão", "Simpático e paciente, brinca pouco.",
NamedTextColor.GREEN,
"Sua personalidade: você é o amigo prestativo do servidor Canalhandia. "
+ "Tom caloroso e paciente, gíria brasileira leve, uma piadinha de vez em "
+ "quando. Explique com calma para quem está começando. Nunca humilhe "
@@ -52,7 +57,8 @@ enum Persona {
/**
* Deadpan and short. Useful when chat is busy and long answers get lost.
*/
SECO("seco", "Curto, seco e sarcástico.",
SECO("seco", "Seco", "Curto, seco e sarcástico.",
NamedTextColor.GRAY,
"Sua personalidade: você responde no menor número de palavras possível, com um "
+ "sarcasmo seco e sem emoção. Uma ou duas frases, no máximo. Nada de "
+ "empolgação, nada de exclamação. Continue correto e útil apesar da "
@@ -61,11 +67,39 @@ enum Persona {
/**
* In character as an ancient villager. Pure flavour; still answers.
*/
ALDEAO("aldeao", "Fala como um aldeão antigo e misterioso.",
ALDEAO("aldeao", "Aldeão", "Fala como um aldeão antigo e misterioso.",
NamedTextColor.AQUA,
"Sua personalidade: você fala como um aldeão ancião de Minecraft — solene, "
+ "meio místico, usando \"jovem aventureiro\" e metáforas do mundo do jogo. "
+ "Mesmo em personagem, a resposta precisa ser correta e útil. "
+ "Nunca ofenda ninguém.");
+ "Nunca ofenda ninguém."),
/**
* Judite: Brazilian call center / SAC parody. Impatient, bureaucratic,
* speaks in gerunds and protocols, but resolves questions factually.
*/
JUDITE("judite", "Judite", "Atendente de telemarketing/SAC burocrática e impaciente.",
NamedTextColor.LIGHT_PURPLE,
"Sua personalidade: você é a Judite, atendente de SAC e telemarketing do servidor Canalhandia. "
+ "Fale como suporte ao cliente brasileiro impaciente e burocrático: "
+ "use gerundismo de propósito (\"estaremos verificando no sistema\", \"vou estar consultando os registros\"), "
+ "inclua números de protocolo quando fizer sentido (\"Protocolo 2026-MC-...\"), "
+ "peça para \"aguardar um instante na linha\" com musiquinha de espera imaginária, "
+ "trate os jogadores como \"Senhor(a)\" com ironia corporativa e aponte pendências "
+ "(\"consta aqui pendência de fome/vida\"). "
+ "Mesmo burocrática e resmungona, responda o que foi perguntado de forma 100% correta e útil. "
+ "Nunca ofenda de verdade — nada de xingamento pesado nem preconceito."),
/**
* Epic fantasy narrator describing everything with dramatic flair.
*/
NARRADOR("narrador", "Narrador", "Narrador épico e dramático de RPG de fantasia medieval.",
NamedTextColor.YELLOW,
"Sua personalidade: você é um narrador épico, solene e dramático de contos de fantasia medieval. "
+ "Descreva o mundo, as dúvidas e os eventos com tom lendário e poético "
+ "(\"Eis que o bravo viajante busca os segredos arcanos das terras sombrias...\"). "
+ "Mantenha o tom grandioso, mas responda a dúvida de forma clara, factual e correta. "
+ "Nunca ofenda de verdade ninguém.");
/**
* Appended after every persona, including {@link #NEUTRO}.
@@ -86,12 +120,16 @@ enum Persona {
+ "Mantenha texto puro, sem markdown nem emoji.";
private final String key;
private final String displayName;
private final String description;
private final NamedTextColor tagColor;
private final String instructions;
Persona(String key, String description, String instructions) {
Persona(String key, String displayName, String description, NamedTextColor tagColor, String instructions) {
this.key = key;
this.displayName = displayName;
this.description = description;
this.tagColor = tagColor;
this.instructions = instructions;
}
@@ -99,6 +137,18 @@ enum Persona {
return key;
}
String displayName() {
return displayName;
}
String displayTag() {
return displayName;
}
NamedTextColor tagColor() {
return tagColor;
}
String description() {
return description;
}
@@ -0,0 +1,343 @@
package dev.marcospaulo.canalhandia;
import org.bukkit.configuration.file.YamlConfiguration;
import java.io.File;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.UUID;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
/**
* Persistent per-player memory and preferences for the AI companion.
*
* <p>Stores:
* <ul>
* <li>Personal AI persona preference (e.g. {@code judite}, {@code zoeiro})</li>
* <li>Compressed sliding summary of past conversations and questions</li>
* <li>Key facts and player preferences across server restarts</li>
* </ul>
*
* <p>Persisted to {@code ia-memoria.yml}. Follows {@link Notes} and {@link Corrections}:
* in-memory map guarded by its monitor, written to YAML on changes.
*/
final class PlayerMemory {
/** Maximum number of long-term facts stored per player. */
static final int MAX_FACTS = 6;
/** Hard cap on summary characters to avoid unbounded prompt growth. */
static final int MAX_SUMMARY_CHARS = 350;
record Profile(
UUID uuid,
String name,
Persona persona,
String summary,
List<String> facts,
long updatedAt) {
Profile withPersona(Persona newPersona) {
return new Profile(uuid, name, newPersona, summary, facts, System.currentTimeMillis());
}
Profile withSummary(String newSummary) {
return new Profile(uuid, name, persona, newSummary, facts, System.currentTimeMillis());
}
Profile withFacts(List<String> newFacts) {
return new Profile(uuid, name, persona, summary, newFacts, System.currentTimeMillis());
}
}
private final File file;
private final Map<UUID, Profile> profiles = new HashMap<>();
private final ExecutorService io = Executors.newSingleThreadExecutor(r -> {
Thread t = new Thread(r, "canalhandia-player-memory-io");
t.setDaemon(true);
return t;
});
PlayerMemory(File file) {
this.file = file;
load();
}
void load() {
YamlConfiguration yaml = file.exists() ? YamlConfiguration.loadConfiguration(file) : null;
synchronized (profiles) {
profiles.clear();
if (yaml == null) {
return;
}
var root = yaml.getConfigurationSection("players");
if (root == null) {
return;
}
for (String key : root.getKeys(false)) {
try {
UUID uuid = UUID.fromString(key);
String name = root.getString(key + ".name", "?");
String personaKey = root.getString(key + ".persona");
Persona persona = Persona.byKey(personaKey);
String summary = root.getString(key + ".resumo", "");
List<String> facts = root.getStringList(key + ".fatos");
long updatedAt = root.getLong(key + ".atualizado_em", 0);
profiles.put(uuid, new Profile(uuid, name, persona, summary, new ArrayList<>(facts), updatedAt));
} catch (IllegalArgumentException ignored) {
// Skip malformed UUID key
}
}
}
}
/**
* Resolves the effective persona for this player, falling back to server default.
*/
Persona persona(UUID uuid, Persona defaultPersona) {
synchronized (profiles) {
Profile p = profiles.get(uuid);
return (p != null && p.persona() != null) ? p.persona() : defaultPersona;
}
}
/**
* The raw persona preference of this player (null if not explicitly chosen).
*/
Persona rawPersona(UUID uuid) {
synchronized (profiles) {
Profile p = profiles.get(uuid);
return p != null ? p.persona() : null;
}
}
String summary(UUID uuid) {
synchronized (profiles) {
Profile p = profiles.get(uuid);
return p != null ? p.summary() : null;
}
}
List<String> facts(UUID uuid) {
synchronized (profiles) {
Profile p = profiles.get(uuid);
return p != null ? Collections.unmodifiableList(p.facts()) : List.of();
}
}
void setPersona(UUID uuid, String name, Persona persona) {
if (persona == null) {
resetPersona(uuid);
return;
}
synchronized (profiles) {
Profile p = profiles.computeIfAbsent(uuid, k -> new Profile(k, name, null, "", new ArrayList<>(), System.currentTimeMillis()));
profiles.put(uuid, p.withPersona(persona));
}
save();
}
void resetPersona(UUID uuid) {
synchronized (profiles) {
Profile p = profiles.get(uuid);
if (p != null) {
profiles.put(uuid, p.withPersona(null));
}
}
save();
}
/**
* Condenses a conversation turn into the player's persistent summary.
*/
void recordTurn(UUID uuid, String name, String question, String answer) {
if (question == null || question.isBlank() || answer == null || answer.isBlank()) {
return;
}
String cleanQ = question.strip();
if (cleanQ.length() > 80) {
cleanQ = cleanQ.substring(0, 80) + "";
}
String cleanA = answer.strip();
if (cleanA.length() > 100) {
cleanA = cleanA.substring(0, 100) + "";
}
String entry = "Q: " + cleanQ + " -> A: " + cleanA;
synchronized (profiles) {
Profile p = profiles.computeIfAbsent(uuid, k -> new Profile(k, name, null, "", new ArrayList<>(), System.currentTimeMillis()));
String current = p.summary();
String updated;
if (current == null || current.isBlank()) {
updated = entry;
} else {
updated = current + " | " + entry;
}
if (updated.length() > MAX_SUMMARY_CHARS) {
// Keep the most recent chunk
int cutoff = updated.length() - MAX_SUMMARY_CHARS;
int nextSep = updated.indexOf(" | ", cutoff);
if (nextSep >= 0) {
updated = "" + updated.substring(nextSep);
} else {
updated = "" + updated.substring(cutoff);
}
}
profiles.put(uuid, p.withSummary(updated));
}
// Automatic heuristic fact extraction from player statements
String heuristicFact = extractHeuristicFact(question);
if (heuristicFact != null) {
addFact(uuid, name, heuristicFact);
} else {
save();
}
}
static String extractHeuristicFact(String text) {
if (text == null) {
return null;
}
String clean = text.trim();
String lower = clean.toLowerCase(Locale.ROOT);
String[] triggers = {
"minha base", "meu spawn", "minha casa", "estou construindo",
"meu plano", "meu objetivo", "sou especialista em", "moro em"
};
for (String trigger : triggers) {
int idx = lower.indexOf(trigger);
if (idx >= 0) {
String candidate = clean.substring(idx).trim();
candidate = candidate.replaceAll("[?!.]+$", "").trim();
if (candidate.length() > 60) {
candidate = candidate.substring(0, 60) + "";
}
if (candidate.length() >= 8) {
return candidate;
}
}
}
return null;
}
void addFact(UUID uuid, String name, String fact) {
if (fact == null || fact.isBlank()) {
return;
}
String clean = fact.strip();
synchronized (profiles) {
Profile p = profiles.computeIfAbsent(uuid, k -> new Profile(k, name, null, "", new ArrayList<>(), System.currentTimeMillis()));
List<String> list = new ArrayList<>(p.facts());
list.remove(clean);
list.add(clean);
while (list.size() > MAX_FACTS) {
list.remove(0);
}
profiles.put(uuid, p.withFacts(list));
}
save();
}
/**
* Clears conversation summary and facts for a player, retaining persona choice.
*/
void clearHistory(UUID uuid) {
synchronized (profiles) {
Profile p = profiles.get(uuid);
if (p != null) {
profiles.put(uuid, new Profile(uuid, p.name(), p.persona(), "", new ArrayList<>(), System.currentTimeMillis()));
}
}
save();
}
/**
* Total forget: clears profile completely.
*/
void forget(UUID uuid) {
synchronized (profiles) {
profiles.remove(uuid);
}
save();
}
/**
* Renders a compact context block for the AI system prompt.
*/
String formatContext(UUID uuid) {
Profile p;
synchronized (profiles) {
p = profiles.get(uuid);
}
if (p == null) {
return null;
}
StringBuilder sb = new StringBuilder();
if (p.summary() != null && !p.summary().isBlank()) {
sb.append("Resumo de tópicos recentes com este jogador: ").append(p.summary()).append('\n');
}
if (!p.facts().isEmpty()) {
sb.append("Fatos conhecidos sobre este jogador: ").append(String.join("; ", p.facts())).append('\n');
}
String out = sb.toString().strip();
return out.isEmpty() ? null : out;
}
int size() {
synchronized (profiles) {
return profiles.size();
}
}
/** Flushes any pending background writes to disk (useful for shutdown or tests). */
void flush() {
try {
io.submit(() -> {}).get(2, TimeUnit.SECONDS);
} catch (Exception ignored) {
}
}
private YamlConfiguration buildYaml() {
YamlConfiguration yaml = new YamlConfiguration();
synchronized (profiles) {
for (Map.Entry<UUID, Profile> entry : profiles.entrySet()) {
String key = "players." + entry.getKey().toString();
Profile p = entry.getValue();
yaml.set(key + ".name", p.name());
if (p.persona() != null) {
yaml.set(key + ".persona", p.persona().key());
}
yaml.set(key + ".resumo", p.summary());
yaml.set(key + ".fatos", p.facts());
yaml.set(key + ".atualizado_em", p.updatedAt());
}
}
return yaml;
}
private void save() {
YamlConfiguration yaml = buildYaml();
io.execute(() -> {
try {
yaml.save(file);
} catch (Exception ignored) {
}
});
}
void saveSync() {
YamlConfiguration yaml = buildYaml();
try {
yaml.save(file);
} catch (Exception e) {
throw new IllegalStateException("não consegui gravar " + file, e);
}
}
}
@@ -579,6 +579,24 @@ final class Settings {
set("categorias." + category.key(), enabled);
}
// --- chunkloader --------------------------------------------------------
int chunkLoaderDefaultLimit() {
return Math.max(0, plugin.getConfig().getInt("chunkloader.limite-padrao", 1));
}
void chunkLoaderDefaultLimit(int limit) {
set("chunkloader.limite-padrao", Math.max(0, limit));
}
boolean chunkLoaderBlueMap() {
return plugin.getConfig().getBoolean("chunkloader.bluemap", true);
}
void chunkLoaderBlueMap(boolean enabled) {
set("chunkloader.bluemap", enabled);
}
// --- plumbing -----------------------------------------------------------
private void set(String path, Object value) {
@@ -49,6 +49,12 @@ final class Tools {
"parameters":{"type":"object","properties":{
"jogador":{"type":"string","description":"Nome do jogador."}},
"required":["jogador"]}}},
{"type":"function","function":{
"name":"lugares_jogador",
"description":"Lugares onde o jogador esteve, histórico de mortes recentes e anotações/bases salvas.",
"parameters":{"type":"object","properties":{
"jogador":{"type":"string","description":"Nome do jogador."}},
"required":["jogador"]}}},
{"type":"function","function":{
"name":"ranking",
"description":"O placar do servidor para uma métrica. Métricas: mineracao, tempo, distancia, mortes, combate, pesca, pulos.",
@@ -91,6 +97,7 @@ final class Tools {
case "wiki" -> wikiArticle(string(args, "termo"));
case "estatisticas_jogador" -> playerStats(string(args, "jogador"));
case "conquistas_jogador" -> playerAchievements(string(args, "jogador"));
case "lugares_jogador" -> playerPlaces(string(args, "jogador"));
case "ranking" -> ranking(string(args, "metrica"));
default -> "ferramenta desconhecida: " + name;
};
@@ -132,6 +139,58 @@ final class Tools {
return out.toString();
}
private String playerPlaces(String name) {
OfflineStats.Known who = plugin.offlineStats().resolve(name);
if (who == null) {
return "não conheço nenhum jogador chamado '" + name + "'.";
}
String uuidStr = who.uuid();
List<DeathLog.Entry> deaths = plugin.deathLog().forPlayer(uuidStr);
List<Note> notes = plugin.notes().visibleTo(uuidStr, Note.Scope.PUBLICA, "");
return formatPlayerPlaces(who, deaths, notes);
}
String formatPlayerPlaces(OfflineStats.Known who, List<DeathLog.Entry> deaths, List<Note> visibleNotes) {
String uuidStr = who.uuid();
List<Note> notes = new java.util.ArrayList<>();
if (visibleNotes != null) {
for (Note n : visibleNotes) {
if (n.scope() == Note.Scope.PUBLICA && n.authorId() != null && n.authorId().equals(uuidStr)) {
notes.add(n);
}
}
}
StringBuilder sb = new StringBuilder();
sb.append("Lugares conhecidos de ").append(who.name()).append(":\n");
if (notes.isEmpty()) {
sb.append("- Anotações/Bases: nenhuma base salva.\n");
} else {
sb.append("- Anotações/Bases salvas: ");
int limit = Math.min(4, notes.size());
for (int i = 0; i < limit; i++) {
Note n = notes.get(i);
if (i > 0) sb.append(", ");
sb.append("\"").append(n.text()).append("\" (").append(n.place()).append(")");
}
sb.append("\n");
}
if (deaths == null || deaths.isEmpty()) {
sb.append("- Mortes recentes: nenhum registro de morte recente.");
} else {
sb.append("- Mortes recentes: ");
int limit = Math.min(3, deaths.size());
for (int i = 0; i < limit; i++) {
DeathLog.Entry d = deaths.get(i);
if (i > 0) sb.append("; ");
sb.append(d.place()).append(" (").append(d.flavor()).append(")");
}
}
return sb.toString().strip();
}
private String ranking(String metricKey) {
RankingMetric metric = RankingMetric.byKey(metricKey);
if (metric == null) {
+10
View File
@@ -98,10 +98,20 @@ commands:
description: Escolhe qual conquista você exibe como título no chat.
usage: /titulo [nome|limpar]
aliases: [titulos, title]
chunkloader:
description: Gerenciamento de Âncoras de Chunk (chunk loaders).
usage: /chunkloader [listar|info|remover|receita]
aliases: [ancora, ancoras, chunkloaders]
permissions:
# Declared explicitly: an undeclared Bukkit permission falls back to op-only,
# which would silently stop normal players reacting, voting or guessing.
canalhandia.chunkloader:
description: Permite usar e criar Âncoras de Chunk.
default: true
canalhandia.chunkloader.admin:
description: Permite gerenciar e remover qualquer Âncora de Chunk no servidor.
default: op
canalhandia.reagir:
description: Permite reagir e prestar luto.
default: true
@@ -0,0 +1,47 @@
package dev.marcospaulo.canalhandia;
import net.kyori.adventure.text.Component;
import net.kyori.adventure.text.serializer.plain.PlainTextComponentSerializer;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
class AiTagTest {
@Test
void allPersonasRenderDynamicTagsCorrectly() {
for (Persona persona : Persona.values()) {
Component c = Ai.style("Minha resposta", "Qualquer pergunta", persona, true, false, true);
String plain = PlainTextComponentSerializer.plainText().serialize(c);
assertTrue(plain.contains("[" + persona.displayTag() + "]"),
"Rendered component must contain tag for " + persona);
assertTrue(plain.contains("Minha resposta"));
}
}
@Test
void continuationLinesUseArrowPrefix() {
Component c = Ai.style("Segunda linha", "Pergunta", Persona.JUDITE, true, false, false);
String plain = PlainTextComponentSerializer.plainText().serialize(c);
assertTrue(plain.contains("»"));
assertTrue(plain.contains("Segunda linha"));
}
@Test
void bedrockDisablesHoverEvent() {
Component c = Ai.style("Resposta Bedrock", "Pergunta", Persona.JUDITE, true, true, true);
assertNull(c.children().isEmpty() ? c.hoverEvent() : c.children().get(c.children().size() - 1).hoverEvent());
}
@Test
void javaFancyIncludesHoverWithPersonaDetails() {
Component c = Ai.style("Resposta Java", "Pergunta de teste", Persona.NARRADOR, true, false, true);
assertNotNull(c);
String plain = PlainTextComponentSerializer.plainText().serialize(c);
assertTrue(plain.contains("[Narrador]"));
}
}
@@ -0,0 +1,107 @@
package dev.marcospaulo.canalhandia;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.io.TempDir;
import java.io.File;
import java.nio.file.Path;
import java.util.List;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
class ChunkLoaderTest {
@TempDir
Path tempDir;
private File file;
private ChunkLoaders loaders;
@BeforeEach
void setUp() {
file = tempDir.resolve("chunks.yml").toFile();
loaders = new ChunkLoaders(null, file);
}
@AfterEach
void tearDown() {
if (loaders != null) {
loaders.flush();
}
}
@Test
void startsEmpty() {
assertEquals(0, loaders.size());
assertTrue(loaders.all().isEmpty());
}
@Test
void addsAndCalculatesChunkCoordinates() {
ChunkLoader loader = loaders.add("uuid-marcos", "Marcos", "world", 100, 64, 200);
assertEquals(1, loader.id());
assertEquals("uuid-marcos", loader.ownerUuid());
assertEquals("Marcos", loader.ownerName());
assertEquals(6, loader.chunkX()); // 100 >> 4 = 6
assertEquals(12, loader.chunkZ()); // 200 >> 4 = 12
assertEquals("100, 64, 200 (world)", loader.place());
assertEquals("[6, 12]", loader.chunkCoords());
assertEquals(1, loaders.size());
}
@Test
void queriesByChunkLocationAndOwner() {
ChunkLoader l1 = loaders.add("uuid-marcos", "Marcos", "world", 16, 64, 32);
ChunkLoader l2 = loaders.add("uuid-ana", "Ana", "world_nether", 0, 70, 0);
assertEquals(l1, loaders.byLocation("world", 16, 64, 32));
assertNull(loaders.byLocation("world", 17, 64, 32));
assertEquals(l1, loaders.byChunk("world", 1, 2));
assertEquals(l2, loaders.byChunk("world_nether", 0, 0));
assertNull(loaders.byChunk("world", 0, 0));
List<ChunkLoader> marcosLoaders = loaders.byOwner("uuid-marcos");
assertEquals(1, marcosLoaders.size());
assertEquals(l1, marcosLoaders.get(0));
List<ChunkLoader> anaLoaders = loaders.byOwner("uuid-ana");
assertEquals(1, anaLoaders.size());
assertEquals(l2, anaLoaders.get(0));
}
@Test
void removesLoaderById() {
ChunkLoader l1 = loaders.add("uuid-marcos", "Marcos", "world", 16, 64, 32);
assertTrue(loaders.remove(l1.id()));
assertEquals(0, loaders.size());
assertNull(loaders.byId(l1.id()));
assertFalse(loaders.remove(l1.id()));
}
@Test
void persistsToDiskAndReloads() {
loaders.add("uuid-marcos", "Marcos", "world", 100, 64, 200);
loaders.add("uuid-ana", "Ana", "world_nether", 50, 70, -50);
loaders.flush();
ChunkLoaders reloaded = new ChunkLoaders(null, file);
assertEquals(2, reloaded.size());
ChunkLoader l1 = reloaded.byId(1);
assertNotNull(l1);
assertEquals("uuid-marcos", l1.ownerUuid());
assertEquals(6, l1.chunkX());
assertEquals(12, l1.chunkZ());
ChunkLoader l2 = reloaded.byId(2);
assertNotNull(l2);
assertEquals("uuid-ana", l2.ownerUuid());
}
}
@@ -0,0 +1,82 @@
package dev.marcospaulo.canalhandia;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.io.TempDir;
import java.io.File;
import java.nio.file.Path;
import java.util.UUID;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
class EventTest {
@TempDir
Path tempDir;
private PlayerMemory memory;
@BeforeEach
void setUp() {
File file = tempDir.resolve("ia-memoria.yml").toFile();
memory = new PlayerMemory(file);
}
@Test
void eventResolvesPlayerCustomPersonaWhenSet() {
UUID id = UUID.randomUUID();
Persona defaultPersona = Persona.ZOEIRO;
// Default fallback
assertEquals(Persona.ZOEIRO, memory.persona(id, defaultPersona));
// Player custom choice
memory.setPersona(id, "Marcos", Persona.JUDITE);
assertEquals(Persona.JUDITE, memory.persona(id, defaultPersona));
// Switch to Narrador
memory.setPersona(id, "Marcos", Persona.NARRADOR);
assertEquals(Persona.NARRADOR, memory.persona(id, defaultPersona));
}
@Test
void joinWelcomePromptContainsPlayerAndStats() {
String name = "Marcos";
String stats = "100 diamantes minerados, 2 mortes";
String prompt = "O jogador " + name + " acabou de entrar no servidor."
+ " Estatísticas dele: " + stats
+ " Dê as boas-vindas do seu jeito e na sua personalidade, em uma frase curta.";
assertTrue(prompt.contains("Marcos"));
assertTrue(prompt.contains("100 diamantes"));
assertTrue(prompt.contains("personalidade"));
}
@Test
void deathStreakPromptContainsCountAndFlavor() {
String name = "Marcos";
int count = 4;
String flavor = "abraçou um Creeper";
String prompt = "O jogador " + name + " morreu " + count
+ " vezes seguidas em poucos minutos. A última foi assim: " + flavor
+ ". Comente na sua personalidade, sem ofender de verdade.";
assertTrue(prompt.contains("morreu 4 vezes seguidas"));
assertTrue(prompt.contains("abraçou um Creeper"));
}
@Test
void achievementUnlockPromptContainsTitleAndDescription() {
String title = "Mestre dos Diamantes";
String desc = "Minerou 1000 diamantes";
String prompt = "O jogador Marcos desbloqueou a conquista \""
+ title + "\" (" + desc
+ "). Faça um breve comentário na sua personalidade.";
assertTrue(prompt.contains(title));
assertTrue(prompt.contains(desc));
}
}
@@ -122,6 +122,31 @@ class PersonaTest {
}
}
@Test
void juditeHasSacFlavour() {
assertEquals("judite", Persona.JUDITE.key());
assertEquals("Judite", Persona.JUDITE.displayTag());
assertTrue(Persona.JUDITE.instructions().contains("Judite"));
assertTrue(Persona.JUDITE.instructions().contains("gerundismo") || Persona.JUDITE.instructions().contains("estaremos"));
assertTrue(Persona.JUDITE.instructions().contains("protocolo") || Persona.JUDITE.instructions().contains("Protocolo"));
}
@Test
void narradorHasEpicFlavour() {
assertEquals("narrador", Persona.NARRADOR.key());
assertEquals("Narrador", Persona.NARRADOR.displayTag());
assertTrue(Persona.NARRADOR.instructions().contains("narrador épico") || Persona.NARRADOR.instructions().contains("fantasia"));
}
@Test
void everyPersonaHasValidDisplayTagAndColor() {
for (Persona persona : Persona.values()) {
assertNotNull(persona.displayTag(), persona.key() + " needs a displayTag");
assertFalse(persona.displayTag().isBlank(), persona.key() + " displayTag cannot be blank");
assertNotNull(persona.tagColor(), persona.key() + " needs a tagColor");
}
}
@Test
void guardForbidsInventingStats() {
// The AI is now fed real numbers; without this it would happily make up
@@ -0,0 +1,163 @@
package dev.marcospaulo.canalhandia;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.io.TempDir;
import java.io.File;
import java.nio.file.Path;
import java.util.List;
import java.util.UUID;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
class PlayerMemoryTest {
@TempDir
Path tempDir;
private File file;
private PlayerMemory memory;
@BeforeEach
void setUp() {
file = tempDir.resolve("ia-memoria.yml").toFile();
memory = new PlayerMemory(file);
}
@org.junit.jupiter.api.AfterEach
void tearDown() {
if (memory != null) {
memory.flush();
}
}
@Test
void startsEmpty() {
assertEquals(0, memory.size());
}
@Test
void setsAndPersistsPersona() {
UUID id = UUID.randomUUID();
assertEquals(Persona.ZOEIRO, memory.persona(id, Persona.ZOEIRO));
assertNull(memory.rawPersona(id));
memory.setPersona(id, "Marcos", Persona.JUDITE);
assertEquals(Persona.JUDITE, memory.persona(id, Persona.ZOEIRO));
assertEquals(Persona.JUDITE, memory.rawPersona(id));
// Reload from disk
memory.flush();
PlayerMemory reloaded = new PlayerMemory(file);
assertEquals(Persona.JUDITE, reloaded.persona(id, Persona.ZOEIRO));
assertEquals(Persona.JUDITE, reloaded.rawPersona(id));
// Reset
reloaded.resetPersona(id);
reloaded.flush();
assertNull(reloaded.rawPersona(id));
assertEquals(Persona.ZOEIRO, reloaded.persona(id, Persona.ZOEIRO));
}
@Test
void recordsTurnAndCompressesWhenLong() {
UUID id = UUID.randomUUID();
memory.recordTurn(id, "Marcos", "Onde tem diamante?", "Na camada -58.");
String s = memory.summary(id);
assertNotNull(s);
assertTrue(s.contains("diamante"));
assertTrue(s.contains("-58"));
// Push many turns to trigger compression
for (int i = 0; i < 20; i++) {
memory.recordTurn(id, "Marcos", "Pergunta " + i, "Resposta bem longa para a pergunta " + i);
}
String compressed = memory.summary(id);
assertNotNull(compressed);
assertTrue(compressed.length() <= PlayerMemory.MAX_SUMMARY_CHARS + 10);
}
@Test
void addsAndCapsFacts() {
UUID id = UUID.randomUUID();
for (int i = 1; i <= 10; i++) {
memory.addFact(id, "Marcos", "Fato número " + i);
}
List<String> facts = memory.facts(id);
assertEquals(PlayerMemory.MAX_FACTS, facts.size());
assertTrue(facts.contains("Fato número 10"));
assertFalse(facts.contains("Fato número 1")); // Oldest evicted
}
@Test
void formatContextProducesCleanPrompt() {
UUID id = UUID.randomUUID();
assertNull(memory.formatContext(id));
memory.recordTurn(id, "Marcos", "Como fazer poção?", "Use suporte de poções.");
memory.addFact(id, "Marcos", "Mora na vila do deserto");
String context = memory.formatContext(id);
assertNotNull(context);
assertTrue(context.contains("Resumo de tópicos recentes"));
assertTrue(context.contains("Fatos conhecidos"));
assertTrue(context.contains("Mora na vila do deserto"));
}
@Test
void clearHistoryKeepsPersona() {
UUID id = UUID.randomUUID();
memory.setPersona(id, "Marcos", Persona.SECO);
memory.recordTurn(id, "Marcos", "Oi", "Tchau");
memory.addFact(id, "Marcos", "Fato 1");
memory.clearHistory(id);
assertEquals(Persona.SECO, memory.rawPersona(id));
assertEquals("", memory.summary(id));
assertTrue(memory.facts(id).isEmpty());
}
@Test
void forgetRemovesProfileCompletely() {
UUID id = UUID.randomUUID();
memory.setPersona(id, "Marcos", Persona.NARRADOR);
memory.forget(id);
assertEquals(0, memory.size());
assertNull(memory.rawPersona(id));
}
@Test
void extractsHeuristicFactsAutomatically() {
UUID id = UUID.randomUUID();
memory.recordTurn(id, "Marcos", "Minha base fica nas montanhas nevadas!", "Que lugar bonito!");
List<String> facts = memory.facts(id);
assertFalse(facts.isEmpty());
assertTrue(facts.get(0).toLowerCase().contains("minha base"));
String fact = PlayerMemory.extractHeuristicFact("Eu estou construindo uma pirâmide gigante?");
assertNotNull(fact);
assertTrue(fact.contains("estou construindo uma pirâmide gigante"));
assertNull(PlayerMemory.extractHeuristicFact("quantos blocos tem o mundo?"));
// Leading / trailing whitespace index alignment
assertEquals("minha base fica no topo", PlayerMemory.extractHeuristicFact(" minha base fica no topo! "));
assertEquals("estou construindo uma ponte", PlayerMemory.extractHeuristicFact(" oi, estou construindo uma ponte..."));
}
@Test
void flushesToDiskCorrectly() {
UUID id = UUID.randomUUID();
memory.setPersona(id, "Marcos", Persona.JUDITE);
memory.recordTurn(id, "Marcos", "Preciso de ajuda", "Aguarde na linha");
memory.flush();
PlayerMemory disk = new PlayerMemory(file);
assertEquals(Persona.JUDITE, disk.persona(id, Persona.ZOEIRO));
assertTrue(disk.summary(id).contains("ajuda"));
}
}
@@ -0,0 +1,78 @@
package dev.marcospaulo.canalhandia;
import com.google.gson.JsonArray;
import org.junit.jupiter.api.Test;
import java.util.List;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
class ToolsTest {
@Test
void definitionsIncludeLugaresJogador() {
Tools tools = new Tools(null, null, null, s -> {});
JsonArray defs = tools.definitions();
assertNotNull(defs);
assertTrue(defs.size() >= 6);
boolean foundLugares = false;
for (int i = 0; i < defs.size(); i++) {
var fn = defs.get(i).getAsJsonObject().getAsJsonObject("function");
String name = fn.get("name").getAsString();
if ("lugares_jogador".equals(name)) {
foundLugares = true;
assertTrue(fn.has("description"));
assertTrue(fn.getAsJsonObject("parameters").has("properties"));
}
}
assertTrue(foundLugares, "lugares_jogador must be defined in tools schema");
}
@Test
void unknownToolReturnsErrorText() {
Tools tools = new Tools(null, null, null, s -> {});
String res = tools.run("nao_existe", "{}");
assertTrue(res.contains("ferramenta desconhecida"));
}
@Test
void malformedJsonReturnsError() {
Tools tools = new Tools(null, null, null, s -> {});
String res = tools.run("wiki", "malformed json");
assertTrue(res.contains("argumentos inválidos"));
}
@Test
void formatPlayerPlacesFiltersOutPrivateNotesAndOtherAuthors() {
Tools tools = new Tools(null, null, null, s -> {});
OfflineStats.Known who = new OfflineStats.Known("uuid-ana", "ana");
Note privateNote = new Note(1, Note.Scope.PRIVADA, "ana", "uuid-ana", "segredo", "world", 10, 20, 30, 1000L);
Note publicNote = new Note(2, Note.Scope.PUBLICA, "ana", "uuid-ana", "vila do spawn", "world", 100, 64, 200, 1000L);
Note otherAuthorPublicNote = new Note(3, Note.Scope.PUBLICA, "bob", "uuid-bob", "base do bob", "world", 500, 64, 500, 1000L);
String formatted = tools.formatPlayerPlaces(who, List.of(), List.of(privateNote, publicNote, otherAuthorPublicNote));
assertTrue(formatted.contains("vila do spawn"));
assertFalse(formatted.contains("segredo"), "Private notes must never be included in places output");
assertFalse(formatted.contains("base do bob"), "Notes of other players must not be included");
assertTrue(formatted.contains("nenhum registro de morte recente"));
}
@Test
void formatPlayerPlacesIncludesDeathsAndFormatsPlaces() {
Tools tools = new Tools(null, null, null, s -> {});
OfflineStats.Known who = new OfflineStats.Known("uuid-ana", "ana");
DeathLog.Entry d = new DeathLog.Entry("uuid-ana", "abraçou um Creeper", "Mundo normal", 12, 64, -80, 1000L);
String formatted = tools.formatPlayerPlaces(who, List.of(d), List.of());
assertTrue(formatted.contains("Lugares conhecidos de ana:"));
assertTrue(formatted.contains("nenhuma base salva"));
assertTrue(formatted.contains("12, 64, -80 (Mundo normal)"));
assertTrue(formatted.contains("abraçou um Creeper"));
}
}