server/app/push/internal/biz/publish_registration.go

package biz

import (
	"context"
	"w303a/server/pkg/zaplog"
)

// 设备系统枚举
type DeviceSystem int32

const (
	DeviceSystem_ANDROID DeviceSystem = 0
	DeviceSystem_IOS     DeviceSystem = 1
)

// 推送人使用的平台枚举
type RegistrantPlatformType int32

const (
	// 其他平台（极光推送）
	RegistrantPlatformType_OTHER RegistrantPlatformType = 0
	// 华为
	RegistrantPlatformType_HUAWEI RegistrantPlatformType = 1
	// 小米
	RegistrantPlatformType_XIAOMI RegistrantPlatformType = 2
	// OPPO
	RegistrantPlatformType_OPPO RegistrantPlatformType = 3
	// VIVO
	RegistrantPlatformType_VIVO RegistrantPlatformType = 4
	// 苹果 APNS
	RegistrantPlatformType_APNS RegistrantPlatformType = 5
)

// PublishRegistration is a publish registration entity.
type PublishRegistration struct {
	Entity[int64]

	UserID ID[UUID]
	RegID  string

	RegistrantPlatformType RegistrantPlatformType
	DeviceSystem           DeviceSystem
	DeviceSystemVersion    string
	DeviceManufacturer     string
	DeviceModel            string
}

// PublishRegistration is a publish registration repository.
type PublishRegistrationRepo interface {

	// Save saves the registration.
	Save(ctx context.Context, publishRegistration *PublishRegistration) error
}

// RegistrationUsecase is a registration usecase.
type PublishRegistrationUsecase struct {
	log                     *zaplog.Logger
	publishRegistrationRepo PublishRegistrationRepo
}

// NewPublishRegistrationUsecase returns a new PublishRegistrationUsecase.
func NewPublishRegistrationUsecase(
	log *zaplog.Logger,
	publishRegistrationRepo PublishRegistrationRepo,
) *PublishRegistrationUsecase {
	return &PublishRegistrationUsecase{
		log:                     log,
		publishRegistrationRepo: publishRegistrationRepo,
	}
}

// Subscribe subscribes the registration.
func (uc *PublishRegistrationUsecase) Subscribe(ctx context.Context, publishRegistration *PublishRegistration) error {
	//
	return uc.publishRegistrationRepo.Save(ctx, publishRegistration)
}

// Unsubscribe unsubscribes the registration.
func (uc *PublishRegistrationUsecase) Unsubscribe(ctx context.Context, id ID[int64]) error {
	return nil
}