nitterbot/main.go

package main

import (
	"fmt"
	"log"
	"regexp"
	"strings"
	"time"

	"github.com/ekzyis/sn-goapi"
)

var (
	TwitterUrlRegexp = regexp.MustCompile(`^(?:https?:\/\/)?((www\.)?(twitter|x)\.com)\/`)
	NitterUrls       = []string{"nitter.net", "nitter.it", "nitter.cz"}
)

func WaitUntilNext(d time.Duration) {
	now := time.Now()
	dur := now.Truncate(d).Add(d).Sub(now)
	log.Println("sleeping for", dur.Round(time.Second))
	time.Sleep(dur)
}

func CheckNotifications() {
	var prevHasNewNotes bool
	for {
		log.Println("Checking notifications ...")
		hasNewNotes, err := sn.CheckNotifications()
		if err != nil {
			SendToNostr(fmt.Sprint(err))
		} else {
			if !prevHasNewNotes && hasNewNotes {
				// only send on "rising edge"
				SendToNostr("new notifications")
				log.Println("Forwarded notifications to monitoring")
			} else if hasNewNotes {
				log.Println("Notifications already forwarded")
			}
		}
		prevHasNewNotes = hasNewNotes
		WaitUntilNext(time.Hour)
	}
}

func SessionKeepAlive() {
	for {
		log.Println("Refresh session using GET /api/auth/session ...")
		sn.RefreshSession()
		WaitUntilNext(time.Hour)
	}
}

func main() {
	go CheckNotifications()
	go SessionKeepAlive()
	for {
		log.Println("fetching items ...")
		r, err := sn.Items(&sn.ItemsQuery{Sort: "recent", Limit: 21})
		if err != nil {
			SendToNostr(fmt.Sprint(err))
			WaitUntilNext(time.Minute)
			continue
		}

		for _, item := range r.Items {
			if m := TwitterUrlRegexp.FindStringSubmatch(item.Url); m != nil {
				log.Printf("item %d is twitter link\n", item.Id)
				if ItemHasComment(item.Id) {
					log.Printf("item %d already has nitter links comment\n", item.Id)
					continue
				}
				comment := "Nitter links:\n\n"
				for _, nUrl := range NitterUrls {
					nitterLink := strings.Replace(item.Url, m[1], nUrl, 1)
					comment += nitterLink + "\n"
				}
				comment += "\n_Nitter is a free and open source alternative Twitter front-end focused on privacy and performance. "
				comment += "Click [here](https://github.com/zedeus/nitter) for more information._"
				cId, err := sn.CreateComment(item.Id, comment)
				if err != nil {
					SendToNostr(fmt.Sprint(err))
					continue
				}
				log.Printf("created comment %d\n", cId)
				SaveComment(&sn.Comment{Id: cId, Text: comment, ParentId: item.Id})
			} else {
				log.Printf("item %d is not twitter link\n", item.Id)
			}
		}

		WaitUntilNext(time.Minute)
	}
}