marketplace

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

type APIConfig struct {
	// BasePath is the API base path (e.g., "/api/v1").
	BasePath string
}

type ArchiveListingInput struct {
	ID string `path:"id" format:"uuid"`
}

type ArchiveListingOutput struct {
	Body *ListingResponse
}

type AssignSeatInput struct {
	LicenseID string `path:"license_id" format:"uuid"`
	Body      struct {
		PrincipalID string `json:"principal_id" required:"true" format:"uuid"`
		AssignedBy  string `json:"assigned_by" required:"true" format:"uuid"`
	}
}

type AssignSeatOutput struct {
	Body *SeatAssignmentResponse
}

type AuthzSyncer interface {
	// SyncListing syncs a listing to the authorization system.
	SyncListing(ctx context.Context, listing *Listing) error

	// SyncLicense syncs a license grant to the authorization system.
	SyncLicense(ctx context.Context, license *License) error

	// SyncLicenseRevocation syncs a license revocation to the authorization system.
	SyncLicenseRevocation(ctx context.Context, license *License) error

	// SyncSeatAssignment syncs a seat assignment to the authorization system.
	SyncSeatAssignment(ctx context.Context, assignment *SeatAssignment) error

	// SyncSeatUnassignment syncs a seat removal to the authorization system.
	SyncSeatUnassignment(ctx context.Context, licenseID, principalID uuid.UUID) error
}

type CheckoutRequest struct {
	// ListingID is the listing to purchase.
	ListingID uuid.UUID

	// OrganizationID is the purchasing organization.
	OrganizationID uuid.UUID

	// PurchaserID is the principal making the purchase.
	PurchaserID uuid.UUID

	// Seats is the number of seats (for per-seat pricing).
	Seats *int

	// SuccessURL is the redirect URL on success.
	SuccessURL string

	// CancelURL is the redirect URL on cancel.
	CancelURL string
}

type CheckoutService interface {
	// CreateCheckoutSession creates a Stripe checkout session for a listing.
	CreateCheckoutSession(ctx context.Context, req CheckoutRequest) (*CheckoutSession, error)

	// ProcessWebhook handles Stripe webhook events.
	ProcessWebhook(ctx context.Context, payload []byte, signature string) error
}

type CheckoutSession struct {
	// SessionID is the Stripe checkout session ID.
	SessionID string

	// URL is the checkout URL to redirect the user to.
	URL string
}

type CreateCheckoutInput struct {
	Body struct {
		ListingID      string `json:"listing_id" required:"true" format:"uuid"`
		OrganizationID string `json:"organization_id" required:"true" format:"uuid"`
		PurchaserID    string `json:"purchaser_id" required:"true" format:"uuid"`
		Seats          *int   `json:"seats,omitempty" minimum:"1"`
		SuccessURL     string `json:"success_url" required:"true" format:"uri"`
		CancelURL      string `json:"cancel_url" required:"true" format:"uri"`
	}
}

type CreateCheckoutOutput struct {
	Body struct {
		SessionID string `json:"session_id"`
		URL       string `json:"url"`
	}
}

type CreateListingInput struct {
	Body struct {
		CreatorOrgID string         `json:"creator_org_id" required:"true" format:"uuid"`
		OwnerID      string         `json:"owner_id" required:"true" format:"uuid"`
		ProductType  string         `json:"product_type" required:"true" minLength:"1" maxLength:"50"`
		ProductID    *string        `json:"product_id,omitempty" format:"uuid"`
		Title        string         `json:"title" required:"true" minLength:"1" maxLength:"200"`
		Description  string         `json:"description,omitempty" maxLength:"5000"`
		PricingModel string         `json:"pricing_model" required:"true" enum:"free,one_time,subscription,per_seat"`
		PriceCents   int64          `json:"price_cents" minimum:"0"`
		Currency     string         `json:"currency" required:"true" minLength:"3" maxLength:"3" default:"USD"`
		Metadata     map[string]any `json:"metadata,omitempty"`
	}
}

type CreateListingOutput struct {
	Body *ListingResponse
}

type DeleteListingInput struct {
	ID string `path:"id" format:"uuid"`
}

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

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

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

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

type GetLicenseInput struct {
	ID string `path:"id" format:"uuid"`
}

type GetLicenseOutput struct {
	Body *LicenseResponse
}

type GetListingInput struct {
	ID string `path:"id" format:"uuid"`
}

type GetListingOutput struct {
	Body *ListingResponse
}

