Allow matches to update their labels.

install/cloud/**/*.json

install/cloud/**/*.tfvars

*.pprof

### Go ###

# Compiled Object files, Static and Dynamic libs (Shared Objects)

*.o

- Authoritative match modules now allow a `match_join` callback that triggers when users have completed their join process.

- New stream API function to upsert a user presence.

- Extended validation of Google tokens to account for different token payloads.

- Authoritative match labels can now be updated using the dispatcher's `match_label_update` function.

### Changed

- Presence list in match join responses no longer contains the user's own presence. 

- Presence list in channel join responses no longer contains the user's own presence.

- Socket read/write buffer sizes are now set based on the `socket.max_message_size_bytes` config value.

- Console GRPC port now set relative to `console.port` config value.

## [2.0.1] - 2018-06-15

### Added

    -- a presence to tag on the message as the 'sender', or nil

  match_kick = function(presences)

    -- a list of presences to remove from the match

  match_label_update = function(label)

    -- a new label to set for the match

}

Tick is the current match tick number, starts at 0 and increments after every match_loop call. Does not increment with

    -- a presence to tag on the message as the 'sender', or nil

  match_kick = function(presences)

    -- a list of presences to remove from the match

  match_label_update = function(label)

    -- a new label to set for the match

}

Tick is the current match tick number, starts at 0 and increments after every match_loop call. Does not increment with

    -- a presence to tag on the message as the 'sender', or nil

  match_kick = function(presences)

    -- a list of presences to remove from the match

  match_label_update = function(label)

    -- a new label to set for the match

}

Tick is the current match tick number, starts at 0 and increments after every match_loop call. Does not increment with

    -- a presence to tag on the message as the 'sender', or nil

  match_kick = function(presences)

    -- a list of presences to remove from the match

  match_label_update = function(label)

    -- a new label to set for the match

}

Tick is the current match tick number, starts at 0 and increments after every match_loop call. Does not increment with

	}

	console.RegisterConsoleServer(grpcServer, s)

	startupLogger.Info("Starting Console server for gRPC requests", zap.Int("port", config.GetSocket().Port-2))

	startupLogger.Info("Starting Console server for gRPC requests", zap.Int("port", config.GetConsole().Port-3))

	go func() {

		listener, err := net.Listen("tcp", fmt.Sprintf("127.0.0.1:%d", config.GetSocket().Port-2))

		listener, err := net.Listen("tcp", fmt.Sprintf("127.0.0.1:%d", config.GetConsole().Port-3))

		if err != nil {

			startupLogger.Fatal("Console server listener failed to start", zap.Error(err))

		}

	ctx := context.Background()

	grpcGateway := runtime.NewServeMux()

	dialAddr := fmt.Sprintf("127.0.0.1:%d", config.GetSocket().Port-2)

	dialAddr := fmt.Sprintf("127.0.0.1:%d", config.GetConsole().Port-3)

	dialOpts := []grpc.DialOption{

		//TODO (mo, zyro): Do we need to pass the statsHandler here as well?

		grpc.WithDefaultCallOptions(grpc.MaxCallSendMsgSize(int(config.GetSocket().MaxMessageSizeBytes))),

	"github.com/pkg/errors"

	"github.com/satori/go.uuid"

	"github.com/yuin/gopher-lua"

	"go.uber.org/atomic"

	"go.uber.org/zap"

)

}

type MatchHandler struct {

	sync.Mutex

	logger        *zap.Logger

	matchRegistry MatchRegistry

	tracker       Tracker

	ticker  *time.Ticker

	callCh  chan func(*MatchHandler)

	stopCh  chan struct{}

	stopped bool

	stopped *atomic.Bool

	// Immutable configuration set by match init.

	Label string

	// Configuration set by match init.

	Label *atomic.String

	Rate  int

	// Match state.

		// Ticker below.

		callCh:  make(chan func(mh *MatchHandler), config.GetMatch().CallQueueSize),

		stopCh:  make(chan struct{}),

		stopped: false,

		stopped: atomic.NewBool(false),

		Label: labelStr,

		Label: atomic.NewString(labelStr),

		Rate:  rateInt,

		state: state,

	}

	// Set up the dispatcher that exposes control functions to the match loop.

	mh.dispatcher = vm.SetFuncs(vm.CreateTable(0, 2), map[string]lua.LGFunction{

	mh.dispatcher = vm.SetFuncs(vm.CreateTable(0, 3), map[string]lua.LGFunction{

		"broadcast_message":  mh.broadcastMessage,

		"match_kick":         mh.matchKick,

		"match_label_update": mh.matchLabelUpdate,

	})

	// Set up the ticker that governs the match loop.

// Used when the match is closed externally.

func (mh *MatchHandler) Close() {

	mh.Lock()

	if mh.stopped {

		mh.Unlock()

	if !mh.stopped.CAS(false, true) {

		return

	}

	mh.stopped = true

	mh.Unlock()

	close(mh.stopCh)

	mh.ticker.Stop()

}

}

func loop(mh *MatchHandler) {

	mh.Lock()

	if mh.stopped {

		mh.Unlock()

	if mh.stopped.Load() {

		return

	}

	mh.Unlock()

	// Drain the input queue into a Lua table.

	size := len(mh.inputCh)

func JoinAttempt(resultCh chan *MatchJoinResult, userID, sessionID uuid.UUID, username, node string) func(mh *MatchHandler) {

	return func(mh *MatchHandler) {

		mh.Lock()

		if mh.stopped {

			mh.Unlock()

		if mh.stopped.Load() {

			resultCh <- &MatchJoinResult{Allow: false}

			return

		}

		mh.Unlock()

		presence := mh.vm.CreateTable(0, 4)

		presence.RawSetString("user_id", lua.LString(userID.String()))

		mh.vm.Pop(1)

		mh.state = state

		resultCh <- &MatchJoinResult{Allow: allow, Reason: reason, Label: mh.Label}

		resultCh <- &MatchJoinResult{Allow: allow, Reason: reason, Label: mh.Label.Load()}

	}

}

			return

		}

		mh.Lock()

		if mh.stopped {

			mh.Unlock()

		if mh.stopped.Load() {

			return

		}

		mh.Unlock()

		presences := mh.vm.CreateTable(len(joins), 0)

		for i, p := range joins {

func Leave(leaves []*MatchPresence) func(mh *MatchHandler) {

	return func(mh *MatchHandler) {

		mh.Lock()

		if mh.stopped {

			mh.Unlock()

		if mh.stopped.Load() {

			return

		}

		mh.Unlock()

		presences := mh.vm.CreateTable(len(leaves), 0)

		for i, p := range leaves {

	mh.matchRegistry.Kick(mh.Stream, presences)

	return 0

}

func (mh *MatchHandler) matchLabelUpdate(l *lua.LState) int {

	input := l.OptString(1, "")

	mh.Label.Store(input)

	// This must be executed from inside a match call so safe to update here.

	mh.ctx.RawSetString(__CTX_MATCH_LABEL, lua.LString(input))

	return 0

}