-
Notifications
You must be signed in to change notification settings - Fork 0
/
event.go
75 lines (65 loc) · 1.43 KB
/
event.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
package event
import (
"bytes"
"context"
"encoding/gob"
"errors"
"reflect"
"strings"
)
type EventType string
type Event interface {
Type() EventType
WithContext(ctx context.Context)
Context(ctx context.Context) context.Context
}
type EventLogger struct {
// Logger *slog.Logger
}
func (e *EventLogger) Context(ctx context.Context) context.Context {
return ctx
// if e.Logger == nil {
// return ctx
// }
// return clog.Update(ctx, func(l *slog.Logger) *slog.Logger {
// return e.Logger
// })
}
func (e *EventLogger) WithContext(ctx context.Context) {
// e.Logger = clog.Use(ctx)
}
var (
ErrEventTypeNotFound = errors.New("event type not found")
)
func encodeEvent(e Event) ([]byte, error) {
buff := bytes.NewBufferString(strings.ReplaceAll(string(e.Type()), "|", "🔥") + "|")
err := gob.NewEncoder(buff).Encode(e)
if err != nil {
return nil, err
}
return buff.Bytes(), nil
}
func decodeEvent(b []byte, events map[EventType]reflect.Type) (Event, error) {
parts := bytes.SplitN(b, []byte{'|'}, 2)
eventType := EventType(parts[0])
data := parts[1]
t, ok := events[eventType]
if !ok {
return nil, ErrEventTypeNotFound
}
dereferenced := false
if t.Kind() == reflect.Ptr {
dereferenced = true
t = t.Elem()
}
v := reflect.New(t)
buff := bytes.NewBuffer(data)
err := gob.NewDecoder(buff).DecodeValue(v)
if err != nil {
return nil, err
}
if !dereferenced {
v = v.Elem()
}
return v.Interface().(Event), nil
}