Add topics to event filter.

services/execdb/filters.go

@@ -184,6 +184,10 @@ type EventFilter struct {
 	// Address is the address of the contract that generated the event.
 	// If nil then no filter is applied
 	Address *[]byte
+
+	// Topics are the topics of the event.
+	// If nil then no filter is applied.
+	Topics [][]byte
 }
 
 // TransactionBalanceChangeFilter defines a filter for fetching transaction balance changes.

services/execdb/postgresql/events.go

@@ -75,6 +75,15 @@ FROM t_events`)
 		queryVals = append(queryVals, *filter.To)
 		queryBuilder.WriteString(fmt.Sprintf(`
 %s f_block_height <= $%d`, wherestr, len(queryVals)))
+		wherestr = "  AND"
+	}
+
+	if len(filter.Topics) > 0 {
+		queryVals = append(queryVals, filter.Topics)
+		queryBuilder.WriteString(fmt.Sprintf(`
+%s f_topics && $%d IS TRUE`, wherestr, len(queryVals)))
+		//nolint
+		wherestr = "  AND"
 	}
 
 	switch filter.Order {

services/execdb/postgresql/events_test.go

@@ -35,6 +35,15 @@ func hashPtr(input string) *[]byte {
 	return &res
 }
 
+func hash(input string) []byte {
+	res, err := hex.DecodeString(strings.TrimPrefix(input, "0x"))
+	if err != nil {
+		panic(err)
+	}
+
+	return res
+}
+
 func TestEvents(t *testing.T) {
 	ctx := context.Background()
 	s, err := postgresql.New(ctx,
@@ -90,6 +99,17 @@ func TestEvents(t *testing.T) {
 			},
 			events: `[{"TransactionHash":"WJ6BebauwoVbUX44QURYdMEzu36dxFPZrqXH309XsfY=","BlockHeight":12690581,"Index":133,"Address":"wCqqObIj/o0KDlxPJ+rZCDx1bMI=","Topics":["4f/8xJI9BLVZ9NKai/xs2gTrWw08RgdRwkAsXFzJEJw=","AAAAAAAAAAAAAAAAAAAAAAAAfxUL1vVMQKNNfD1en1Y="],"Data":"AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAABotlX2fLCfBk="},{"TransactionHash":"WJ6BebauwoVbUX44QURYdMEzu36dxFPZrqXH309XsfY=","BlockHeight":12690581,"Index":134,"Address":"YZNcvdAih7UREZ3bEa60LxWTt+8=","Topics":["aGl5Hwo0eBspiCmCzDnognaM8slplcKhEMV3xTvJMtU=","AAAAAAAAAAAAAAAAYXRvhnPuocUUaWvFI8qZH/WGTnc=","AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA=","7WI7IfwtFeOW4BgQ4ggsPDoP8LfriT7ca4p25LcZOZs="],"Data":"AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAWAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAABwAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAIgAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAkAAAAAAAAAAAAAAAAAAAAAAAAB/FQvW9UxAo018PV6fVgAAAAAAAAAAAAAAAAAAAAAAAH8VC9b1TECjTXw9Xp9WAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAz5dzgiony/3LoAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAGi2VfZ8sJ8GQAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAADoCfh2gVkAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAk9HJhsAAAAAAAAAAAAAAAAGsXVHTokJTETamLlU7t6sSVJx0PAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAk9HJhsAAAAAAAAAAAAAAAAMAqqjmyI/6NCg5cTyfq2Qg8dWzCAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA="},{"TransactionHash":"WJ6BebauwoVbUX44QURYdMEzu36dxFPZrqXH309XsfY=","BlockHeight":12690581,"Index":135,"Address":"wCqqObIj/o0KDlxPJ+rZCDx1bMI=","Topics":["3fJSrRviyJtpwrBo/DeNqpUrp/FjxKEWKPVaTfUjs+8=","AAAAAAAAAAAAAAAAAAAAAAAAfxUL1vVMQKNNfD1en1Y=","AAAAAAAAAAAAAAAAYXRvhnPuocUUaWvFI8qZH/WGTnc="],"Data":"AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAABotlX2fLCfBk="},{"TransactionHash":"WJ6BebauwoVbUX44QURYdMEzu36dxFPZrqXH309XsfY=","BlockHeight":12690581,"Index":136,"Address":"axdUdOiQlMRNqYuVTu3qxJUnHQ8=","Topics":["3fJSrRviyJtpwrBo/DeNqpUrp/FjxKEWKPVaTfUjs+8=","AAAAAAAAAAAAAAAAYXRvhnPuocUUaWvFI8qZH/WGTnc=","AAAAAAAAAAAAAAAAAAAAAAAAfxUL1vVMQKNNfD1en1Y="],"Data":"AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAz5dzgiony/3Lo="},{"TransactionHash":"WJ6BebauwoVbUX44QURYdMEzu36dxFPZrqXH309XsfY=","BlockHeight":12690581,"Index":137,"Address":"axdUdOiQlMRNqYuVTu3qxJUnHQ8=","Topics":["3fJSrRviyJtpwrBo/DeNqpUrp/FjxKEWKPVaTfUjs+8=","AAAAAAAAAAAAAAAAAAAAAAAAfxUL1vVMQKNNfD1en1Y=","AAAAAAAAAAAAAAAAw9A+TwQf1M04jFSe4qKanlB1iC8="],"Data":"AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAz5dzgionz/+PI="},{"TransactionHash":"WJ6BebauwoVbUX44QURYdMEzu36dxFPZrqXH309XsfY=","BlockHeight":12690581,"Index":138,"Address":"wCqqObIj/o0KDlxPJ+rZCDx1bMI=","Topics":["3fJSrRviyJtpwrBo/DeNqpUrp/FjxKEWKPVaTfUjs+8=","AAAAAAAAAAAAAAAAw9A+TwQf1M04jFSe4qKanlB1iC8=","AAAAAAAAAAAAAAAAAAAAAAAAfxUL1vVMQKNNfD1en1Y="],"Data":"AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAABoxq1uv/WbVg="},{"TransactionHash":"WJ6BebauwoVbUX44QURYdMEzu36dxFPZrqXH309XsfY=","BlockHeight":12690581,"Index":139,"Address":"w9A+TwQf1M04jFSe4qKanlB1iC8=","Topics":["HEEempbgcSQcLyH3cmsXronjyrTHi+UOBisDqf/7utE="],"Data":"AAAAAAAAAAAAAAAAAAAAAAAAAAAAUvAD6bCOsY8KMU4AAAAAAAAAAAAAAAAAAAAAAAAAAAAACn18ilgKn8fgwQ=="},{"TransactionHash":"WJ6BebauwoVbUX44QURYdMEzu36dxFPZrqXH309XsfY=","BlockHeight":12690581,"Index":140,"Address":"w9A+TwQf1M04jFSe4qKanlB1iC8=","Topics":["14rZX6RsmUtlUdDahfwnX+YTzjdlf7jV49EwhAFZ2CI=","AAAAAAAAAAAAAAAAAAAAAAAAfxUL1vVMQKNNfD1en1Y=","AAAAAAAAAAAAAAAAAAAAAAAAfxUL1vVMQKNNfD1en1Y="],"Data":"AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAz5dzgionz/+PIAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAABoxq1uv/WbVg="},{"TransactionHash":"WJ6BebauwoVbUX44QURYdMEzu36dxFPZrqXH309XsfY=","BlockHeight":12690581,"Index":141,"Address":"wCqqObIj/o0KDlxPJ+rZCDx1bMI=","Topics":["f89TLBXwptsL1tDgOL6nHTDYCMfZjLO/cmipW/UIG2U=","AAAAAAAAAAAAAAAAAAAAAAAAfxUL1vVMQKNNfD1en1Y="],"Data":"AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAABoxq1uv/WbVg="}]`,
 		},
+		{
+			name: "Topics",
+			filter: &execdb.EventFilter{
+				Order: execdb.OrderEarliest,
+				Limit: 1,
+				Topics: [][]byte{
+					hash("0x93cdeb708b7545dc668eb9280176169d1c33cfd8ed6f04690a0bcc88a93fc4ae"),
+				},
+			},
+			events: `[{"TransactionHash":"8A+NE0Y7I20qTBvJZUlW0NY5y+5tAaiag+9KO+ZHOuY=","BlockHeight":3676978,"Index":8,"Address":"MUFZJl3Y27MQZC+Y9QwGYXPBJZs=","Topics":["zgRX/nNzH4JMwnI3YWkjUSjBGLSdNEgXQXxtEI0VXoI=","k83rcIt1RdxmjrkoAXYWnRwzz9jtbwRpCgvMiKk/xK4=","AAAEJbRGLhlGC+20vM/PFtJwl174gvA4Mb89QPc0I1U="],"Data":"AAAAAAAAAAAAAAAACQTawzR+pH0gjz/WdALQOaO5mFk="}]`,
+		},
 	}
 
 	for _, test := range tests {