rob/octoplex
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

fixup! wip: refactor: API

Browse Source
This commit is contained in:
Rob Watson 2025-05-11 06:14:17 +02:00
parent b8a77d9c6c
commit 977b6fe7d7
2 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/event/bus.go
View File

@ -58,7 +58,7 @@ func (b *Bus) Send(evt Event) {
select { select {
case ch <- evt: case ch <- evt:
default: default:
b.logger.Warn("Event dropped", "name", evt.name()) b.logger.Warn("Event dropped", "name", evt.EventName())
} }
} }
} }

22
internal/event/events.go
View File

@ -19,7 +19,7 @@ const (
// Event represents something which happened in the appllication. // Event represents something which happened in the appllication.
type Event interface { type Event interface {
name() Name EventName() Name
} }
// AppStateChangedEvent is emitted when the application state changes. // AppStateChangedEvent is emitted when the application state changes.
@ -27,7 +27,7 @@ type AppStateChangedEvent struct {
State domain.AppState State domain.AppState
} }
func (e AppStateChangedEvent) name() Name { func (e AppStateChangedEvent) EventName() Name {
return EventNameAppStateChanged return EventNameAppStateChanged
} }
@ -36,7 +36,7 @@ type DestinationAddedEvent struct {
URL string URL string
} }
func (e DestinationAddedEvent) name() Name { func (e DestinationAddedEvent) EventName() Name {
return EventNameDestinationAdded return EventNameDestinationAdded
} }
@ -46,7 +46,7 @@ type AddDestinationFailedEvent struct {
Err error Err error
} }
func (e AddDestinationFailedEvent) name() Name { func (e AddDestinationFailedEvent) EventName() Name {
return EventNameAddDestinationFailed return EventNameAddDestinationFailed
} }
@ -56,7 +56,7 @@ type DestinationStreamExitedEvent struct {
Err error Err error
} }
func (e DestinationStreamExitedEvent) name() Name { func (e DestinationStreamExitedEvent) EventName() Name {
return EventNameDestinationStreamExited return EventNameDestinationStreamExited
} }
@ -66,7 +66,7 @@ type StartDestinationFailedEvent struct {
Message string Message string
} }
func (e StartDestinationFailedEvent) name() Name { func (e StartDestinationFailedEvent) EventName() Name {
return EventNameStartDestinationFailed return EventNameStartDestinationFailed
} }
@ -76,7 +76,7 @@ type DestinationRemovedEvent struct {
URL string URL string
} }
func (e DestinationRemovedEvent) name() Name { func (e DestinationRemovedEvent) EventName() Name {
return EventNameDestinationRemoved return EventNameDestinationRemoved
} }
@ -87,7 +87,7 @@ type RemoveDestinationFailedEvent struct {
Err error Err error
} }
func (e RemoveDestinationFailedEvent) name() Name { func (e RemoveDestinationFailedEvent) EventName() Name {
return EventNameRemoveDestinationFailed return EventNameRemoveDestinationFailed
} }
@ -100,11 +100,11 @@ type FatalErrorOccurredEvent struct {
// OtherInstanceDetectedEvent is emitted when the app launches and detects another instance. // OtherInstanceDetectedEvent is emitted when the app launches and detects another instance.
type OtherInstanceDetectedEvent struct{} type OtherInstanceDetectedEvent struct{}
func (e OtherInstanceDetectedEvent) name() Name { func (e OtherInstanceDetectedEvent) EventName() Name {
return EventNameOtherInstanceDetected return EventNameOtherInstanceDetected
} }
func (e FatalErrorOccurredEvent) name() Name { func (e FatalErrorOccurredEvent) EventName() Name {
return "fatal_error_occurred" return "fatal_error_occurred"
} }
@ -114,6 +114,6 @@ type MediaServerStartedEvent struct {
RTMPSURL string RTMPSURL string
} }
func (e MediaServerStartedEvent) name() Name { func (e MediaServerStartedEvent) EventName() Name {
return "media_server_started" return "media_server_started"
} }