client

README

auth-client

A simple mqtt client that supports sm9-based authentication

Documentation

Index

• func OfbEncrypt(key, data []byte) ([]byte, error)
• type Client
  • func (c *Client) Connect() error
  • func (c *Client) Disconnect() error
  • func (c *Client) Publish(topic, payload string) error
  • func (c *Client) SetMsgHandler(handler paho.MessageHandler)
  • func (c *Client) Subscribe(topic string) error
• type ClientConfig
• type Sm9Auth
  • func NewSm9Auth(c *Client) *Sm9Auth
  • func (s *Sm9Auth) Authenticate(a *paho.Auth) *paho.Auth
  • func (s *Sm9Auth) Authenticated()
  • func (s *Sm9Auth) GetRandom1(expectedLen int) string
• type User
  • func NewUser(conf *UserConfig) *User
  • func (u *User) GetEncryptMasterPublicKey() *sm9.EncryptMasterPublicKey
  • func (u *User) GetEncryptPrivateKey() *sm9.EncryptPrivateKey
  • func (u *User) GetSignMasterPublicKey() *sm9.SignMasterPublicKey
  • func (u *User) GetSignPrivateKey() *sm9.SignPrivateKey
  • func (u *User) SetEncryptMasterPublicKey(encMasterPublicKey string) error
  • func (u *User) SetEncryptPrivateKey(encPrivateKey string) error
  • func (u *User) SetSignMasterPublicKey(signMasterPublicKey string) error
  • func (u *User) SetSignPrivateKey(signPrivateKey string) error
• type UserConfig

Functions

func OfbEncrypt

func OfbEncrypt(key, data []byte) ([]byte, error)

Types

type Client

type Client struct {
	ServerUrl   *url.URL
	AuthHandler *Sm9Auth
	User        *User
	Cm          *autopaho.ConnectionManager
	Cancel      context.CancelFunc
	Config      *ClientConfig
	MsgHandler  paho.MessageHandler
}

func (*Client) Connect

func (c *Client) Connect() error

func (*Client) Disconnect

func (c *Client) Disconnect() error

func (*Client) Publish

func (c *Client) Publish(topic, payload string) error

func (*Client) SetMsgHandler

func (c *Client) SetMsgHandler(handler paho.MessageHandler)

func (*Client) Subscribe

func (c *Client) Subscribe(topic string) error

type ClientConfig

type ClientConfig struct {
	Name              string
	Topic             string
	Qos               byte
	Keepalive         uint16
	ConnectRetryDelay uint16
	Debug             bool
}

type Sm9Auth

type Sm9Auth struct {
	Random1 string
	Server  *User
	// contains filtered or unexported fields
}

func NewSm9Auth

func NewSm9Auth(c *Client) *Sm9Auth

func (*Sm9Auth) Authenticate

func (s *Sm9Auth) Authenticate(a *paho.Auth) *paho.Auth

func (*Sm9Auth) Authenticated

func (s *Sm9Auth) Authenticated()

func (*Sm9Auth) GetRandom1

func (s *Sm9Auth) GetRandom1(expectedLen int) string

type User

type User struct {
	Uid        []byte
	Hid        byte
	SessionKey []byte
	// contains filtered or unexported fields
}

func NewUser

func NewUser(conf *UserConfig) *User

func (*User) GetEncryptMasterPublicKey

func (u *User) GetEncryptMasterPublicKey() *sm9.EncryptMasterPublicKey

func (*User) GetEncryptPrivateKey

func (u *User) GetEncryptPrivateKey() *sm9.EncryptPrivateKey

func (*User) GetSignMasterPublicKey

func (u *User) GetSignMasterPublicKey() *sm9.SignMasterPublicKey

func (*User) GetSignPrivateKey

func (u *User) GetSignPrivateKey() *sm9.SignPrivateKey

func (*User) SetEncryptMasterPublicKey

func (u *User) SetEncryptMasterPublicKey(encMasterPublicKey string) error

func (*User) SetEncryptPrivateKey

func (u *User) SetEncryptPrivateKey(encPrivateKey string) error

func (*User) SetSignMasterPublicKey

func (u *User) SetSignMasterPublicKey(signMasterPublicKey string) error

func (*User) SetSignPrivateKey

func (u *User) SetSignPrivateKey(signPrivateKey string) error

type UserConfig

type UserConfig struct {
	Uid                    string `yaml:"uid"`
	Hid                    byte   `yaml:"hid"`
	EncryptPrivateKey      string `yaml:"encrypt_private_key"`
	SignPrivateKey         string `yaml:"sign_private_key"`
	EncryptMasterPublicKey string `yaml:"encrypt_master_public_key"`
	SignMasterPublicKey    string `yaml:"sign_master_public_key"`
}