Function NewOAuthService

internal/services/oauth.go:23–56

(db *db.DB, cfg *cfg.Cfg, logger *logger.Logger)

}

func NewOAuthService(db *db.DB, cfg *cfg.Cfg, logger *logger.Logger) *OAuthService {
	base := NewBaseService(db, cfg, logger)
	collection := base.db.Collection((models.OAuth{}).CollectionName())

	indexModels := []mongo.IndexModel{
		{
			Keys: bson.D{{Key: "code", Value: 1}},
			Options: options.Index().
				SetUnique(true).
				SetPartialFilterExpression(bson.M{"code": bson.M{"$exists": true}}),
		},
		{
			Keys: bson.D{{Key: "access_token", Value: 1}},
			Options: options.Index().
				SetUnique(true).
				SetPartialFilterExpression(bson.M{"access_token": bson.M{"$exists": true}}),
		},
		{
			Keys: bson.D{{Key: "state", Value: 1}},
			Options: options.Index().
				SetUnique(true).
				SetPartialFilterExpression(bson.M{"state": bson.M{"$exists": true}}),
		},
	}
	_, err := collection.Indexes().CreateMany(context.Background(), indexModels)
	if err != nil {
		logger.Error("Failed to create indexes for OAuth collection", err)
	}

	return &OAuthService{
		BaseService:     base,
		oauthCollection: collection,
	}
}

func (s *OAuthService) CreateOAuthRecord(ctx context.Context, code, state, accessToken string) error {
	// Check if state already exists