instantout: add instantout store

Author: sputn1ck

instantout/store.go

@@ -0,0 +1,36 @@
+package instantout
+
+import (
+	"crypto/rand"
+	"testing"
+
+	"github.com/lightninglabs/loop/instantout/reservation"
+	"github.com/stretchr/testify/require"
+)
+
+func TestConvertingReservations(t *testing.T) {
+	var resId1, resId2 reservation.ID
+
+	// fill the ids with random values.
+	if _, err := rand.Read(resId1[:]); err != nil {
+		t.Fatal(err)
+	}
+
+	if _, err := rand.Read(resId2[:]); err != nil {
+		t.Fatal(err)
+	}
+
+	reservations := []*reservation.Reservation{
+		{ID: resId1}, {ID: resId2},
+	}
+
+	byteSlice := reservationIdsToByteSlice(reservations)
+	require.Len(t, byteSlice, 64)
+
+	reservationIds, err := byteSliceToReservationIds(byteSlice)
+	require.NoError(t, err)
+
+	require.Len(t, reservationIds, 2)
+	require.Equal(t, resId1, reservationIds[0])
+	require.Equal(t, resId2, reservationIds[1])
+}

instantout/store_test.go

@@ -543,7 +543,7 @@ func ConvertLoopOutRow(network *chaincfg.Params, row sqlc.GetLoopOutSwapRow,
 	}
 
 	if row.OutgoingChanSet != "" {
-		chanSet, err := convertOutgoingChanSet(row.OutgoingChanSet)
+		chanSet, err := ConvertOutgoingChanSet(row.OutgoingChanSet)
 		if err != nil {
 			return nil, err
 		}
@@ -666,9 +666,9 @@ func getSwapEvents(updates []sqlc.SwapUpdate) ([]*LoopEvent, error) {
 	return events, nil
 }
 
-// convertOutgoingChanSet converts a comma separated string of channel IDs into
+// ConvertOutgoingChanSet converts a comma separated string of channel IDs into
 // a ChannelSet.
-func convertOutgoingChanSet(outgoingChanSet string) (ChannelSet, error) {
+func ConvertOutgoingChanSet(outgoingChanSet string) (ChannelSet, error) {
 	// Split the string into a slice of strings
 	chanStrings := strings.Split(outgoingChanSet, ",")
 	channels := make([]uint64, len(chanStrings))

loopdb/sql_store.go

@@ -0,0 +1,4 @@
+DROP INDEX IF EXISTS instantout_updates_swap_hash_idx;
+DROP INDEX IF EXISTS instantout_swap_hash_idx;
+DROP TABLE IF EXISTS instantout_updates;
+DROP TABLE IF EXISTS instantout_swaps;