qiniuproxy_log

qiniuproxy_log

package main

import (
	"fmt"
	"io/ioutil"
	"log"
	"net/http"
	"os"
	"strings"
)

func main() {

	fileName := "listen.log"

	logFile, errlog := os.Create(fileName)

	if errlog != nil {
		log.Fatalln("open file error !")
	}

	mainBugLog := log.New(logFile, "[Debug]", log.LstdFlags)

	mainBugLog.Println("main message here")

	fmt.Println("come on...")

	http.HandleFunc("/xunlei_qiniu", ProxyServer)

	err := http.ListenAndServe(":80", nil)

	if err != nil {
		log.Fatal("ListenAndServe:", err)
	}

}

// proxyServer
func ProxyServer(w http.ResponseWriter, req *http.Request) {

	fileName := "ProxyServer.log"

	logFile, errlog := os.Create(fileName)

	if errlog != nil {
		log.Fatalln("open file error !")
	}

	proxyBugLog := log.New(logFile, "[Debug]", log.LstdFlags)

	proxyBugLog.Println("ProxyServer message here")

	proxyBugLog.Println(req.Method)
	proxyBugLog.Println(req.Body)

	rb, _ := ioutil.ReadAll(req.Body)
	str := strings.Replace(string(rb), "ret=", "", 1)
	proxyBugLog.Println(str)
	httpDo(str)

}

func httpDo(str string) {

	fileName := "httpDo.log"

	logFile, errlog := os.Create(fileName)

	if errlog != nil {
		log.Fatalln("open file error !")
	}

	httpDoBugLog := log.New(logFile, "[Debug]", log.LstdFlags)

	client := &http.Client{}

	req, err := http.NewRequest("POST", "http://qiniu.com/path_qiniu", strings.NewReader(str))

	if err != nil {
		httpDoBugLog.Println(err)
	}
	req.Header.Set("Content-Type", "text/plain")
	resp, err := client.Do(req)
	defer resp.Body.Close()
	body, err := ioutil.ReadAll(resp.Body)

	httpDoBugLog.Println(string(body))
}