feat: update Local function to accept any type for key parameter

container/container.go

@@ -75,3 +75,18 @@ func (p Providers) Provide(config *viper.Viper) error {
 	}
 	return nil
 }
+
+// laters for run later funcs
+var later []func() error
+
+func Later(f func() error) {
+	later = append(later, f)
+}
+
+func RunLaterFuncs() {
+	for _, f := range later {
+		if err := f(); err != nil {
+			log.Fatal(err)
+		}
+	}
+}

contracts/cron_job.go

@@ -1,15 +1,23 @@
 package contracts
 
 import (
-	"time"
-
 	"github.com/riverqueue/river"
 )
 
 type CronJob interface {
-	Description() string
-	Periodic() time.Duration
-	JobArgs() []river.JobArgs
-	InsertOpts() *river.InsertOpts
-	RunOnStart() bool
+	Args() []CronJobArg
+}
+
+type JobArgs interface {
+	river.JobArgs
+	river.JobArgsWithInsertOpts
+
+	UniqueID() string
+}
+
+type CronJobArg struct {
+	RunOnStart       bool
+	PeriodicInterval river.PeriodicSchedule
+
+	Arg JobArgs
 }

contracts/events.go

@@ -4,6 +4,15 @@ import "github.com/ThreeDotsLabs/watermill/message"
 
 type EventHandler interface {
 	Topic() string
-	PublishToTopic() string
+	Channel() Channel
+	PublishTo() (Channel, string)
 	Handler(msg *message.Message) ([]*message.Message, error)
 }
+
+type Channel string
+
+type EventPublisher interface {
+	Topic() string
+	Channel() Channel
+	Marshal() ([]byte, error)
+}

fen/bind.go

@@ -14,7 +14,7 @@ func File[T any](key string) func(fiber.Ctx) (*multipart.FileHeader, error) {
 	}
 }
 
-func Local[T any](key string) func(fiber.Ctx) (T, error) {
+func Local[T any](key any) func(fiber.Ctx) (T, error) {
 	return func(ctx fiber.Ctx) (T, error) {
 		v := fiber.Locals[T](ctx, key)
 		return v, nil