// Copyright (c) Mainflux // SPDX-License-Identifier: Apache-2.0 package sdk import ( "bytes" "encoding/json" "fmt" "io/ioutil" "net/http" "strings" "github.com/mainflux/mainflux/pkg/errors" ) const channelsEndpoint = "channels" func (sdk mfSDK) CreateChannel(c Channel, token string) (string, error) { data, err := json.Marshal(c) if err != nil { return "", err } url := createURL(sdk.baseURL, sdk.thingsPrefix, channelsEndpoint) req, err := http.NewRequest(http.MethodPost, url, bytes.NewReader(data)) if err != nil { return "", err } resp, err := sdk.sendRequest(req, token, string(CTJSON)) if err != nil { return "", err } if resp.StatusCode != http.StatusCreated { return "", errors.Wrap(ErrFailedCreation, errors.New(resp.Status)) } id := strings.TrimPrefix(resp.Header.Get("Location"), fmt.Sprintf("/%s/", channelsEndpoint)) return id, nil } func (sdk mfSDK) CreateChannels(chs []Channel, token string) ([]Channel, error) { data, err := json.Marshal(chs) if err != nil { return []Channel{}, err } endpoint := fmt.Sprintf("%s/%s", channelsEndpoint, "bulk") url := createURL(sdk.baseURL, sdk.channelsPrefix, endpoint) req, err := http.NewRequest(http.MethodPost, url, bytes.NewReader(data)) if err != nil { return []Channel{}, err } resp, err := sdk.sendRequest(req, token, string(CTJSON)) if err != nil { return []Channel{}, err } defer resp.Body.Close() if resp.StatusCode != http.StatusCreated { return []Channel{}, errors.Wrap(ErrFailedCreation, errors.New(resp.Status)) } body, err := ioutil.ReadAll(resp.Body) if err != nil { return []Channel{}, err } var ccr createChannelsRes if err := json.Unmarshal(body, &ccr); err != nil { return []Channel{}, err } return ccr.Channels, nil } func (sdk mfSDK) Channels(token string, offset, limit uint64, name string) (ChannelsPage, error) { endpoint := fmt.Sprintf("%s?offset=%d&limit=%d&name=%s", channelsEndpoint, offset, limit, name) url := createURL(sdk.baseURL, sdk.thingsPrefix, endpoint) req, err := http.NewRequest(http.MethodGet, url, nil) if err != nil { return ChannelsPage{}, err } resp, err := sdk.sendRequest(req, token, string(CTJSON)) if err != nil { return ChannelsPage{}, err } defer resp.Body.Close() body, err := ioutil.ReadAll(resp.Body) if err != nil { return ChannelsPage{}, err } if resp.StatusCode != http.StatusOK { return ChannelsPage{}, errors.Wrap(ErrFailedFetch, errors.New(resp.Status)) } var cp ChannelsPage if err := json.Unmarshal(body, &cp); err != nil { return ChannelsPage{}, err } return cp, nil } func (sdk mfSDK) ChannelsByThing(token, thingID string, offset, limit uint64, connected bool) (ChannelsPage, error) { endpoint := fmt.Sprintf("things/%s/channels?offset=%d&limit=%d&connected=%t", thingID, offset, limit, connected) url := createURL(sdk.baseURL, sdk.thingsPrefix, endpoint) req, err := http.NewRequest(http.MethodGet, url, nil) if err != nil { return ChannelsPage{}, err } resp, err := sdk.sendRequest(req, token, string(CTJSON)) if err != nil { return ChannelsPage{}, err } defer resp.Body.Close() body, err := ioutil.ReadAll(resp.Body) if err != nil { return ChannelsPage{}, err } if resp.StatusCode != http.StatusOK { return ChannelsPage{}, errors.Wrap(ErrFailedFetch, errors.New(resp.Status)) } var cp ChannelsPage if err := json.Unmarshal(body, &cp); err != nil { return ChannelsPage{}, err } return cp, nil } func (sdk mfSDK) Channel(id, token string) (Channel, error) { endpoint := fmt.Sprintf("%s/%s", channelsEndpoint, id) url := createURL(sdk.baseURL, sdk.thingsPrefix, endpoint) req, err := http.NewRequest(http.MethodGet, url, nil) if err != nil { return Channel{}, err } resp, err := sdk.sendRequest(req, token, string(CTJSON)) if err != nil { return Channel{}, err } defer resp.Body.Close() body, err := ioutil.ReadAll(resp.Body) if err != nil { return Channel{}, err } if resp.StatusCode != http.StatusOK { return Channel{}, errors.Wrap(ErrFailedFetch, errors.New(resp.Status)) } var c Channel if err := json.Unmarshal(body, &c); err != nil { return Channel{}, err } return c, nil } func (sdk mfSDK) UpdateChannel(c Channel, token string) error { data, err := json.Marshal(c) if err != nil { return err } endpoint := fmt.Sprintf("%s/%s", channelsEndpoint, c.ID) url := createURL(sdk.baseURL, sdk.thingsPrefix, endpoint) req, err := http.NewRequest(http.MethodPut, url, bytes.NewReader(data)) if err != nil { return err } resp, err := sdk.sendRequest(req, token, string(CTJSON)) if err != nil { return err } if resp.StatusCode != http.StatusOK { return errors.Wrap(ErrFailedUpdate, errors.New(resp.Status)) } return nil } func (sdk mfSDK) DeleteChannel(id, token string) error { endpoint := fmt.Sprintf("%s/%s", channelsEndpoint, id) url := createURL(sdk.baseURL, sdk.thingsPrefix, endpoint) req, err := http.NewRequest(http.MethodDelete, url, nil) if err != nil { return err } resp, err := sdk.sendRequest(req, token, string(CTJSON)) if err != nil { return err } if resp.StatusCode != http.StatusNoContent { return errors.Wrap(ErrFailedRemoval, errors.New(resp.Status)) } return nil }