mirror of
https://github.com/slhaf/Partner.git
synced 2026-05-12 08:43:02 +08:00
chore: add slf4j log annotation on AgentModule implementations
This commit is contained in:
@@ -1,5 +1,6 @@
|
|||||||
package work.slhaf.partner.module.action.executor;
|
package work.slhaf.partner.module.action.executor;
|
||||||
|
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import lombok.val;
|
import lombok.val;
|
||||||
import org.jetbrains.annotations.NotNull;
|
import org.jetbrains.annotations.NotNull;
|
||||||
import work.slhaf.partner.core.action.ActionCapability;
|
import work.slhaf.partner.core.action.ActionCapability;
|
||||||
@@ -23,6 +24,7 @@ import java.util.concurrent.atomic.AtomicInteger;
|
|||||||
import java.util.concurrent.atomic.AtomicReference;
|
import java.util.concurrent.atomic.AtomicReference;
|
||||||
import java.util.stream.Collectors;
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
|
@Slf4j
|
||||||
public class ActionExecutor extends AbstractAgentModule.Standalone {
|
public class ActionExecutor extends AbstractAgentModule.Standalone {
|
||||||
|
|
||||||
private static final int MAX_EXTRACTOR_ATTEMPTS = 3;
|
private static final int MAX_EXTRACTOR_ATTEMPTS = 3;
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
package work.slhaf.partner.module.action.planner;
|
package work.slhaf.partner.module.action.planner;
|
||||||
|
|
||||||
import kotlin.Unit;
|
import kotlin.Unit;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.jetbrains.annotations.NotNull;
|
import org.jetbrains.annotations.NotNull;
|
||||||
import org.w3c.dom.Document;
|
import org.w3c.dom.Document;
|
||||||
import org.w3c.dom.Element;
|
import org.w3c.dom.Element;
|
||||||
@@ -37,6 +38,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
|
|||||||
/**
|
/**
|
||||||
* 负责针对本次输入生成基础的行动计划
|
* 负责针对本次输入生成基础的行动计划
|
||||||
*/
|
*/
|
||||||
|
@Slf4j
|
||||||
public class ActionPlanner extends AbstractAgentModule.Running<PartnerRunningFlowContext> {
|
public class ActionPlanner extends AbstractAgentModule.Running<PartnerRunningFlowContext> {
|
||||||
|
|
||||||
private static final String IMMEDIATE_WATCHER_CRON = "0/5 * * * * ?";
|
private static final String IMMEDIATE_WATCHER_CRON = "0/5 * * * * ?";
|
||||||
|
|||||||
@@ -287,7 +287,7 @@ class ActionScheduler : AbstractAgentModule.Standalone() {
|
|||||||
val now1 = System.nanoTime()
|
val now1 = System.nanoTime()
|
||||||
val sleepNanos = nextTickNanos - now1
|
val sleepNanos = nextTickNanos - now1
|
||||||
if (sleepNanos > 0) {
|
if (sleepNanos > 0) {
|
||||||
delay(sleepNanos / 1_000_000L) // 毫秒级 delay 足够;剩余 nanos 不必忙等
|
delay((sleepNanos / 1_000_000L).milliseconds) // 毫秒级 delay 足够;剩余 nanos 不必忙等
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -299,7 +299,7 @@ class ActionScheduler : AbstractAgentModule.Standalone() {
|
|||||||
).toMillis()
|
).toMillis()
|
||||||
// withTimeoutOrNull 内部已处理 seconds 小于 0 的情况
|
// withTimeoutOrNull 内部已处理 seconds 小于 0 的情况
|
||||||
log.debug("Start waiting {} ms at {}, target time: {}", seconds, currentTime, nextHour)
|
log.debug("Start waiting {} ms at {}, target time: {}", seconds, currentTime, nextHour)
|
||||||
withTimeoutOrNull(seconds) {
|
withTimeoutOrNull(seconds.milliseconds) {
|
||||||
state.first { it == WheelState.ACTIVE }
|
state.first { it == WheelState.ACTIVE }
|
||||||
}
|
}
|
||||||
log.debug("Waiting ended at {}", ZonedDateTime.now())
|
log.debug("Waiting ended at {}", ZonedDateTime.now())
|
||||||
|
|||||||
@@ -1,5 +1,6 @@
|
|||||||
package work.slhaf.partner.module.communication;
|
package work.slhaf.partner.module.communication;
|
||||||
|
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.jetbrains.annotations.NotNull;
|
import org.jetbrains.annotations.NotNull;
|
||||||
import org.w3c.dom.Document;
|
import org.w3c.dom.Document;
|
||||||
import org.w3c.dom.Element;
|
import org.w3c.dom.Element;
|
||||||
@@ -25,6 +26,7 @@ import java.util.List;
|
|||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.stream.Collectors;
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
|
@Slf4j
|
||||||
public class CommunicationProducer extends AbstractAgentModule.Running<PartnerRunningFlowContext> implements ActivateModel {
|
public class CommunicationProducer extends AbstractAgentModule.Running<PartnerRunningFlowContext> implements ActivateModel {
|
||||||
|
|
||||||
private static final String INTERRUPTED_MARKER = " [response interrupted due to internal exception]";
|
private static final String INTERRUPTED_MARKER = " [response interrupted due to internal exception]";
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
package work.slhaf.partner.module.communication;
|
package work.slhaf.partner.module.communication;
|
||||||
|
|
||||||
import kotlin.Unit;
|
import kotlin.Unit;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.jetbrains.annotations.NotNull;
|
import org.jetbrains.annotations.NotNull;
|
||||||
import org.w3c.dom.Document;
|
import org.w3c.dom.Document;
|
||||||
import org.w3c.dom.Element;
|
import org.w3c.dom.Element;
|
||||||
@@ -34,6 +35,7 @@ import java.util.List;
|
|||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
import java.util.concurrent.atomic.AtomicBoolean;
|
import java.util.concurrent.atomic.AtomicBoolean;
|
||||||
|
|
||||||
|
@Slf4j
|
||||||
public class DialogRolling extends AbstractAgentModule.Running<PartnerRunningFlowContext> {
|
public class DialogRolling extends AbstractAgentModule.Running<PartnerRunningFlowContext> {
|
||||||
|
|
||||||
private static final String AUTO_UPDATE_CRON = "0/10 * * * * ?";
|
private static final String AUTO_UPDATE_CRON = "0/10 * * * * ?";
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
package work.slhaf.partner.module.memory.selector;
|
package work.slhaf.partner.module.memory.selector;
|
||||||
|
|
||||||
import kotlin.Unit;
|
import kotlin.Unit;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.jetbrains.annotations.NotNull;
|
import org.jetbrains.annotations.NotNull;
|
||||||
import org.w3c.dom.Document;
|
import org.w3c.dom.Document;
|
||||||
import org.w3c.dom.Element;
|
import org.w3c.dom.Element;
|
||||||
@@ -24,6 +25,7 @@ import work.slhaf.partner.runtime.PartnerRunningFlowContext;
|
|||||||
import java.time.LocalDate;
|
import java.time.LocalDate;
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
|
|
||||||
|
@Slf4j
|
||||||
public class MemorySelector extends AbstractAgentModule.Running<PartnerRunningFlowContext> {
|
public class MemorySelector extends AbstractAgentModule.Running<PartnerRunningFlowContext> {
|
||||||
|
|
||||||
private static final String BLOCK_NAME = "activated_memory_slices";
|
private static final String BLOCK_NAME = "activated_memory_slices";
|
||||||
|
|||||||
@@ -1,7 +1,5 @@
|
|||||||
package work.slhaf.partner.framework.agent.factory.component.abstracts
|
package work.slhaf.partner.framework.agent.factory.component.abstracts
|
||||||
|
|
||||||
import org.slf4j.Logger
|
|
||||||
import org.slf4j.LoggerFactory
|
|
||||||
import work.slhaf.partner.framework.agent.factory.component.annotation.AgentComponent
|
import work.slhaf.partner.framework.agent.factory.component.annotation.AgentComponent
|
||||||
import work.slhaf.partner.framework.agent.interaction.flow.RunningFlowContext
|
import work.slhaf.partner.framework.agent.interaction.flow.RunningFlowContext
|
||||||
import work.slhaf.partner.framework.agent.log.LogAdviceProvider
|
import work.slhaf.partner.framework.agent.log.LogAdviceProvider
|
||||||
@@ -15,9 +13,6 @@ sealed class AbstractAgentModule {
|
|||||||
|
|
||||||
var moduleName: String = javaClass.simpleName
|
var moduleName: String = javaClass.simpleName
|
||||||
|
|
||||||
@JvmField
|
|
||||||
val log: Logger = LoggerFactory.getLogger(javaClass.simpleName)
|
|
||||||
|
|
||||||
abstract class Running<T : RunningFlowContext> : AbstractAgentModule() {
|
abstract class Running<T : RunningFlowContext> : AbstractAgentModule() {
|
||||||
|
|
||||||
private val advice = run {
|
private val advice = run {
|
||||||
|
|||||||
Reference in New Issue
Block a user