Replace the locations of the accounts for testing a Mint

cmd/connector-common-winners-timescale/main.go

@@ -5,10 +5,17 @@
 package main
 
 import (
+	"github.com/fluidity-money/fluidity-app/lib/databases/postgres/solana"
 	database "github.com/fluidity-money/fluidity-app/lib/databases/timescale/winners"
 	queue "github.com/fluidity-money/fluidity-app/lib/queues/winners"
 )
 
 func main() {
-	queue.WinnersAll(database.InsertWinner)
+	go queue.WinnersEthereum(database.InsertWinner)
+
+	queue.WinnersSolana(func(winner queue.Winner) {
+		winningSignature := solana.GetIntermediateWinner(winner.TransactionHash)
+		winner.SendTransactionHash = winningSignature
+		database.InsertWinner(winner)
+	})
 }

database/101-up-postgres/20231211120959-solana_winner_tracking_add_intermediate_winning_hash.sql

@@ -0,0 +1,12 @@
+
+-- migrate:up
+
+CREATE TABLE solana_intermediate_winners (
+	created TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+	winning_signature VARCHAR NOT NULL,
+	payout_signature VARCHAR NOT NULL
+);
+
+-- migrate:down
+
+DROP TABLE solana_intermediate_winners;

lib/databases/postgres/solana/intermediate-winners.go

@@ -0,0 +1,57 @@
+// Copyright 2022 Fluidity Money. All rights reserved. Use of this
+// source code is governed by a GPL-style license that can be found in the
+// LICENSE.md file.
+
+package solana
+
+import (
+	"fmt"
+
+	"github.com/fluidity-money/fluidity-app/lib/log"
+	"github.com/fluidity-money/fluidity-app/lib/postgres"
+)
+
+// GetIntermediateWinner using a payout transaction signature
+func GetIntermediateWinner(payoutSignature string) (winningSignature string) {
+	databaseClient := postgres.Client()
+
+	statementText := fmt.Sprintf(
+		`SELECT  winning_signature
+		FROM %s
+		WHERE payout_signature = $;`,
+
+		TableIntermediateWinners,
+	)
+
+	row := databaseClient.QueryRow(statementText, payoutSignature)
+
+	if err := row.Err(); err != nil {
+		log.Fatal(func(k *log.Log) {
+			k.Context = Context
+
+			k.Format(
+				"Failed to query for an intermediate winner with payout sig %v",
+				payoutSignature,
+			)
+
+			k.Payload = err
+		})
+	}
+
+	err := row.Scan(&winningSignature)
+
+	if err != nil {
+		log.Fatal(func(k *log.Log) {
+			k.Context = Context
+
+			k.Format(
+				"Failed to scan the intermediate winners table for payout signature %v",
+				payoutSignature,
+			)
+
+			k.Payload = err
+		})
+	}
+
+	return winningSignature
+}

lib/databases/postgres/solana/solana.go

@@ -15,4 +15,9 @@ const (
 
 	// TableMintLimits is used to store each token's per user mint limit
 	TableMintLimits = `solana_mint_limits`
+
+	// TableIntermediateWinners to use to track winners that were
+	// paid out and need to be linked in the winners database to the
+	// winning transaction
+	TableIntermediateWinners = `solana_intermediate_winners`
 )