astra/bsky2tg
1
0
Fork 0
Code Issues Pull requests Packages 1 Activity Actions

Compare commits

base: astra:04e29ed525400b4681a3e0f6a9c772db46a64378
Branches Tags
astra:main
astra:post
astra:linkalias
...
compare: astra:878efc08d057b8fc5ff012f7aaa45021d862ff9f
Branches Tags
astra:main
astra:post
astra:linkalias

2 commits
04e29ed525 ... 878efc08d0

Author SHA1 Message Date
astravexton
878efc08d0 close file 2025-06-06 09:54:10 +01:00
astravexton
3a03a056e9 Change quotePostFormat 2025-06-05 07:28:22 +01:00
1 changed files with 5 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
main.go
View file

@ -30,6 +30,7 @@ const (
serverAddr = "wss://jetstream2.us-west.bsky.network/subscribe" serverAddr = "wss://jetstream2.us-west.bsky.network/subscribe"
// serverAddr = "wss://stream.zio.blue/subscribe" // serverAddr = "wss://stream.zio.blue/subscribe"
postFormat = "%s\n—\n<a href=\"https://bsky.app/profile/%s/post/%s\">🦋 @%s</a>" postFormat = "%s\n—\n<a href=\"https://bsky.app/profile/%s/post/%s\">🦋 @%s</a>"
quotePostFormat = "<blockquote>%s</blockquote>\n<a href=\"https://bsky.app/profile/%s/post/%s\">➡️ @%s</a>\n—\n<a href=\"https://bsky.app/profile/%s/post/%s\">🦋 @%s</a>"
) )
type handler struct { type handler struct {
@ -178,7 +179,7 @@ func (h *handler) ProcessPost(event *models.Event) error {
if ps.Embed.Record.Type == "app.bsky.embed.record" { if ps.Embed.Record.Type == "app.bsky.embed.record" {
handle, _ := h.bsky.GetHandleFromDID(strings.Split(ps.Embed.Record.Record.URI, "/")[2]) handle, _ := h.bsky.GetHandleFromDID(strings.Split(ps.Embed.Record.Record.URI, "/")[2])
captionText = fmt.Sprintf( captionText = fmt.Sprintf(
"<blockquote>%s</blockquote>\n<a href=\"https://bsky.app/profile/%s/post/%s\">➡️ @%s</a>\n—\n<a href=\"https://bsky.app/profile/%s/post/%s\">🦋 @%s</a>", quotePostFormat,
ps.ProcessFacets(), ps.ProcessFacets(),
strings.Split(ps.Embed.Record.Record.URI, "/")[2], strings.Split(ps.Embed.Record.Record.URI, "/")[2],
strings.Split(ps.Embed.Record.Record.URI, "/")[4], strings.Split(ps.Embed.Record.Record.URI, "/")[4],
@ -189,7 +190,7 @@ func (h *handler) ProcessPost(event *models.Event) error {
} else { } else {
handle, _ := h.bsky.GetHandleFromDID(strings.Split(ps.Embed.Record.URI, "/")[2]) handle, _ := h.bsky.GetHandleFromDID(strings.Split(ps.Embed.Record.URI, "/")[2])
captionText = fmt.Sprintf( captionText = fmt.Sprintf(
"<blockquote>%s</blockquote>\n<a href=\"https://bsky.app/profile/%s/post/%s\">➡️ @%s</a>\n—\n<a href=\"https://bsky.app/profile/%s/post/%s\">🦋 @%s</a>", quotePostFormat,
ps.ProcessFacets(), ps.ProcessFacets(),
strings.Split(ps.Embed.Record.URI, "/")[2], strings.Split(ps.Embed.Record.URI, "/")[2],
strings.Split(ps.Embed.Record.URI, "/")[4], 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)) resp, _ := http.Get(buildBlobURL(h.bsky.Bluesky.Cfg.PDSURL, h.bsky.Bluesky.Cfg.DID, media.URI))
defer resp.Body.Close() defer resp.Body.Close()
f, _ := os.Create(media.URI + ".mp4") f, _ := os.Create(media.URI + ".mp4")
defer f.Close()
io.Copy(f, resp.Body) io.Copy(f, resp.Body)
f.Seek(0, 0) f.Seek(0, 0)
mediaAdd := tgbotapi.NewInputMediaVideo(tgbotapi.FileReader{Name: "video.mp4", Reader: f}) mediaAdd := tgbotapi.NewInputMediaVideo(tgbotapi.FileReader{Name: "video.mp4", Reader: f})