Compare commits

..

No commits in common. "e89137224bceb96b810e6904aa98cc0febd4b8a6" and "70b30a9313655b52e7e55de5a09b86b5fc049dcf" have entirely different histories.

50
main.go
View file

@ -43,9 +43,8 @@ type handler struct {
}
var (
post = flag.String("post", "", "URL to a BlueSky post")
delete = flag.Bool("delete", false, "true/false to delete post")
oldPosts = flag.Float64("oldposttime", 24, "Ignore posts if createdAt more than this many hours ago")
post = flag.String("post", "", "URL to a BlueSky post")
delete = flag.Bool("delete", false, "true/false to delete post")
)
func main() {
@ -190,22 +189,12 @@ func (h *handler) ProcessPost(event *models.Event) error {
ps, _ := h.bsky.ParsePost(event.Commit.Record)
po := ps.GetEmbeds()
cid, _ := strconv.ParseInt(os.Getenv("TG_CHANNEL_ID"), 10, 64)
isEditedPost := false
now := time.Now()
createdAt := ps.CreatedAt
duration := now.Sub(createdAt)
if duration.Hours() > *oldPosts ||
strings.HasPrefix(ps.Text, "@") ||
ps.IsReply() {
if ps.IsReply() { //|| ps.IsQuotePost() {
// don't want to post replies to channel
return nil
}
telegramRecord, telegramRecordErr := h.bsky.Bluesky.GetTelegramData(event.Commit.RKey)
if telegramRecordErr == "" {
isEditedPost = true
}
var captionText string
if ps.IsQuotePost() {
if ps.Embed.Record.Type == "app.bsky.embed.record" {
@ -294,25 +283,20 @@ func (h *handler) ProcessPost(event *models.Event) error {
if len(mediaGroup) == 0 {
log.Print("No mediaGroup to send, see previous error")
} else {
if isEditedPost {
resp, err := h.tg.Send(tgbotapi.NewEditMessageCaption(telegramRecord.ChannelID, telegramRecord.MessageID[0], captionText))
fmt.Println(resp, err)
} else {
resp, _ := h.tg.SendMediaGroup(tgbotapi.NewMediaGroup(cid, mediaGroup))
uri, cid := getLink(event)
var messageIDs []int
for _, msgID := range resp {
messageIDs = append(messageIDs, msgID.MessageID)
}
h.bsky.Bluesky.CommitTelegramResponse(&bsky.TelegramRecord{
ChannelID: resp[0].Chat.ID,
MessageID: messageIDs,
Link: &bsky.Link{
Cid: cid,
URI: uri,
},
}, event.Commit.RKey)
resp, _ := h.tg.SendMediaGroup(tgbotapi.NewMediaGroup(cid, mediaGroup))
uri, cid := getLink(event)
var messageIDs []int
for _, msgID := range resp {
messageIDs = append(messageIDs, msgID.MessageID)
}
h.bsky.Bluesky.CommitTelegramResponse(&bsky.TelegramRecord{
ChannelID: resp[0].Chat.ID,
MessageID: messageIDs,
Link: &bsky.Link{
Cid: cid,
URI: uri,
},
}, event.Commit.RKey)
}
} else {
m := tgbotapi.MessageConfig{}