Method acc

server/session.go:372–452

Account creation

(msg *ClientComMessage)

// Account creation
func (s *Session) acc(msg *ClientComMessage) {
	if msg.Acc.Auth == nil {
		s.QueueOut(ErrMalformed(msg.Acc.Id, "", msg.timestamp))
		return
	} else if len(msg.Acc.Auth) == 0 {
		s.QueueOut(ErrAuthUnknownScheme(msg.Acc.Id, "", msg.timestamp))
		return
	}

	if msg.Acc.User == "new" {
		// Request to create a new account
		for _, auth := range msg.Acc.Auth {
			if auth.Scheme == "basic" {
				var private interface{}
				var user types.User
				if msg.Acc.Init != nil {
					user.Access.Auth = DEFAULT_AUTH_ACCESS
					user.Access.Anon = DEFAULT_ANON_ACCESS

					if msg.Acc.Init.DefaultAcs != nil {
						if msg.Acc.Init.DefaultAcs.Auth != "" {
							user.Access.Auth.UnmarshalText([]byte(msg.Acc.Init.DefaultAcs.Auth))
						}
						if msg.Acc.Init.DefaultAcs.Anon != "" {
							user.Access.Anon.UnmarshalText([]byte(msg.Acc.Init.DefaultAcs.Anon))
						}
					}
					user.Public = msg.Acc.Init.Public
					private = msg.Acc.Init.Private
				}
				_, err := store.Users.Create(s.appid, &user, auth.Scheme, auth.Secret, private)
				if err != nil {
					if err.Error() == "duplicate credential" {
						s.QueueOut(ErrDuplicateCredential(msg.Acc.Id, "", msg.timestamp))
					} else {
						s.QueueOut(ErrUnknown(msg.Acc.Id, "", msg.timestamp))
					}
					return
				}

				reply := NoErrCreated(msg.Acc.Id, "", msg.timestamp)
				info := &MsgTopicInfo{
					CreatedAt: &user.CreatedAt,
					UpdatedAt: &user.UpdatedAt,
					DefaultAcs: &MsgDefaultAcsMode{
						Auth: user.Access.Auth.String(),
						Anon: user.Access.Anon.String()},
					Public:  user.Public,
					Private: private}

				reply.Ctrl.Params = map[string]interface{}{
					"uid":  user.Uid().UserId(),
					"info": info,
				}
				s.QueueOut(NoErr(msg.Acc.Id, "", msg.timestamp))
			} else {
				s.QueueOut(ErrAuthUnknownScheme(msg.Acc.Id, "", msg.timestamp))
				return