Skip to content

Commit

Permalink
feat: fix bug that fails to import built-in org via init_data.json (#…
Browse files Browse the repository at this point in the history 
…2922)
  • Loading branch information
@dacongda
dacongda committed May 4, 2024
1 parent d43d58d commit 1dfbbf0
Showing 1 changed file with 161 additions and 23 deletions.
184 changes: 161 additions & 23 deletions object/init_data.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand All @@ -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)
Expand All @@ -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()
Expand All @@ -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)
Expand All @@ -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 {
Expand All @@ -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 {
Expand All @@ -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)
Expand All @@ -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)
Expand All @@ -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)
Expand All @@ -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)
Expand All @@ -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)
Expand All @@ -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)
Expand All @@ -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)
Expand All @@ -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)
Expand All @@ -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)
Expand All @@ -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)
Expand All @@ -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)
Expand All @@ -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)
Expand All @@ -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)
Expand All @@ -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)
Expand All @@ -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")
Expand Down Expand Up @@ -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)
Expand All @@ -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)
Expand Down

0 comments on commit 1dfbbf0

Please sign in to comment.