From e6b42ee8bf9a0b8f71b588733c5b8cf21d87224b Mon Sep 17 00:00:00 2001
From: krehermann <keith.rehermann@smartcontract.com>
Date: Wed, 10 Jan 2024 08:33:04 -0700
Subject: [PATCH] delete unused libpq notify channels

---
 core/chains/evm/logpoller/log_poller_test.go | 57 --------------------
 core/services/pg/channels.go                 |  4 --
 2 files changed, 61 deletions(-)
 delete mode 100644 core/services/pg/channels.go

diff --git a/core/chains/evm/logpoller/log_poller_test.go b/core/chains/evm/logpoller/log_poller_test.go
index 81d1b74e42d..4bfc403e341 100644
--- a/core/chains/evm/logpoller/log_poller_test.go
+++ b/core/chains/evm/logpoller/log_poller_test.go
@@ -20,7 +20,6 @@ import (
 	"github.com/leanovate/gopter"
 	"github.com/leanovate/gopter/gen"
 	"github.com/leanovate/gopter/prop"
-	"github.com/lib/pq"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
 	"github.com/stretchr/testify/require"
@@ -39,7 +38,6 @@ import (
 	"github.com/smartcontractkit/chainlink/v2/core/internal/testutils"
 	"github.com/smartcontractkit/chainlink/v2/core/internal/testutils/evmtest"
 	"github.com/smartcontractkit/chainlink/v2/core/internal/testutils/pgtest"
-	"github.com/smartcontractkit/chainlink/v2/core/services/chainlink"
 	"github.com/smartcontractkit/chainlink/v2/core/services/pg"
 )
 
@@ -1325,61 +1323,6 @@ func TestLogPoller_DBErrorHandling(t *testing.T) {
 	assert.Contains(t, logMsgs, "Backup log poller ran before filters loaded, skipping")
 }
 
-func TestNotifyAfterInsert(t *testing.T) {
-	t.Parallel()
-
-	// Use a non-transactional db for this test because notify events
-	// are not delivered until the transaction is committed.
-	var dbURL string
-	_, sqlxDB := heavyweight.FullTestDBV2(t, func(c *chainlink.Config, s *chainlink.Secrets) {
-		dbURL = s.Database.URL.URL().String()
-	})
-
-	lggr, _ := logger.TestObserved(t, zapcore.WarnLevel)
-	chainID := big.NewInt(1337)
-	o := logpoller.NewORM(chainID, sqlxDB, lggr, pgtest.NewQConfig(true))
-
-	listener := pq.NewListener(dbURL, time.Second, time.Second, nil)
-	err := listener.Listen(pg.ChannelInsertOnEVMLogs)
-	require.NoError(t, err)
-
-	log := logpoller.Log{
-		EvmChainId:     ubig.New(chainID),
-		LogIndex:       10,
-		BlockHash:      testutils.Random32Byte(),
-		BlockNumber:    100,
-		BlockTimestamp: time.Now(),
-		Topics: pq.ByteaArray{
-			testutils.NewAddress().Bytes(),
-			testutils.NewAddress().Bytes(),
-		},
-		EventSig:  testutils.Random32Byte(),
-		Address:   testutils.NewAddress(),
-		TxHash:    testutils.Random32Byte(),
-		Data:      []byte("test_data"),
-		CreatedAt: time.Now(),
-	}
-
-	err = o.InsertLogs([]logpoller.Log{log})
-	require.NoError(t, err)
-
-	testutils.AssertEventually(t, func() bool {
-		select {
-		case event := <-listener.Notify:
-			expectedPayload := fmt.Sprintf(
-				"%s:%s,%s",
-				hexutil.Encode(log.Address.Bytes())[2:], // strip the leading 0x
-				hexutil.Encode(log.Topics[0])[2:],
-				hexutil.Encode(log.Topics[1])[2:],
-			)
-			require.Equal(t, event.Extra, expectedPayload)
-			return true
-		default:
-			return false
-		}
-	})
-}
-
 type getLogErrData struct {
 	From  string
 	To    string
diff --git a/core/services/pg/channels.go b/core/services/pg/channels.go
deleted file mode 100644
index aed132a7f2c..00000000000
--- a/core/services/pg/channels.go
+++ /dev/null
@@ -1,4 +0,0 @@
-package pg
-
-// Postgres channel to listen for new evm.txes
-const ChannelInsertOnEVMLogs = "evm.insert_on_logs"