65 lines
2.3 KiB
Java
65 lines
2.3 KiB
Java
package net.minecraft.client.telemetry;
|
|
|
|
import com.mojang.logging.LogUtils;
|
|
import java.io.IOException;
|
|
import java.nio.channels.FileChannel;
|
|
import java.nio.file.Path;
|
|
import java.time.LocalDate;
|
|
import java.util.Optional;
|
|
import java.util.concurrent.CompletableFuture;
|
|
import net.fabricmc.api.EnvType;
|
|
import net.fabricmc.api.Environment;
|
|
import net.minecraft.Util;
|
|
import net.minecraft.util.eventlog.EventLogDirectory;
|
|
import org.jetbrains.annotations.Nullable;
|
|
import org.slf4j.Logger;
|
|
|
|
@Environment(EnvType.CLIENT)
|
|
public class TelemetryLogManager implements AutoCloseable {
|
|
private static final Logger LOGGER = LogUtils.getLogger();
|
|
private static final String RAW_EXTENSION = ".json";
|
|
private static final int EXPIRY_DAYS = 7;
|
|
private final EventLogDirectory directory;
|
|
@Nullable
|
|
private CompletableFuture<Optional<TelemetryEventLog>> sessionLog;
|
|
|
|
private TelemetryLogManager(EventLogDirectory directory) {
|
|
this.directory = directory;
|
|
}
|
|
|
|
public static CompletableFuture<Optional<TelemetryLogManager>> open(Path path) {
|
|
return CompletableFuture.supplyAsync(() -> {
|
|
try {
|
|
EventLogDirectory eventLogDirectory = EventLogDirectory.open(path, ".json");
|
|
eventLogDirectory.listFiles().prune(LocalDate.now(), 7).compressAll();
|
|
return Optional.of(new TelemetryLogManager(eventLogDirectory));
|
|
} catch (Exception var2) {
|
|
LOGGER.error("Failed to create telemetry log manager", (Throwable)var2);
|
|
return Optional.empty();
|
|
}
|
|
}, Util.backgroundExecutor());
|
|
}
|
|
|
|
public CompletableFuture<Optional<TelemetryEventLogger>> openLogger() {
|
|
if (this.sessionLog == null) {
|
|
this.sessionLog = CompletableFuture.supplyAsync(() -> {
|
|
try {
|
|
EventLogDirectory.RawFile rawFile = this.directory.createNewFile(LocalDate.now());
|
|
FileChannel fileChannel = rawFile.openChannel();
|
|
return Optional.of(new TelemetryEventLog(fileChannel, Util.backgroundExecutor()));
|
|
} catch (IOException var3) {
|
|
LOGGER.error("Failed to open channel for telemetry event log", (Throwable)var3);
|
|
return Optional.empty();
|
|
}
|
|
}, Util.backgroundExecutor());
|
|
}
|
|
|
|
return this.sessionLog.thenApply(optional -> optional.map(TelemetryEventLog::logger));
|
|
}
|
|
|
|
public void close() {
|
|
if (this.sessionLog != null) {
|
|
this.sessionLog.thenAccept(optional -> optional.ifPresent(TelemetryEventLog::close));
|
|
}
|
|
}
|
|
}
|