package controllers

import (
	"basic.com/valib/bhomeclient.git"
	"basic.com/valib/logger.git"
	"vamicro/system-service/serf"
)

type ProxySync struct {
}

/**
代理支持所有应用广播同步消息到serf集群中
*/
func (ps *ProxySync) Sync(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
	type PSyncVo struct {
		Body string `json:"body"`
	}
	var reqBody PSyncVo
	err := c.BindJSON(&reqBody)
	if err != nil {
		return &bhomeclient.Reply{Msg: err.Error()}
	}
	err = serf.SyncProxy(serf.DataSystemSerfSubscribe, []byte(reqBody.Body))
	if err != nil {
		logger.Error("SyncProxy err:", err)
		return &bhomeclient.Reply{Msg: err.Error()}
	}
	return &bhomeclient.Reply{Success: true, Msg: "同步成功"}
}