fix table renaming and from address query filter (#159)

* Adds missing filter clauses for `FromAddress` query filter param
* Fixes incorrect table name checks for filter clauses when table names are being overriden
* Omits empty metadata

Author: iuwqyir

api/api.go

@@ -54,17 +54,17 @@ type Meta struct {
 	// @Description Chain ID of the blockchain
 	ChainId uint64 `json:"chain_id"`
 	// @Description Contract address
-	ContractAddress string `json:"address"`
+	ContractAddress string `json:"address,omitempty"`
 	// @Description Function or event signature
-	Signature string `json:"signature"`
+	Signature string `json:"signature,omitempty"`
 	// @Description Current page number
 	Page int `json:"page"`
 	// @Description Number of items per page
-	Limit int `json:"limit"`
+	Limit int `json:"limit,omitempty"`
 	// @Description Total number of items
-	TotalItems int `json:"total_items"`
+	TotalItems int `json:"total_items,omitempty"`
 	// @Description Total number of pages
-	TotalPages int `json:"total_pages"`
+	TotalPages int `json:"total_pages,omitempty"`
 }
 
 // QueryResponse represents the response structure for a query

internal/storage/clickhouse.go

@@ -469,6 +469,10 @@ func (c *ClickHouseConnector) GetAggregations(table string, qf QueryFilter) (Que
 	if contractAddressClause != "" {
 		whereClauses = append(whereClauses, contractAddressClause)
 	}
+	fromAddressClause := createFromAddressClause(table, qf.FromAddress)
+	if fromAddressClause != "" {
+		whereClauses = append(whereClauses, fromAddressClause)
+	}
 	signatureClause := createSignatureClause(table, qf.Signature)
 	if signatureClause != "" {
 		whereClauses = append(whereClauses, signatureClause)
@@ -545,8 +549,7 @@ func (c *ClickHouseConnector) GetAggregations(table string, qf QueryFilter) (Que
 }
 
 func executeQuery[T any](c *ClickHouseConnector, table, columns string, qf QueryFilter, scanFunc func(driver.Rows) (T, error)) (QueryResult[T], error) {
-	tableName := c.getTableName(qf.ChainId, table)
-	query := c.buildQuery(tableName, columns, qf)
+	query := c.buildQuery(table, columns, qf)
 
 	if err := common.ValidateQuery(query); err != nil {
 		return QueryResult[T]{}, err
@@ -573,7 +576,8 @@ func executeQuery[T any](c *ClickHouseConnector, table, columns string, qf Query
 }
 
 func (c *ClickHouseConnector) buildQuery(table, columns string, qf QueryFilter) string {
-	query := fmt.Sprintf("SELECT %s FROM %s.%s", columns, c.cfg.Database, table)
+	tableName := c.getTableName(qf.ChainId, table)
+	query := fmt.Sprintf("SELECT %s FROM %s.%s", columns, c.cfg.Database, tableName)
 	if qf.ForceConsistentData {
 		query += " FINAL"
 	}
@@ -590,6 +594,10 @@ func (c *ClickHouseConnector) buildQuery(table, columns string, qf QueryFilter)
 	if contractAddressClause != "" {
 		whereClauses = append(whereClauses, contractAddressClause)
 	}
+	fromAddressClause := createFromAddressClause(table, qf.FromAddress)
+	if fromAddressClause != "" {
+		whereClauses = append(whereClauses, fromAddressClause)
+	}
 	signatureClause := createSignatureClause(table, qf.Signature)
 	if signatureClause != "" {
 		whereClauses = append(whereClauses, signatureClause)
@@ -660,6 +668,17 @@ func createContractAddressClause(table, contractAddress string) string {
 	return ""
 }
 
+func createFromAddressClause(table, fromAddress string) string {
+	if fromAddress == "" {
+		return ""
+	}
+	fromAddress = strings.ToLower(fromAddress)
+	if table == "transactions" {
+		return fmt.Sprintf("from_address = '%s'", fromAddress)
+	}
+	return ""
+}
+
 func createBlockNumbersClause(blockNumbers []*big.Int) string {
 	if len(blockNumbers) > 0 {
 		return fmt.Sprintf("block_number IN (%s)", getBlockNumbersStringArray(blockNumbers))