Update runtime Nakama module signatures. (ada0c44e) · Commits · public-projects / Nakama

runtime/runtime.go

+47 −48

Original line number	Diff line number	Diff line
		@@ -283,24 +283,23 @@ type StorageDelete struct {
		}

		type NakamaModule interface {
		AuthenticateCustom(id, username string, create bool) (string, string, bool, error)
		AuthenticateDevice(id, username string, create bool) (string, string, bool, error)
		AuthenticateEmail(email, password, username string, create bool) (string, string, bool, error)
		AuthenticateFacebook(token string, importFriends bool, username string, create bool) (string, string, bool, error)
		AuthenticateGameCenter(playerID, bundleID string, timestamp int64, salt, signature, publicKeyUrl, username string, create bool) (string, string, bool, error)
		AuthenticateGoogle(token, username string, create bool) (string, string, bool, error)
		AuthenticateSteam(token, username string, create bool) (string, string, bool, error)
		AuthenticateCustom(ctx context.Context, id, username string, create bool) (string, string, bool, error)
		AuthenticateDevice(ctx context.Context, id, username string, create bool) (string, string, bool, error)
		AuthenticateEmail(ctx context.Context, email, password, username string, create bool) (string, string, bool, error)
		AuthenticateFacebook(ctx context.Context, token string, importFriends bool, username string, create bool) (string, string, bool, error)
		AuthenticateGameCenter(ctx context.Context, playerID, bundleID string, timestamp int64, salt, signature, publicKeyUrl, username string, create bool) (string, string, bool, error)
		AuthenticateGoogle(ctx context.Context, token, username string, create bool) (string, string, bool, error)
		AuthenticateSteam(ctx context.Context, token, username string, create bool) (string, string, bool, error)

		AuthenticateTokenGenerate(userID, username string, exp int64) (string, int64, error)

		AccountGetId(userID string) (*api.Account, error)
		// TODO nullable fields?
		AccountUpdateId(userID, username string, metadata map[string]interface{}, displayName, timezone, location, langTag, avatarUrl string) error
		AccountGetId(ctx context.Context, userID string) (*api.Account, error)
		AccountUpdateId(ctx context.Context, userID, username string, metadata map[string]interface{}, displayName, timezone, location, langTag, avatarUrl string) error

		UsersGetId(userIDs []string) ([]*api.User, error)
		UsersGetUsername(usernames []string) ([]*api.User, error)
		UsersBanId(userIDs []string) error
		UsersUnbanId(userIDs []string) error
		UsersGetId(ctx context.Context, userIDs []string) ([]*api.User, error)
		UsersGetUsername(ctx context.Context, usernames []string) ([]*api.User, error)
		UsersBanId(ctx context.Context, userIDs []string) error
		UsersUnbanId(ctx context.Context, userIDs []string) error

		StreamUserList(mode uint8, subject, descriptor, label string, includeHidden, includeNotHidden bool) ([]Presence, error)
		StreamUserGet(mode uint8, subject, descriptor, label, userID, sessionID string) (PresenceMeta, error)
		@@ -312,38 +311,38 @@ type NakamaModule interface {
		StreamSend(mode uint8, subject, descriptor, label, data string) error

		MatchCreate(module string, params map[string]interface{}) (string, error)
		MatchList(limit int, authoritative bool, label string, minSize, maxSize int) []*api.Match

		NotificationSend(userID, subject string, content map[string]interface{}, code int, sender string, persistent bool) error
		NotificationsSend(notifications []*NotificationSend) error

		WalletUpdate(userID string, changeset, metadata map[string]interface{}) error
		WalletsUpdate(updates []*WalletUpdate) error
		WalletLedgerUpdate(itemID string, metadata map[string]interface{}) (WalletLedgerItem, error)
		WalletLedgerList(userID string) ([]WalletLedgerItem, error)

		StorageList(userID, collection string, limit int, cursor string) ([]*api.StorageObject, string, error)
		StorageRead(reads []StorageRead) ([]api.StorageObject, error)
		StorageWrite(writes []StorageWrite) ([]api.StorageObjectAck, error)
		StorageDelete(deletes []*StorageDelete) error

		LeaderboardCreate(id string, authoritative bool, sortOrder, operator, resetSchedule string, metadata map[string]interface{}) error
		LeaderboardDelete(id string) error
		LeaderboardRecordsList(id string, ownerIDs []string, limit int, cursor string, expiry int64) ([]api.LeaderboardRecord, []api.LeaderboardRecord, string, string, error)
		LeaderboardRecordWrite(id, ownerID, username string, score, subscore int64, metadata map[string]interface{}) (*api.LeaderboardRecord, error)
		LeaderboardRecordDelete(id, ownerID string) error

		TournamentCreate(id string, sortOrder, operator, resetSchedule string, metadata map[string]interface{}, title, description string, category, startTime, endTime, duration, maxSize, maxNumScore int, joinRequired bool) error
		TournamentDelete(id string) error
		TournamentAddAttempt(id, ownerID string, count int) error
		TournamentJoin(id, ownerID, username string) error
		TournamentList(categoryStart, categoryEnd, startTime, endTime, limit int, cursor string) (*api.TournamentList, error)
		TournamentRecordWrite(id, ownerID, username string, score, subscore int64, metadata map[string]interface{}) (*api.LeaderboardRecord, error)
		TournamentRecordsHaystack(id, ownerID string, limit int) ([]*api.LeaderboardRecord, error)

		GroupCreate(userID, name, creatorID, langTag, description, avatarUrl string, open bool, metadata map[string]interface{}, maxCount int) (*api.Group, error)
		GroupUpdate(id, name, creatorID, langTag, description, avatarUrl string, open bool, metadata map[string]interface{}, maxCount int) error
		GroupDelete(id string) error
		GroupUsersList(id string) ([]*api.GroupUserList_GroupUser, error)
		UserGroupsList(userID string) ([]*api.UserGroupList_UserGroup, error)
		MatchList(ctx context.Context, limit int, authoritative bool, label string, minSize, maxSize int) []*api.Match

		NotificationSend(ctx context.Context, userID, subject string, content map[string]interface{}, code int, sender string, persistent bool) error
		NotificationsSend(ctx context.Context, notifications []*NotificationSend) error

		WalletUpdate(ctx context.Context, userID string, changeset, metadata map[string]interface{}) error
		WalletsUpdate(ctx context.Context, updates []*WalletUpdate) error
		WalletLedgerUpdate(ctx context.Context, itemID string, metadata map[string]interface{}) (WalletLedgerItem, error)
		WalletLedgerList(ctx context.Context, userID string) ([]WalletLedgerItem, error)

		StorageList(ctx context.Context, userID, collection string, limit int, cursor string) ([]*api.StorageObject, string, error)
		StorageRead(ctx context.Context, reads []StorageRead) ([]api.StorageObject, error)
		StorageWrite(ctx context.Context, writes []StorageWrite) ([]api.StorageObjectAck, error)
		StorageDelete(ctx context.Context, deletes []*StorageDelete) error

		LeaderboardCreate(ctx context.Context, id string, authoritative bool, sortOrder, operator, resetSchedule string, metadata map[string]interface{}) error
		LeaderboardDelete(ctx context.Context, id string) error
		LeaderboardRecordsList(ctx context.Context, id string, ownerIDs []string, limit int, cursor string, expiry int64) ([]api.LeaderboardRecord, []api.LeaderboardRecord, string, string, error)
		LeaderboardRecordWrite(ctx context.Context, id, ownerID, username string, score, subscore int64, metadata map[string]interface{}) (*api.LeaderboardRecord, error)
		LeaderboardRecordDelete(ctx context.Context, id, ownerID string) error

		TournamentCreate(ctx context.Context, id string, sortOrder, operator, resetSchedule string, metadata map[string]interface{}, title, description string, category, startTime, endTime, duration, maxSize, maxNumScore int, joinRequired bool) error
		TournamentDelete(ctx context.Context, id string) error
		TournamentAddAttempt(ctx context.Context, id, ownerID string, count int) error
		TournamentJoin(ctx context.Context, id, ownerID, username string) error
		TournamentList(ctx context.Context, categoryStart, categoryEnd, startTime, endTime, limit int, cursor string) (*api.TournamentList, error)
		TournamentRecordWrite(ctx context.Context, id, ownerID, username string, score, subscore int64, metadata map[string]interface{}) (*api.LeaderboardRecord, error)
		TournamentRecordsHaystack(ctx context.Context, id, ownerID string, limit int) ([]*api.LeaderboardRecord, error)

		GroupCreate(ctx context.Context, userID, name, creatorID, langTag, description, avatarUrl string, open bool, metadata map[string]interface{}, maxCount int) (*api.Group, error)
		GroupUpdate(ctx context.Context, id, name, creatorID, langTag, description, avatarUrl string, open bool, metadata map[string]interface{}, maxCount int) error
		GroupDelete(ctx context.Context, id string) error
		GroupUsersList(ctx context.Context, id string) ([]*api.GroupUserList_GroupUser, error)
		UserGroupsList(ctx context.Context, userID string) ([]*api.UserGroupList_UserGroup, error)
		}

sample_go_module/sample.go

+23 −7

Original line number	Diff line number	Diff line
		@@ -17,22 +17,33 @@ package main
		import (
		"context"
		"database/sql"
		"github.com/heroiclabs/nakama/api"
		"github.com/heroiclabs/nakama/rtapi"
		"github.com/heroiclabs/nakama/runtime"
		"log"
		)

		func InitModule(ctx context.Context, logger log.Logger, db sql.DB, nk runtime.NakamaModule, initializer runtime.Initializer) {
		initializer.RegisterRpc("go_echo_sample", rpcEcho)
		initializer.RegisterBeforeRt("ChannelJoin", beforeChannelJoin)
		initializer.RegisterMatch("match", func(ctx context.Context, logger log.Logger, db sql.DB, nk runtime.NakamaModule) (runtime.Match, error) {
		func InitModule(ctx context.Context, logger log.Logger, db sql.DB, nk runtime.NakamaModule, initializer runtime.Initializer) error {
		if err := initializer.RegisterRpc("go_echo_sample", rpcEcho); err != nil {
		return err
		}
		if err := initializer.RegisterBeforeRt("ChannelJoin", beforeChannelJoin); err != nil {
		return err
		}
		if err := initializer.RegisterAfterGetAccount(afterGetAccount); err != nil {
		return err
		}
		if err := initializer.RegisterMatch("match", func(ctx context.Context, logger log.Logger, db sql.DB, nk runtime.NakamaModule) (runtime.Match, error) {
		return &Match{}, nil
		})
		}); err != nil {
		return err
		}
		return nil
		}

		func rpcEcho(ctx context.Context, logger log.Logger, db sql.DB, nk runtime.NakamaModule, payload string) (string, error, int) {
		func rpcEcho(ctx context.Context, logger log.Logger, db sql.DB, nk runtime.NakamaModule, payload string) (string, error) {
		logger.Print("RUNNING IN GO")
		return payload, nil, 0
		return payload, nil
		}

		func beforeChannelJoin(ctx context.Context, logger log.Logger, db sql.DB, nk runtime.NakamaModule, envelope rtapi.Envelope) (rtapi.Envelope, error) {
		@@ -40,6 +51,11 @@ func beforeChannelJoin(ctx context.Context, logger log.Logger, db sql.DB, nk r
		return envelope, nil
		}

		func afterGetAccount(ctx context.Context, logger log.Logger, db sql.DB, nk runtime.NakamaModule, in *api.Account) error {
		logger.Printf("Intercepted response to get account '%v'", in)
		return nil
		}

		type MatchState struct {
		debug bool
		}

server/console.go

+3 −2

Original line number	Diff line number	Diff line
		@@ -87,8 +87,9 @@ func StartConsoleServer(logger zap.Logger, startupLogger zap.Logger, config Co

		grpcGatewayRouter := mux.NewRouter()

		grpcGatewayRouter.Handle("/", console.Handler()).Methods("GET")
		grpcGatewayRouter.PathPrefix("/assets/").Handler(console.Handler()).Methods("GET")
		grpcGatewayRouter.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) { w.WriteHeader(200) }).Methods("GET")
		// grpcGatewayRouter.Handle("/", console.Handler()).Methods("GET")
		// grpcGatewayRouter.PathPrefix("/assets/").Handler(console.Handler()).Methods("GET")

		grpcGatewayRouter.HandleFunc("/rpcz", func(w http.ResponseWriter, r *http.Request) {
		zpages.Handler.ServeHTTP(w, r)

server/runtime_go_nakama.go

+42 −41

File changed.

Preview size limit exceeded, changes collapsed.