Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 1 addition & 6 deletions index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,6 @@ import { Logger } from "./lib/logger"
import { createSessionState } from "./lib/state"
import { PromptStore } from "./lib/prompts/store"
import {
createChatMessageHandler,
createChatMessageTransformHandler,
createCommandExecuteHandler,
createEventHandler,
Expand Down Expand Up @@ -68,7 +67,6 @@ const server: Plugin = (async (ctx) => {
prompts,
hostPermissions,
) as any,
"chat.message": createChatMessageHandler(state, logger, config, hostPermissions),
"experimental.text.complete": createTextCompleteHandler(),
"command.execute.before": createCommandExecuteHandler(
ctx.client,
Expand Down Expand Up @@ -135,7 +133,4 @@ const server: Plugin = (async (ctx) => {
}
}) satisfies Plugin

export default {
id,
server,
}
export default server
21 changes: 0 additions & 21 deletions lib/hooks.ts
Original file line number Diff line number Diff line change
Expand Up @@ -365,24 +365,3 @@ export function createEventHandler(state: SessionState, logger: Logger) {
}
}
}

export function createChatMessageHandler(
state: SessionState,
logger: Logger,
_config: PluginConfig,
_hostPermissions: HostPermissionSnapshot,
) {
return async (
input: {
sessionID: string
agent?: string
model?: { providerID: string; modelID: string }
messageID?: string
variant?: string
},
_output: any,
) => {
state.variant = input.variant
logger.debug("Cached variant from chat.message hook", { variant: input.variant })
}
}
7 changes: 1 addition & 6 deletions lib/messages/prune.ts
Original file line number Diff line number Diff line change
Expand Up @@ -202,12 +202,7 @@ const filterCompressedRanges = (
: rawSummaryContent
const summarySeed = `${summary.blockId}:${summary.anchorMessageId}`
result.push(
createSyntheticUserMessage(
userMessage,
summaryContent,
userInfo.variant,
summarySeed,
),
createSyntheticUserMessage(userMessage, summaryContent, summarySeed),
)

logger.info("Injected compress summary", {
Expand Down
2 changes: 0 additions & 2 deletions lib/messages/utils.ts
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@ const generateStableId = (prefix: string, seed: string): string => {
export const createSyntheticUserMessage = (
baseMessage: WithParts,
content: string,
variant?: string,
stableSeed?: string,
): WithParts => {
const userInfo = baseMessage.info as UserMessage
Expand All @@ -33,7 +32,6 @@ export const createSyntheticUserMessage = (
agent: userInfo.agent,
model: userInfo.model,
time: { created: now },
...(variant !== undefined && { variant }),
},
parts: [
{
Expand Down
2 changes: 0 additions & 2 deletions lib/state/state.ts
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,6 @@ export function createSessionState(): SessionState {
},
lastCompaction: 0,
currentTurn: 0,
variant: undefined,
modelContextLimit: undefined,
systemPromptTokens: undefined,
}
Expand Down Expand Up @@ -131,7 +130,6 @@ export function resetSessionState(state: SessionState): void {
}
state.lastCompaction = 0
state.currentTurn = 0
state.variant = undefined
state.modelContextLimit = undefined
state.systemPromptTokens = undefined
}
Expand Down
1 change: 0 additions & 1 deletion lib/state/types.ts
Original file line number Diff line number Diff line change
Expand Up @@ -106,7 +106,6 @@ export interface SessionState {
messageIds: MessageIdState
lastCompaction: number
currentTurn: number
variant: string | undefined
modelContextLimit: number | undefined
systemPromptTokens: number | undefined
}
4 changes: 2 additions & 2 deletions lib/token-utils.ts
Original file line number Diff line number Diff line change
Expand Up @@ -54,14 +54,14 @@ export function getCurrentParams(
providerId: undefined,
modelId: undefined,
agent: undefined,
variant: state.variant,
variant: undefined,
}
}
const userInfo = userMsg.info as UserMessage
const agent: string = userInfo.agent
const providerId: string | undefined = userInfo.model.providerID
const modelId: string | undefined = userInfo.model.modelID
const variant: string | undefined = state.variant ?? userInfo.variant
const variant: string | undefined = userInfo.model.variant

return { providerId, modelId, agent, variant }
}
Expand Down
Loading
Loading