37 lines
986 B
Go
37 lines
986 B
Go
package publisher
|
|
|
|
import (
|
|
"log"
|
|
"net/url"
|
|
|
|
"github.com/ChimeraCoder/anaconda"
|
|
"github.com/umputun/rss2twitter/app/rss"
|
|
)
|
|
|
|
// Interface for publishers
|
|
type Interface interface {
|
|
Publish(event rss.Event, formatter func(rss.Event) string) error
|
|
}
|
|
|
|
// Stdout implements publisher.Interface and sends to stdout
|
|
type Stdout struct{}
|
|
|
|
// Publish to logger
|
|
func (s Stdout) Publish(event rss.Event, formatter func(rss.Event) string) error {
|
|
log.Printf("[EVENT] %s", formatter(event))
|
|
return nil
|
|
}
|
|
|
|
// Twitter implements publisher.Interface and sends to twitter
|
|
type Twitter struct {
|
|
ConsumerKey, ConsumerSecret string
|
|
AccessToken, AccessSecret string
|
|
}
|
|
|
|
// Publish to twitter
|
|
func (t Twitter) Publish(event rss.Event, formatter func(rss.Event) string) error {
|
|
log.Printf("[INFO] publish %+v", event)
|
|
api := anaconda.NewTwitterApiWithCredentials(t.AccessToken, t.AccessSecret, t.ConsumerKey, t.ConsumerSecret)
|
|
_, err := api.PostTweet(formatter(event), url.Values{})
|
|
return err
|
|
}
|