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
64 lines
1.3 KiB
Go
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)
|
|
}
|