diff --git a/main.go b/main.go index 7200cb2..cf3a4a4 100644 --- a/main.go +++ b/main.go @@ -29,7 +29,8 @@ import ( const ( serverAddr = "wss://jetstream2.us-west.bsky.network/subscribe" // serverAddr = "wss://stream.zio.blue/subscribe" - postFormat = "%s\n—\nšŸ¦‹ @%s" + postFormat = "%s\n—\nšŸ¦‹ @%s" + quotePostFormat = "
%s
\nāž”ļø @%s\n—\nšŸ¦‹ @%s" ) type handler struct { @@ -178,7 +179,7 @@ func (h *handler) ProcessPost(event *models.Event) error { if ps.Embed.Record.Type == "app.bsky.embed.record" { handle, _ := h.bsky.GetHandleFromDID(strings.Split(ps.Embed.Record.Record.URI, "/")[2]) captionText = fmt.Sprintf( - "
%s
\nāž”ļø @%s\n—\nšŸ¦‹ @%s", + quotePostFormat, ps.ProcessFacets(), strings.Split(ps.Embed.Record.Record.URI, "/")[2], strings.Split(ps.Embed.Record.Record.URI, "/")[4], @@ -189,7 +190,7 @@ func (h *handler) ProcessPost(event *models.Event) error { } else { handle, _ := h.bsky.GetHandleFromDID(strings.Split(ps.Embed.Record.URI, "/")[2]) captionText = fmt.Sprintf( - "
%s
\nāž”ļø @%s\n—\nšŸ¦‹ @%s", + quotePostFormat, ps.ProcessFacets(), strings.Split(ps.Embed.Record.URI, "/")[2], strings.Split(ps.Embed.Record.URI, "/")[4], @@ -231,6 +232,7 @@ func (h *handler) ProcessPost(event *models.Event) error { resp, _ := http.Get(buildBlobURL(h.bsky.Bluesky.Cfg.PDSURL, h.bsky.Bluesky.Cfg.DID, media.URI)) defer resp.Body.Close() f, _ := os.Create(media.URI + ".mp4") + defer f.Close() io.Copy(f, resp.Body) f.Seek(0, 0) mediaAdd := tgbotapi.NewInputMediaVideo(tgbotapi.FileReader{Name: "video.mp4", Reader: f})