Merge pull request #43 from waku-org/Store_tests_Part1

Adding store files

Author: AYAHASSAN287

.gitignore

@@ -23,3 +23,9 @@ go.work
 # Generated dependencies and cache
 third_party
 nimcache
+
+waku/store.sqlite3
+
+waku/store.sqlite3-shm
+
+waku/store.sqlite3-wal

waku/nwaku_test_utils.go

@@ -12,6 +12,7 @@ import (
 	"time"
 
 	"github.com/cenkalti/backoff/v3"
+	"github.com/libp2p/go-libp2p/core/peer"
 	"github.com/waku-org/go-waku/waku/v2/protocol/pb"
 	"github.com/waku-org/waku-go-bindings/waku/common"
 	"google.golang.org/protobuf/proto"
@@ -94,7 +95,7 @@ func (n *WakuNode) CreateMessage(customMessage ...*pb.WakuMessage) *pb.WakuMessa
 	Debug("Using default message format on node %s", n.nodeName)
 	defaultMessage := &pb.WakuMessage{
 		Payload:      []byte("This is a default Waku message payload"),
-		ContentTopic: "test-content-topic",
+		ContentTopic: DefaultContentTopic,
 		Version:      proto.Uint32(0),
 		Timestamp:    proto.Int64(time.Now().UnixNano()),
 	}
@@ -215,3 +216,42 @@ func SubscribeNodesToTopic(nodes []*WakuNode, topic string) error {
 	}
 	return nil
 }
+
+func (n *WakuNode) GetStoredMessages(storeNode *WakuNode, storeRequest *common.StoreQueryRequest) (*common.StoreQueryResponse, error) {
+	Debug("Starting store query request")
+
+	if storeRequest == nil {
+		Debug("Using DefaultStoreQueryRequest")
+		storeRequest = &DefaultStoreQueryRequest
+	}
+
+	storeMultiaddr, err := storeNode.ListenAddresses()
+	if err != nil {
+		Error("Failed to retrieve listen addresses for store node: %v", err)
+		return nil, err
+	}
+
+	if len(storeMultiaddr) == 0 {
+		Error("Store node has no available listen addresses")
+		return nil, errors.New("store node has no available listen addresses")
+	}
+
+	storeNodeAddrInfo, err := peer.AddrInfoFromString(storeMultiaddr[0].String())
+	if err != nil {
+		Error("Failed to convert store node address to AddrInfo: %v", err)
+		return nil, err
+	}
+
+	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+	defer cancel()
+
+	Debug("Querying store node for messages")
+	res, err := n.StoreQuery(ctx, storeRequest, *storeNodeAddrInfo)
+	if err != nil {
+		Error("StoreQuery failed: %v", err)
+		return nil, err
+	}
+
+	Debug("Store query successful, retrieved %d messages", len(*res.Messages))
+	return res, nil
+}