Method latestWorkspaceAgentNeedsRestart

coderd/x/chatd/chatd.go:997–1021

(
	ctx context.Context,
	workspaceID uuid.UUID,
)

}

func (c *turnWorkspaceContext) latestWorkspaceAgentNeedsRestart(
	ctx context.Context,
	workspaceID uuid.UUID,
) (bool, error) {
	agentID, err := c.latestWorkspaceAgentID(ctx, workspaceID)
	if err != nil {
		if xerrors.Is(err, errChatHasNoWorkspaceAgent) {
			return false, err
		}
		c.server.logger.Warn(ctx, "failed to resolve latest agent for timeout classification", slog.Error(err))
		return false, nil
	}

	agent, err := c.server.db.GetWorkspaceAgentByID(ctx, agentID)
	if err != nil {
		c.server.logger.Warn(ctx, "failed to load latest agent for timeout classification",
			slog.F("agent_id", agentID),
			slog.Error(err),
		)
		return false, nil
	}

	disconnectedFor, disconnected := agentDisconnectedFor(c.server.clock.Now(), agent, c.server.agentInactiveDisconnectTimeout)
	return disconnected && disconnectedFor >= agentDisconnectedRecoveryThreshold, nil
}

func (c *turnWorkspaceContext) externalAgentError(
	ctx context.Context,