feat: index ownership changes, bump min go version

internal/handler/ownership.go

@@ -0,0 +1,11 @@
+package handler
+
+import (
+	"context"
+
+	"github.com/grassrootseconomics/eth-tracker/pkg/event"
+)
+
+func (h *Handler) IndexOwnershipChange(ctx context.Context, event event.Event) error {
+	return h.store.InsertOwnershipChange(ctx, event)
+}

internal/store/pg.go

@@ -29,15 +29,16 @@ type (
 	}
 
 	queries struct {
-		InsertTx            string `query:"insert-tx"`
-		InsertTokenTransfer string `query:"insert-token-transfer"`
-		InsertTokenMint     string `query:"insert-token-mint"`
-		InsertTokenBurn     string `query:"insert-token-burn"`
-		InsertFaucetGive    string `query:"insert-faucet-give"`
-		InsertPoolSwap      string `query:"insert-pool-swap"`
-		InsertPoolDeposit   string `query:"insert-pool-deposit"`
-		InsertToken         string `query:"insert-token"`
-		InsertPool          string `query:"insert-pool"`
+		InsertTx              string `query:"insert-tx"`
+		InsertTokenTransfer   string `query:"insert-token-transfer"`
+		InsertTokenMint       string `query:"insert-token-mint"`
+		InsertTokenBurn       string `query:"insert-token-burn"`
+		InsertFaucetGive      string `query:"insert-faucet-give"`
+		InsertPoolSwap        string `query:"insert-pool-swap"`
+		InsertPoolDeposit     string `query:"insert-pool-deposit"`
+		InsertOwnershipChange string `query:"insert-ownership-change"`
+		InsertToken           string `query:"insert-token"`
+		InsertPool            string `query:"insert-pool"`
 	}
 )
 
@@ -199,6 +200,25 @@ func (pg *Pg) InsertPoolDeposit(ctx context.Context, eventPayload event.Event) e
 	})
 }
 
+func (pg *Pg) InsertOwnershipChange(ctx context.Context, eventPayload event.Event) error {
+	return pg.executeTransaction(ctx, func(tx pgx.Tx) error {
+		txID, err := pg.insertTx(ctx, tx, eventPayload)
+		if err != nil {
+			return err
+		}
+
+		_, err = tx.Exec(
+			ctx,
+			pg.queries.InsertOwnershipChange,
+			txID,
+			eventPayload.Payload["previousOwner"].(string),
+			eventPayload.Payload["newOwner"].(string),
+			eventPayload.ContractAddress,
+		)
+		return err
+	})
+}
+
 func (pg *Pg) InsertToken(ctx context.Context, contractAddress string, name string, symbol string, decimals uint8, sinkAddress string) error {
 	return pg.executeTransaction(ctx, func(tx pgx.Tx) error {
 		_, err := tx.Exec(

internal/store/store.go

@@ -15,6 +15,7 @@ type (
 		InsertFaucetGive(context.Context, event.Event) error
 		InsertPoolSwap(context.Context, event.Event) error
 		InsertPoolDeposit(context.Context, event.Event) error
+		InsertOwnershipChange(context.Context, event.Event) error
 		InsertToken(context.Context, string, string, string, uint8, string) error
 		InsertPool(context.Context, string, string, string) error
 		Pool() *pgxpool.Pool