db

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

type DBService interface {
	// A PaymentRequest is created first by the user
	SaveNewPaymentRequest(ctx context.Context, bsr *proto.BuySubscriptionRequest, billingID string) (err error)
	GetPaymentRequest(ctx context.Context, billingID string) (pr *PaymentRequest, err error)
	UpdatePaymentRequest(ctx context.Context, pr *PaymentRequest, billingID string) (err error)

	// When payment is completed, we create a new subscription
	// with []payments array (do not confuse with PaymentRequest)
	GetSubscriptionForUser(ctx context.Context, userAnyID string) (sub *Subscription, err error)
	GetSubscription(ctx context.Context, subID string) (sub *Subscription, err error)
	// max output - 100 items
	GetAllSubscriptionsInStatus(ctx context.Context, status proto.SubscriptionStatus) (subsIds []string, err error)
	CreateOrUpdateSubscription(ctx context.Context, sub *Subscription, userAnyID string) (err error)

	app.Component
}

type NSOperation struct {
	OperationType  NSOperationType          `bson:"OperationType"`
	OperationId    string                   `bson:"OperationId"`
	OperationState anyns_api.OperationState `bson:"OperationState"`
}

type NSOperationType uint8

type Payment struct {
	Id              primitive.ObjectID `bson:"_id"`
	PaymentState    ReqState           `bson:"PaymentState"`
	PaymentProvider PaymentProvider    `bson:"PaymentProvider"`

	// If through Stripe
	StripePaymentMethod uint8 `bson:"StripePaymentMethod"`
}

type PaymentProvider uint8

type PaymentRequest struct {
	Id primitive.ObjectID `bson:"_id"`

	// random generated string
	BillingID     string                 `bson:"BillingID"`
	RequestedTier proto.SubscriptionTier `bson:"RequestedTier"`

	OwnerAnyID      string `bson:"OwnerAnyID"`
	OwnerEthAddress string `bson:"OwnerEthAddress"`

	PaymentMethod       proto.PaymentMethod `bson:"PaymentMethod"`
	PaymentRequestState ReqState            `bson:"PaymentRequestState"`
}

type ReqState uint8

type Subscription struct {
	Id primitive.ObjectID `bson:"_id"`

	OwnerAnyID      string                 `bson:"OwnerAnyID"`
	OwnerEthAddress string                 `bson:"OwnerEthAddress"`
	CurrentTier     proto.SubscriptionTier `bson:"CurrentTier"`

	Started uint64 `bson:"Started"`
	Ends    uint64 `bson:"Ends"`

	SubscriptionStatus proto.SubscriptionStatus `bson:"SubscriptionStatus"`
	IsAutoRenew        bool                     `bson:"IsAutoRenew"`

	// if through Stripe
	StripeSessionId      string `bson:"StripeSessionId"`
	StripeSubscriptionID string `bson:"StripeSubscriptionID"`

	Payments              []Payment     `bson:"Payments"`
	NameServiceOperations []NSOperation `bson:"NameServiceOperations"`
}