46 行
1.3 KiB
Go
46 行
1.3 KiB
Go
package publisher
|
|
|
|
import (
|
|
"net/url"
|
|
"strings"
|
|
|
|
"github.com/ChimeraCoder/anaconda"
|
|
log "github.com/go-pkgz/lgr"
|
|
"github.com/pkg/errors"
|
|
|
|
"git.lattuga.net/boyska/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("[INFO] 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 to twitter %+v", event.Title)
|
|
api := anaconda.NewTwitterApiWithCredentials(t.AccessToken, t.AccessSecret, t.ConsumerKey, t.ConsumerSecret)
|
|
v := url.Values{}
|
|
v.Set("tweet_mode", "extended")
|
|
msg := formatter(event)
|
|
if _, err := api.PostTweet(msg, v); err != nil {
|
|
return errors.Wrap(err, "can't send to twitter")
|
|
}
|
|
log.Printf("[DEBUG] published to twitter %s", strings.Replace(msg, "\n", " ", -1))
|
|
return nil
|
|
}
|