extend-event-handler-go

flowchart LR
   subgraph AccelByte Gaming Services
   KF[Kafka]
   KB[Kafka Connect]
   end
   subgraph Extend Event Handler App
   SV["gRPC Server"]   
   KB --- SV
   KF --- KB
   end

AccelByte Gaming Services (AGS) capabilities can be enhanced using Extend Event Handler apps. An Extend Event Handler app is a gRPC server that receives AGS events through Kafka Connect and performs actions based on custom logic.

Overview

This repository provides a project template for an Extend Event Handler app written in Go. It includes examples to handle AGS userLoggedIn and userThirdPartyLoggedIn events and grant an in-game item to the user. Additionally, it comes with built-in instrumentation for observability, ensuring that metrics, traces, and logs are available upon deployment.

You can clone this repository to begin developing your own Extend Event Handler app. Simply modify this project by including the AGS event spec files you need and implement custom logic to handle those events.

Project Structure

Here are some important folders you need to know to be able to start modifying this project.

...
├── pkg
│  ├── pb
│    └── accelbyte-asyncapi         # Code generated from AGS event spec files
│  ├── proto
│    └── accelbyte-asyncapi         # AGS event spec files (*.proto)
│  └── service
│    ├── loginHandler.go            # userLoggedIn event handler
│    └── thirdPartyLoginHandler.go  # userThirdPartyLoggedIn event handler
...

❗ In the example included in this project, we focus solely on the userLoggedIn and userThirdPartyLoggedIn events. Therefore, only the AGS event spec files for these two events are included. For other events, the AGS event spec files are available here.

Prerequisites

Windows 11 WSL2 or Linux Ubuntu 22.04 or macOS 14+ with the following tools installed:

a. Bash
- On Windows WSL2 or Linux Ubuntu:
```
bash --version

GNU bash, version 5.1.16(1)-release (x86_64-pc-linux-gnu)
...
```
- On macOS:
```
bash --version

GNU bash, version 3.2.57(1)-release (arm64-apple-darwin23)
...
```
b. Make
- On Windows WSL2 or Linux Ubuntu:
  
  To install from the Ubuntu repository, run sudo apt update && sudo apt install make.
```
make --version

GNU Make 4.3
...
```
- On macOS:
```
make --version

GNU Make 3.81
...
```
c. Docker (Docker Desktop 4.30+/Docker Engine v23.0+)
- On Linux Ubuntu:
  1. To install from the Ubuntu repository, run sudo apt update && sudo apt install docker.io docker-buildx docker-compose-v2.
  2. Add your user to the docker group: sudo usermod -aG docker $USER.
  3. Log out and log back in to allow the changes to take effect.
- On Windows or macOS:
  
  Follow Docker's documentation on installing the Docker Desktop on Windows or macOS.
```
docker version

...
Server: Docker Desktop
   Engine:
   Version:          24.0.5
...
```
d. Go v1.24
- Follow Go's installation guide.
```
go version

go version go1.24.0 ...
```
e. Postman
- Use binary available here
f. extend-helper-cli
- Use binary available here
❗ In macOS, you may use Homebrew to easily install some of the tools above.
Access to AccelByte Gaming Services environment.

a. Base URL:
- Sample URL for AGS Shared Cloud customers: https://spaceshooter.prod.gamingservices.accelbyte.io
- Sample URL for AGS Private Cloud customers: https://dev.accelbyte.io
b. Create a Game Namespace if you don't have one yet. Keep the Namespace ID.

c. Create an OAuth Client with confidential client type with the following permissions. Keep the Client ID and Client Secret.
- For AGS Private Cloud customers:
  - ADMIN:NAMESPACE:{namespace}:USER:*:FULFILLMENT [CREATE]
- For AGS Shared Cloud customers:
  - Platform Store -> Fulfillment (Create)
A published AGS Store. Take a note of the in-game item id which is to be granted after a user in a certain namespace successfully logged in.

Setup

To be able to run this app, you will need to follow these setup steps.

Create a docker compose .env file by copying the content of .env.template file.

⚠️ The host OS environment variables have higher precedence compared to .env file variables: If the variables in .env file do not seem to take effect properly, check if there are host OS environment variables with the same name. See documentation about docker compose environment variables precedence for more details.

Fill in the required environment variables in .env file as shown below.

AB_BASE_URL=https://demo.accelbyte.io      # Base URL of AccelByte Gaming Services demo environment
AB_CLIENT_ID='xxxxxxxxxx'                  # Use Client ID from the Prerequisites section
AB_CLIENT_SECRET='xxxxxxxxxx'              # Use Client Secret from the Prerequisites section
AB_NAMESPACE='xxxxxxxxxx'                  # Use Namespace ID from the Prerequisites section
ITEM_ID_TO_GRANT='xxxxxxxxxxx'             # In-game item id from a published store we noted previously

Building

To build this app, use the following command.

make build

Running

To (build and) run this app in a container, use the following command.

docker compose up --build

Testing

Test in Local Development Environment

This app can be tested locally using Postman.

Run this app by using the command below.
```
docker compose up --build
```
Open Postman, create a new gRPC request, and enter localhost:6565 as the URL.

⚠️ If you are running grpc-plugin-dependencies stack alongside this project as mentioned in Test Observability: Use localhost:10000 instead of localhost:6565. This way, the gRPC server will be called via Envoy service within grpc-plugin-dependencies stack instead of directly.
Since we are interested in userLoggedIn event, select UserAuthenticationUserLoggedInService/OnMessage method.

