package com.l7tech.server.log;

import com.l7tech.gateway.common.log.LogAccessAdmin;
import com.l7tech.gateway.common.log.LogFileInfo;
import com.l7tech.gateway.common.log.LogSinkData;
import com.l7tech.gateway.common.log.LogSinkQuery;
import com.l7tech.objectmodel.FindException;
import com.l7tech.objectmodel.Goid;
import com.l7tech.server.cluster.ClusterInfoManager;
import jakarta.inject.Inject;
import java.util.Collection;
import java.util.Collections;

public class LogAccessAdminImpl implements LogAccessAdmin {
   @Inject
   private SinkManager sinkManager;
   @Inject
   private ClusterInfoManager clusterInfoManager;

   public Collection<LogFileInfo> findAllFilesForSinkByNode(String var1, Goid var2) throws FindException {
      try {
         if (!var1.equals(this.clusterInfoManager.thisNodeId())) {
            return Collections.emptyList();
         }
      } catch (FindException var3) {
         throw a(var3);
      }

      return this.sinkManager.findAllFilesForSinkByNode(var1, var2);
   }

   public LogSinkData getSinkLogs(String var1, Goid var2, String var3, LogSinkQuery var4) throws FindException {
      try {
         if (!var1.equals(this.clusterInfoManager.thisNodeId())) {
            return null;
         }
      } catch (FindException var5) {
         throw a(var5);
      }

      return this.sinkManager.getSinkLogs(var1, var2, var3, var4);
   }

   private static FindException a(FindException var0) {
      return var0;
   }
}