41 lines
883 B
Go
41 lines
883 B
Go
package repository
|
|
|
|
import (
|
|
"codeword/internal/models"
|
|
"context"
|
|
"fmt"
|
|
"go.mongodb.org/mongo-driver/mongo"
|
|
"go.mongodb.org/mongo-driver/mongo/readpref"
|
|
"time"
|
|
)
|
|
|
|
type UserRepository struct {
|
|
db *mongo.Database
|
|
}
|
|
|
|
func NewUserRepository(db *mongo.Database) *UserRepository {
|
|
return &UserRepository{db}
|
|
}
|
|
|
|
func (r *UserRepository) FindByEmail(email string) (*models.User, error) {
|
|
//todo
|
|
return &models.User{}, nil
|
|
}
|
|
|
|
func (r *UserRepository) StoreRecoveryRecord(userID, signature string, createdAt time.Time) error {
|
|
//todo
|
|
|
|
return nil
|
|
}
|
|
|
|
func (r *UserRepository) GetRecoveryRecord(signature string) (*models.RestoreRequest, error) {
|
|
//todo
|
|
|
|
return &models.RestoreRequest{UserID: "123", Sign: signature, CreatedAt: time.Now()}, nil
|
|
}
|
|
|
|
func (r *UserRepository) Ping(ctx context.Context) error {
|
|
fmt.Println("Ping")
|
|
return r.db.Client().Ping(ctx, readpref.Primary())
|
|
}
|