From f9b6c39353cac7fbc26882816727759155b60bfb Mon Sep 17 00:00:00 2001 From: sirrow Date: Sun, 16 Mar 2025 19:24:56 +0900 Subject: [PATCH] change error handling --- main.go | 7 ++++++- output/bluesky.go | 10 ++++------ output/output.go | 1 + output/twitter.go | 8 ++++---- 4 files changed, 15 insertions(+), 11 deletions(-) diff --git a/main.go b/main.go index ce9ce85..02e9383 100644 --- a/main.go +++ b/main.go @@ -23,7 +23,12 @@ func main() { for tweet := range tweetchannel { fmt.Println(tweet) for _, output := range outputs { - output.Write(tweet) + err := output.Write(tweet) + if err != nil { + errstr := fmt.Sprintf("%s Error: %s", output.GetName(), err) + fmt.Fprintln(os.Stderr, errstr) + d.Write(errstr) + } } } } diff --git a/output/bluesky.go b/output/bluesky.go index 9846ecd..a50f114 100644 --- a/output/bluesky.go +++ b/output/bluesky.go @@ -2,9 +2,7 @@ package output import ( "context" - "fmt" "log" - "os" "time" "github.com/bluesky-social/indigo/api/atproto" @@ -60,9 +58,9 @@ func (bo *blueskyoutput) Write(str string) error { } _, recerr := atproto.RepoCreateRecord(context.TODO(), cli, Recordinput) - if recerr != nil { - fmt.Fprint(os.Stderr, "bsky err: ") - fmt.Fprintln(os.Stderr, recerr) - } return recerr } + +func (bo *blueskyoutput) GetName() string { + return "bluesky" +} diff --git a/output/output.go b/output/output.go index f81c8ac..cdad68e 100644 --- a/output/output.go +++ b/output/output.go @@ -2,4 +2,5 @@ package output type OutputInterface interface { Write(string) error + GetName() string } diff --git a/output/twitter.go b/output/twitter.go index 8481972..6006e1b 100644 --- a/output/twitter.go +++ b/output/twitter.go @@ -47,9 +47,9 @@ func (to *twitteroutput) Write(str string) error { } _, err := managetweet.Create(context.Background(), to.client, p) - if err != nil { - fmt.Fprint(os.Stderr, "twitter err: ") - fmt.Fprintln(os.Stderr, err) - } return err } + +func (to *twitteroutput) GetName() string { + return "twitter" +}