this repo has no description
idk some changes to the code + rm qt
+13
-3
+13
-3
beeper.go
+13
-3
beeper.go
···
113
113
func (c *Consumer) Consume(ctx context.Context) error {
114
114
scheduler := sequential.NewScheduler("jetstream_localdev", slog.Default(), c.handler.HandleEvent)
115
115
defer scheduler.Shutdown()
116
-
client, err := client.NewClient(c.cfg, slog.Default(), scheduler)
116
+
opts := slog.HandlerOptions{
117
+
Level: slog.LevelError,
118
+
}
119
+
handler := slog.NewJSONHandler(os.Stdout, &opts)
120
+
client, err := client.NewClient(c.cfg, slog.New(handler), scheduler)
117
121
if err != nil {
118
122
return errors.New("failed to create client: " + err.Error())
119
123
}
···
173
177
174
178
type model struct {
175
179
records []*record
180
+
width int
181
+
height int
176
182
}
177
183
178
184
type record struct {
···
205
211
206
212
return m, tea.Quit
207
213
}
214
+
case tea.WindowSizeMsg:
215
+
m.width = msg.Width
216
+
m.height = msg.Height
208
217
case ChatMsg:
209
218
record := record{
210
219
text: msg.text,
···
216
225
}
217
226
218
227
func (m model) View() string {
219
-
s := "\n"
228
+
s := ""
220
229
for _, record := range m.records {
221
230
str := "invalid handle"
222
231
if record.handle != nil {
···
227
236
if record.text != nil {
228
237
bdy = fmt.Sprintf("%s", *record.text)
229
238
}
230
-
s = s + bold.Render(str) + bdy + "\n"
239
+
style := lipgloss.NewStyle().Width(m.width)
240
+
s = s + "\n" + bold.Render(str) + "\n" + style.Render(bdy) + "\n"
231
241
}
232
242
return s
233
243
}
thread_notification.qt
thread_notification.qt
This is a binary file and will not be displayed.