Skip to content

Commit 26c1d7a

Browse files
authored
Merge branch 'staging' into coordinator_api_debug_test
2 parents 9bb3c0c + aa885f0 commit 26c1d7a

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

bridge/l2/relayer.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,8 @@ func (r *Layer2Relayer) ProcessSavedEvents(wg *sync.WaitGroup) {
107107
// msgs are sorted by nonce in increasing order
108108
msgs, err := r.db.GetL2Messages(
109109
map[string]interface{}{"status": orm.MsgPending},
110-
fmt.Sprintf("AND height<=%d ORDER BY nonce ASC LIMIT %d", batch.EndBlockNumber, processMsgLimit),
110+
fmt.Sprintf("AND height<=%d", batch.EndBlockNumber),
111+
fmt.Sprintf("ORDER BY nonce ASC LIMIT %d", processMsgLimit),
111112
)
112113

113114
if err != nil {

database/migrate/migrations/00002_l1_message.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ create table l1_message
2020
);
2121

2222
comment
23-
on column l1_message.status is 'undefined, pending, submitted, confirmed';
23+
on column l1_message.status is 'undefined, pending, submitted, confirmed, failed, expired';
2424

2525
create unique index l1_message_hash_uindex
2626
on l1_message (msg_hash);

database/migrate/migrations/00003_l2_message.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ create table l2_message
2121
);
2222

2323
comment
24-
on column l2_message.status is 'undefined, pending, submitted, confirmed';
24+
on column l2_message.status is 'undefined, pending, submitted, confirmed, failed, expired';
2525

2626
create unique index l2_message_hash_uindex
2727
on l2_message (msg_hash);

0 commit comments

Comments
 (0)