type License struct {
	// ID is the unique identifier for this license.
	ID uuid.UUID `json:"id"`

	// ListingID references the marketplace listing.
	ListingID uuid.UUID `json:"listingId"`

	// OrganizationID is the organization that holds this license.
	OrganizationID uuid.UUID `json:"organizationId"`

	// LicenseType defines the scope of access.
	LicenseType LicenseType `json:"licenseType"`

	// Seats is the number of allowed users (nil for unlimited).
	Seats *int `json:"seats,omitempty"`

	// UsedSeats is the current number of assigned users.
	UsedSeats int `json:"usedSeats"`

	// ValidFrom is when the license becomes active.
	ValidFrom time.Time `json:"validFrom"`

	// ValidUntil is when the license expires (nil for perpetual).
	ValidUntil *time.Time `json:"validUntil,omitempty"`

	// StripeSubscriptionID is the Stripe subscription (for recurring).
	StripeSubscriptionID *string `json:"stripeSubscriptionId,omitempty"`

	// PurchasedBy is the principal who purchased this license.
	PurchasedBy uuid.UUID `json:"purchasedBy"`

	// CreatedAt is when the license was created.
	CreatedAt time.Time `json:"createdAt"`

	// UpdatedAt is when the license was last modified.
	UpdatedAt time.Time `json:"updatedAt"`
}

type LicenseResponse struct {
	ID                   string     `json:"id"`
	ListingID            string     `json:"listing_id"`
	OrganizationID       string     `json:"organization_id"`
	LicenseType          string     `json:"license_type"`
	Seats                *int       `json:"seats,omitempty"`
	UsedSeats            int        `json:"used_seats"`
	ValidFrom            time.Time  `json:"valid_from"`
	ValidUntil           *time.Time `json:"valid_until,omitempty"`
	StripeSubscriptionID *string    `json:"stripe_subscription_id,omitempty"`
	PurchasedBy          string     `json:"purchased_by"`
	CreatedAt            time.Time  `json:"created_at"`
	UpdatedAt            time.Time  `json:"updated_at"`
}

type LicenseService interface {
	// Grant creates a new license for an organization.
	Grant(ctx context.Context, license *License) error

	// Get retrieves a license by ID.
	Get(ctx context.Context, id uuid.UUID) (*License, error)

	// GetByListingAndOrg retrieves a license for a specific listing and organization.
	GetByListingAndOrg(ctx context.Context, listingID, orgID uuid.UUID) (*License, error)

	// Update updates a license's details.
	Update(ctx context.Context, license *License) error

	// Revoke revokes a license, removing access.
	Revoke(ctx context.Context, id uuid.UUID) error

	// Check checks if an organization has a valid license for a listing.
	Check(ctx context.Context, listingID, orgID uuid.UUID) (bool, error)

	// CheckPrincipal checks if a principal has access via license.
	CheckPrincipal(ctx context.Context, listingID, principalID uuid.UUID) (bool, error)

	// List retrieves licenses for an organization.
	List(ctx context.Context, orgID uuid.UUID) ([]*License, error)

	// ListByListing retrieves all licenses for a listing.
	ListByListing(ctx context.Context, listingID uuid.UUID) ([]*License, error)

	// AssignSeat assigns a user to a license seat.
	AssignSeat(ctx context.Context, assignment *SeatAssignment) error

	// UnassignSeat removes a user from a license seat.
	UnassignSeat(ctx context.Context, licenseID, principalID uuid.UUID) error

	// ListSeatAssignments retrieves all seat assignments for a license.
	ListSeatAssignments(ctx context.Context, licenseID uuid.UUID) ([]*SeatAssignment, error)
}

type LicenseType string

type ListLicensesInput struct {
	OrganizationID string `query:"organization_id" required:"true" format:"uuid"`
}

type ListLicensesOutput struct {
	Body struct {
		Licenses []*LicenseResponse `json:"licenses"`
	}
}

type ListListingsInput struct {
	Status       *string `query:"status" enum:"draft,pending_review,published,archived"`
	ProductType  *string `query:"product_type"`
	CreatorOrgID *string `query:"creator_org_id" format:"uuid"`
	Published    *bool   `query:"published"`
	Limit        int     `query:"limit" default:"20" minimum:"1" maximum:"100"`
	Offset       int     `query:"offset" default:"0" minimum:"0"`
}

type ListListingsOptions struct {
	// Status filters by listing status.
	Status *ListingStatus

	// ProductType filters by product type.
	ProductType *string

	// CreatorOrgID filters by creator organization.
	CreatorOrgID *uuid.UUID

	// PublishedOnly returns only published listings.
	PublishedOnly bool

	// Limit is the maximum number of results.
	Limit int

	// Offset is the pagination offset.
	Offset int

	// OrderBy specifies the sort order.
	OrderBy string
}

