in multistream chats, mentions which chat record is from

README.md

···
 did:plc:25z6ogppprfvijcnqo2fsfce`
 
 if you want to see the union of alice and bob's chats, and their dids are
-`did:plc:12345` and `did:plc:abcde`, then do `go run . did:plc:12345 did:plc:abcde`
+`did:plc:12345` and `did:plc:abcde`, then do `go run . did:plc:12345
+did:plc:abcde`
 
 pretty simple!
 

beeper.go

···
 }
 
 var (
-	hasArgs bool
+	hasArgs       bool
+	didToHandle   map[syntax.DID]*syntax.Handle
+	noNeedForFrom bool
 )
 
 func main() {
 	fmt.Println("beep")
 	if len(os.Args) != 1 {
 		hasArgs = true
+	}
+	if len(os.Args) == 2 {
+		noNeedForFrom = true
 	}
 	f, err := os.Open("thread_notification.wav")
 	if err != nil {
···
 		np,
 		tp,
 	}
+	didToHandle = make(map[syntax.DID]*syntax.Handle)
 	go consumeLoop(context.Background(), ns)
 	ns.tp.Run()
 }
···
 
 func (h *handler) HandleEvent(ctx context.Context, event *models.Event) error {
 	if event.Commit != nil && event.Commit.Collection == "place.stream.chat.message" && event.Commit.Operation == "create" {
-		dd := identity.DefaultDirectory()
-		did, err := syntax.ParseDID(event.Did)
+		handle, err := getHandle(event.Did, ctx)
 		if err != nil {
 			panic(err)
-		}
-		id, err := dd.LookupDID(ctx, did)
-		if err != nil {
-			return nil
 		}
 		var v ChatMessage
 		err = json.Unmarshal(event.Commit.Record, &v)
···
 			}
 		}
 		if shouldSend {
-			h.ns.Notify(v.Text, id.Handle)
+			var streamer string
+			if !noNeedForFrom {
+				streamer, err = getHandle(v.Streamer, ctx)
+				if err != nil {
+					panic(err)
+				}
+			}
+			h.ns.Notify(v.Text, handle, streamer)
 		}
 	}
 	return nil
 }
 
-func (ns *NotificationSystem) Notify(text string, handle syntax.Handle) {
+func getHandle(did string, ctx context.Context) (string, error) {
+	sdid, err := syntax.ParseDID(did)
+	if err != nil {
+		return "", err
+	}
+	h, ok := didToHandle[sdid]
+	if ok {
+		return h.String(), nil
+	}
+	dd := identity.DefaultDirectory()
+	id, err := dd.LookupDID(ctx, sdid)
+	if err != nil {
+		return "failed.to.lookup", nil
+	}
+	didToHandle[sdid] = &id.Handle
+	return id.Handle.String(), nil
+}
 
-	streamer := ns.np.audioData.Streamer(0, ns.np.audioData.Len())
-	speaker.Play(streamer)
-	h := handle.String()
-	ns.tp.Send(ChatMsg{text: &text, handle: &h})
+func (ns *NotificationSystem) Notify(text string, handle string, streamer string) {
+
+	noise := ns.np.audioData.Streamer(0, ns.np.audioData.Len())
+	speaker.Play(noise)
+	ns.tp.Send(ChatMsg{text: &text, handle: &handle, streamer: &streamer})
 }
 
 type model struct {
···
 }
 
 type record struct {
-	handle *string
-	text   *string
+	handle   *string
+	text     *string
+	streamer *string
 }
 
 func initialModel() model {
···
 //15191e
 
 type ChatMsg struct {
-	handle *string
-	text   *string
+	handle   *string
+	text     *string
+	streamer *string
 }
 
 func (m model) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
···
 		m.height = msg.Height
 	case ChatMsg:
 		record := record{
-			text:   msg.text,
-			handle: msg.handle,
+			text:     msg.text,
+			handle:   msg.handle,
+			streamer: msg.streamer,
 		}
 		m.records = append(m.records, &record)
 	}
···
 	for _, record := range m.records {
 		str := "invalid handle"
 		if record.handle != nil {
-			str = fmt.Sprintf("%s ", *record.handle)
+			str = fmt.Sprintf("%s", *record.handle)
 		}
 		bold := lipgloss.NewStyle().Bold(true).Foreground(lipgloss.Color(hashStringToColor(str)))
 		bdy := ""
 		if record.text != nil {
 			bdy = fmt.Sprintf("%s", *record.text)
 		}
+		middleText := "\n"
+		if !noNeedForFrom {
+			boldStrmr := lipgloss.NewStyle().Bold(true).Foreground(lipgloss.Color(hashStringToColor(*record.streamer)))
+			middleText = fmt.Sprintf(" in %s's chat\n", boldStrmr.Render(*record.streamer))
+		}
 		style := lipgloss.NewStyle().Width(m.width)
-		s = s + "\n" + bold.Render(str) + "\n" + style.Render(bdy) + "\n"
+		s = s + "\n" + bold.Render(str) + middleText + style.Render(bdy) + "\n"
 	}
 	return s
 }