Persistence — MongoDB

public static final String PRODUCTION_DATABASE = "beebot";
public static final String TEST_DATABASE = "beebot_test";
public static String getDatabaseName(boolean testing) { return testing ? TEST_DATABASE : PRODUCTION_DATABASE; }
public static synchronized MongoDatabase getDatabase() {
    if (database == null) database = getClient().getDatabase(App.isTesting() ? TEST_DATABASE : PRODUCTION_DATABASE);
    if (!collectionsReady) { ensureCollections(database); collectionsReady = true; }
    return database;
}

private static final List<String> COLLECTION_NAMES = List.of(
    "summoner", "match", "match_events", "profile_statistics", "champion",
    "champion_builds", "champion_stats", "profile_activity", "profile_matchups", PROFILE_RECORDS_COLLECTION, LEADERBOARD_AGGREGATES_COLLECTION,
    COMPETITIVE_COLLECTION,
    CHAMPION_INDEXABLES_COLLECTION, PROFILE_INDEXABLES_COLLECTION, "migration_runs");

{
  "_id": "puuid-abc123",
  "puuid": "puuid-abc123",
  "riotId": "Faker#KR1",
  "riotSearch": "faker#kr1",
  "region": "KR",
  "level": 512,
  "icon": 4567,
  "userId": "discord-123",
  "tracking": true,
  "ranks": {
    "RANKED_SOLO_5X5": { "tier": "CHALLENGER", "division": 1, "lp": 1280, "wins": 342, "losses": 298, "tierDivisionType": "CHALLENGER_I" },
    "RANKED_FLEX_SR": { "tier": "MASTER", "lp": 45 }
  },
  "masteries": [{ "championId": 157, "championPoints": 1234567, "championLevel": 7, "lastPlayTime": 1715434800000 }],
  "lastUpdate": 1715434800000,
  "lastSeenAt": 1715434800000
}

{
  "_id": "EUW1_1234567890",
  "id": 1234567890,
  "gameId": "EUW1_1234567890",
  "region": "EUW1",
  "leagueShard": "EUW1",
  "queue": "RANKED_SOLO_5X5",
  "rank": "EMERALD",
  "patch": "15.6.1",
  "patchMajor": "15.6",
  "timeStart": 1715000000000,
  "timeEnd": 1715001800000,
  "lastUpdate": 1715434800000,
  "tracked": true,
  "bans": { "BLUE": [157, 64], "RED": [238, 122] },
  "participants": [
    {
      "puuid": "abc", "champion": 157, "lane": "MID", "team": "BLUE", "win": true, "kda": "8/2/6",
      "kills": 8, "deaths": 2, "assists": 6, "cs": 245, "goldEarned": 14200, "visionScore": 23,
      "damage": 28000, "rankProgress": { "rank": "EMERALD_I", "lp": 45, "gain": 18, "previousRank": "EMERALD_I", "previousLp": 27 },
      "starterItems": [1055, 2003], "boots": 3006, "supportItem": 0,
      "item0": 6672, "item1": 3031, "item2": 3508, "item3": 3072, "item4": 3033, "item5": 0,
      "skillOrder": [1,3,2,1,1,4], "augments": [], "primaryRunes": [8005], "secondaryRunes": [8275], "statsRunes": [5005]
    }
  ],
  "events": { "events": [] },
  "eventData": {}
}

{
  "_id": "EUW1_1234567890",
  "gameId": "EUW1_1234567890",
  "data": "{\"events\": [...], \"frames\": [...]}",
  "patchMajor": "15.6",
  "lastUpdate": 1715434800000
}

{
  "_id": "abc-puuid:BASE64URL_FILTER_SUMMONER_KEY",
  "puuid": "abc-puuid",
  "filterKey": "BASE64URL_SUMMONER_KEY",
  "filter": { "champion": 0, "lane": null, "queue": null, "rank": null, "patch": null, "region": null, "opponent": 0, "duo": 0, "timeStart": 1700000000000, "timeEnd": 1716000000000 },
  "overview": { "games": 320, "wins": 180, "losses": 140, "winrate": 0.562, "kda": 3.2, "csPerMinute": 7.1 },
  "rows": [{ "champion": 157, "lane": "MID", "games": 80, "wins": 45, "winrate": 0.562 }],
  "lastUpdate": 1715434800000
}

{
  "_id": "abc:BASE64URL_KEY",
  "puuid": "abc",
  "filterKey": "BASE64URL",
  "overview": { "games": 120, "wins": 68, "kda": 3.1 },
  "champions": [{ "champion": 157, "games": 40, "wins": 24 }],
  "lanes": [{ "lane": "MID", "games": 80, "wins": 45 }],
  "lastUpdate": 1715434800000
}

{
  "_id": "abc:BASE64URL_STATE_KEY",
  "puuid": "abc",
  "filterKey": "BASE64URL_STATE_KEY",
  "filter": { "queue": "RANKED_SOLO_5X5", "lane": "MID", "patch": "15.6", "minGames": 5 },
  "matchups": { "238": [{ "opponent": 238, "games": 12, "wins": 5, "losses": 7, "winrate": 0.416 }] },
  "lastUpdate": 1715434800000
}

// champions_indexable
{ "_id": "157_MID_15.6", "championId": 157, "role": "MID", "patchMajor": "15.6", "games": 12400, "indexable": true, "lastUpdate": 1715434800000 }

// profiles_indexable
{ "_id": "abc-puuid", "puuid": "abc-puuid", "riotId": "Faker#KR1", "region": "KR", "rank": "CHALLENGER_I", "lastUpdate": 1715434800000 }

// Verify indexes
db.summoner.getIndexes()
db.match.getIndexes()

// Explain for match history
db.match.explain("executionStats").find(
  { "participants.puuid": "abc-puuid", "region": "EUW1", "queue": "RANKED_SOLO_5X5" }
).sort({ timeStart: -1 }).limit(20)

// Must show:
// winningPlan: { stage: "FETCH", inputStage: { stage: "IXSCAN", keyPattern: { "participants.puuid":1, timeStart:-1 } } }
// executionStats.totalDocsExamined == nReturned (no COLLSCAN)

private static CreateCollectionOptions collectionOptions(String collection) {
    if (!"match_events".equals(collection)) return new CreateCollectionOptions();
    return new CreateCollectionOptions().storageEngineOptions(new Document("wiredTiger", new Document("configString", EVENTS_STORAGE_ENGINE_CONFIG)));
}
// EVENTS_STORAGE_ENGINE_CONFIG = "block_compressor=zstd" (:106)

interface EntityWriter { boolean execute(String collection, String id, List<Map<String, Object>> operations, Map<String, Object> filters, boolean upsert); }
private static final EntityWriter DEFAULT_WRITER = MongoDB::applyEntityUpdate;
static boolean execute(...) { return writer.execute(collection, id, operations, filters, upsert); }
static void installWriterForTests(EntityWriter testWriter) { writer = testWriter == null ? DEFAULT_WRITER : testWriter; }

private static final ObjectMapper MAPPER = JsonMapper.builder()
    .addModule(new JavaTimeModule())
    .configure(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS, false)
    .configure(MapperFeature.CAN_OVERRIDE_ACCESS_MODIFIERS, true)
    .visibility(GETTER, NONE).visibility(IS_GETTER, NONE).visibility(FIELD, ANY)
    .build();
public static String toJson(Object value) { return MAPPER.writeValueAsString(value); }
public static <T> T fromJson(String json, Class<T> type) { return MAPPER.readValue(json, type); }
public static Document toDocument(Object value) { return Document.parse(toJson(value)); }