ping rpc

ping.go

@@ -1,30 +1,29 @@
 package main
 
 import (
+	"bytes"
+	"encoding/xml"
 	"io/ioutil"
 	"net/http"
 	"net/url"
 
+	"github.com/eiblog/eiblog/setting"
 	"github.com/eiblog/utils/logd"
 )
 
-type Feeder interface {
+type Pinger interface {
 	PingFunc(url string)
 }
 
 // superfeedr
 // http://<your-hub-name>.superfeedr.com/
-type Superfeedr struct {
-	URL string
-}
+type superfeedr struct{}
 
-func (f *Superfeedr) PingFunc(urls ...string) {
+func (_ *superfeedr) PingFunc(slug string) {
 	vals := url.Values{}
 	vals.Set("hub.mode", "publish")
-	for _, u := range urls {
-		vals.Add("hub.url", u)
-	}
-	res, err := http.PostForm(f.URL, vals)
+	vals.Add("hub.url", "https://"+setting.Conf.Mode.Domain+"/post/"+slug+".html")
+	res, err := http.PostForm(setting.Conf.FeedrURL, vals)
 	if err != nil {
 		logd.Error(err)
 		return
@@ -39,3 +38,70 @@ func (f *Superfeedr) PingFunc(urls ...string) {
 		logd.Error(string(data))
 	}
 }
+
+// google baidu
+// params
+// BlogName string `xml:"param>value>string"`
+// HomePage string `xml:"param>value>string"`
+// Article  string `xml:"param>value>string"`
+// RSS_URL  string `xml:"param>value>string"`
+type pingRPC struct {
+	XMLName    xml.Name `xml:"methodCall"`
+	MethodName string   `xml:"methodName"`
+	Params     struct {
+		Param [4]rpcValue `xml:"param"`
+	} `xml:"params"`
+}
+
+type rpcValue struct {
+	Value string `xml:"value>string"`
+}
+
+func (p *pingRPC) PingFunc(slug string) {
+	p.Params.Param[1].Value = "https://" + setting.Conf.Mode.Domain + "/post/" + slug + ".html"
+	buf := &bytes.Buffer{}
+	buf.WriteString(xml.Header)
+	enc := xml.NewEncoder(buf)
+	if err := enc.Encode(p); err != nil {
+		logd.Error(err)
+		return
+	}
+	for _, url := range setting.Conf.PingRPCs {
+		rep, err := http.Post(url, "text/xml", buf)
+		if err != nil {
+			logd.Error(err)
+			continue
+		}
+		defer rep.Body.Close()
+		data, err := ioutil.ReadAll(rep.Body)
+		if err != nil {
+			logd.Error(err)
+			continue
+		}
+		logd.Print(string(data))
+		if rep.StatusCode != 200 {
+			logd.Error(string(data))
+			continue
+		}
+	}
+}
+
+var Pings []Pinger
+
+func init() {
+	Pings = append(Pings, &superfeedr{})
+	pr := &pingRPC{MethodName: "weblogUpdates.extendedPing"}
+	pr.Params.Param = [4]rpcValue{
+		0: rpcValue{Value: Ei.BTitle},
+		1: rpcValue{Value: "https://" + setting.Conf.Mode.Domain},
+		2: rpcValue{},
+		3: rpcValue{Value: "https://" + setting.Conf.Mode.Domain + "/rss.html"},
+	}
+	Pings = append(Pings, pr)
+}
+
+func DoPings(slug string) {
+	for _, p := range Pings {
+		go p.PingFunc(slug)
+	}
+}