|
@@ -16,16 +16,16 @@ 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 {
|
|
|
- server.Log.Errorf("validate device token error. deviceid : %v, token : %v, error: %v", deviceid, token, err)
|
|
|
- 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 {
|
|
|
+ // server.Log.Errorf("validate device token error. deviceid : %v, token : %v, error: %v", deviceid, token, err)
|
|
|
+ // return err
|
|
|
+ //}
|
|
|
return nil
|
|
|
}
|
|
|
func (mp *MQTTProvider) OnDeviceOnline(args rpcs.ArgsGetOnline, VendorId string) error {
|