repositories

type DraftMailRepository struct {
	// contains filtered or unexported fields
}

type DraftMailRepositoryInterface interface {
	// GetAll retrieves draft mails for a user. If page and limit are >0, returns paginated results and total count. If page or limit <=0, returns all draft mails and total count.
	GetAll(ctx context.Context, userID primitive.ObjectID, page, limit int64) ([]*models.SendMail, int64, error)
	GetByID(ctx context.Context, id primitive.ObjectID) (*models.SendMail, error)
	Create(ctx context.Context, sendMail *models.SendMail) (*models.SendMail, error)
	Update(ctx context.Context, id primitive.ObjectID, update bson.M) (*models.SendMail, error)
	Trash(ctx context.Context, id primitive.ObjectID) error
	Delete(ctx context.Context, id primitive.ObjectID) error
	// GetSince retrieves draft mails where updated_at is after the specified time for a specific user. If page and limit are >0, returns paginated results and total count. If page or limit <=0, returns all draft mails and total count.
	GetSince(ctx context.Context, userID primitive.ObjectID, since time.Time, page, limit int64) ([]*models.SendMail, int64, error)
}

type FolderRepository struct {
	// contains filtered or unexported fields
}

type FolderRepositoryInterface interface {
	GetAll(ctx context.Context, userID primitive.ObjectID) ([]*models.Folder, error)
	Create(ctx context.Context, folder *models.Folder) (*models.Folder, error)
	Update(ctx context.Context, id primitive.ObjectID, folder *models.Folder) (*models.Folder, error)
	Delete(ctx context.Context, id primitive.ObjectID) error
	DeleteByUserID(ctx context.Context, userID primitive.ObjectID) error
}

type MailRepository struct {
	// contains filtered or unexported fields
}

type MailRepositoryInterface interface {
	// GetAll retrieves mails for a user. If page and limit are >0, returns paginated results and total count. If page or limit <=0, returns all mails and total count.
	GetAll(ctx context.Context, userID primitive.ObjectID, page, limit int64) ([]*models.Mail, int64, error)
	GetByID(ctx context.Context, id primitive.ObjectID) (*models.Mail, error)
	Create(ctx context.Context, mail *models.Mail) (*models.Mail, error)
	CreateMany(ctx context.Context, mails []models.Mail) (bool, error)
	// Update updates a mail object
	Update(ctx context.Context, mail *models.Mail) error
	// CleanupTrash cleans up trash mails
	CleanupTrash(ctx context.Context, userID *primitive.ObjectID, days *int) error
	// GetSince retrieves mails where updated_at is after the specified time for a specific user. If page and limit are >0, returns paginated results and total count. If page or limit <=0, returns all mails and total count.
	GetSince(ctx context.Context, userID primitive.ObjectID, since time.Time, page, limit int64) ([]*models.Mail, int64, error)
}

type SendMailRepository struct {
	// contains filtered or unexported fields
}

type SendMailRepositoryInterface interface {
	// GetAll retrieves send mails for a user. If page and limit are >0, returns paginated results and total count. If page or limit <=0, returns all send mails and total count.
	GetAll(ctx context.Context, userID primitive.ObjectID, page, limit int64) ([]*models.SendMail, int64, error)
	GetByID(ctx context.Context, id primitive.ObjectID) (*models.SendMail, error)
	Create(ctx context.Context, sendMail *models.SendMail) (*models.SendMail, error)
	Update(ctx context.Context, id primitive.ObjectID, update bson.M) (*models.SendMail, error)
	Delete(ctx context.Context, id primitive.ObjectID) error
	// GetSince retrieves send mails where updated_at is after the specified time for a specific user. If page and limit are >0, returns paginated results and total count. If page or limit <=0, returns all send mails and total count.
	GetSince(ctx context.Context, userID primitive.ObjectID, since time.Time, page, limit int64) ([]*models.SendMail, int64, error)
}

type TagRepository struct {
	// contains filtered or unexported fields
}

type TagRepositoryInterface interface {
	GetAll(ctx context.Context, userID *primitive.ObjectID) ([]*models.Tag, error)
	GetByID(ctx context.Context, id primitive.ObjectID) (*models.Tag, error)
	Create(ctx context.Context, tag *models.Tag) (*models.Tag, error)
	Update(ctx context.Context, tag *models.Tag) (*models.Tag, error)
	Delete(ctx context.Context, id primitive.ObjectID) error
	DeleteByUserID(ctx context.Context, userID primitive.ObjectID) error
}