addHistoryWithBudget(request, history, getHistoryMaxChars());
        request.addUserMessage(wrapUserInput(userMessage));
        applyPromptTypeParams(request, "docnotfound");
        request.setStream(true);

        streamChatWithConcurrencyControl(request, callback);
    }

    @Override

	lockMap map[string]int64

	// Refresh returns lock not found if set to true
	lockNotFound bool

	// Set to true if you want peers servers to do not respond
	responseDelay int64
}

func (l *lockServer) setRefreshReply(refreshed bool) {
	l.mutex.Lock()
	defer l.mutex.Unlock()
	l.lockNotFound = !refreshed
}

func (l *lockServer) setResponseDelay(responseDelay time.Duration) {

	// c) timed out
	//
	lockNotFound, lockRefreshed := 0, 0
	done := false

	for range len(restClnts) {
		select {
		case refreshResult := <-ch:
			if refreshResult.offline {
				continue
			}
			if refreshResult.refreshed {
				lockRefreshed++
			} else {
				lockNotFound++
			}
			if lockRefreshed >= quorum || lockNotFound > len(restClnts)-quorum {
				done = true
			}