feat(event): add VersionFromContext

events/context.go

@@ -15,3 +15,8 @@ func GroupIDFromContext(ctx context.Context) int {
 func EventIDFromContext(ctx context.Context) string {
 	return ctx.Value(internal.EventIDKey).(string)
 }
+
+// VersionFromContext returns the version from context.
+func VersionFromContext(ctx context.Context) string {
+	return ctx.Value(internal.EventVersionKey).(string)
+}

events/context_test.go

@@ -24,3 +24,11 @@ func TestEventIDFromContext(t *testing.T) {
 	ctx := context.WithValue(context.Background(), internal.EventIDKey, eventID)
 	assert.Equal(t, eventID, events.EventIDFromContext(ctx))
 }
+
+func TestVersionFromContext(t *testing.T) {
+	t.Parallel()
+
+	const version = "5.131"
+	ctx := context.WithValue(context.Background(), internal.EventVersionKey, version)
+	assert.Equal(t, version, events.VersionFromContext(ctx))
+}

events/events.go

@@ -81,6 +81,7 @@ type GroupEvent struct {
 	Object  json.RawMessage `json:"object"`
 	GroupID int             `json:"group_id"`
 	EventID string          `json:"event_id"`
+	V       string          `json:"v"`
 	Secret  string          `json:"secret"`
 }
 
@@ -158,6 +159,7 @@ func NewFuncList() *FuncList {
 func (fl FuncList) Handler(ctx context.Context, e GroupEvent) error { // nolint:gocyclo
 	ctx = context.WithValue(ctx, internal.GroupIDKey, e.GroupID)
 	ctx = context.WithValue(ctx, internal.EventIDKey, e.EventID)
+	ctx = context.WithValue(ctx, internal.EventVersionKey, e.V)
 
 	if sliceFunc, ok := fl.special[e.Type]; ok {
 		for _, f := range sliceFunc {

internal/transport.go

@@ -28,6 +28,7 @@ const (
 	CallbackRetryCounterKey
 	CallbackRetryAfterKey
 	CallbackRemove
+	EventVersionKey
 )
 
 // ContextClient return *http.Client.