mirror of
https://github.com/wu736139669/hapi.git
synced 2026-08-05 06:24:37 +00:00
@@ -10,6 +10,7 @@ import { startHappyServer } from '@/claude/utils/startHappyServer';
|
|||||||
import { getHappyCliCommand } from '@/utils/spawnHappyCLI';
|
import { getHappyCliCommand } from '@/utils/spawnHappyCLI';
|
||||||
import { registerKillSessionHandler } from '@/claude/registerKillSessionHandler';
|
import { registerKillSessionHandler } from '@/claude/registerKillSessionHandler';
|
||||||
import { bootstrapSession } from '@/agent/sessionFactory';
|
import { bootstrapSession } from '@/agent/sessionFactory';
|
||||||
|
import { formatMessageWithAttachments } from '@/utils/attachmentFormatter';
|
||||||
|
|
||||||
function emitReadyIfIdle(props: {
|
function emitReadyIfIdle(props: {
|
||||||
queueSize: () => number;
|
queueSize: () => number;
|
||||||
@@ -45,7 +46,8 @@ export async function runAgentSession(opts: {
|
|||||||
const messageQueue = new MessageQueue2<Record<string, never>>(() => hashObject({}));
|
const messageQueue = new MessageQueue2<Record<string, never>>(() => hashObject({}));
|
||||||
|
|
||||||
session.onUserMessage((message) => {
|
session.onUserMessage((message) => {
|
||||||
messageQueue.push(message.content.text, {});
|
const formattedText = formatMessageWithAttachments(message.content.text, message.content.attachments);
|
||||||
|
messageQueue.push(formattedText, {});
|
||||||
});
|
});
|
||||||
|
|
||||||
const backend: AgentBackend = AgentRegistry.create(opts.agentType);
|
const backend: AgentBackend = AgentRegistry.create(opts.agentType);
|
||||||
|
|||||||
@@ -10,6 +10,7 @@ import { bootstrapSession } from '@/agent/sessionFactory';
|
|||||||
import { createModeChangeHandler, createRunnerLifecycle, setControlledByUser } from '@/agent/runnerLifecycle';
|
import { createModeChangeHandler, createRunnerLifecycle, setControlledByUser } from '@/agent/runnerLifecycle';
|
||||||
import { isPermissionModeAllowedForFlavor } from '@hapi/protocol';
|
import { isPermissionModeAllowedForFlavor } from '@hapi/protocol';
|
||||||
import { PermissionModeSchema } from '@hapi/protocol/schemas';
|
import { PermissionModeSchema } from '@hapi/protocol/schemas';
|
||||||
|
import { formatMessageWithAttachments } from '@/utils/attachmentFormatter';
|
||||||
|
|
||||||
export { emitReadyIfIdle } from './utils/emitReadyIfIdle';
|
export { emitReadyIfIdle } from './utils/emitReadyIfIdle';
|
||||||
|
|
||||||
@@ -73,7 +74,8 @@ export async function runCodex(opts: {
|
|||||||
const enhancedMode: EnhancedMode = {
|
const enhancedMode: EnhancedMode = {
|
||||||
permissionMode: messagePermissionMode ?? 'default'
|
permissionMode: messagePermissionMode ?? 'default'
|
||||||
};
|
};
|
||||||
messageQueue.push(message.content.text, enhancedMode);
|
const formattedText = formatMessageWithAttachments(message.content.text, message.content.attachments);
|
||||||
|
messageQueue.push(formattedText, enhancedMode);
|
||||||
});
|
});
|
||||||
|
|
||||||
const formatFailureReason = (message: string): string => {
|
const formatFailureReason = (message: string): string => {
|
||||||
|
|||||||
Reference in New Issue
Block a user