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

Compare commits

base: astra:bfa829d8c72be0cf4dd74d72777e4ef1fc784bf9
Branches Tags
astra:main
astra:post
astra:linkalias
...
compare: astra:435f3fbb5375ae19f835383e15eb4abb3e307bd5
Branches Tags
astra:main
astra:post
astra:linkalias

2 commits
bfa829d8c7 ... 435f3fbb53

Author SHA1 Message Date
astravexton
435f3fbb53 add delete flag 2025-07-02 16:38:18 +01:00
astravexton
b390554348 update deleteRecord 2025-07-02 16:37:47 +01:00
1 changed files with 16 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

18
main.go
View file

@ -44,7 +44,8 @@ type handler struct {
}
var (
post = flag.String("post", "", "URL to a BlueSky post")
post = flag.String("post", "", "URL to a BlueSky post")
delete = flag.Bool("delete", false, "true/false to delete post")
)
func main() {
@ -85,6 +86,19 @@ func main() {
handle, _ = bskyClient.ResolveHandle(s[1])
}
if *delete {
r, e := h.bsky.Bluesky.GetTelegramData(s[2])
if e == "" {
log.Printf("Found post %s in channel %d, deleting", s[2], r.ChannelID)
m := tgbotapi.NewDeleteMessage(r.ChannelID, r.MessageID)
h.tg.Send(m)
h.bsky.Bluesky.DeleteRecord([]string{s[2], s[1], "blue.zio.bsky2tg.post"})
} else {
log.Printf("Unable to find post %s on PDS", s[2])
}
return
}
postJSON := bskyClient.Bluesky.FetchPost(handle, s[2])
p, _ := json.Marshal(postJSON.Record)
h.ProcessPost(&models.Event{
@ -196,7 +210,7 @@ func (h *handler) HandleEvent(ctx context.Context, event *models.Event) error {
if e == "" {
m := tgbotapi.NewDeleteMessage(r.ChannelID, r.MessageID)
h.tg.Send(m)
h.bsky.Bluesky.DeleteRecord([]string{event.Commit.RKey, event.Did, event.Commit.Collection})
h.bsky.Bluesky.DeleteRecord([]string{event.Commit.RKey, event.Did, "blue.zio.bsky2tg.post"})
}
}