auth
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.
| 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 } |