package main

import (
    "encoding/json"
    "fmt"
    "io/ioutil"
    "log"
    "os"
    "os/signal"
    "syscall"
    "time"
)

//全局自定义拦截
var intercept []Intercept


var filename string = "intercept.json"

type Intercept struct {
    Url        string            `json:"url"`
    Method     string            `json:"method"`
    RespHeader map[string]string `json:"resp_header"`
    RespBody   interface{}       `json:"resp_body"`
    RespCode   int               `json:"resp_code"`
}

//读取自定义响应文件
func Read_resp() {
    intercept_data, err := ioutil.ReadFile(filename)
    if err != nil {
        log.Fatalln(err)
    }
    err = json.Unmarshal(intercept_data, &intercept)
    if err != nil {
        log.Fatalln(err)
    }
}

func main() {
    //初始读取
    Read_resp()

    //监听信号
    sig := make(chan os.Signal, 1)
    signal.Notify(sig, syscall.SIGUSR1)
    go func() {
        for {
            select {
            //获取到信号，再次执行
            case <-sig:
                Read_resp()
            }
        }
    }()

    //循环打印
    for {
        time.Sleep(1 * time.Second)
        if len(intercept) > 0 {
            fmt.Println(intercept[0].RespBody)
        }
    }
}