Compare commits

..

4 Commits

Author SHA1 Message Date
ekzyis 60b4af4139 Fix coracle.social parsing 2024-07-03 09:40:22 +02:00
ekzyis 1880916418 Update to snappy v0.5.2 2024-07-03 09:40:22 +02:00
ekzyis 0309c953bd Use xcancel.com as nitter instance
Apparently, nitter is back via https://xcancel.com/
2024-07-03 08:42:42 +02:00
ekzyis a719b892d4 Rename sqlite file 2024-07-03 08:42:10 +02:00
5 changed files with 54 additions and 54 deletions

View File

@ -1 +1 @@
SN_AUTH_COOKIE=
SN_API_KEY=

4
db.go
View File

@ -5,7 +5,7 @@ import (
"fmt"
"log"
"github.com/ekzyis/sn-goapi"
sn "github.com/ekzyis/snappy"
_ "github.com/mattn/go-sqlite3"
)
@ -15,7 +15,7 @@ var (
func init() {
var err error
db, err = sql.Open("sqlite3", "unpaywall.sqlite3")
db, err = sql.Open("sqlite3", "nitterbot.sqlite3")
if err != nil {
log.Fatal(err)
}

7
go.mod
View File

@ -3,11 +3,6 @@ module git.ekzyis.com/ekzyis/unpaywall
go 1.21.0
require (
github.com/ekzyis/sn-goapi v0.3.3
github.com/ekzyis/snappy v0.5.2
github.com/mattn/go-sqlite3 v1.14.17
)
require (
github.com/joho/godotenv v1.5.1 // indirect
github.com/namsral/flag v1.7.4-pre // indirect
)

10
go.sum
View File

@ -1,10 +1,4 @@
github.com/ekzyis/sn-goapi v0.3.2 h1:BGY2tOD9IZD40UXUpexysWoC+eLEoUs7JRo9FQ37S6M=
github.com/ekzyis/sn-goapi v0.3.2/go.mod h1:FObbYr/NXgnXNWU+EwiWKoWQy+wAaRS6AoW3NgsJ/Oo=
github.com/ekzyis/sn-goapi v0.3.3 h1:5WHGLyYVPwZ12lQrRD40eM+gjWEpDdgdWTshwL8CDEE=
github.com/ekzyis/sn-goapi v0.3.3/go.mod h1:FObbYr/NXgnXNWU+EwiWKoWQy+wAaRS6AoW3NgsJ/Oo=
github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
github.com/ekzyis/snappy v0.5.2 h1:3dZyj3Kz7fV3OStllq/koL6d5qNfBRK+4UB2L3RNmiQ=
github.com/ekzyis/snappy v0.5.2/go.mod h1:BxJwdGlCwUw0Q5pQzBr59weAIS6pkVdivBBaZkkWTSo=
github.com/mattn/go-sqlite3 v1.14.17 h1:mCRHCLDUBXgpKAqIKsaAaAsrAlbkeomtRFKXh2L6YIM=
github.com/mattn/go-sqlite3 v1.14.17/go.mod h1:2eHXhiwb8IkHr+BDWZGa96P6+rkvnG63S2DGjv9HUNg=
github.com/namsral/flag v1.7.4-pre h1:b2ScHhoCUkbsq0d2C15Mv+VU8bl8hAXV8arnWiOHNZs=
github.com/namsral/flag v1.7.4-pre/go.mod h1:OXldTctbM6SWH1K899kPZcf65KxJiD7MsceFUpB5yDo=

85
main.go
View File

@ -1,13 +1,15 @@
package main
import (
"bufio"
"fmt"
"log"
"os"
"regexp"
"strings"
"time"
"github.com/ekzyis/sn-goapi"
sn "github.com/ekzyis/snappy"
)
type NostrClient struct {
@ -21,7 +23,7 @@ var (
// - https://github.com/zedeus/nitter/wiki/Instances
// - https://status.d420.de/
NitterClearnetUrls = []string{
"nitter.privacydev.net",
"xcancel.com",
}
// since v0.4.0, bot also replaces nostr links with nostr.com so users can pick their client
@ -33,7 +35,7 @@ var (
`|iris\.to\/` +
`|highlighter\.com\/(?:a\/)?` +
`|nostter\.app\/` +
`|coracle\.social\/` +
`|coracle\.social\/(?:notes\/)?` +
`|satellite\.earth\/` +
`|nostrudel\.ninja\/(?:#\/n\/)?` +
`)((note|nevent)[a-zA-Z0-9]+)$`)
@ -57,41 +59,17 @@ func WaitUntilNext(d time.Duration) {
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()
loadEnv()
c := sn.NewClient(
sn.WithBaseUrl(os.Getenv("SN_BASE_URL")),
sn.WithApiKey(os.Getenv("SN_API_KEY")),
)
for {
log.Println("fetching items ...")
r, err := sn.Items(&sn.ItemsQuery{Sort: "recent", Limit: 21})
r, err := c.Items(&sn.ItemsQuery{Sort: "recent", Limit: 21})
if err != nil {
log.Println(err)
SendToNostr(fmt.Sprint(err))
@ -114,7 +92,7 @@ func main() {
comment = strings.TrimRight(comment, "| ")
comment += "\n\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)
cId, err := c.CreateComment(item.Id, comment)
if err != nil {
log.Println(err)
SendToNostr(fmt.Sprint(err))
@ -137,7 +115,7 @@ func main() {
comment += fmt.Sprintf("[%s](%s) | ", client.Name, client.Url+noteId)
}
comment = strings.TrimRight(comment, "| ")
cId, err := sn.CreateComment(item.Id, comment)
cId, err := c.CreateComment(item.Id, comment)
if err != nil {
log.Println(err)
SendToNostr(fmt.Sprint(err))
@ -153,3 +131,36 @@ func main() {
WaitUntilNext(time.Minute)
}
}
func loadEnv() {
var (
f *os.File
s *bufio.Scanner
err error
)
if f, err = os.Open(".env"); err != nil {
log.Fatalf("error opening .env: %v", err)
}
defer f.Close()
s = bufio.NewScanner(f)
s.Split(bufio.ScanLines)
for s.Scan() {
line := s.Text()
parts := strings.SplitN(line, "=", 2)
// Check if we have exactly 2 parts (key and value)
if len(parts) == 2 {
os.Setenv(parts[0], parts[1])
} else {
log.Fatalf(".env: invalid line: %s\n", line)
}
}
// Check for errors during scanning
if err = s.Err(); err != nil {
fmt.Println("error scanning .env:", err)
}
}