refactor: pre-render table row data

internal/logging/writer.go

@@ -35,8 +35,9 @@ func (w *writer) Write(p []byte) (int, error) {
 				msg.Message = string(d.Value())
 			default:
 				msg.Attributes = append(msg.Attributes, Attr{
-					Key:   string(d.Key()),
-					Value: string(d.Value()),
+					Key:    string(d.Key()),
+					Value:  string(d.Value()),
+					Common: resource.New(resource.LogAttr, msg),
 				})
 			}
 		}

internal/pubsub/broker.go

@@ -17,15 +17,15 @@ type Logger interface {
 }
 
 // Broker allows clients to publish events and subscribe to events
-type Broker[T any] struct {
+type Broker[T resource.Resource] struct {
 	subs   map[chan resource.Event[T]]struct{} // subscriptions
 	mu     sync.Mutex                          // sync access to map
 	done   chan struct{}                       // close when broker is shutting down
 	logger Logger
 }
 
 // NewBroker constructs a pub/sub broker.
-func NewBroker[T any](logger Logger) *Broker[T] {
+func NewBroker[T resource.Resource](logger Logger) *Broker[T] {
 	b := &Broker[T]{
 		subs:   make(map[chan resource.Event[T]]struct{}),
 		done:   make(chan struct{}),

internal/resource/event.go

@@ -11,7 +11,7 @@ type (
 	EventType string
 
 	// Event represents an event in the lifecycle of a resource
-	Event[T any] struct {
+	Event[T Resource] struct {
 		Type    EventType
 		Payload T
 	}
@@ -20,7 +20,3 @@ type (
 		Publish(EventType, T)
 	}
 )
-
-func NewEvent[T any](t EventType, payload T) Event[T] {
-	return Event[T]{Type: t, Payload: payload}
-}

internal/tui/logs/model.go

@@ -46,28 +46,29 @@ func (mm *Maker) Make(id resource.ID, width, height int) (tea.Model, error) {
 			valueColumn.Key: attr.Value,
 		}
 	}
-	items := map[resource.ID]logging.Attr{
-		resource.NewID(resource.LogAttr): {
-			Key:   timeAttrKey,
-			Value: msg.Time.Format(timeFormat),
-		},
-		resource.NewID(resource.LogAttr): {
-			Key:   messageAttrKey,
-			Value: msg.Message,
-		},
-		resource.NewID(resource.LogAttr): {
-			Key:   levelAttrKey,
-			Value: coloredLogLevel(msg.Level),
-		},
-	}
-	for _, attr := range msg.Attributes {
-		items[resource.NewID(resource.LogAttr)] = attr
-	}
 	table := table.New(columns, renderer, width, height,
 		table.WithSortFunc(byAttribute),
 		table.WithSelectable[logging.Attr](false),
 	)
-	table.SetItems(items)
+	items := []logging.Attr{
+		{
+			Key:    timeAttrKey,
+			Value:  msg.Time.Format(timeFormat),
+			Common: resource.New(resource.LogAttr, resource.GlobalResource),
+		},
+		{
+			Key:    messageAttrKey,
+			Value:  msg.Message,
+			Common: resource.New(resource.LogAttr, resource.GlobalResource),
+		},
+		{
+			Key:    levelAttrKey,
+			Value:  coloredLogLevel(msg.Level),
+			Common: resource.New(resource.LogAttr, resource.GlobalResource),
+		},
+	}
+	items = append(items, msg.Attributes...)
+	table.SetItems(items...)
 
 	return model{
 		msg:    msg,

internal/tui/module/list.go

@@ -121,6 +121,12 @@ func (m list) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
 	)
 
 	switch msg := msg.(type) {
+	case resource.Event[*task.Task]:
+		// Re-render module whenever a task event is received belonging to the
+		// module.
+		if mod := msg.Payload.Module(); mod != nil {
+			m.table.AddItems(mod.(*module.Module))
+		}
 	case tea.KeyMsg:
 		switch {
 		case key.Matches(msg, localKeys.ReloadModules):