deviceauthlogic

Documentation

Index

• Variables
• type AccessAuthLogic
  • func NewAccessAuthLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AccessAuthLogic
  • func (l *AccessAuthLogic) AccessAuth(in *dm.AccessAuthReq) (*dm.Response, error)
  • func (l *AccessAuthLogic) Auth(in *dm.AccessAuthReq) (err error)
  • func (l *AccessAuthLogic) DeviceSelfAuth(in *dm.AccessAuthReq) (err error)
  • func (l *AccessAuthLogic) SubSetAuth(in *dm.AccessAuthReq, ld *deviceAuth.LoginDevice, ti *devices.TopicInfo) (err error)
• type DeviceRegisterLogic
  • func NewDeviceRegisterLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceRegisterLogic
  • func (l *DeviceRegisterLogic) DeviceRegister(in *dm.DeviceRegisterReq) (*dm.DeviceRegisterResp, error)
• type DeviceRegisterPayload
• type LoginAuthLogic
  • func NewLoginAuthLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LoginAuthLogic
  • func (l *LoginAuthLogic) LoginAuth(in *dm.LoginAuthReq) (*dm.Response, error)
  • func (l *LoginAuthLogic) UpdateLoginTime()
• type RootCheckLogic
  • func NewRootCheckLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RootCheckLogic
  • func (l *RootCheckLogic) RootCheck(in *dm.RootCheckReq) (*dm.Response, error)

Variables

var (
	AccessMap = map[string]devices.Direction{
		devices.Pub: devices.Up,
		devices.Sub: devices.Down,
	}
	AccessToActionMap = map[string]string{
		devices.Pub: "publish",
		devices.Sub: "subscribe",
	}
)

Types

type AccessAuthLogic

type AccessAuthLogic struct {
	logx.Logger

	GdDB *relationDB.GatewayDeviceRepo
	// contains filtered or unexported fields
}

func NewAccessAuthLogic

func NewAccessAuthLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AccessAuthLogic

func (*AccessAuthLogic) AccessAuth

func (l *AccessAuthLogic) AccessAuth(in *dm.AccessAuthReq) (*dm.Response, error)

AccessAuth 设备操作认证

func (*AccessAuthLogic) Auth

func (l *AccessAuthLogic) Auth(in *dm.AccessAuthReq) (err error)

func (*AccessAuthLogic) DeviceSelfAuth

func (l *AccessAuthLogic) DeviceSelfAuth(in *dm.AccessAuthReq) (err error)

DeviceSelfAuth 设备自己的topic认证

func (*AccessAuthLogic) SubSetAuth

func (l *AccessAuthLogic) SubSetAuth(in *dm.AccessAuthReq,
	ld *deviceAuth.LoginDevice, ti *devices.TopicInfo) (err error)

SubSetAuth 网关代理子设备topic校验

type DeviceRegisterLogic

type DeviceRegisterLogic struct {
	logx.Logger
	PiDB *relationDB.ProductInfoRepo
	DiDB *relationDB.DeviceInfoRepo
	// contains filtered or unexported fields
}

func NewDeviceRegisterLogic

func NewDeviceRegisterLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceRegisterLogic

func (*DeviceRegisterLogic) DeviceRegister

func (l *DeviceRegisterLogic) DeviceRegister(in *dm.DeviceRegisterReq) (*dm.DeviceRegisterResp, error)

设备动态注册

type DeviceRegisterPayload

type DeviceRegisterPayload struct {
	EncryptionType int    `json:"encryptionType"` //加密类型，1表示证书认证，2表示签名认证
	Psk            string `json:"psk"`            //设备密钥，当产品认证类型为签名认证时有此参数。
	ClientCert     string `json:"clientCert"`     //设备证书文件字符串格式，当产品认证类型为证书认证时有此参数
	ClientKey      string `json:"clientKey"`      //设备私钥文件字符串格式，当产品认证类型为证书认证时有此参数
}

type LoginAuthLogic

type LoginAuthLogic struct {
	logx.Logger
	DiDB *relationDB.DeviceInfoRepo
	// contains filtered or unexported fields
}

func NewLoginAuthLogic

func NewLoginAuthLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LoginAuthLogic

func (*LoginAuthLogic) LoginAuth

func (l *LoginAuthLogic) LoginAuth(in *dm.LoginAuthReq) (*dm.Response, error)

func (*LoginAuthLogic) UpdateLoginTime

func (l *LoginAuthLogic) UpdateLoginTime()

type RootCheckLogic

type RootCheckLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewRootCheckLogic

func NewRootCheckLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RootCheckLogic

func (*RootCheckLogic) RootCheck

func (l *RootCheckLogic) RootCheck(in *dm.RootCheckReq) (*dm.Response, error)

鉴定是否是root账号