type ListListingsOutput struct {
	Body struct {
		Listings []*ListingResponse `json:"listings"`
		Total    int                `json:"total"`
	}
}

type ListSeatsInput struct {
	LicenseID string `path:"license_id" format:"uuid"`
}

type ListSeatsOutput struct {
	Body struct {
		Seats          []*SeatAssignmentResponse `json:"seats"`
		TotalSeats     *int                      `json:"total_seats,omitempty"`
		UsedSeats      int                       `json:"used_seats"`
		AvailableSeats int                       `json:"available_seats"`
	}
}

type Listing struct {
	// ID is the unique identifier for this listing.
	ID uuid.UUID `json:"id"`

	// CreatorOrgID is the organization that created this listing.
	CreatorOrgID uuid.UUID `json:"creatorOrgId"`

	// OwnerID is the principal who owns this listing.
	OwnerID uuid.UUID `json:"ownerId"`

	// ProductType identifies the type of product (app-specific).
	// Examples: "course", "dashboard_template", "data_connector"
	ProductType string `json:"productType"`

	// ProductID references the actual product in the app's domain.
	ProductID uuid.UUID `json:"productId"`

	// Title is the display name for the listing.
	Title string `json:"title"`

	// Description is the detailed description of the product.
	Description string `json:"description,omitempty"`

	// PricingModel defines how the product is priced.
	PricingModel PricingModel `json:"pricingModel"`

	// PriceCents is the price in cents (0 for free).
	PriceCents int64 `json:"priceCents"`

	// Currency is the ISO 4217 currency code.
	Currency string `json:"currency"`

	// Status is the publication state.
	Status ListingStatus `json:"status"`

	// Metadata contains app-specific data.
	Metadata map[string]any `json:"metadata,omitempty"`

	// CreatedAt is when the listing was created.
	CreatedAt time.Time `json:"createdAt"`

	// UpdatedAt is when the listing was last modified.
	UpdatedAt time.Time `json:"updatedAt"`

	// PublishedAt is when the listing was published (nil if not published).
	PublishedAt *time.Time `json:"publishedAt,omitempty"`
}

type ListingResponse struct {
	ID           string         `json:"id"`
	CreatorOrgID string         `json:"creator_org_id"`
	OwnerID      string         `json:"owner_id"`
	ProductType  string         `json:"product_type"`
	ProductID    *string        `json:"product_id,omitempty"`
	Title        string         `json:"title"`
	Description  string         `json:"description,omitempty"`
	PricingModel string         `json:"pricing_model"`
	PriceCents   int64          `json:"price_cents"`
	Currency     string         `json:"currency"`
	Status       string         `json:"status"`
	Metadata     map[string]any `json:"metadata,omitempty"`
	CreatedAt    time.Time      `json:"created_at"`
	UpdatedAt    time.Time      `json:"updated_at"`
	PublishedAt  *time.Time     `json:"published_at,omitempty"`
}

type ListingService interface {
	// Create creates a new listing in draft status.
	Create(ctx context.Context, listing *Listing) error

	// Get retrieves a listing by ID.
	Get(ctx context.Context, id uuid.UUID) (*Listing, error)

	// GetByProduct retrieves a listing by product type and ID.
	GetByProduct(ctx context.Context, productType string, productID uuid.UUID) (*Listing, error)

	// Update updates a listing's details.
	Update(ctx context.Context, listing *Listing) error

	// Delete removes a listing (must be draft or archived).
	Delete(ctx context.Context, id uuid.UUID) error

	// Publish publishes a listing to the marketplace.
	Publish(ctx context.Context, id uuid.UUID) error

	// Archive archives a listing, removing it from the marketplace.
	Archive(ctx context.Context, id uuid.UUID) error

	// List retrieves listings with optional filters.
	List(ctx context.Context, opts ListListingsOptions) ([]*Listing, error)

	// ListByCreator retrieves all listings for a creator organization.
	ListByCreator(ctx context.Context, creatorOrgID uuid.UUID) ([]*Listing, error)
}

type ListingStatus string

type PricingModel string

type PublishListingInput struct {
	ID string `path:"id" format:"uuid"`
}

type PublishListingOutput struct {
	Body *ListingResponse
}

type RevenueShare struct {
	// CreatorPercent is the percentage going to the creator (0-100).
	CreatorPercent int `json:"creatorPercent"`

	// PlatformPercent is the percentage going to the platform (0-100).
	PlatformPercent int `json:"platformPercent"`
}

