Function createAuth

sqlite/auth.go:250–300

createAuth creates a new auth object in the database. On success, the ID is set to the new database ID & timestamp fields are set to the current time.

(ctx context.Context, tx *Tx, auth *wtf.Auth)

// createAuth creates a new auth object in the database. On success, the
// ID is set to the new database ID & timestamp fields are set to the current time.
func createAuth(ctx context.Context, tx *Tx, auth *wtf.Auth) error {
	// Set timestamp fields to current time.
	auth.CreatedAt = tx.now
	auth.UpdatedAt = auth.CreatedAt

	// Ensure auth object passes basic validation.
	if err := auth.Validate(); err != nil {
		return err
	}

	// Convert expiry date to RFC 3339 for SQLite.
	var expiry *string
	if auth.Expiry != nil {
		tmp := auth.Expiry.Format(time.RFC3339)
		expiry = &tmp
	}

	// Execute insertion query.
	result, err := tx.ExecContext(ctx, `
		INSERT INTO auths (
			user_id,
			source,
			source_id,
			access_token,
			refresh_token,
			expiry,
			created_at,
			updated_at
		)
		VALUES (?, ?, ?, ?, ?, ?, ?, ?)
	`,
		auth.UserID,
		auth.Source,
		auth.SourceID,
		auth.AccessToken,
		auth.RefreshToken,
		expiry,
		(*NullTime)(&auth.CreatedAt),
		(*NullTime)(&auth.UpdatedAt),
	)
	if err != nil {
		return FormatError(err)
	}

	// Update caller object to set ID.
	if auth.ID, err = lastInsertID(result); err != nil {
		return err
	}

	return nil
}

// updateAuth updates tokens & expiry on exist auth object.
// Returns new state of the auth object.