Send a userLoggedIn event to the gRPC server by copying and pasting the sample Kafka event JSON below, replace at least namespace and userId with valid values, and then click Invoke.

{
  "payload": {
     "user_account": {
        "user_id": "string",
        "email_address": "string",
        "country": "string",
        "namespace": "string"
     },
     "user_authentication": {
        "platform_id": "string",
        "refresh": true
     }
  },
  "id": "string",
  "version": 0,
  "name": "string",
  "namespace": "string",
  "parent_namespace": "string",
  "timestamp": "2019-08-24T14:15:22Z",
  "client_id": "string",
  "user_id": "string",
  "trace_id": "string",
  "session_id": "string"
}

If successful, the response will appear as shown below, and you will also be able to see the in-game item granted to the user you are using for this test.

To do the same with userThirdPartyLoggedIn event, select UserAuthenticationUserThirdPartyLoggedInService/OnMessage and use the sample Kafka event JSON below. Valid values for at least namespace and userId are also required.

{
   "payload": {
      "userAccount": {
         "userId": "string",
         "emailAddress": "string",
         "userName": "string",
         "country": "string",
         "namespace": "string",
         "platformId": "string",
         "displayName": "string"
      },
      "userAuthentication": {
         "platformId": "string",
         "refresh": true,
         "platformUserId": "string",
         "simultaneousPlatformId": "string",
         "simultaneousPlatformUserId": "string"
      },
      "loginLocation": {
         "country": "string",
         "state": "string",
         "city": "string"
      }
   },
   "id": "string",
   "version": 0,
   "name": "string",
   "namespace": "string",
   "parentNamespace": "string",
   "timestamp": "2019-08-24T14:15:22Z",
   "clientId": "string",
   "userId": "string",
   "traceId": "string",
   "sessionId": "string"
}

❗ For other AGS events: You can find the information and the corresponding sample Kafka event JSON here.

Test Observability

To be able to see the how the observability works in this app locally, there are few things that need be setup before performing tests.

Uncomment loki logging driver in docker-compose.yaml
```
 # logging:
 #   driver: loki
 #   options:
 #     loki-url: http://host.docker.internal:3100/loki/api/v1/push
 #     mode: non-blocking
 #     max-buffer-size: 4m
 #     loki-retries: "3"
```
⚠️ Make sure to install docker loki plugin beforehand: Otherwise, this project will not be able to run. This is required so that container logs can flow to the loki service within grpc-plugin-dependencies stack. Use this command to install docker loki plugin: docker plugin install grafana/loki-docker-driver:latest --alias loki --grant-all-permissions.
Clone and run grpc-plugin-dependencies stack alongside this project. After this, Grafana will be accessible at http://localhost:3000.
```
git clone https://github.com/AccelByte/grpc-plugin-dependencies.git
cd grpc-plugin-dependencies
docker compose up
```
❗ More information about grpc-plugin-dependencies is available here.
Perform testing. For example, by following Test in Local Development Environment.

Deploying

After completing testing, the next step is to deploy your app to AccelByte Gaming Services.

Create an Extend Event Handler app

If you do not already have one, create a new Extend Event Handler App.

On the App Detail page, take note of the following values.
- Namespace
- App Name
Under the Environment Configuration section, set the required secrets and/or variables.
- Secrets
  - AB_CLIENT_ID
  - AB_CLIENT_SECRET
- Variables
  - ITEM_ID_TO_GRANT
Build and Push the Container Image

Use extend-helper-cli to build and upload the container image.
```
extend-helper-cli image-upload --login --namespace <namespace> --app <app-name> --image-tag v0.0.1
```
⚠️ Run this command from your project directory. If you are in a different directory, add the --work-dir <project-dir> option to specify the correct path.
Deploy the Image

On the App Detail page:
- Click Image Version History
- Select the image you just pushed
- Click Deploy Image

Next Step

Proceed by modifying this Extend Event Handler app template to implement your own custom logic. For more details, see here.

Name		Name	Last commit message	Last commit date
Latest commit History 136 Commits
.cursor		.cursor
.devcontainer		.devcontainer
.vscode		.vscode
demo		demo
docs		docs
pkg		pkg
.dockerignore		.dockerignore
.env.template		.env.template
.gitignore		.gitignore
.golangci.yml		.golangci.yml
Dockerfile		Dockerfile
LICENSE.txt		LICENSE.txt
Makefile		Makefile
README.md		README.md
docker-compose.yaml		docker-compose.yaml
go.mod		go.mod
go.sum		go.sum
main.go		main.go
proto.sh		proto.sh
renovate.json		renovate.json

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Repository files navigation

extend-event-handler-go

Overview

Project Structure

Prerequisites

Setup

Building

Running

Testing

Test in Local Development Environment

Test Observability

Deploying

Next Step

About

Uh oh!

Uh oh!

Contributors

Uh oh!

Languages

Folders and files

Latest commit

History

Repository files navigation

extend-event-handler-go

Overview

Project Structure

Prerequisites

Setup

Building

Running

Testing

Test in Local Development Environment

Test Observability

Deploying

Next Step

About

Resources

License

Uh oh!

Stars

Watchers

Forks

Uh oh!

Contributors

Uh oh!

Languages