Add match signal function.

## [Unreleased]

### Added

- Add final notification sent to sockets closed via single socket option.

- Add match signal function to server framework.

### Changed

- Match handlers are now required to implement a signal handler function.

## [3.7.0] - 2021-09-28

### Added

}

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

calls to match_join_attempt, match_join, or match_leave.

calls to match_join_attempt, match_join, match_leave, match_terminate, or match_signal.

State is the current in-memory match state, may be any Lua term except nil.

}

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

calls to match_join_attempt, match_join, or match_leave.

calls to match_join_attempt, match_join, match_leave, match_terminate, or match_signal.

State is the current in-memory match state, may be any Lua term except nil.

}

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

calls to match_join_attempt, match_join, or match_leave.

calls to match_join_attempt, match_join, match_leave, match_terminate, or match_signal.

State is the current in-memory match state, may be any Lua term except nil.

}

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

calls to match_join_attempt, match_join, or match_leave.

calls to match_join_attempt, match_join, match_leave, match_terminate, or match_signal.

State is the current in-memory match state, may be any Lua term except nil.

    print("match " .. context.match_id .. " tick " .. tick)

    print("match " .. context.match_id .. " messages:\n" .. du.print_r(messages))

  end

  if tick < 10 then

--   if tick < 10 then

    return state

  end

--   end

end

--[[

}

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

calls to match_join_attempt, match_join, or match_leave.

calls to match_join_attempt, match_join, match_leave, match_terminate, or match_signal.

State is the current in-memory match state, may be any Lua term except nil.

  return state

end

--[[

Called when the match handler receives a runtime signal.

Context represents information about the match and server, for information purposes. Format:

{

  env = {}, -- key-value data set in the runtime.env server configuration.

  executionMode = "Match",

  match_id = "client-friendly match ID, can be shared with clients and used in match join operations",

  match_node = "name of the Nakama node hosting this match",

  match_label = "the label string returned from match_init",

  match_tick_rate = 1 -- the tick rate returned by match_init

}

Dispatcher exposes useful functions to the match. Format:

{

  broadcast_message = function(op_code, data, presences, sender),

    -- numeric message op code

    -- a data payload string, or nil

    -- list of presences (a subset of match participants) to use as message targets, or nil to send to the whole match

    -- 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

calls to match_join_attempt, match_join, match_leave, match_terminate, or match_signal.

State is the current in-memory match state, may be any Lua term except nil.

Data is arbitrary input supplied by the runtime caller of the signal.

Expected return these values (all required) in order:

1. An (optionally) updated state. May be any non-nil Lua term, or nil to end the match.

1. Arbitrary data to return to the runtime caller of the signal. May be a string, or nil.

--]]

local function match_signal(context, dispatcher, tick, state, data)

  if state.debug then

    print("match " .. context.match_id .. " tick " .. tick)

    print("match " .. context.match_id .. " data " .. data)

  end

  return state, "signal received: " .. data

end

-- Match modules must return a table with these functions defined. All functions are required.

return {

  match_init = match_init,

  match_join = match_join,

  match_leave = match_leave,

  match_loop = match_loop,

  match_terminate = match_terminate

  match_terminate = match_terminate,

  match_signal = match_signal

}

	github.com/gorilla/mux v1.8.0

	github.com/gorilla/websocket v1.4.2

	github.com/grpc-ecosystem/grpc-gateway/v2 v2.3.0

	github.com/heroiclabs/nakama-common v1.18.0

	github.com/heroiclabs/nakama-common v0.0.0-20211005124542-143e8d8ce05e

	github.com/jackc/pgconn v1.8.1

	github.com/jackc/pgerrcode v0.0.0-20201024163028-a0d42d470451

	github.com/jackc/pgtype v1.7.0

github.com/hashicorp/mdns v1.0.0/go.mod h1:tL+uN++7HEJ6SQLQ2/p+z2pH24WQKWjBPkE0mNTz8vQ=

github.com/hashicorp/memberlist v0.1.3/go.mod h1:ajVTdAv/9Im8oMAAj5G31PhhMCZJV2pPBoIllUwCN7I=

github.com/hashicorp/serf v0.8.2/go.mod h1:6hOLApaqBFA1NXqRQAsxw9QxuDEvNxSQRwA/JwenrHc=

github.com/heroiclabs/nakama-common v0.0.0-20211005124542-143e8d8ce05e h1:U056PgGxvN0QSgdOR2JrUIkDLydUxh+EOiw5ilLdOg4=

github.com/heroiclabs/nakama-common v0.0.0-20211005124542-143e8d8ce05e/go.mod h1:jzIGV5bI45ALRQFzHPkJn4Z0tV+xhtho1+pZhOXVAsk=

github.com/heroiclabs/nakama-common v1.18.0 h1:afrtYzS9M73j5d02SX4h9ylFpgO0qKxLewgkc16l1jA=

github.com/heroiclabs/nakama-common v1.18.0/go.mod h1:jzIGV5bI45ALRQFzHPkJn4Z0tV+xhtho1+pZhOXVAsk=

github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=

import (

	"context"

	"database/sql"

	"flag"

	"fmt"

	"google.golang.org/protobuf/encoding/protojson"

	"io/ioutil"

	"math/rand"

	"net/http"

	"net/url"

	"os"

	"os/signal"

	"path/filepath"

	"runtime"

	"strings"

	"syscall"

	"time"

	"io/ioutil"

	"path/filepath"

	"github.com/gofrs/uuid"

	"github.com/heroiclabs/nakama/v3/ga"

	"github.com/heroiclabs/nakama/v3/migrate"

	_ "github.com/jackc/pgx/v4/stdlib"

	"go.uber.org/zap"

	"go.uber.org/zap/zapcore"

	"google.golang.org/protobuf/encoding/protojson"

)

const cookieFilename = ".cookie"

	}

	startupLogger.Info("Database connections", zap.Strings("dsns", redactedAddresses))

	db, dbVersion := dbConnect(startupLogger, config)

	db, dbVersion := server.DbConnect(startupLogger, config)

	startupLogger.Info("Database information", zap.String("version", dbVersion))

	// Global server context.

	os.Exit(0)

}

