mirror of
https://github.com/dnote/dnote
synced 2026-03-15 15:05:51 +01:00
891be61031* Add app abstraction * Abstract out email sending * Get sender * Test * Move operations to app * Test * Test * Add license * Fix lint
80 lines
2.4 KiB
Go
80 lines
2.4 KiB
Go
/* Copyright (C) 2019 Monomax Software Pty Ltd
|
|
*
|
|
* This file is part of Dnote.
|
|
*
|
|
* Dnote is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU Affero General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* Dnote is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU Affero General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Affero General Public License
|
|
* along with Dnote. If not, see <https://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
package app
|
|
|
|
import (
|
|
"github.com/dnote/dnote/pkg/server/database"
|
|
"github.com/pkg/errors"
|
|
|
|
"github.com/stripe/stripe-go"
|
|
"github.com/stripe/stripe-go/sub"
|
|
)
|
|
|
|
// ErrSubscriptionActive is an error indicating that the subscription is active
|
|
// and therefore cannot be reactivated
|
|
var ErrSubscriptionActive = errors.New("The subscription is currently active")
|
|
|
|
// CancelSub cancels the subscription of the given user
|
|
func (a *App) CancelSub(subscriptionID string, user database.User) error {
|
|
updateParams := &stripe.SubscriptionParams{
|
|
CancelAtPeriodEnd: stripe.Bool(true),
|
|
}
|
|
|
|
_, err := sub.Update(subscriptionID, updateParams)
|
|
if err != nil {
|
|
return errors.Wrap(err, "updating subscription on Stripe")
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// ReactivateSub reactivates the subscription of the given user
|
|
func (a *App) ReactivateSub(subscriptionID string, user database.User) error {
|
|
s, err := sub.Get(subscriptionID, nil)
|
|
if err != nil {
|
|
return errors.Wrap(err, "fetching subscription")
|
|
}
|
|
|
|
if !s.CancelAtPeriodEnd {
|
|
return ErrSubscriptionActive
|
|
}
|
|
|
|
updateParams := &stripe.SubscriptionParams{
|
|
CancelAtPeriodEnd: stripe.Bool(false),
|
|
}
|
|
if _, err := sub.Update(subscriptionID, updateParams); err != nil {
|
|
return errors.Wrap(err, "updating subscription on Stripe")
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// MarkUnsubscribed marks the user unsubscribed
|
|
func (a *App) MarkUnsubscribed(stripeCustomerID string) error {
|
|
var user database.User
|
|
if err := a.DB.Where("stripe_customer_id = ?", stripeCustomerID).First(&user).Error; err != nil {
|
|
return errors.Wrap(err, "finding user")
|
|
}
|
|
|
|
if err := a.DB.Model(&user).Update("cloud", false).Error; err != nil {
|
|
return errors.Wrap(err, "updating user")
|
|
}
|
|
|
|
return nil
|
|
}
|