fixed failing test

anthdm · Jan 11, 2024 · 4c07bc4 · 4c07bc4
1 parent 4b54786
commit 4c07bc4
Show file tree

Hide file tree

Showing 3 changed files with 20 additions and 4 deletions.
diff --git a/actor/engine_test.go b/actor/engine_test.go
@@ -38,7 +38,7 @@ func newTickReceiver(wg *sync.WaitGroup) Producer {
 }
 
 func TestSpawnWithContext(t *testing.T) {
-	e, _ := NewEngine(nil)
+	e, _ := NewEngine(NewEngineConfig())
 	type key struct {
 		key string
 	}

diff --git a/examples/cluster/member_1/main.go b/examples/cluster/member_1/main.go
@@ -1,6 +1,7 @@
 package main
 
 import (
+	"fmt"
 	"log"
 
 	"github.com/anthdm/hollywood/actor"
@@ -23,6 +24,8 @@ func main() {
 
 	eventPID := c.Engine().SpawnFunc(func(ctx *actor.Context) {
 		switch msg := ctx.Message().(type) {
+		case cluster.ActivationEvent:
+			fmt.Println("got activation event")
 		case cluster.MemberJoinEvent:
 			if msg.Member.ID == "B" {
 				config := cluster.NewActivationConfig().

diff --git a/examples/cluster/member_2/main.go b/examples/cluster/member_2/main.go
@@ -1,8 +1,11 @@
 package main
 
 import (
+	"fmt"
 	"log"
+	"reflect"
 
+	"github.com/anthdm/hollywood/actor"
 	"github.com/anthdm/hollywood/cluster"
 	"github.com/anthdm/hollywood/examples/cluster/shared"
 )
@@ -13,11 +16,21 @@ func main() {
 		WithID("B").
 		WithListenAddr("127.0.0.1:3001").
 		WithRegion("us-west")
-	cluster, err := cluster.New(config)
+	c, err := cluster.New(config)
 	if err != nil {
 		log.Fatal(err)
 	}
-	cluster.RegisterKind("playerSession", shared.NewPlayer, nil)
-	cluster.Start()
+	eventPID := c.Engine().SpawnFunc(func(ctx *actor.Context) {
+		switch msg := ctx.Message().(type) {
+		case *cluster.Activation:
+			fmt.Println("got activation event", msg)
+		default:
+			fmt.Println("got", reflect.TypeOf(msg))
+		}
+	}, "event")
+
+	c.Engine().Subscribe(eventPID)
+	c.RegisterKind("playerSession", shared.NewPlayer, nil)
+	c.Start()
 	select {}
 }