auth

Paddy 2014-12-14 Parent:3a1fe5ee17f5 Child:c03b5eb3179e

106:d442523df640 Go to Latest

auth/profile.go

Init Config, add profile handlers, and add grant template. Call config.Init() before attempting to use it. Register our profile handlers with the router. Define a simple get_grant template for the authorization grant endpoint.

History
paddy@27 1 package auth
paddy@27 2
paddy@27 3 import (
paddy@99 4 "encoding/json"
paddy@38 5 "errors"
paddy@99 6 "net/http"
paddy@99 7 "regexp"
paddy@99 8 "strings"
paddy@27 9 "time"
paddy@27 10
paddy@45 11 "code.secondbit.org/uuid"
paddy@99 12
paddy@99 13 "github.com/extemporalgenome/slug"
paddy@105 14 "github.com/gorilla/mux"
paddy@27 15 )
paddy@27 16
paddy@48 17 const (
paddy@57 18 // MinPassphraseLength is the minimum length, in bytes, of a passphrase, exclusive.
paddy@48 19 MinPassphraseLength = 6
paddy@57 20 // MaxPassphraseLength is the maximum length, in bytes, of a passphrase, exclusive.
paddy@48 21 MaxPassphraseLength = 64
paddy@69 22 // CurPassphraseScheme is the current passphrase scheme. Incrememnt it when we use a different passphrase scheme
paddy@69 23 CurPassphraseScheme = 1
paddy@99 24 // MaxNameLength is the maximum length, in bytes, of a name, exclusive.
paddy@99 25 MaxNameLength = 64
paddy@99 26 // MaxUsernameLength is the maximum length, in bytes, of a username, exclusive.
paddy@99 27 MaxUsernameLength = 16
paddy@99 28 // MaxEmailLength is the maximum length, in bytes, of an email address, exclusive.
paddy@99 29 MaxEmailLength = 64
paddy@48 30 )
paddy@48 31
paddy@38 32 var (
paddy@57 33 // ErrNoProfileStore is returned when a Context tries to act on a profileStore without setting one first.
paddy@57 34 ErrNoProfileStore = errors.New("no profileStore was specified for the Context")
paddy@57 35 // ErrProfileAlreadyExists is returned when a Profile is added to a profileStore, but another Profile with
paddy@57 36 // the same ID already exists in the profileStore.
paddy@57 37 ErrProfileAlreadyExists = errors.New("profile already exists in profileStore")
paddy@57 38 // ErrProfileNotFound is returned when a Profile is requested but not found in the profileStore.
paddy@57 39 ErrProfileNotFound = errors.New("profile not found in profileStore")
paddy@57 40 // ErrLoginAlreadyExists is returned when a Login is added to a profileStore, but another Login with the same
paddy@57 41 // Type and Value already exists in the profileStore.
paddy@57 42 ErrLoginAlreadyExists = errors.New("login already exists in profileStore")
paddy@57 43 // ErrLoginNotFound is returned when a Login is requested but not found in the profileStore.
paddy@57 44 ErrLoginNotFound = errors.New("login not found in profileStore")
paddy@48 45
paddy@57 46 // ErrMissingPassphrase is returned when a ProfileChange is validated but does not contain a
paddy@57 47 // Passphrase, and requires one.
paddy@57 48 ErrMissingPassphrase = errors.New("missing passphrase")
paddy@57 49 // ErrMissingPassphraseReset is returned when a ProfileChange is validated but does not contain
paddy@57 50 // a PassphraseReset, and requires one.
paddy@57 51 ErrMissingPassphraseReset = errors.New("missing passphrase reset")
paddy@57 52 // ErrMissingPassphraseResetCreated is returned when a ProfileChange is validated but does not
paddy@57 53 // contain a PassphraseResetCreated, and requires one.
paddy@48 54 ErrMissingPassphraseResetCreated = errors.New("missing passphrase reset created timestamp")
paddy@57 55 // ErrPassphraseTooShort is returned when a ProfileChange is validated and contains a Passphrase,
paddy@57 56 // but the Passphrase is shorter than MinPassphraseLength.
paddy@57 57 ErrPassphraseTooShort = errors.New("passphrase too short")
paddy@57 58 // ErrPassphraseTooLong is returned when a ProfileChange is validated and contains a Passphrase,
paddy@57 59 // but the Passphrase is longer than MaxPassphraseLength.
paddy@57 60 ErrPassphraseTooLong = errors.New("passphrase too long")
paddy@99 61
paddy@99 62 // ErrProfileCompromised is returned when a user tries to log in with a profile that is suspected
paddy@99 63 // of being compromised.
paddy@99 64 ErrProfileCompromised = errors.New("profile compromised")
paddy@99 65 // ErrProfileLocked is returned when a user tries to log in with a profile that is locked for a certain
paddy@99 66 // duration, to prevent brute force attacks.
paddy@99 67 ErrProfileLocked = errors.New("profile locked")
paddy@38 68 )
paddy@38 69
paddy@57 70 // Profile represents a single user of the service,
paddy@57 71 // including their authentication information, but not
paddy@57 72 // including their username or email.
paddy@27 73 type Profile struct {
paddy@105 74 ID uuid.ID `json:"id,omitempty"`
paddy@105 75 Name string `json:"name,omitempty"`
paddy@105 76 Passphrase string `json:"-"`
paddy@105 77 Iterations int `json:"-"`
paddy@105 78 Salt string `json:"-"`
paddy@105 79 PassphraseScheme int `json:"-"`
paddy@105 80 Compromised bool `json:"-"`
paddy@105 81 LockedUntil time.Time `json:"-"`
paddy@105 82 PassphraseReset string `json:"-"`
paddy@105 83 PassphraseResetCreated time.Time `json:"-"`
paddy@105 84 Created time.Time `json:"created,omitempty"`
paddy@105 85 LastSeen time.Time `json:"last_seen,omitempty"`
paddy@38 86 }
paddy@38 87
paddy@57 88 // ApplyChange applies the properties of the passed ProfileChange
paddy@57 89 // to the Profile it is called on.
paddy@38 90 func (p *Profile) ApplyChange(change ProfileChange) {
paddy@38 91 if change.Name != nil {
paddy@38 92 p.Name = *change.Name
paddy@38 93 }
paddy@38 94 if change.Passphrase != nil {
paddy@38 95 p.Passphrase = *change.Passphrase
paddy@38 96 }
paddy@38 97 if change.Iterations != nil {
paddy@38 98 p.Iterations = *change.Iterations
paddy@38 99 }
paddy@38 100 if change.Salt != nil {
paddy@38 101 p.Salt = *change.Salt
paddy@38 102 }
paddy@38 103 if change.PassphraseScheme != nil {
paddy@38 104 p.PassphraseScheme = *change.PassphraseScheme
paddy@38 105 }
paddy@38 106 if change.Compromised != nil {
paddy@38 107 p.Compromised = *change.Compromised
paddy@38 108 }
paddy@38 109 if change.LockedUntil != nil {
paddy@38 110 p.LockedUntil = *change.LockedUntil
paddy@38 111 }
paddy@38 112 if change.PassphraseReset != nil {
paddy@38 113 p.PassphraseReset = *change.PassphraseReset
paddy@38 114 }
paddy@38 115 if change.PassphraseResetCreated != nil {
paddy@38 116 p.PassphraseResetCreated = *change.PassphraseResetCreated
paddy@38 117 }
paddy@38 118 if change.LastSeen != nil {
paddy@38 119 p.LastSeen = *change.LastSeen
paddy@38 120 }
paddy@38 121 }
paddy@38 122
paddy@57 123 // ApplyBulkChange applies the properties of the passed BulkProfileChange
paddy@57 124 // to the Profile it is called on.
paddy@44 125 func (p *Profile) ApplyBulkChange(change BulkProfileChange) {
paddy@44 126 if change.Compromised != nil {
paddy@44 127 p.Compromised = *change.Compromised
paddy@44 128 }
paddy@44 129 }
paddy@44 130
paddy@57 131 // ProfileChange represents a single atomic change to a Profile's mutable data.
paddy@38 132 type ProfileChange struct {
paddy@38 133 Name *string
paddy@38 134 Passphrase *string
paddy@69 135 Iterations *int
paddy@38 136 Salt *string
paddy@38 137 PassphraseScheme *int
paddy@38 138 Compromised *bool
paddy@38 139 LockedUntil *time.Time
paddy@38 140 PassphraseReset *string
paddy@38 141 PassphraseResetCreated *time.Time
paddy@38 142 LastSeen *time.Time
paddy@38 143 }
paddy@38 144
paddy@57 145 // Validate checks the ProfileChange it is called on
paddy@57 146 // and asserts its internal validity, or lack thereof.
paddy@57 147 // A descriptive error will be returned in the case of
paddy@57 148 // an invalid change.
paddy@38 149 func (c ProfileChange) Validate() error {
paddy@48 150 if c.Name == nil && c.Passphrase == nil && c.Iterations == nil && c.Salt == nil && c.PassphraseScheme == nil && c.Compromised == nil && c.LockedUntil == nil && c.PassphraseReset == nil && c.PassphraseResetCreated == nil && c.LastSeen == nil {
paddy@48 151 return ErrEmptyChange
paddy@48 152 }
paddy@48 153 if c.PassphraseScheme != nil && c.Passphrase == nil {
paddy@48 154 return ErrMissingPassphrase
paddy@48 155 }
paddy@48 156 if c.PassphraseReset != nil && c.PassphraseResetCreated == nil {
paddy@48 157 return ErrMissingPassphraseResetCreated
paddy@48 158 }
paddy@48 159 if c.PassphraseReset == nil && c.PassphraseResetCreated != nil {
paddy@48 160 return ErrMissingPassphraseReset
paddy@48 161 }
paddy@48 162 if c.Salt != nil && c.Passphrase == nil {
paddy@48 163 return ErrMissingPassphrase
paddy@48 164 }
paddy@48 165 if c.Iterations != nil && c.Passphrase == nil {
paddy@48 166 return ErrMissingPassphrase
paddy@48 167 }
paddy@48 168 if c.Passphrase != nil && len(*c.Passphrase) < MinPassphraseLength {
paddy@48 169 return ErrPassphraseTooShort
paddy@48 170 }
paddy@48 171 if c.Passphrase != nil && len(*c.Passphrase) > MaxPassphraseLength {
paddy@48 172 return ErrPassphraseTooLong
paddy@48 173 }
paddy@38 174 return nil
paddy@27 175 }
paddy@27 176
paddy@57 177 // BulkProfileChange represents a single atomic change to many Profiles' mutable data.
paddy@57 178 // It is a subset of a ProfileChange, as it doesn't make sense to mutate some of the
paddy@57 179 // ProfileChange values across many Profiles all at once.
paddy@44 180 type BulkProfileChange struct {
paddy@44 181 Compromised *bool
paddy@44 182 }
paddy@44 183
paddy@57 184 // Validate checks the BulkProfileChange it is called on
paddy@57 185 // and asserts its internal validity, or lack thereof.
paddy@57 186 // A descriptive error will be returned in the case of an
paddy@57 187 // invalid change.
paddy@44 188 func (b BulkProfileChange) Validate() error {
paddy@48 189 if b.Compromised == nil {
paddy@48 190 return ErrEmptyChange
paddy@48 191 }
paddy@44 192 return nil
paddy@44 193 }
paddy@44 194
paddy@57 195 // Login represents a single human-friendly identifier for
paddy@57 196 // a given Profile that can be used to log into that Profile.
paddy@57 197 // Each Profile may only have one Login for each Type.
paddy@27 198 type Login struct {
paddy@105 199 Type string `json:"type,omitempty"`
paddy@105 200 Value string `json:"value,omitempty"`
paddy@105 201 ProfileID uuid.ID `json:"profile_id,omitempty"`
paddy@105 202 Created time.Time `json:"created,omitempty"`
paddy@105 203 LastUsed time.Time `json:"last_used,omitempty"`
paddy@27 204 }
paddy@27 205
paddy@99 206 type newProfileRequest struct {
paddy@99 207 Username string `json:"username"`
paddy@99 208 Email string `json:"email"`
paddy@99 209 Passphrase string `json:"passphrase"`
paddy@99 210 Name string `json:"name"`
paddy@99 211 }
paddy@99 212
paddy@99 213 func validateNewProfileRequest(req *newProfileRequest) []requestError {
paddy@99 214 errors := []requestError{}
paddy@99 215 req.Name = strings.TrimSpace(req.Name)
paddy@99 216 req.Email = strings.TrimSpace(req.Email)
paddy@99 217 req.Username = slug.SlugAscii(strings.TrimSpace(req.Username))
paddy@99 218 if len(req.Passphrase) < MinPassphraseLength {
paddy@99 219 errors = append(errors, requestError{
paddy@99 220 Slug: requestErrInsufficient,
paddy@99 221 Field: "/passphrase",
paddy@99 222 })
paddy@99 223 }
paddy@99 224 if len(req.Passphrase) > MaxPassphraseLength {
paddy@99 225 errors = append(errors, requestError{
paddy@99 226 Slug: requestErrOverflow,
paddy@99 227 Field: "/passphrase",
paddy@99 228 })
paddy@99 229 }
paddy@99 230 if len(req.Name) > MaxNameLength {
paddy@99 231 errors = append(errors, requestError{
paddy@99 232 Slug: requestErrOverflow,
paddy@99 233 Field: "/name",
paddy@99 234 })
paddy@99 235 }
paddy@99 236 if len(req.Username) > MaxUsernameLength {
paddy@99 237 errors = append(errors, requestError{
paddy@99 238 Slug: requestErrOverflow,
paddy@99 239 Field: "/username",
paddy@99 240 })
paddy@99 241 }
paddy@99 242 if req.Email == "" {
paddy@99 243 errors = append(errors, requestError{
paddy@99 244 Slug: requestErrMissing,
paddy@99 245 Field: "/email",
paddy@99 246 })
paddy@99 247 }
paddy@99 248 if len(req.Email) > MaxEmailLength {
paddy@99 249 errors = append(errors, requestError{
paddy@99 250 Slug: requestErrOverflow,
paddy@99 251 Field: "/email",
paddy@99 252 })
paddy@99 253 }
paddy@99 254 re := regexp.MustCompile(".+@.+\\..+")
paddy@99 255 if !re.Match([]byte(req.Email)) {
paddy@99 256 errors = append(errors, requestError{
paddy@105 257 Slug: requestErrInvalidFormat,
paddy@99 258 Field: "/email",
paddy@99 259 })
paddy@99 260 }
paddy@99 261 return errors
paddy@99 262 }
paddy@99 263
paddy@57 264 type profileStore interface {
paddy@57 265 getProfileByID(id uuid.ID) (Profile, error)
paddy@69 266 getProfileByLogin(value string) (Profile, error)
paddy@57 267 saveProfile(profile Profile) error
paddy@57 268 updateProfile(id uuid.ID, change ProfileChange) error
paddy@57 269 updateProfiles(ids []uuid.ID, change BulkProfileChange) error
paddy@57 270 deleteProfile(id uuid.ID) error
paddy@44 271
paddy@57 272 addLogin(login Login) error
paddy@69 273 removeLogin(value string, profile uuid.ID) error
paddy@69 274 recordLoginUse(value string, when time.Time) error
paddy@57 275 listLogins(profile uuid.ID, num, offset int) ([]Login, error)
paddy@38 276 }
paddy@27 277
paddy@57 278 func (m *memstore) getProfileByID(id uuid.ID) (Profile, error) {
paddy@38 279 m.profileLock.RLock()
paddy@38 280 defer m.profileLock.RUnlock()
paddy@38 281 p, ok := m.profiles[id.String()]
paddy@38 282 if !ok {
paddy@38 283 return Profile{}, ErrProfileNotFound
paddy@38 284 }
paddy@38 285 return p, nil
paddy@27 286 }
paddy@38 287
paddy@69 288 func (m *memstore) getProfileByLogin(value string) (Profile, error) {
paddy@44 289 m.loginLock.RLock()
paddy@44 290 defer m.loginLock.RUnlock()
paddy@69 291 login, ok := m.logins[value]
paddy@44 292 if !ok {
paddy@44 293 return Profile{}, ErrLoginNotFound
paddy@44 294 }
paddy@44 295 m.profileLock.RLock()
paddy@44 296 defer m.profileLock.RUnlock()
paddy@44 297 profile, ok := m.profiles[login.ProfileID.String()]
paddy@44 298 if !ok {
paddy@44 299 return Profile{}, ErrProfileNotFound
paddy@44 300 }
paddy@44 301 return profile, nil
paddy@38 302 }
paddy@38 303
paddy@57 304 func (m *memstore) saveProfile(profile Profile) error {
paddy@38 305 m.profileLock.Lock()
paddy@38 306 defer m.profileLock.Unlock()
paddy@38 307 _, ok := m.profiles[profile.ID.String()]
paddy@38 308 if ok {
paddy@38 309 return ErrProfileAlreadyExists
paddy@38 310 }
paddy@38 311 m.profiles[profile.ID.String()] = profile
paddy@38 312 return nil
paddy@38 313 }
paddy@38 314
paddy@57 315 func (m *memstore) updateProfile(id uuid.ID, change ProfileChange) error {
paddy@38 316 m.profileLock.Lock()
paddy@38 317 defer m.profileLock.Unlock()
paddy@38 318 p, ok := m.profiles[id.String()]
paddy@38 319 if !ok {
paddy@38 320 return ErrProfileNotFound
paddy@38 321 }
paddy@38 322 p.ApplyChange(change)
paddy@38 323 m.profiles[id.String()] = p
paddy@38 324 return nil
paddy@38 325 }
paddy@38 326
paddy@57 327 func (m *memstore) updateProfiles(ids []uuid.ID, change BulkProfileChange) error {
paddy@44 328 m.profileLock.Lock()
paddy@44 329 defer m.profileLock.Unlock()
paddy@44 330 for id, profile := range m.profiles {
paddy@44 331 for _, i := range ids {
paddy@44 332 if id == i.String() {
paddy@44 333 profile.ApplyBulkChange(change)
paddy@44 334 m.profiles[id] = profile
paddy@44 335 break
paddy@44 336 }
paddy@44 337 }
paddy@44 338 }
paddy@44 339 return nil
paddy@44 340 }
paddy@44 341
paddy@57 342 func (m *memstore) deleteProfile(id uuid.ID) error {
paddy@38 343 m.profileLock.Lock()
paddy@38 344 defer m.profileLock.Unlock()
paddy@38 345 _, ok := m.profiles[id.String()]
paddy@38 346 if !ok {
paddy@38 347 return ErrProfileNotFound
paddy@38 348 }
paddy@38 349 delete(m.profiles, id.String())
paddy@38 350 return nil
paddy@38 351 }
paddy@40 352
paddy@57 353 func (m *memstore) addLogin(login Login) error {
paddy@44 354 m.loginLock.Lock()
paddy@44 355 defer m.loginLock.Unlock()
paddy@69 356 _, ok := m.logins[login.Value]
paddy@44 357 if ok {
paddy@44 358 return ErrLoginAlreadyExists
paddy@44 359 }
paddy@69 360 m.logins[login.Value] = login
paddy@69 361 m.profileLoginLookup[login.ProfileID.String()] = append(m.profileLoginLookup[login.ProfileID.String()], login.Value)
paddy@44 362 return nil
paddy@44 363 }
paddy@44 364
paddy@69 365 func (m *memstore) removeLogin(value string, profile uuid.ID) error {
paddy@44 366 m.loginLock.Lock()
paddy@44 367 defer m.loginLock.Unlock()
paddy@69 368 l, ok := m.logins[value]
paddy@44 369 if !ok {
paddy@44 370 return ErrLoginNotFound
paddy@44 371 }
paddy@44 372 if !l.ProfileID.Equal(profile) {
paddy@44 373 return ErrLoginNotFound
paddy@44 374 }
paddy@69 375 delete(m.logins, value)
paddy@44 376 pos := -1
paddy@44 377 for p, id := range m.profileLoginLookup[profile.String()] {
paddy@69 378 if id == value {
paddy@44 379 pos = p
paddy@44 380 break
paddy@44 381 }
paddy@44 382 }
paddy@44 383 if pos >= 0 {
paddy@44 384 m.profileLoginLookup[profile.String()] = append(m.profileLoginLookup[profile.String()][:pos], m.profileLoginLookup[profile.String()][pos+1:]...)
paddy@44 385 }
paddy@44 386 return nil
paddy@44 387 }
paddy@44 388
paddy@69 389 func (m *memstore) recordLoginUse(value string, when time.Time) error {
paddy@44 390 m.loginLock.Lock()
paddy@44 391 defer m.loginLock.Unlock()
paddy@69 392 l, ok := m.logins[value]
paddy@44 393 if !ok {
paddy@44 394 return ErrLoginNotFound
paddy@44 395 }
paddy@44 396 l.LastUsed = when
paddy@69 397 m.logins[value] = l
paddy@44 398 return nil
paddy@44 399 }
paddy@44 400
paddy@57 401 func (m *memstore) listLogins(profile uuid.ID, num, offset int) ([]Login, error) {
paddy@44 402 m.loginLock.RLock()
paddy@44 403 defer m.loginLock.RUnlock()
paddy@44 404 ids, ok := m.profileLoginLookup[profile.String()]
paddy@44 405 if !ok {
paddy@44 406 return []Login{}, nil
paddy@44 407 }
paddy@44 408 if len(ids) > num+offset {
paddy@44 409 ids = ids[offset : num+offset]
paddy@44 410 } else if len(ids) > offset {
paddy@44 411 ids = ids[offset:]
paddy@44 412 } else {
paddy@44 413 return []Login{}, nil
paddy@44 414 }
paddy@44 415 logins := []Login{}
paddy@44 416 for _, id := range ids {
paddy@44 417 login, ok := m.logins[id]
paddy@44 418 if !ok {
paddy@44 419 continue
paddy@44 420 }
paddy@44 421 logins = append(logins, login)
paddy@44 422 }
paddy@44 423 return logins, nil
paddy@44 424 }
paddy@99 425
paddy@105 426 // RegisterProfileHandlers adds handlers to the passed router to handle the profile endpoints, like registration and user retrieval.
paddy@105 427 func RegisterProfileHandlers(r *mux.Router, context Context) {
paddy@105 428 r.Handle("/profiles", wrap(context, CreateProfileHandler)).Methods("POST")
paddy@105 429 }
paddy@105 430
paddy@99 431 // CreateProfileHandler is an HTTP handler for registering new profiles.
paddy@99 432 func CreateProfileHandler(w http.ResponseWriter, r *http.Request, context Context) {
paddy@99 433 scheme, ok := passphraseSchemes[CurPassphraseScheme]
paddy@99 434 if !ok {
paddy@105 435 encode(w, r, http.StatusInternalServerError, actOfGodResponse)
paddy@99 436 return
paddy@99 437 }
paddy@99 438 var req newProfileRequest
paddy@99 439 errors := []requestError{}
paddy@99 440 decoder := json.NewDecoder(r.Body)
paddy@99 441 err := decoder.Decode(&req)
paddy@99 442 if err != nil {
paddy@105 443 encode(w, r, http.StatusBadRequest, invalidFormatResponse)
paddy@99 444 return
paddy@99 445 }
paddy@99 446 errors = append(errors, validateNewProfileRequest(&req)...)
paddy@99 447 if len(errors) > 0 {
paddy@105 448 encode(w, r, http.StatusBadRequest, response{Errors: errors})
paddy@99 449 return
paddy@99 450 }
paddy@99 451 passphrase, salt, err := scheme.create(req.Passphrase, context.config.iterations)
paddy@99 452 if err != nil {
paddy@105 453 encode(w, r, http.StatusInternalServerError, actOfGodResponse)
paddy@99 454 return
paddy@99 455 }
paddy@99 456 profile := Profile{
paddy@99 457 ID: uuid.NewID(),
paddy@99 458 Name: req.Name,
paddy@99 459 Passphrase: string(passphrase),
paddy@99 460 Iterations: context.config.iterations,
paddy@99 461 Salt: string(salt),
paddy@99 462 PassphraseScheme: CurPassphraseScheme,
paddy@99 463 Created: time.Now(),
paddy@99 464 LastSeen: time.Now(),
paddy@99 465 }
paddy@99 466 err = context.SaveProfile(profile)
paddy@99 467 if err != nil {
paddy@105 468 if err == ErrProfileAlreadyExists {
paddy@105 469 encode(w, r, http.StatusBadRequest, response{Errors: []requestError{{Slug: requestErrConflict, Field: "/id"}}})
paddy@105 470 return
paddy@105 471 }
paddy@105 472 encode(w, r, http.StatusInternalServerError, actOfGodResponse)
paddy@99 473 return
paddy@99 474 }
paddy@99 475 logins := []Login{}
paddy@99 476 login := Login{
paddy@99 477 Type: "email",
paddy@99 478 Value: req.Email,
paddy@99 479 Created: profile.Created,
paddy@99 480 LastUsed: profile.Created,
paddy@99 481 ProfileID: profile.ID,
paddy@99 482 }
paddy@99 483 err = context.AddLogin(login)
paddy@99 484 if err != nil {
paddy@105 485 if err == ErrLoginAlreadyExists {
paddy@105 486 encode(w, r, http.StatusBadRequest, response{Errors: []requestError{{Slug: requestErrConflict, Field: "/email"}}})
paddy@105 487 return
paddy@105 488 }
paddy@105 489 encode(w, r, http.StatusInternalServerError, actOfGodResponse)
paddy@99 490 return
paddy@99 491 }
paddy@99 492 logins = append(logins, login)
paddy@99 493 if req.Username != "" {
paddy@99 494 login.Type = "username"
paddy@99 495 login.Value = req.Username
paddy@99 496 err = context.AddLogin(login)
paddy@99 497 if err != nil {
paddy@105 498 if err == ErrLoginAlreadyExists {
paddy@105 499 encode(w, r, http.StatusBadRequest, response{Errors: []requestError{{Slug: requestErrConflict, Field: "/username"}}})
paddy@105 500 return
paddy@105 501 }
paddy@105 502 encode(w, r, http.StatusInternalServerError, actOfGodResponse)
paddy@99 503 return
paddy@99 504 }
paddy@99 505 logins = append(logins, login)
paddy@99 506 }
paddy@105 507 resp := response{
paddy@105 508 Logins: logins,
paddy@105 509 Profiles: []Profile{profile},
paddy@105 510 }
paddy@105 511 encode(w, r, http.StatusCreated, resp)
paddy@99 512 // TODO(paddy): should we kick off the email validation flow?
paddy@99 513 }