Login user,passwd.
(ctx context.Context, req *meta.GateUserLoginRequest)
| 234 | |
| 235 | // Login user,passwd. |
| 236 | func (g *Gate) Login(ctx context.Context, req *meta.GateUserLoginRequest) (*meta.GateUserLoginResponse, error) { |
| 237 | log.Debug("Gate Login") |
| 238 | s, err := g.getSession(ctx) |
| 239 | if err != nil { |
| 240 | return &meta.GateUserLoginResponse{Header: &meta.ResponseHeader{Code: util.ErrorGetSession, Msg: err.Error()}}, nil |
| 241 | } |
| 242 | |
| 243 | log.Debugf("Login user:%v password:%v", req.User, req.Password) |
| 244 | id, err := g.store.auth(req.User, req.Password) |
| 245 | if err != nil { |
| 246 | log.Errorf("auth error:%v", err) |
| 247 | return &meta.GateUserLoginResponse{Header: &meta.ResponseHeader{Code: util.ErrorAuth, Msg: err.Error()}}, nil |
| 248 | } |
| 249 | |
| 250 | g.online(s, id) |
| 251 | |
| 252 | //订阅消息 |
| 253 | if err := g.notice.Subscribe(s.getID(), g.host); err != nil { |
| 254 | return &meta.GateUserLoginResponse{Header: &meta.ResponseHeader{Code: util.ErrorSubscribe, Msg: err.Error()}}, nil |
| 255 | } |
| 256 | |
| 257 | return &meta.GateUserLoginResponse{ID: id}, nil |
| 258 | } |
| 259 | |
| 260 | // Logout nil. |
| 261 | func (g *Gate) Logout(ctx context.Context, req *meta.GateUserLogoutRequest) (*meta.GateUserLogoutResponse, error) { |