68 lines
1.7 KiB
Go
68 lines
1.7 KiB
Go
// Copyright (c) Mainflux
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package sdk
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"net/http"
|
|
"strings"
|
|
|
|
"github.com/mainflux/mainflux/internal/apiutil"
|
|
"github.com/mainflux/mainflux/pkg/errors"
|
|
)
|
|
|
|
const channelParts = 2
|
|
|
|
func (sdk mfSDK) SendMessage(chanName, msg, key string) errors.SDKError {
|
|
chanNameParts := strings.SplitN(chanName, ".", channelParts)
|
|
chanID := chanNameParts[0]
|
|
subtopicPart := ""
|
|
if len(chanNameParts) == channelParts {
|
|
subtopicPart = fmt.Sprintf("/%s", strings.ReplaceAll(chanNameParts[1], ".", "/"))
|
|
}
|
|
|
|
url := fmt.Sprintf("%s/channels/%s/messages%s", sdk.httpAdapterURL, chanID, subtopicPart)
|
|
|
|
_, _, err := sdk.processRequest(http.MethodPost, url, ThingPrefix+key, []byte(msg), nil, http.StatusAccepted)
|
|
|
|
return err
|
|
}
|
|
|
|
func (sdk mfSDK) ReadMessages(chanName, token string) (MessagesPage, errors.SDKError) {
|
|
chanNameParts := strings.SplitN(chanName, ".", channelParts)
|
|
chanID := chanNameParts[0]
|
|
subtopicPart := ""
|
|
if len(chanNameParts) == channelParts {
|
|
subtopicPart = fmt.Sprintf("?subtopic=%s", chanNameParts[1])
|
|
}
|
|
|
|
url := fmt.Sprintf("%s/channels/%s/messages%s", sdk.readerURL, chanID, subtopicPart)
|
|
|
|
header := make(map[string]string)
|
|
header["Content-Type"] = string(sdk.msgContentType)
|
|
|
|
_, body, err := sdk.processRequest(http.MethodGet, url, token, nil, header, http.StatusOK)
|
|
if err != nil {
|
|
return MessagesPage{}, err
|
|
}
|
|
|
|
var mp MessagesPage
|
|
if err := json.Unmarshal(body, &mp); err != nil {
|
|
return MessagesPage{}, errors.NewSDKError(err)
|
|
}
|
|
|
|
return mp, nil
|
|
}
|
|
|
|
func (sdk *mfSDK) SetContentType(ct ContentType) errors.SDKError {
|
|
if ct != CTJSON && ct != CTJSONSenML && ct != CTBinary {
|
|
return errors.NewSDKError(apiutil.ErrUnsupportedContentType)
|
|
}
|
|
|
|
sdk.msgContentType = ct
|
|
|
|
return nil
|
|
}
|