client_schedule.go

package jpushclient

import (
	"bytes"
	"encoding/json"
	"strconv"
)

func (c *Client) CreateSingleSchedule(req *ScheduleRequest) (map[string]any, error) {
	link := c.pushUrl + "/v3/schedules"
	buf, err := json.Marshal(req)
	if err != nil {
		return nil, err
	}
	resp, err := c.request("POST", link, bytes.NewReader(buf), false)
	if err != nil {
		return nil, err
	}
	return resp.Map()
}

func (c *Client) GetSchedules(page int) (map[string]any, error) {
	link := c.pushUrl + "/v3/schedules"
	if page > 0 {
		link += "?page=" + strconv.Itoa(page)
	}
	resp, err := c.request("GET", link, nil, false)
	if err != nil {
		return nil, err
	}
	return resp.Map()
}

func (c *Client) GetSchedule(id string) (map[string]any, error) {
	link := c.pushUrl + "/v3/schedules/" + id
	resp, err := c.request("GET", link, nil, false)
	if err != nil {
		return nil, err
	}
	return resp.Map()
}

func (c *Client) GetMsgIds(id string) (map[string]any, error) {
	link := c.pushUrl + "/v3/schedules/" + id + "/msg_ids"
	resp, err := c.request("GET", link, nil, false)
	if err != nil {
		return nil, err
	}
	return resp.Map()
}

func (c *Client) UpdateSingleSchedule(id string, req *ScheduleRequest) (map[string]any, error) {
	link := c.pushUrl + "/v3/schedules/" + id
	buf, err := json.Marshal(req)
	if err != nil {
		return nil, err
	}
	resp, err := c.request("PUT", link, bytes.NewReader(buf), false)
	if err != nil {
		return nil, err
	}
	return resp.Map()
}

func (c *Client) DeleteSchedule(id string) ([]byte, error) {
	link := c.pushUrl + "/v3/schedules/" + id
	resp, err := c.request("DELETE", link, nil, false)
	if err != nil {
		return nil, err
	}
	return resp.Bytes(), nil
}