File tree Expand file tree Collapse file tree 2 files changed +9
-5
lines changed Expand file tree Collapse file tree 2 files changed +9
-5
lines changed Original file line number Diff line number Diff line change @@ -133,11 +133,11 @@ func ResetHeight(db types.DB, nodeName string) error {
133
133
}
134
134
nodeDB := db .WithPrefix ([]byte (nodeName ))
135
135
136
- if err := DeletePendingEvents (db ); err != nil {
136
+ if err := DeletePendingEvents (nodeDB ); err != nil {
137
137
return err
138
138
}
139
139
140
- if err := DeletePendingChallenges (db ); err != nil {
140
+ if err := DeletePendingChallenges (nodeDB ); err != nil {
141
141
return err
142
142
}
143
143
Original file line number Diff line number Diff line change @@ -13,6 +13,8 @@ func ResetHeights(db types.DB) error {
13
13
types .HostName ,
14
14
types .ChildName ,
15
15
types .BatchName ,
16
+ types .DAHostName ,
17
+ types .DACelestiaName ,
16
18
}
17
19
for _ , dbName := range dbNames {
18
20
if err := ResetHeight (db , dbName ); err != nil {
@@ -25,18 +27,20 @@ func ResetHeights(db types.DB) error {
25
27
func ResetHeight (db types.DB , nodeName string ) error {
26
28
if nodeName != types .HostName &&
27
29
nodeName != types .ChildName &&
28
- nodeName != types .BatchName {
30
+ nodeName != types .BatchName &&
31
+ nodeName != types .DAHostName &&
32
+ nodeName != types .DACelestiaName {
29
33
return errors .New ("unknown node name" )
30
34
}
31
35
nodeDB := db .WithPrefix ([]byte (nodeName ))
32
36
err := node .DeleteSyncInfo (nodeDB )
33
37
if err != nil {
34
38
return err
35
39
}
36
- if err := node .DeletePendingTxs (db ); err != nil {
40
+ if err := node .DeletePendingTxs (nodeDB ); err != nil {
37
41
return err
38
42
}
39
- if err := node .DeleteProcessedMsgs (db ); err != nil {
43
+ if err := node .DeleteProcessedMsgs (nodeDB ); err != nil {
40
44
return err
41
45
}
42
46
fmt .Printf ("reset height to 0 for node %s\n " , string (nodeDB .GetPrefix ()))
You can’t perform that action at this time.
0 commit comments