lethdat
a0ae2b681a
- Added videoWorkflowRepository with methods to manage video and user interactions. - Introduced catalog_mapper for converting database models to protobuf representations. - Created domain_helpers for normalizing domain and ad format values. - Defined service interfaces for payment, account, notification, domain, ad template, player config, video, and user management. - Implemented OAuth helpers for generating state and caching keys. - Developed payment_proto_helpers for mapping payment-related models to protobuf. - Added service policy helpers to enforce plan requirements and user permissions. - Created user_mapper for converting user payloads to protobuf format. - Implemented value_helpers for handling various value conversions and nil checks. - Developed video_helpers for normalizing video statuses and managing storage types. - Created video_mapper for mapping video models to protobuf format. - Implemented render workflow for managing video creation and job processing.
29 lines
674 B
Go
29 lines
674 B
Go
package service
|
|
|
|
import (
|
|
"context"
|
|
|
|
"stream.api/internal/database/model"
|
|
"stream.api/pkg/logger"
|
|
)
|
|
|
|
type usagePayload struct {
|
|
UserID string `json:"user_id"`
|
|
TotalVideos int64 `json:"total_videos"`
|
|
TotalStorage int64 `json:"total_storage"`
|
|
}
|
|
|
|
func loadUsage(ctx context.Context, videoRepo VideoRepository, l logger.Logger, user *model.User) (*usagePayload, error) {
|
|
totalVideos, err := videoRepo.CountByUser(ctx, user.ID)
|
|
if err != nil {
|
|
l.Error("Failed to count user videos", "error", err, "user_id", user.ID)
|
|
return nil, err
|
|
}
|
|
|
|
return &usagePayload{
|
|
UserID: user.ID,
|
|
TotalVideos: totalVideos,
|
|
TotalStorage: user.StorageUsed,
|
|
}, nil
|
|
}
|