type SeatAssignment struct {
	// ID is the unique identifier for this assignment.
	ID uuid.UUID `json:"id"`

	// LicenseID references the license.
	LicenseID uuid.UUID `json:"licenseId"`

	// PrincipalID is the user assigned to this seat.
	PrincipalID uuid.UUID `json:"principalId"`

	// AssignedBy is who made this assignment.
	AssignedBy uuid.UUID `json:"assignedBy"`

	// AssignedAt is when the seat was assigned.
	AssignedAt time.Time `json:"assignedAt"`
}

type SeatAssignmentResponse struct {
	ID          string    `json:"id"`
	LicenseID   string    `json:"license_id"`
	PrincipalID string    `json:"principal_id"`
	AssignedBy  string    `json:"assigned_by"`
	AssignedAt  time.Time `json:"assigned_at"`
}

type Service interface {
	Listings() ListingService
	Licenses() LicenseService
	Subscriptions() SubscriptionService
	Checkout() CheckoutService
}

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

type Subscription struct {
	// ID is the unique identifier for this subscription.
	ID uuid.UUID `json:"id"`

	// OrganizationID is the subscribing organization.
	OrganizationID uuid.UUID `json:"organizationId"`

	// PlanTier is the subscription plan name.
	PlanTier string `json:"planTier"`

	// Status is the subscription state.
	Status SubscriptionStatus `json:"status"`

	// CurrentPeriodStart is when the current billing period began.
	CurrentPeriodStart time.Time `json:"currentPeriodStart"`

	// CurrentPeriodEnd is when the current billing period ends.
	CurrentPeriodEnd time.Time `json:"currentPeriodEnd"`

	// StripeSubscriptionID is the Stripe subscription ID.
	StripeSubscriptionID string `json:"stripeSubscriptionId"`

	// StripeCustomerID is the Stripe customer ID.
	StripeCustomerID string `json:"stripeCustomerId"`

	// CancelAtPeriodEnd indicates if subscription will cancel at period end.
	CancelAtPeriodEnd bool `json:"cancelAtPeriodEnd"`

	// CreatedAt is when the subscription was created.
	CreatedAt time.Time `json:"createdAt"`

	// UpdatedAt is when the subscription was last modified.
	UpdatedAt time.Time `json:"updatedAt"`
}

type SubscriptionService interface {
	// Create creates a new subscription.
	Create(ctx context.Context, sub *Subscription) error

	// Get retrieves a subscription by ID.
	Get(ctx context.Context, id uuid.UUID) (*Subscription, error)

	// GetByOrg retrieves the subscription for an organization.
	GetByOrg(ctx context.Context, orgID uuid.UUID) (*Subscription, error)

	// Update updates a subscription's details.
	Update(ctx context.Context, sub *Subscription) error

	// Cancel cancels a subscription at period end.
	Cancel(ctx context.Context, id uuid.UUID) error

	// CancelImmediately cancels a subscription immediately.
	CancelImmediately(ctx context.Context, id uuid.UUID) error

	// Reactivate reactivates a canceled subscription.
	Reactivate(ctx context.Context, id uuid.UUID) error

	// ChangePlan changes the subscription plan.
	ChangePlan(ctx context.Context, id uuid.UUID, newPlan string) error

	// IsActive checks if an organization has an active subscription.
	IsActive(ctx context.Context, orgID uuid.UUID) (bool, error)

	// GetPlanTier returns the current plan tier for an organization.
	GetPlanTier(ctx context.Context, orgID uuid.UUID) (string, error)
}

type SubscriptionStatus string

type UnassignSeatInput struct {
	LicenseID   string `path:"license_id" format:"uuid"`
	PrincipalID string `path:"principal_id" format:"uuid"`
}

type UpdateListingInput struct {
	ID   string `path:"id" format:"uuid"`
	Body struct {
		Title        *string        `json:"title,omitempty" maxLength:"200"`
		Description  *string        `json:"description,omitempty" maxLength:"5000"`
		PricingModel *string        `json:"pricing_model,omitempty" enum:"free,one_time,subscription,per_seat"`
		PriceCents   *int64         `json:"price_cents,omitempty" minimum:"0"`
		Currency     *string        `json:"currency,omitempty" minLength:"3" maxLength:"3"`
		ProductID    *string        `json:"product_id,omitempty" format:"uuid"`
		Metadata     map[string]any `json:"metadata,omitempty"`
	}
}

type UpdateListingOutput struct {
	Body *ListingResponse
}

type WebhookInput struct {
	StripeSignature string `header:"Stripe-Signature"`
	RawBody         []byte
}