mirror of
https://github.com/bitechdev/ResolveSpec.git
synced 2026-03-07 05:58:55 +00:00
Hein
79720d5421
- Implement BeforeHandle hook to enforce authentication based on model rules. - Integrate with existing security mechanisms to allow or deny access. - Update documentation to reflect new hook and its usage.
55 lines
1.7 KiB
Go
55 lines
1.7 KiB
Go
package mqttspec
|
|
|
|
import (
|
|
"github.com/bitechdev/ResolveSpec/pkg/websocketspec"
|
|
)
|
|
|
|
// Hook types - aliases to websocketspec for lifecycle hook consistency
|
|
type (
|
|
// HookType defines the type of lifecycle hook
|
|
HookType = websocketspec.HookType
|
|
|
|
// HookFunc is a function that executes during a lifecycle hook
|
|
HookFunc = websocketspec.HookFunc
|
|
|
|
// HookContext contains all context for hook execution
|
|
// Note: For MQTT, the Client is stored in Metadata["mqtt_client"]
|
|
HookContext = websocketspec.HookContext
|
|
|
|
// HookRegistry manages all registered hooks
|
|
HookRegistry = websocketspec.HookRegistry
|
|
)
|
|
|
|
// Hook type constants - all lifecycle hooks
|
|
const (
|
|
// BeforeHandle fires after model resolution, before operation dispatch
|
|
BeforeHandle = websocketspec.BeforeHandle
|
|
|
|
// CRUD operation hooks
|
|
BeforeRead = websocketspec.BeforeRead
|
|
AfterRead = websocketspec.AfterRead
|
|
BeforeCreate = websocketspec.BeforeCreate
|
|
AfterCreate = websocketspec.AfterCreate
|
|
BeforeUpdate = websocketspec.BeforeUpdate
|
|
AfterUpdate = websocketspec.AfterUpdate
|
|
BeforeDelete = websocketspec.BeforeDelete
|
|
AfterDelete = websocketspec.AfterDelete
|
|
|
|
// Subscription hooks
|
|
BeforeSubscribe = websocketspec.BeforeSubscribe
|
|
AfterSubscribe = websocketspec.AfterSubscribe
|
|
BeforeUnsubscribe = websocketspec.BeforeUnsubscribe
|
|
AfterUnsubscribe = websocketspec.AfterUnsubscribe
|
|
|
|
// Connection hooks
|
|
BeforeConnect = websocketspec.BeforeConnect
|
|
AfterConnect = websocketspec.AfterConnect
|
|
BeforeDisconnect = websocketspec.BeforeDisconnect
|
|
AfterDisconnect = websocketspec.AfterDisconnect
|
|
)
|
|
|
|
// NewHookRegistry creates a new hook registry
|
|
func NewHookRegistry() *HookRegistry {
|
|
return websocketspec.NewHookRegistry()
|
|
}
|