Files
agent-radar 2ed3415fb7
Publish Claude Code Binaries / Stage and publish binaries (push) Canceled after 0s
Publish Tutti App Runtime / Build darwin-arm64 (push) Canceled after 0s
Publish Tutti App Runtime / Build darwin-amd64 (push) Canceled after 0s
Publish Tutti App Runtime / Build linux-amd64 (push) Canceled after 0s
Publish Tutti App Runtime / Build windows-amd64 (push) Canceled after 0s
Sync Tutti Agent Skills / sync (push) Canceled after 0s
Windows Agent Adapters / Test Windows agent adapters (push) Canceled after 0s
Windows Daemon Adapters / Test Windows daemon adapters (push) Canceled after 0s
Publish Tutti App Runtime / Publish runtime catalog (push) Canceled after 0s
源码快照 @ 2026-09-01 (source-only, 剔除非源码素材)
2026-09-01 20:17:27 +08:00

64 lines
1.3 KiB
Go

package commerce
import (
"context"
"time"
)
type Service struct {
client *client
rewards *rewardCoordinator
now func() time.Time
}
func NewService(config Config) (*Service, error) {
client, err := newClient(config)
if err != nil {
return nil, err
}
if config.RewardReceiptStore == nil {
return nil, ErrRewardReceiptStoreRequired
}
now := config.Now
if now == nil {
now = time.Now
}
return &Service{
client: client,
rewards: &rewardCoordinator{
client: client,
store: config.RewardReceiptStore,
now: now,
failClosedUsers: make(map[string]struct{}),
},
now: now,
}, nil
}
func (s *Service) ProductSummary(ctx context.Context, userID string) ProductSummary {
reward := s.rewards.reward(ctx, userID)
remote := s.fetchSummary(ctx)
membership, membershipAccess := MembershipFromUserInfo(remote.userInfo)
return ProductSummary{
Membership: membership,
MembershipAccess: membershipAccess,
Credits: CreditsSummaryFromResponses(
remote.creditsOverview,
remote.userInfo,
s.now(),
),
RegistrationCreditsReward: reward,
PartialError: productSummaryPartialError(
remote.membershipErr,
remote.creditsErr,
),
}
}
func (s *Service) DismissRegistrationCreditsReward(
ctx context.Context,
rewardID string,
) error {
return s.rewards.dismiss(ctx, rewardID)
}