func dbConnect(multiLogger *zap.Logger, config server.Config) (*sql.DB, string) {

	rawURL := config.GetDatabase().Addresses[0]

	if !(strings.HasPrefix(rawURL, "postgresql://") || strings.HasPrefix(rawURL, "postgres://")) {

		rawURL = fmt.Sprintf("postgres://%s", rawURL)

	}

	parsedURL, err := url.Parse(rawURL)

	if err != nil {

		multiLogger.Fatal("Bad database connection URL", zap.Error(err))

	}

	query := parsedURL.Query()

	if len(query.Get("sslmode")) == 0 {

		query.Set("sslmode", "prefer")

		parsedURL.RawQuery = query.Encode()

	}

	if len(parsedURL.User.Username()) < 1 {

		parsedURL.User = url.User("root")

	}

	if len(parsedURL.Path) < 1 {

		parsedURL.Path = "/nakama"

	}

	multiLogger.Debug("Complete database connection URL", zap.String("raw_url", parsedURL.String()))

	db, err := sql.Open("pgx", parsedURL.String())

	if err != nil {

		multiLogger.Fatal("Error connecting to database", zap.Error(err))

	}

	// Limit the time allowed to ping database and get version to 15 seconds total.

	ctx, ctxCancelFn := context.WithTimeout(context.Background(), 15*time.Second)

	defer ctxCancelFn()

	if err = db.PingContext(ctx); err != nil {

		if strings.HasSuffix(err.Error(), "does not exist (SQLSTATE 3D000)") {

			multiLogger.Fatal("Database schema not found, run `nakama migrate up`", zap.Error(err))

		}

		multiLogger.Fatal("Error pinging database", zap.Error(err))

	}

	db.SetConnMaxLifetime(time.Millisecond * time.Duration(config.GetDatabase().ConnMaxLifetimeMs))

	db.SetMaxOpenConns(config.GetDatabase().MaxOpenConns)

	db.SetMaxIdleConns(config.GetDatabase().MaxIdleConns)

	var dbVersion string

	if err = db.QueryRowContext(ctx, "SELECT version()").Scan(&dbVersion); err != nil {

		multiLogger.Fatal("Error querying database version", zap.Error(err))

	}

	return db, dbVersion

}

// Help improve Nakama by sending anonymous usage statistics.

//

// You can disable the telemetry completely before server start by setting the