Skip to content

Commit 8ee3584

Browse files
committed
fix lint
1 parent c00924c commit 8ee3584

2 files changed

Lines changed: 10 additions & 4 deletions

File tree

sender/writer.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,10 @@ func (w *TxsWriter) Flush() error {
6767
}()
6868
// write to dir `~/load_txs`
6969
// make dir if it doesn't exist
70-
os.MkdirAll(w.txsDir, 0755)
70+
err := os.MkdirAll(w.txsDir, 0755)
71+
if err != nil {
72+
return err
73+
}
7174
txsFile := filepath.Join(w.txsDir, fmt.Sprintf("%d_txs.json", w.nextHeight))
7275
txData := TxWriteData{
7376
TxPayloads: make([][]byte, 0),

sender/writer_test.go

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -34,19 +34,22 @@ func TestTxsWriter_Flush(t *testing.T) {
3434

3535
txs := generator.GenerateN(3)
3636

37-
writer.Send(context.Background(), txs[0])
37+
err := writer.Send(context.Background(), txs[0])
38+
require.NoError(t, err)
3839
require.Equal(t, uint64(1), writer.nextHeight)
3940
require.Equal(t, uint64(21000), writer.bufferGas)
4041
require.Len(t, writer.txBuffer, 1)
4142
require.Equal(t, txs[0], writer.txBuffer[0])
4243

43-
writer.Send(context.Background(), txs[1])
44+
err = writer.Send(context.Background(), txs[1])
45+
require.NoError(t, err)
4446
require.Equal(t, uint64(1), writer.nextHeight)
4547
require.Equal(t, uint64(42000), writer.bufferGas)
4648
require.Len(t, writer.txBuffer, 2)
4749
require.Equal(t, txs[1], writer.txBuffer[1])
4850

49-
writer.Send(context.Background(), txs[2])
51+
err = writer.Send(context.Background(), txs[2])
52+
require.NoError(t, err)
5053
// now should be flushed and have the new tx
5154
require.Equal(t, uint64(2), writer.nextHeight)
5255
require.Equal(t, uint64(21000), writer.bufferGas)

0 commit comments

Comments
 (0)