|
@@ -17,15 +17,15 @@ func NewMQTTProvider() *MQTTProvider {
|
|
|
}
|
|
|
|
|
|
func (mp *MQTTProvider) ValidateDeviceToken(deviceid string, token []byte) error {
|
|
|
- //args := rpcs.ArgsValidateDeviceAccessToken{
|
|
|
- // Id: deviceid,
|
|
|
- // AccessToken: token,
|
|
|
- //}
|
|
|
- //reply := rpcs.ReplyValidateDeviceAccessToken{}
|
|
|
- //err := server.RPCCallByName(nil, rpcs.DeviceManagerName, "DeviceManager.ValidateDeviceAccessToken", args, &reply)
|
|
|
- //if err != nil {
|
|
|
- // return err
|
|
|
- //}
|
|
|
+ args := rpcs.ArgsValidateDeviceAccessToken{
|
|
|
+ Id: deviceid,
|
|
|
+ AccessToken: token,
|
|
|
+ }
|
|
|
+ reply := rpcs.ReplyValidateDeviceAccessToken{}
|
|
|
+ err := server.RPCCallByName(nil, rpcs.DeviceManagerName, "DeviceManager.ValidateDeviceAccessToken", args, &reply)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
return nil
|
|
|
}
|
|
|
func (mp *MQTTProvider) OnDeviceOnline(args rpcs.ArgsGetOnline, VendorId string) error {
|