allow custom cleanups

.gitignore

@@ -1 +1,2 @@
 .vscode
+.idea

README.md

@@ -3,7 +3,8 @@
 ## How To
 
 In this Example i use the generic-di package to Inject a Service into a Event.
-first you have to create some Event Handler:
+First you have to create some Event Handler and/or Effects that was fired when a Event happens.
+Then you give the Effects and the EventHandlers to a Registration to serve it.
 
 services/external_service.go
 
@@ -104,3 +105,51 @@ func (event *UserLoginEvent) Handle(ctx *serverevents.Context) {
   })
 }
 ```
+
+effects/login_success_effect.go
+
+```go
+package effects
+
+type LoginSuccessEffect struct {}
+
+func NewLoginSuccessEffect() *LoginSuccessEffect {
+  return &LoginSuccessEffect{}
+}
+
+// implement a Method that gives the Name of the Event to listen
+func (effect *LoginSuccessEffect) OnEvent() string {
+  return "login success"
+}
+
+// implement a Method to Handle the Effect triggered
+func (effect *LoginSuccessEffect) Execute(ctx *serverevents.Context) {
+  // do something on login success here...
+}
+```
+
+main.go
+
+```go
+package main
+
+import (
+  serverevents "git.apihub24.de/admin/server_events"
+)
+
+func main() {
+  port := ":8080"
+
+  serverevents.RegisterEvents([]serverevents.EventHandler{
+		events.NewLoginEvent(),
+	}, []serverevents.Effect{
+		effects.NewLoginSuccessEffect(),
+	}, nil)
+
+  log.Default().Printf("Start Server at Port %s", port)
+	err := http.ListenAndServe(port, nil)
+	if err != nil {
+		log.Fatalf("Error on start Server: %v", err)
+	}
+}
+```

v2/context.go

@@ -0,0 +1,131 @@
+package serverevents
+
+import (
+	gocontext "context"
+	"sync"
+	"time"
+
+	di "git.apihub24.de/admin/generic-di"
+	"github.com/coder/websocket"
+)
+
+func init() {
+	di.Injectable(newContext)
+}
+
+type IContext interface {
+	SetId(id string)
+	GetId() string
+	SetConnection(conn *websocket.Conn)
+	GetConnection() *websocket.Conn
+	Set(key string, data any)
+	Get(key string) (any, bool)
+	RemoveMetaData(key string)
+	CleanupIn(lifetime time.Duration, onCleanup ...func())
+	Dispatch(event IEvent, filter func(c IContext) bool)
+	IsCaller(c IContext) bool
+}
+
+type context struct {
+	id       string
+	metadata map[string]any
+	timer    *time.Timer
+	hub      IEventHub
+	mutex    sync.RWMutex
+	c        *websocket.Conn
+	ctx      gocontext.Context
+}
+
+func newContext() IContext {
+	return &context{
+		id:       "",
+		metadata: make(map[string]any),
+		timer:    nil,
+		hub:      di.Inject[IEventHub](),
+		mutex:    sync.RWMutex{},
+		c:        nil,
+	}
+}
+
+func (context *context) SetId(id string) {
+	context.mutex.Lock()
+	defer context.mutex.Unlock()
+
+	if context.timer != nil {
+		context.timer.Stop()
+		context.timer = nil
+	}
+	context.id = id
+}
+
+func (context *context) GetId() string {
+	return context.id
+}
+
+func (context *context) IsCaller(c IContext) bool {
+	return context.id == c.GetId()
+}
+
+func (context *context) Set(key string, data any) {
+	context.mutex.Lock()
+	defer context.mutex.Unlock()
+
+	context.metadata[key] = data
+}
+
+func (context *context) Get(key string) (any, bool) {
+	context.mutex.RLock()
+	defer context.mutex.RUnlock()
+
+	v, ok := context.metadata[key]
+	return v, ok
+}
+
+func (context *context) RemoveMetaData(key string) {
+	context.mutex.Lock()
+	defer context.mutex.Unlock()
+
+	delete(context.metadata, key)
+}
+
+func (context *context) CleanupIn(lifetime time.Duration, onCleanup ...func()) {
+	context.mutex.Lock()
+	defer context.mutex.Unlock()
+
+	if context.timer != nil {
+		context.timer.Stop()
+	}
+	context.timer = time.NewTimer(lifetime)
+	go func(currentId string) {
+		<-context.timer.C
+
+		context.mutex.Lock()
+		defer context.mutex.Unlock()
+
+		if context.timer != nil {
+			di.Destroy[IContext](context.id)
+			for _, cleaner := range onCleanup {
+				cleaner()
+			}
+			context.timer = nil
+		}
+	}(context.id)
+}
+
+func (context *context) Dispatch(event IEvent, filter func(c IContext) bool) {
+	ev := Event{
+		Type:          event.GetEventName(),
+		Data:          event.GetEventData(),
+		IsBackendOnly: filter == nil,
+		Filter:        filter,
+	}
+	context.hub.Dispatch(ev, context)
+}
+
+func (context *context) GetConnection() *websocket.Conn {
+	return context.c
+}
+
+func (context *context) SetConnection(conn *websocket.Conn) {
+	context.c = conn
+}

v2/context_helper.go

@@ -0,0 +1,29 @@
+package serverevents
+
+import "encoding/json"
+
+func CreateMetaDataFilter[T any](c IContext, metaDataSelector func(IContext) T, vgl func(a T, b T) bool) func(context IContext) bool {
+	return func(context IContext) bool {
+		metaA := metaDataSelector(c)
+		metaB := metaDataSelector(context)
+		return vgl(metaA, metaB)
+	}
+}
+
+func MetadataAs[T any](context IContext, key string) (T, bool) {
+	tmp, _ := context.Get(key)
+	return ValueAs[T](tmp)
+}
+
+func ValueAs[T any](data any) (T, bool) {
+	var v T
+	str, err := json.Marshal(data)
+	if err != nil {
+		return v, false
+	}
+	err = json.Unmarshal(str, &v)
+	if err != nil {
+		return v, false
+	}
+	return v, true
+}

v2/event.go

@@ -0,0 +1,13 @@
+package serverevents
+
+type Event struct {
+	Type          string                `json:"type"`
+	Data          any                   `json:"data"`
+	IsBackendOnly bool                  `json:"-"`
+	Filter        func(c IContext) bool `json:"-"`
+}
+
+type IEvent interface {
+	GetEventName() string
+	GetEventData() any
+}

v2/go.mod

@@ -0,0 +1,13 @@
+module git.apihub24.de/admin/server_events/v2
+
+go 1.23.0
+
+toolchain go1.24.4
+
+require (
+	git.apihub24.de/admin/generic-di v1.4.0
+)
+
+require (
+	github.com/coder/websocket v1.8.13 // indirect
+)

v2/go.sum

@@ -0,0 +1,108 @@
+git.apihub24.de/admin/generic-di v1.4.0 h1:0mQnpAcavMLBcnF5UO+tUI7abZ6zQPleqPsjEk3WIaU=
+git.apihub24.de/admin/generic-di v1.4.0/go.mod h1:VcHV8MOb1qhwabHdO09CpjEg2VaDesehul86g1iyOxY=
+github.com/cenkalti/backoff/v4 v4.3.0 h1:MyRJ/UdXutAwSAT+s3wNd7MfTIcy71VQueUuFK343L8=
+github.com/cenkalti/backoff/v4 v4.3.0/go.mod h1:Y3VNntkOUPxTVeUxJ/G5vcM//AlwfmyYozVcomhLiZE=
+github.com/coder/websocket v1.8.13 h1:f3QZdXy7uGVz+4uCJy2nTZyM0yTBj8yANEHhqlXZ9FE=
+github.com/coder/websocket v1.8.13/go.mod h1:LNVeNrXQZfe5qhS9ALED3uA+l5pPqvwXg3CKoDBB2gs=
+github.com/dave/jennifer v1.7.0 h1:uRbSBH9UTS64yXbh4FrMHfgfY762RD+C7bUPKODpSJE=
+github.com/dave/jennifer v1.7.0/go.mod h1:nXbxhEmQfOZhWml3D1cDK5M1FLnMSozpbFN/m3RmGZc=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/francoispqt/gojay v1.2.13 h1:d2m3sFjloqoIUQU3TsHBgj6qg/BVGlTBeHDUmyJnXKk=
+github.com/francoispqt/gojay v1.2.13/go.mod h1:ehT5mTG4ua4581f1++1WLG0vPdaA9HaiDsoyrBGkyDY=
+github.com/fsnotify/fsnotify v1.7.0 h1:8JEhPFa5W2WU7YfeZzPNqzMP6Lwt7L2715Ggo0nosvA=
+github.com/fsnotify/fsnotify v1.7.0/go.mod h1:40Bi/Hjc2AVfZrqy+aj+yEI+/bRxZnMJyTJwOpGvigM=
+github.com/go-kit/log v0.2.1 h1:MRVx0/zhvdseW+Gza6N9rVzU/IVzaeE1SFI4raAhmBU=
+github.com/go-kit/log v0.2.1/go.mod h1:NwTd00d/i8cPZ3xOwwiv2PO5MOcx78fFErGNcVmBjv0=
+github.com/go-logfmt/logfmt v0.6.0 h1:wGYYu3uicYdqXVgoYbvnkrPVXkuLM1p1ifugDMEdRi4=
+github.com/go-logfmt/logfmt v0.6.0/go.mod h1:WYhtIu8zTZfxdn5+rREduYbwxfcBr/Vr6KEVveWlfTs=
+github.com/go-logr/logr v1.2.4 h1:g01GSCwiDw2xSZfjJ2/T9M+S6pFdcNtFYsp+Y43HYDQ=
+github.com/go-logr/logr v1.2.4/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
+github.com/go-task/slim-sprig v0.0.0-20230315185526-52ccab3ef572 h1:tfuBGBXKqDEevZMzYi5KSi8KkcZtzBcTgAUUtapy0OI=
+github.com/go-task/slim-sprig v0.0.0-20230315185526-52ccab3ef572/go.mod h1:9Pwr4B2jHnOSGXyyzV8ROjYa2ojvAY6HCGYYfMoC3Ls=
+github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg=
+github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY=
+github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
+github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
+github.com/google/pprof v0.0.0-20240402174815-29b9bb013b0f h1:f00RU+zOX+B3rLAmMMkzHUF2h1z4DeYR9tTCvEq2REY=
+github.com/google/pprof v0.0.0-20240402174815-29b9bb013b0f/go.mod h1:kf6iHlnVGwgKolg33glAes7Yg/8iWP8ukqeldJSO7jw=
+github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
+github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
+github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
+github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
+github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
+github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
+github.com/nxadm/tail v1.4.11 h1:8feyoE3OzPrcshW5/MJ4sGESc5cqmGkGCWlco4l0bqY=
+github.com/nxadm/tail v1.4.11/go.mod h1:OTaG3NK980DZzxbRq6lEuzgU+mug70nY11sMd4JXXHc=
+github.com/onsi/ginkgo v1.16.5 h1:8xi0RTUf59SOSfEtZMvwTvXYMzG4gV23XVHOZiXNtnE=
+github.com/onsi/ginkgo v1.16.5/go.mod h1:+E8gABHa3K6zRBolWtd+ROzc/U5bkGt0FwiG042wbpU=
+github.com/onsi/ginkgo/v2 v2.13.0 h1:0jY9lJquiL8fcf3M4LAXN5aMlS/b2BV86HFFPCPMgE4=
+github.com/onsi/ginkgo/v2 v2.13.0/go.mod h1:TE309ZR8s5FsKKpuB1YAQYBzCaAfUgatB/xlT/ETL/o=
+github.com/onsi/gomega v1.27.10 h1:naR28SdDFlqrG6kScpT8VWpu1xWY5nJRCF3XaYyBjhI=
+github.com/onsi/gomega v1.27.10/go.mod h1:RsS8tutOdbdgzbPtzzATp12yT7kM5I5aElG3evPbQ0M=
+github.com/philippseith/signalr v0.7.0 h1:bt8uusIKr3+hpQ5bRxEsHAM3VbEU15lve7e74Hf5a4E=
+github.com/philippseith/signalr v0.7.0/go.mod h1:deqWw2+rPPcdUQVvzXoB6A6FQB3v1OCnroy8CiUJNkg=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/quic-go/qpack v0.5.1 h1:giqksBPnT/HDtZ6VhtFKgoLOWmlyo9Ei6u9PqzIMbhI=
+github.com/quic-go/qpack v0.5.1/go.mod h1:+PC4XFrEskIVkcLzpEkbLqq1uCoxPhQuvK5rH1ZgaEg=
+github.com/quic-go/quic-go v0.48.2 h1:wsKXZPeGWpMpCGSWqOcqpW2wZYic/8T3aqiOID0/KWE=
+github.com/quic-go/quic-go v0.48.2/go.mod h1:yBgs3rWBOADpga7F+jJsb6Ybg1LSYiQvwWlLX+/6HMs=
+github.com/quic-go/webtransport-go v0.8.1-0.20241018022711-4ac2c9250e66 h1:4WFk6u3sOT6pLa1kQ50ZVdm8BQFgJNA117cepZxtLIg=
+github.com/quic-go/webtransport-go v0.8.1-0.20241018022711-4ac2c9250e66/go.mod h1:Vp72IJajgeOL6ddqrAhmp7IM9zbTcgkQxD/YdxrVwMw=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
+github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
+github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
+github.com/teivah/onecontext v1.3.0 h1:tbikMhAlo6VhAuEGCvhc8HlTnpX4xTNPTOseWuhO1J0=
+github.com/teivah/onecontext v1.3.0/go.mod h1:hoW1nmdPVK/0jrvGtcx8sCKYs2PiS4z0zzfdeuEVyb0=
+github.com/vmihailenco/msgpack/v5 v5.4.1 h1:cQriyiUvjTwOHg8QZaPihLWeRAAVoCpE00IUPn0Bjt8=
+github.com/vmihailenco/msgpack/v5 v5.4.1/go.mod h1:GaZTsDaehaPpQVyxrf5mtQlH+pc21PIudVV/E3rRQok=
+github.com/vmihailenco/tagparser/v2 v2.0.0 h1:y09buUbR+b5aycVFQs/g70pqKVZNBmxwAhO7/IwNM9g=
+github.com/vmihailenco/tagparser/v2 v2.0.0/go.mod h1:Wri+At7QHww0WTrCBeu4J6bNtoV6mEfg5OIWRZA9qds=
+go.uber.org/goleak v1.1.10 h1:z+mqJhf6ss6BSfSM671tgKyZBFPTTJM+HLxnhPC3wu0=
+go.uber.org/goleak v1.1.10/go.mod h1:8a7PlsEVH3e/a/GLqe5IIrQx6GzcnRmZEufDUTk4A7A=
+go.uber.org/mock v0.4.0 h1:VcM4ZOtdbR4f6VXfiOpwpVJDL6lCReaZ6mw31wqh7KU=
+go.uber.org/mock v0.4.0/go.mod h1:a6FSlNadKUHUa9IP5Vyt1zh4fC7uAwxMutEAscFbkZc=
+golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/crypto v0.36.0 h1:AnAEvhDddvBdpY+uR+MyHmuZzzNqXSe/GvuDeob5L34=
+golang.org/x/crypto v0.36.0/go.mod h1:Y4J0ReaxCR1IMaabaSMugxJES1EpwhBHhv2bDHklZvc=
+golang.org/x/exp v0.0.0-20240506185415-9bf2ced13842 h1:vr/HnozRka3pE4EsMEg1lgkXJkTFJCVUX+S/ZT6wYzM=
+golang.org/x/exp v0.0.0-20240506185415-9bf2ced13842/go.mod h1:XtvwrStGgqGPLc4cjQfWqZHG1YFdYs6swckp8vpsjnc=
+golang.org/x/lint v0.0.0-20190930215403-16217165b5de h1:5hukYrvBGR8/eNkX5mdUezrA6JiaEZDtJb9Ei+1LlBs=
+golang.org/x/lint v0.0.0-20190930215403-16217165b5de/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
+golang.org/x/mod v0.17.0 h1:zY54UmvipHiNd+pm+m0x9KhZ9hl1/7QNMyxXbc6ICqA=
+golang.org/x/mod v0.17.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c=
+golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.38.0 h1:vRMAPTMaeGqVhG5QyLJHqNDwecKTomGeqbnfZyKlBI8=
+golang.org/x/net v0.38.0/go.mod h1:ivrbrMbzFq5J41QOQh0siUuly180yBYtLp+CKbEaFx8=
+golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.12.0 h1:MHc5BpPuC30uJk597Ri8TV3CNZcTLu6B6z4lJy+g6Jw=
+golang.org/x/sync v0.12.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
+golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.31.0 h1:ioabZlmFYtWhL+TRYpcnNlLwhyxaM9kWTDEmfnprqik=
+golang.org/x/sys v0.31.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
+golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/text v0.23.0 h1:D71I7dUrlY+VX0gQShAThNGHFxZ13dGLBHQLVl1mJlY=
+golang.org/x/text v0.23.0/go.mod h1:/BLNzu4aZCJ1+kcD0DNRotWKage4q2rGVAg4o22unh4=
+golang.org/x/time v0.5.0 h1:o7cqy6amK/52YcAKIPlM3a+Fpj35zvRj2TP+e1xFSfk=
+golang.org/x/time v0.5.0/go.mod h1:3BpzKBy/shNhVucY/MWOyx10tF3SFh9QdLuxbVysPQM=
+golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
+golang.org/x/tools v0.0.0-20191108193012-7d206e10da11/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d h1:vU5i/LfpvrRCpgM/VPfJLg5KjxD3E+hfT1SH+d9zLwg=
+golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d/go.mod h1:aiJjzUbINMkxbQROHiO6hDPo2LHcIPhhQsa9DLh0yGk=
+golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+google.golang.org/protobuf v1.33.0 h1:uNO2rsAINq/JlFpSdYEKIZ0uKD/R9cpdv0T+yoGwGmI=
+google.golang.org/protobuf v1.33.0/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 h1:uRGJdciOHaEIrze2W8Q3AKkepLTh2hOroT7a+7czfdQ=
+gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7/go.mod h1:dt/ZhP58zS4L8KSrWDmTeBkI65Dw0HsyUHuEVlX15mw=
+gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

v2/handler.go

@@ -0,0 +1,7 @@
+package serverevents
+
+type IEventHandler interface {
+	GetConnectedEventName() string
+	CanExecute(IContext) bool
+	Handle(IContext, any)
+}

v2/hub.go

@@ -0,0 +1,99 @@
+package serverevents
+
+import (
+	gocontext "context"
+	"fmt"
+	di "git.apihub24.de/admin/generic-di"
+	"github.com/coder/websocket"
+	"github.com/coder/websocket/wsjson"
+	"sync"
+	"time"
+)
+
+func init() {
+	di.Injectable(newHub)
+}
+
+type IEventHub interface {
+	SetContextLifetime(duration time.Duration)
+	OnConnected(connectionId string, conn *websocket.Conn)
+	OnDisconnected(connectionId string)
+	Dispatch(event Event, callerCtx IContext)
+	Event(event Event, id string)
+}
+
+type eventHub struct {
+	mu              sync.Mutex
+	contextLifetime time.Duration
+	contexts        map[string]IContext
+	registration    IEventHandlerRegistration
+	parser          IMessageParser
+}
+
+func newHub() IEventHub {
+	return &eventHub{
+		mu:              sync.Mutex{},
+		contextLifetime: 500 * time.Second,
+		contexts:        make(map[string]IContext),
+		registration:    di.Inject[IEventHandlerRegistration](),
+		parser:          di.Inject[IMessageParser](),
+	}
+}
+
+func (hub *eventHub) Dispatch(event Event, callerCtx IContext) {
+	// dispatch Event to Handler
+	handler, getHandlerErr := hub.registration.GetHandler(event.Type)
+	if getHandlerErr == nil && handler.CanExecute(callerCtx) {
+		handler.Handle(callerCtx, event.Data)
+	}
+
+	if event.IsBackendOnly || event.Filter == nil {
+		// only dispatch Event on Backend or we have no Context Filter
+		// if you want to dispatch to all Clients use Filter that returns true
+		return
+	}
+
+	writeCtx, cancel := gocontext.WithTimeout(gocontext.Background(), time.Second*10)
+	defer cancel()
+	for _, ctx := range hub.contexts {
+		if event.Filter(ctx) {
+			writeErr := wsjson.Write(writeCtx, ctx.GetConnection(), event)
+			if writeErr != nil {
+				println(fmt.Sprintf("[Error on write to Websocket]: %v", writeErr))
+			}
+		}
+	}
+}
+
+func (hub *eventHub) SetContextLifetime(duration time.Duration) {
+	hub.contextLifetime = duration
+}
+
+func (hub *eventHub) Event(event Event, id string) {
+	callerCtx, ok := hub.contexts[id]
+	if !ok {
+		println(fmt.Sprintf("[Error on select caller context]: missing context connectionId: %s", id))
+		return
+	}
+
+	// Event from Client not send back!
+	event.IsBackendOnly = true
+	hub.Dispatch(event, callerCtx)
+}
+
+func (hub *eventHub) OnConnected(connectionId string, conn *websocket.Conn) {
+	hub.mu.Lock()
+	defer hub.mu.Unlock()
+
+	hub.contexts[connectionId] = di.Inject[IContext](connectionId)
+	hub.contexts[connectionId].SetId(connectionId)
+	hub.contexts[connectionId].SetConnection(conn)
+}
+
+func (hub *eventHub) OnDisconnected(connectionId string) {
+	hub.mu.Lock()
+	defer hub.mu.Unlock()
+
+	hub.contexts[connectionId].CleanupIn(hub.contextLifetime)
+	delete(hub.contexts, connectionId)
+}

v2/implementation_test/data/dto/greeting.go

@@ -0,0 +1,5 @@
+package dto
+
+type Greeting struct {
+	Message string `json:"message"`
+}

v2/implementation_test/events/definitions/greet_event.go

@@ -0,0 +1,26 @@
+package definitions
+
+import (
+	serverevents "git.apihub24.de/admin/server_events/v2"
+	"git.apihub24.de/admin/server_events/v2/implementation_test/data/dto"
+)
+
+const GreeterEventName = "greet"
+
+type greetEvent struct {
+	data dto.Greeting
+}
+
+func NewGreetEvent(data dto.Greeting) serverevents.IEvent {
+	return &greetEvent{
+		data: data,
+	}
+}
+
+func (ev *greetEvent) GetEventName() string {
+	return GreeterEventName
+}
+
+func (ev *greetEvent) GetEventData() any {
+	return ev.data
+}

v2/implementation_test/events/definitions/greet_me_event.go

@@ -0,0 +1,23 @@
+package definitions
+
+import serverevents "git.apihub24.de/admin/server_events/v2"
+
+const GreetMeEventName = "greet me"
+
+type greetMeEvent struct {
+	data string
+}
+
+func NewGreetMeEvent(name string) serverevents.IEvent {
+	return &greetMeEvent{
+		data: name,
+	}
+}
+
+func (ev *greetMeEvent) GetEventName() string {
+	return GreetMeEventName
+}
+
+func (ev *greetMeEvent) GetEventData() any {
+	return ev.data
+}

v2/implementation_test/events/definitions/ping_event.go

@@ -0,0 +1,19 @@
+package definitions
+
+import serverevents "git.apihub24.de/admin/server_events/v2"
+
+const PingEventName = "ping"
+
+type pingEvent struct{}
+
+func NewPingEvent() serverevents.IEvent {
+	return &pingEvent{}
+}
+
+func (ev *pingEvent) GetEventName() string {
+	return PingEventName
+}
+
+func (ev *pingEvent) GetEventData() any {
+	return nil
+}

v2/implementation_test/events/definitions/pong_event.go

@@ -0,0 +1,19 @@
+package definitions
+
+import serverevents "git.apihub24.de/admin/server_events/v2"
+
+const PongEventName = "pong"
+
+type pongEvent struct{}
+
+func NewPongEvent() serverevents.IEvent {
+	return &pongEvent{}
+}
+
+func (ev *pongEvent) GetEventName() string {
+	return PongEventName
+}
+
+func (ev *pongEvent) GetEventData() any {
+	return nil
+}

v2/implementation_test/events/handler/greet_me_handler.go

@@ -0,0 +1,34 @@
+package handler
+
+import (
+	"fmt"
+
+	serverevents "git.apihub24.de/admin/server_events/v2"
+	"git.apihub24.de/admin/server_events/v2/implementation_test/data/dto"
+	"git.apihub24.de/admin/server_events/v2/implementation_test/events/definitions"
+	"git.apihub24.de/admin/server_events/v2/implementation_test/filter"
+)
+
+type greetMeEventHandler struct{}
+
+func NewGreetMeEventHandler() serverevents.IEventHandler {
+	return &greetMeEventHandler{}
+}
+
+func (handler *greetMeEventHandler) GetConnectedEventName() string {
+	return definitions.GreetMeEventName
+}
+
+func (handler *greetMeEventHandler) CanExecute(_ serverevents.IContext) bool {
+	return true
+}
+
+func (handler *greetMeEventHandler) Handle(context serverevents.IContext, data any) {
+	userName, ok := serverevents.ValueAs[string](data)
+	if !ok || len(userName) < 1 {
+		userName = "Anonymous"
+	}
+	context.Dispatch(definitions.NewGreetEvent(dto.Greeting{
+		Message: fmt.Sprintf("Hello, %s", userName),
+	}), filter.WithSameUserName(context))
+}

v2/implementation_test/events/handler/ping.go

@@ -0,0 +1,24 @@
+package handler
+
+import (
+	serverevents "git.apihub24.de/admin/server_events/v2"
+	"git.apihub24.de/admin/server_events/v2/implementation_test/events/definitions"
+)
+
+type pingEventHandler struct{}
+
+func NewPingEventHandler() serverevents.IEventHandler {
+	return &pingEventHandler{}
+}
+
+func (handler *pingEventHandler) GetConnectedEventName() string {
+	return definitions.PingEventName
+}
+
+func (handler *pingEventHandler) CanExecute(_ serverevents.IContext) bool {
+	return true
+}
+
+func (handler *pingEventHandler) Handle(context serverevents.IContext, _ any) {
+	context.Dispatch(definitions.NewPongEvent(), context.IsCaller)
+}

v2/implementation_test/filter/same_username.go

@@ -0,0 +1,12 @@
+package filter
+
+import serverevents "git.apihub24.de/admin/server_events/v2"
+
+func WithSameUserName(context serverevents.IContext) func(context serverevents.IContext) bool {
+	return serverevents.CreateMetaDataFilter(context, func(c serverevents.IContext) string {
+		userName, _ := serverevents.MetadataAs[string](context, "UserName")
+		return userName
+	}, func(a string, b string) bool {
+		return a == b
+	})
+}

v2/implementation_test/index.go

@@ -0,0 +1,61 @@
+package main
+
+var Index = `<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <title>Test</title>
+    <script src="https://cdnjs.cloudflare.com/ajax/libs/microsoft-signalr/8.0.7/signalr.min.js" integrity="sha512-7SRCYIJtR6F8ocwW7UxW6wGKqbSyqREDbfCORCbGLatU0iugBLwyOXpzhkPyHIFdBO0K2VCu57fvP2Twgx1o2A==" crossorigin="anonymous" referrerpolicy="no-referrer"></script>
+</head>
+<body>
+    <div>
+        <div>
+            <input type="text" id="name" />
+            <button id="greet">Greet</button>
+            <button id="ping">Ping</button>
+        </div>
+        <ul id="events"></ul>
+    </div>
+    <script>
+        (async function () {
+			let ws;
+			function connect() {
+				if (!localStorage.getItem('client_id')) {
+					localStorage.setItem('client_id', crypto.randomUUID());
+				}
+				ws = new WebSocket('/events?id=' + localStorage.getItem('client_id'));
+				ws.addEventListener('open', function () {
+					wsOpen = true;
+				});
+				ws.addEventListener('message', function (message) {
+					const event = JSON.parse(message.data);
+					if (!event.type) {
+						return;
+					}
+					const eventList = document.getElementById('events');
+					const li = document.createElement('li');
+					li.innerText = event.type + ': ' + (event.data ? JSON.stringify(event.data) : 'null');
+					eventList.append(li);
+				});
+				ws.onclose = function () {
+					setTimeout(() => connect(), 5000);
+				};
+			}
+
+            document.getElementById('greet').onclick = function () {
+                const name = document.getElementById('name').value;
+                ws.send(JSON.stringify({
+                    type: 'greet me',
+                    data: name,
+                }));
+            };
+
+            document.getElementById('ping').onclick = function () {
+                ws.send(JSON.stringify({type: 'ping'}));
+            };
+
+            connect();
+        })();
+    </script>
+</body>
+</html>`

v2/implementation_test/main.go

@@ -0,0 +1,38 @@
+package main
+
+import (
+	"log"
+	"net/http"
+	"time"
+
+	di "git.apihub24.de/admin/generic-di"
+	serverevents "git.apihub24.de/admin/server_events/v2"
+	"git.apihub24.de/admin/server_events/v2/implementation_test/events/handler"
+)
+
+func main() {
+	serverEventsMiddleware := di.Inject[serverevents.IMiddleware]()
+	eventRegistration := di.Inject[serverevents.IEventHandlerRegistration]()
+
+	eventRegistration.Use(handler.NewPingEventHandler)
+	eventRegistration.Use(handler.NewGreetMeEventHandler)
+
+	router := http.NewServeMux()
+
+	router.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
+		if r.Method == "GET" {
+			w.Header().Set("Content-Type", "text/html")
+			w.WriteHeader(http.StatusOK)
+			_, _ = w.Write([]byte(Index))
+			return
+		}
+	})
+
+	router = serverEventsMiddleware.Use(serverevents.MiddlewareOptions{
+		Path:            "/events",
+		ContextLifetime: 500 * time.Second,
+		KeepAliveTime:   2 * time.Second,
+	}, router)
+
+	log.Fatal(http.ListenAndServe(":8080", router))
+}

v2/middleware.go

@@ -0,0 +1,83 @@
+package serverevents
+
+import (
+	gocontext "context"
+	"fmt"
+	di "git.apihub24.de/admin/generic-di"
+	"github.com/coder/websocket"
+	"github.com/coder/websocket/wsjson"
+	"net/http"
+	"time"
+)
+
+func init() {
+	di.Injectable(newServerEventsMiddleware)
+}
+
+type MiddlewareOptions struct {
+	Path            string
+	ContextLifetime time.Duration
+	KeepAliveTime   time.Duration
+}
+
+type IMiddleware interface {
+	Use(options MiddlewareOptions, mux *http.ServeMux) *http.ServeMux
+}
+
+type serverEventsMiddleware struct {
+	hub IEventHub
+}
+
+func newServerEventsMiddleware() IMiddleware {
+	return &serverEventsMiddleware{
+		hub: di.Inject[IEventHub](),
+	}
+}
+
+func (middleware *serverEventsMiddleware) Use(options MiddlewareOptions, muxer *http.ServeMux) *http.ServeMux {
+	if muxer == nil {
+		muxer = http.NewServeMux()
+	}
+
+	eventHub := di.Inject[IEventHub]()
+	muxer.HandleFunc(options.Path, func(w http.ResponseWriter, r *http.Request) {
+		id := r.URL.Query().Get("id")
+		if len(id) < 1 {
+			println(fmt.Sprintf("no id found in query websocket closed"))
+			return
+		}
+		c, connectionErr := websocket.Accept(w, r, nil)
+		if connectionErr != nil {
+			println(fmt.Sprintf("[Error on connect Websocket]: %v", connectionErr))
+			return
+		}
+		defer func() {
+			println("Websocket disconnect")
+			eventHub.OnDisconnected(id)
+			_ = c.CloseNow()
+		}()
+
+		eventHub.OnConnected(id, c)
+
+		for {
+			err := readMessage(c, eventHub, id)
+			if err != nil {
+				return
+			}
+		}
+	})
+
+	return muxer
+}
+
+func readMessage(c *websocket.Conn, eventHub IEventHub, id string) error {
+	var message Event
+	readErr := wsjson.Read(gocontext.Background(), c, &message)
+	if readErr != nil {
+		println(fmt.Sprintf("[Error on read from Websocket]: %v", readErr))
+		return readErr
+	}
+
+	eventHub.Event(message, id)
+	return nil
+}

v2/parser.go

@@ -0,0 +1,35 @@
+package serverevents
+
+import (
+	"encoding/json"
+	di "git.apihub24.de/admin/generic-di"
+)
+
+func init() {
+	di.Injectable(newMessageParser)
+}
+
+type IMessageParser interface {
+	ToString(event Event) (string, error)
+	FromString(eventStr string) (Event, error)
+}
+
+type messageParser struct{}
+
+func newMessageParser() IMessageParser {
+	return &messageParser{}
+}
+
+func (parser *messageParser) ToString(event Event) (string, error) {
+	stream, marshalErr := json.Marshal(event)
+	if marshalErr != nil {
+		return "", marshalErr
+	}
+	return string(stream), nil
+}
+
+func (parser *messageParser) FromString(eventStr string) (Event, error) {
+	var ev Event
+	unmarshalErr := json.Unmarshal([]byte(eventStr), &ev)
+	return ev, unmarshalErr
+}

v2/registration.go

@@ -0,0 +1,56 @@
+package serverevents
+
+import (
+	"fmt"
+	"sync"
+
+	di "git.apihub24.de/admin/generic-di"
+)
+
+func init() {
+	di.Injectable(newEventHandlerRegistration)
+}
+
+type IEventHandlerRegistration interface {
+	Use(creator func() IEventHandler)
+	GetHandler(eventType string) (IEventHandler, error)
+}
+
+type eventHandlerRegistration struct {
+	creators  map[string]func() IEventHandler
+	instances map[string]IEventHandler
+	mutex     sync.RWMutex
+}
+
+func newEventHandlerRegistration() IEventHandlerRegistration {
+	return &eventHandlerRegistration{
+		creators:  make(map[string]func() IEventHandler),
+		instances: make(map[string]IEventHandler),
+		mutex:     sync.RWMutex{},
+	}
+}
+
+func (registration *eventHandlerRegistration) Use(creator func() IEventHandler) {
+	registration.mutex.Lock()
+	defer registration.mutex.Unlock()
+
+	tmp := creator()
+	eventType := tmp.GetConnectedEventName()
+	delete(registration.instances, eventType)
+	delete(registration.creators, eventType)
+	registration.creators[eventType] = creator
+}
+
+func (registration *eventHandlerRegistration) GetHandler(eventType string) (IEventHandler, error) {
+	registration.mutex.RLock()
+	defer registration.mutex.RUnlock()
+
+	if creator, ok := registration.creators[eventType]; ok {
+		if instance, ok := registration.instances[eventType]; ok {
+			return instance, nil
+		}
+		registration.instances[eventType] = creator()
+		return registration.instances[eventType], nil
+	}
+	return nil, fmt.Errorf("no instance of IEventHandler registered for Event %s! please call Registration Add in a init function to register your EventHandler", eventType)
+}