tapdb: add support for timestamp range filter in QueryEventIDs

Author: darioAnongba

address/event.go

@@ -60,6 +60,11 @@ type EventQueryParams struct {
 	// (inclusive). Can be set to nil to return events of all creation
 	// times.
 	CreationTimeFrom *time.Time
+
+	// CreationTimeTo is the latest creation time to query for
+	// (inclusive). Can be set to nil to return events of all creation
+	// times.
+	CreationTimeTo *time.Time
 }
 
 // AssetOutput holds the information about a single asset output that was sent

tapdb/addrs.go

@@ -990,9 +990,10 @@ func (t *TapAddressBook) QueryAddrEvents(
 	error) {
 
 	sqlQuery := AddrEventQuery{
-		StatusFrom:   int16(address.StatusTransactionDetected),
-		StatusTo:     int16(address.StatusCompleted),
-		CreatedAfter: time.Unix(0, 0).UTC(),
+		StatusFrom:    int16(address.StatusTransactionDetected),
+		StatusTo:      int16(address.StatusCompleted),
+		CreatedAfter:  time.Unix(0, 0).UTC(),
+		CreatedBefore: time.Now().UTC(),
 	}
 	if len(params.AddrTaprootOutputKey) > 0 {
 		sqlQuery.AddrTaprootKey = params.AddrTaprootOutputKey
@@ -1006,6 +1007,13 @@ func (t *TapAddressBook) QueryAddrEvents(
 	if params.CreationTimeFrom != nil && !params.CreationTimeFrom.IsZero() {
 		sqlQuery.CreatedAfter = params.CreationTimeFrom.UTC()
 	}
+	if params.CreationTimeTo != nil && !params.CreationTimeTo.IsZero() {
+		sqlQuery.CreatedBefore = params.CreationTimeTo.UTC()
+	}
+	if sqlQuery.CreatedAfter.After(sqlQuery.CreatedBefore) {
+		return nil, fmt.Errorf("created after time after " +
+			"created before time")
+	}
 
 	var (
 		readTxOpts = NewAssetStoreReadTx()

tapdb/sqlc/addrs.sql.go

@@ -226,6 +226,7 @@ WHERE addr_events.status >= @status_from
   AND addr_events.status <= @status_to
   AND COALESCE(@addr_taproot_key, addrs.taproot_output_key) = addrs.taproot_output_key
   AND addr_events.creation_time >= @created_after
+  AND addr_events.creation_time <= @created_before
 ORDER by addr_events.creation_time;
 
 -- name: QueryLastEventHeight :one