diff --git a/object/init_data.go b/object/init_data.go index dd308453..7c8ead6e 100644 --- a/object/init_data.go +++ b/object/init_data.go @@ -266,7 +266,13 @@ func initDefinedOrganization(organization *Organization) { } if existed != nil { - return + affected, err := DeleteOrganization(organization) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete organization") + } } organization.CreatedTime = util.GetCurrentTime() organization.AccountItems = getBuiltInAccountItems() @@ -284,7 +290,13 @@ func initDefinedApplication(application *Application) { } if existed != nil { - return + affected, err := DeleteApplication(application) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete application") + } } application.CreatedTime = util.GetCurrentTime() _, err = AddApplication(application) @@ -299,7 +311,13 @@ func initDefinedUser(user *User) { panic(err) } if existed != nil { - return + affected, err := DeleteUser(user) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete user") + } } user.CreatedTime = util.GetCurrentTime() user.Id = util.GenerateId() @@ -319,7 +337,13 @@ func initDefinedCert(cert *Cert) { } if existed != nil { - return + affected, err := DeleteCert(cert) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete cert") + } } cert.CreatedTime = util.GetCurrentTime() _, err = AddCert(cert) @@ -335,7 +359,13 @@ func initDefinedLdap(ldap *Ldap) { } if existed != nil { - return + affected, err := DeleteLdap(ldap) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete ldap") + } } _, err = AddLdap(ldap) if err != nil { @@ -350,7 +380,13 @@ func initDefinedProvider(provider *Provider) { } if existed != nil { - return + affected, err := DeleteProvider(provider) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete provider") + } } _, err = AddProvider(provider) if err != nil { @@ -365,7 +401,13 @@ func initDefinedModel(model *Model) { } if existed != nil { - return + affected, err := DeleteModel(model) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete provider") + } } model.CreatedTime = util.GetCurrentTime() _, err = AddModel(model) @@ -381,7 +423,13 @@ func initDefinedPermission(permission *Permission) { } if existed != nil { - return + affected, err := DeletePermission(permission) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete permission") + } } permission.CreatedTime = util.GetCurrentTime() _, err = AddPermission(permission) @@ -397,7 +445,13 @@ func initDefinedPayment(payment *Payment) { } if existed != nil { - return + affected, err := DeletePayment(payment) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete payment") + } } payment.CreatedTime = util.GetCurrentTime() _, err = AddPayment(payment) @@ -413,7 +467,13 @@ func initDefinedProduct(product *Product) { } if existed != nil { - return + affected, err := DeleteProduct(product) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete product") + } } product.CreatedTime = util.GetCurrentTime() _, err = AddProduct(product) @@ -429,7 +489,13 @@ func initDefinedResource(resource *Resource) { } if existed != nil { - return + affected, err := DeleteResource(resource) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete resource") + } } resource.CreatedTime = util.GetCurrentTime() _, err = AddResource(resource) @@ -445,7 +511,13 @@ func initDefinedRole(role *Role) { } if existed != nil { - return + affected, err := DeleteRole(role) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete role") + } } role.CreatedTime = util.GetCurrentTime() _, err = AddRole(role) @@ -461,7 +533,13 @@ func initDefinedSyncer(syncer *Syncer) { } if existed != nil { - return + affected, err := DeleteSyncer(syncer) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete role") + } } syncer.CreatedTime = util.GetCurrentTime() _, err = AddSyncer(syncer) @@ -477,7 +555,13 @@ func initDefinedToken(token *Token) { } if existed != nil { - return + affected, err := DeleteToken(token) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete token") + } } token.CreatedTime = util.GetCurrentTime() _, err = AddToken(token) @@ -493,7 +577,13 @@ func initDefinedWebhook(webhook *Webhook) { } if existed != nil { - return + affected, err := DeleteWebhook(webhook) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete webhook") + } } webhook.CreatedTime = util.GetCurrentTime() _, err = AddWebhook(webhook) @@ -508,7 +598,13 @@ func initDefinedGroup(group *Group) { panic(err) } if existed != nil { - return + affected, err := DeleteGroup(group) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete group") + } } group.CreatedTime = util.GetCurrentTime() _, err = AddGroup(group) @@ -523,7 +619,13 @@ func initDefinedAdapter(adapter *Adapter) { panic(err) } if existed != nil { - return + affected, err := DeleteAdapter(adapter) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete adapter") + } } adapter.CreatedTime = util.GetCurrentTime() _, err = AddAdapter(adapter) @@ -538,7 +640,13 @@ func initDefinedEnforcer(enforcer *Enforcer) { panic(err) } if existed != nil { - return + affected, err := DeleteEnforcer(enforcer) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete enforcer") + } } enforcer.CreatedTime = util.GetCurrentTime() _, err = AddEnforcer(enforcer) @@ -553,7 +661,13 @@ func initDefinedPlan(plan *Plan) { panic(err) } if existed != nil { - return + affected, err := DeletePlan(plan) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete enforcer") + } } plan.CreatedTime = util.GetCurrentTime() _, err = AddPlan(plan) @@ -568,7 +682,13 @@ func initDefinedPricing(pricing *Pricing) { panic(err) } if existed != nil { - return + affected, err := DeletePricing(pricing) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete pricing") + } } pricing.CreatedTime = util.GetCurrentTime() _, err = AddPricing(pricing) @@ -583,7 +703,13 @@ func initDefinedInvitation(invitation *Invitation) { panic(err) } if existed != nil { - return + affected, err := DeleteInvitation(invitation) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete invitation") + } } invitation.CreatedTime = util.GetCurrentTime() _, err = AddInvitation(invitation, "en") @@ -611,7 +737,13 @@ func initDefinedSubscription(subscription *Subscription) { panic(err) } if existed != nil { - return + affected, err := DeleteSubscription(subscription) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete subscription") + } } subscription.CreatedTime = util.GetCurrentTime() _, err = AddSubscription(subscription) @@ -626,7 +758,13 @@ func initDefinedTransaction(transaction *Transaction) { panic(err) } if existed != nil { - return + affected, err := DeleteTransaction(transaction) + if err != nil { + panic(err) + } + if !affected { + panic("Fail to delete transaction") + } } transaction.CreatedTime = util.GetCurrentTime() _, err = AddTransaction(transaction)