package clt_client

import (
	"bytes"
	"errors"
	"github.com/sirupsen/logrus"
	"io"
	"io/ioutil"
	"lc/common/mqtt"
	"net/http"
)

// SwitchProgram 切换节目
func (c cltclient) SwitchProgram(m mqtt.Message, baseurl string) {
	var p Programm
	m.PayloadJSON(&p)
	url := baseurl + "vsns/sources/lan/vsns/" + p.Name + ".vsn/activated"
	request, err := http.NewRequest("PUT", url, nil)
	if err != nil {
		logrus.Errorf("Newrequest出错:%v", err)
		return
	}
	request.Header.Set("Accept", "application/json")
	resp, err := c.HttpClient.Do(request)
	if err != nil {
		logrus.Errorf("http错误%v", err)
		return
	}
	defer resp.Body.Close()
	ioutil.ReadAll(resp.Body)
}

// brightness
func (c cltclient) CommonPut(payload []byte, url string) error {
	var r io.Reader
	if payload == nil {
		return errors.New("func CommonPut error PUT操作消息体不能为空!")
	} else {
		r = bytes.NewReader(payload)
	}
	req, err := http.NewRequest("PUT", url, r)
	req.Header.Add("Content-Type", "application/json")
	resp, err := c.HttpClient.Do(req)
	if err != nil {
		return err
	}
	defer resp.Body.Close()
	ioutil.ReadAll(resp.Body)
	return nil
}