remove defers

Signed-off-by: Robert Landers <landers.robert@gmail.com>

Author: withinboredom

cli/ext/ext.go

@@ -31,7 +31,11 @@ This is a php extension that operates as a client for durable php
 
 // export_php:namespace Bottledcode\DurablePhp\Ext
 
+// export_php:module shutdown
 func go_shutdown_module() {
+	if helpers.NatServer != nil {
+		helpers.NatServer.Shutdown()
+	}
 	os.RemoveAll(helpers.NatsState)
 }
 
@@ -56,7 +60,7 @@ func go_init_module() {
 			panic(err)
 		}
 
-		s := test.RunServer(&server.Options{
+		helpers.NatServer = test.RunServer(&server.Options{
 			Host:           "localhost",
 			Port:           4222,
 			NoLog:          true,
@@ -66,7 +70,6 @@ func go_init_module() {
 			StoreDir:       helpers.NatsState,
 			HTTPPort:       8222,
 		})
-		defer s.Shutdown()
 		boostrapNats = true
 	}
 
@@ -259,7 +262,7 @@ func go_init_module() {
 			if err != nil {
 				panic(err)
 			}
-			defer consume.Drain()
+			//defer consume.Drain()
 
 			orchestrationConsumer, err := billingStream.CreateOrUpdateConsumer(ctx, jetstream.ConsumerConfig{
 				Durable:       "orchestrationAggregator",
@@ -276,7 +279,7 @@ func go_init_module() {
 			if err != nil {
 				panic(err)
 			}
-			defer consume.Drain()
+			//defer consume.Drain()
 
 			activityConsumer, err := billingStream.CreateOrUpdateConsumer(ctx, jetstream.ConsumerConfig{
 				Durable:       "activityAggregator",
@@ -299,7 +302,7 @@ func go_init_module() {
 			if err != nil {
 				panic(err)
 			}
-			defer consume.Drain()
+			//defer consume.Drain()
 		}
 
 		err := lib.StartBillingProcessor(ctx, cfg, helpers.Js, logger)

cli/ext/helpers/helpers.go

@@ -14,6 +14,7 @@ import (
 	"github.com/bottledcode/durable-php/cli/config"
 	"github.com/bottledcode/durable-php/cli/glue"
 	"github.com/dunglas/frankenphp"
+	"github.com/nats-io/nats-server/v2/server"
 	"github.com/nats-io/nats.go/jetstream"
 	"go.uber.org/zap"
 	"go.uber.org/zap/zapcore"
@@ -41,6 +42,7 @@ var Logger *zap.Logger
 var NatsState string
 var Js jetstream.JetStream
 var Config *config.Config
+var NatServer *server.Server
 
 func ParseEvent(arr *frankenphp.Array) (ev *glue.EventMessage, err error) {
 	ev = &glue.EventMessage{}