Method HandleInputEvents

world.go:78–183

(e events.Event)

}

func (w *World) HandleInputEvents(e events.Event) events.ListenerReturn {

	input, typeOk := e.(events.Input)
	if !typeOk {
		mudlog.Error("Event", "Expected Type", "Input", "Actual Type", e.Type())
		return events.Continue
	}

	var turnCt uint64 = util.GetTurnCount()

	//mudlog.Debug(`Event`, `type`, input.Type(), `UserId`, input.UserId, `MobInstanceId`, input.MobInstanceId, `WaitTurns`, input.WaitTurns, `InputText`, input.InputText)

	// If it's a mob
	if input.MobInstanceId > 0 {

		// If an event was already processed for this user this turn, skip
		// We put this first, so that any delayed command for a mob will block
		// the command pipeline for the mob until executed.
		if _, ok := w.mobInputEventTracker[input.MobInstanceId]; ok {
			return events.CancelAndRequeue
		}

		// 0 and below, process immediately and don't count towards limit
		if input.ReadyTurn <= 0 {
			w.processMobInput(input.MobInstanceId, input.InputText)
			return events.Continue
		}

		// This will cause any pending command to block all further pending commands
		// This is important, otherwise we issue a command with a delay, but other commands
		// Get executed while we wait.
		w.mobInputEventTracker[input.MobInstanceId] = struct{}{}

		if input.ReadyTurn > turnCt {
			return events.CancelAndRequeue
		}

		w.processMobInput(input.MobInstanceId, input.InputText)

		return events.Continue
	}

	// 0 and below, process immediately and don't count towards limit
	if input.ReadyTurn <= 0 {

		// If this command was potentially blocking input, unblock it now.
		if input.Flags.Has(events.CmdUnBlockInput) {

			if _, ok := w.ignoreInput[input.UserId]; ok {
				delete(w.ignoreInput, input.UserId)
				if user := users.GetByUserId(input.UserId); user != nil {
					user.UnblockInput()
				}
			}

		}

		w.processInput(input.UserId, input.InputText, input.Flags)