willdot.net
forked from
hailey.at/cocoon
An atproto PDS written in Go
fix delete account endpoint
Signed-off-by: Will Andrews <will7989@hotmail.com>
+10
-10
server/handle_server_delete_account.go
+10
-10
server/handle_server_delete_account.go
···
76
}
77
78
status := "error"
79
-
func() {
80
if status == "error" {
81
if err := tx.Rollback().Error; err != nil {
82
logger.Error("error rolling back after delete failure", "err", err)
···
84
}
85
}()
86
87
-
if err := tx.Exec("DELETE FROM blocks WHERE did = ?", nil, req.Did).Error; err != nil {
88
logger.Error("error deleting blocks", "error", err)
89
return helpers.ServerError(e, nil)
90
}
91
92
-
if err := tx.Exec("DELETE FROM records WHERE did = ?", nil, req.Did).Error; err != nil {
93
logger.Error("error deleting records", "error", err)
94
return helpers.ServerError(e, nil)
95
}
96
97
-
if err := tx.Exec("DELETE FROM blobs WHERE did = ?", nil, req.Did).Error; err != nil {
98
logger.Error("error deleting blobs", "error", err)
99
return helpers.ServerError(e, nil)
100
}
101
102
-
if err := tx.Exec("DELETE FROM tokens WHERE did = ?", nil, req.Did).Error; err != nil {
103
logger.Error("error deleting tokens", "error", err)
104
return helpers.ServerError(e, nil)
105
}
106
107
-
if err := tx.Exec("DELETE FROM refresh_tokens WHERE did = ?", nil, req.Did).Error; err != nil {
108
logger.Error("error deleting refresh tokens", "error", err)
109
return helpers.ServerError(e, nil)
110
}
111
112
-
if err := tx.Exec("DELETE FROM reserved_keys WHERE did = ?", nil, req.Did).Error; err != nil {
113
logger.Error("error deleting reserved keys", "error", err)
114
return helpers.ServerError(e, nil)
115
}
116
117
-
if err := tx.Exec("DELETE FROM invite_codes WHERE did = ?", nil, req.Did).Error; err != nil {
118
logger.Error("error deleting invite codes", "error", err)
119
return helpers.ServerError(e, nil)
120
}
121
122
-
if err := tx.Exec("DELETE FROM actors WHERE did = ?", nil, req.Did).Error; err != nil {
123
logger.Error("error deleting actor", "error", err)
124
return helpers.ServerError(e, nil)
125
}
126
127
-
if err := tx.Exec("DELETE FROM repos WHERE did = ?", nil, req.Did).Error; err != nil {
128
logger.Error("error deleting repo", "error", err)
129
return helpers.ServerError(e, nil)
130
}
···
76
}
77
78
status := "error"
79
+
defer func() {
80
if status == "error" {
81
if err := tx.Rollback().Error; err != nil {
82
logger.Error("error rolling back after delete failure", "err", err)
···
84
}
85
}()
86
87
+
if err := tx.Exec("DELETE FROM blocks WHERE did = ?", req.Did).Error; err != nil {
88
logger.Error("error deleting blocks", "error", err)
89
return helpers.ServerError(e, nil)
90
}
91
92
+
if err := tx.Exec("DELETE FROM records WHERE did = ?", req.Did).Error; err != nil {
93
logger.Error("error deleting records", "error", err)
94
return helpers.ServerError(e, nil)
95
}
96
97
+
if err := tx.Exec("DELETE FROM blobs WHERE did = ?", req.Did).Error; err != nil {
98
logger.Error("error deleting blobs", "error", err)
99
return helpers.ServerError(e, nil)
100
}
101
102
+
if err := tx.Exec("DELETE FROM tokens WHERE did = ?", req.Did).Error; err != nil {
103
logger.Error("error deleting tokens", "error", err)
104
return helpers.ServerError(e, nil)
105
}
106
107
+
if err := tx.Exec("DELETE FROM refresh_tokens WHERE did = ?", req.Did).Error; err != nil {
108
logger.Error("error deleting refresh tokens", "error", err)
109
return helpers.ServerError(e, nil)
110
}
111
112
+
if err := tx.Exec("DELETE FROM reserved_keys WHERE did = ?", req.Did).Error; err != nil {
113
logger.Error("error deleting reserved keys", "error", err)
114
return helpers.ServerError(e, nil)
115
}
116
117
+
if err := tx.Exec("DELETE FROM invite_codes WHERE did = ?", req.Did).Error; err != nil {
118
logger.Error("error deleting invite codes", "error", err)
119
return helpers.ServerError(e, nil)
120
}
121
122
+
if err := tx.Exec("DELETE FROM actors WHERE did = ?", req.Did).Error; err != nil {
123
logger.Error("error deleting actor", "error", err)
124
return helpers.ServerError(e, nil)
125
}
126
127
+
if err := tx.Exec("DELETE FROM repos WHERE did = ?", req.Did).Error; err != nil {
128
logger.Error("error deleting repo", "error", err)
129
return helpers.ServerError(e, nil)
130
}