subscription

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

type Repository interface {
	Create(ctx context.Context, sub *Subscription) error
	Update(ctx context.Context, id string, types []string) (*Subscription, error)
	Delete(ctx context.Context, id string) error
	GetByID(ctx context.Context, id string) (*Subscription, error)
	GetByAssetAndUser(ctx context.Context, assetID, userID string) (*Subscription, error)
	ListByUser(ctx context.Context, userID string) ([]*SubscriptionWithAsset, error)
	GetSubscribersForAsset(ctx context.Context, assetID string, notificationType string) ([]string, error)
}

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

type Subscription struct {
	ID                string    `json:"id"`
	AssetID           string    `json:"asset_id"`
	UserID            string    `json:"user_id"`
	NotificationTypes []string  `json:"notification_types"`
	CreatedAt         time.Time `json:"created_at"`
	UpdatedAt         time.Time `json:"updated_at"`
}

type SubscriptionWithAsset struct {
	Subscription
	AssetName string `json:"asset_name"`
	AssetMRN  string `json:"asset_mrn"`
	AssetType string `json:"asset_type"`
}

type ValidationError struct {
	Message string
}