Feat: Add PDP Subgraph and subgraph client

assets/pdp-explorer-mockups.excalidraw

@@ -268,13 +268,13 @@
       "updated": 1733889770087,
       "link": null,
       "locked": false,
-      "text": "Search for a ProofSet/Owner 🔍 ",
+      "text": "Search for a DataSet/Owner 🔍 ",
       "fontSize": 16,
       "fontFamily": 5,
       "textAlign": "center",
       "verticalAlign": "top",
       "containerId": null,
-      "originalText": "Search for a ProofSet/Owner 🔍 ",
+      "originalText": "Search for a DataSet/Owner 🔍 ",
       "autoResize": true,
       "lineHeight": 1.25
     },
@@ -1883,13 +1883,13 @@
       "updated": 1733892069758,
       "link": null,
       "locked": false,
-      "text": "ProofSet#",
+      "text": "DataSet#",
       "fontSize": 16,
       "fontFamily": 5,
       "textAlign": "center",
       "verticalAlign": "top",
       "containerId": null,
-      "originalText": "ProofSet#",
+      "originalText": "DataSet#",
       "autoResize": true,
       "lineHeight": 1.25
     },
@@ -2586,13 +2586,13 @@
       "updated": 1733892286732,
       "link": null,
       "locked": false,
-      "text": "ProofSet\nSize",
+      "text": "DataSet\nSize",
       "fontSize": 16,
       "fontFamily": 5,
       "textAlign": "center",
       "verticalAlign": "top",
       "containerId": null,
-      "originalText": "ProofSet\nSize",
+      "originalText": "DataSet\nSize",
       "autoResize": true,
       "lineHeight": 1.25
     },
@@ -3060,13 +3060,13 @@
       "updated": 1733893406824,
       "link": null,
       "locked": false,
-      "text": "ProofSet #ID Overview",
+      "text": "DataSet #ID Overview",
       "fontSize": 19.200000000000003,
       "fontFamily": 5,
       "textAlign": "left",
       "verticalAlign": "top",
       "containerId": null,
-      "originalText": "ProofSet #ID Overview",
+      "originalText": "DataSet #ID Overview",
       "autoResize": true,
       "lineHeight": 1.25
     },
@@ -3173,13 +3173,13 @@
       "updated": 1733896128383,
       "link": null,
       "locked": false,
-      "text": "ProofSet Change",
+      "text": "DataSet Change",
       "fontSize": 16,
       "fontFamily": 5,
       "textAlign": "left",
       "verticalAlign": "top",
       "containerId": null,
-      "originalText": "ProofSet Change",
+      "originalText": "DataSet Change",
       "autoResize": true,
       "lineHeight": 1.25
     },
@@ -6572,13 +6572,13 @@
       "updated": 1733896159564,
       "link": null,
       "locked": false,
-      "text": "# of active proof sets\n# of all proof sets (including deleted ones)\n# of total data size stored\n# of total pieces stored\n# of faults\nFirst Seen\nLast Seen\n\n",
+      "text": "# of active proof sets\n# of all proof sets (including deleted ones)\n# of total data size stored\n# of total Pieces stored\n# of faults\nFirst Seen\nLast Seen\n\n",
       "fontSize": 16,
       "fontFamily": 5,
       "textAlign": "left",
       "verticalAlign": "top",
       "containerId": null,
-      "originalText": "# of active proof sets\n# of all proof sets (including deleted ones)\n# of total data size stored\n# of total pieces stored\n# of faults\nFirst Seen\nLast Seen\n\n",
+      "originalText": "# of active proof sets\n# of all proof sets (including deleted ones)\n# of total data size stored\n# of total Pieces stored\n# of faults\nFirst Seen\nLast Seen\n\n",
       "autoResize": true,
       "lineHeight": 1.25
     },
@@ -7914,13 +7914,13 @@
       "updated": 1733896243335,
       "link": null,
       "locked": false,
-      "text": "ProofSet\nSize",
+      "text": "DataSet\nSize",
       "fontSize": 16,
       "fontFamily": 5,
       "textAlign": "center",
       "verticalAlign": "top",
       "containerId": null,
-      "originalText": "ProofSet\nSize",
+      "originalText": "DataSet\nSize",
       "autoResize": true,
       "lineHeight": 1.25
     },

backend/indexer/internal/infrastructure/database/postgres.go

@@ -77,7 +77,7 @@ func (p *PostgresDB) DeleteReorgedData(ctx context.Context, startHeight, endHeig
 		return fmt.Errorf("failed to delete reorged proof sets: %w", err)
 	}
 
-	// Proofs
+	// Data
 	if err := p.DeleteReorgedProofs(ctx, startHeight, endHeight); err != nil {
 		return fmt.Errorf("failed to delete reorged proofs: %w", err)
 	}
@@ -87,7 +87,7 @@ func (p *PostgresDB) DeleteReorgedData(ctx context.Context, startHeight, endHeig
 		return fmt.Errorf("failed to delete reorged fault records: %w", err)
 	}
 
-	// Roots
+	// Pieces
 	if err := p.DeleteReorgedRoots(ctx, startHeight, endHeight); err != nil {
 		return fmt.Errorf("failed to delete reorged roots: %w", err)
 	}
@@ -131,6 +131,6 @@ func (p *PostgresDB) CleanupFinalizedData(ctx context.Context, currentBlockNumbe
 	if err := p.CleanupFinalizedRoots(ctx, currentBlockNumber); err != nil {
 		return fmt.Errorf("failed to cleanup finalized roots: %w", err)
 	}
-	
+
 	return nil
 }

backend/indexer/internal/infrastructure/database/proof_sets.go

@@ -9,7 +9,7 @@ import (
 )
 
 // StoreProofSet stores a proof set record with version control
-func (p *PostgresDB) StoreProofSet(ctx context.Context, proofSet *models.ProofSet) error {
+func (p *PostgresDB) StoreProofSet(ctx context.Context, proofSet *models.DataSet) error {
 	_, err := p.pool.Exec(ctx, `
 		INSERT INTO proof_sets (
 			set_id, owner, listener_addr, total_faulted_periods, total_data_size,
@@ -44,7 +44,7 @@ func (p *PostgresDB) StoreProofSet(ctx context.Context, proofSet *models.ProofSe
 }
 
 // FindProofSet finds a proof set by its set_id, optionally including historical versions
-func (p *PostgresDB) FindProofSet(ctx context.Context, setId int64, includeHistory bool) ([]*models.ProofSet, error) {
+func (p *PostgresDB) FindProofSet(ctx context.Context, setId int64, includeHistory bool) ([]*models.DataSet, error) {
 	query := `
 		SELECT id, set_id, owner, listener_addr, total_faulted_periods, total_proved_roots, total_data_size,
 			   total_roots, total_fee_paid, last_proven_epoch, next_challenge_epoch, challenge_range,
@@ -63,9 +63,9 @@ func (p *PostgresDB) FindProofSet(ctx context.Context, setId int64, includeHisto
 	}
 	defer rows.Close()
 
-	var proofSets []*models.ProofSet
+	var proofSets []*models.DataSet
 	for rows.Next() {
-		ps := &models.ProofSet{}
+		ps := &models.DataSet{}
 		var totalFeePaidStr string
 		var totalDataSizeStr string
 

backend/indexer/internal/models/proof_set.go

@@ -5,7 +5,7 @@ import (
 	"time"
 )
 
-type ProofSet struct {
+type DataSet struct {
 	ReorgModel                    // Embed ReorgModel to inherit base fields and methods
 	SetId               int64     `db:"set_id" json:"set_id"`
 	Owner               string    `db:"owner" json:"owner"`

backend/indexer/internal/processor/handlers/proof_set_created_handler.go

@@ -134,7 +134,7 @@ func (h *ProofSetCreatedHandler) HandleEvent(ctx context.Context, eventLog *type
 	}
 
 	// Create new proof set
-	proofSet := &models.ProofSet{
+	proofSet := &models.DataSet{
 		ReorgModel: models.ReorgModel{
 			BlockNumber: blockNumber,
 			BlockHash:   eventLog.BlockHash,

backend/indexer/internal/processor/handlers/roots_remove_handler.go

@@ -100,7 +100,7 @@ func (h *RootsRemovedHandler) HandleEvent(ctx context.Context, eventLog *types.L
 		// First get the root to get its raw_size
 		root, err := h.db.FindRoot(ctx, setId.Int64(), rootIdInt)
 		if err != nil {
-			return fmt.Errorf("[Roots Removed] failed to find root: %w", err)
+			return fmt.Errorf("[Pieces Removed] failed to find root: %w", err)
 		}
 
 		if root != nil {

backend/indexer/internal/processor/handlers/types.go

@@ -13,9 +13,9 @@ type Database interface {
 	StoreProvider(ctx context.Context, provider *models.Provider) error
 	FindProvider(ctx context.Context, address string, includeHistory bool) ([]*models.Provider, error)
 
-	// ProofSet methods
-	StoreProofSet(ctx context.Context, proofSet *models.ProofSet) error
-	FindProofSet(ctx context.Context, setId int64, includeHistory bool) ([]*models.ProofSet, error)
+	// DataSet methods
+	StoreProofSet(ctx context.Context, proofSet *models.DataSet) error
+	FindProofSet(ctx context.Context, setId int64, includeHistory bool) ([]*models.DataSet, error)
 
 	// ProofFee methods
 	StoreProofFee(ctx context.Context, proofFee *models.ProofFee) error

backend/server/internal/handlers/handlers.go

@@ -17,12 +17,12 @@ type Handler struct {
 type Service interface {
 	GetProviders(offset, limit int) ([]Provider, int, error)
 	GetProviderDetails(providerID string) (*ProviderDetails, error)
-	GetProofSets(sortBy string, order string, offset, limit int) ([]ProofSet, int, error)
+	GetProofSets(sortBy string, order string, offset, limit int) ([]DataSet, int, error)
 	GetProofSetDetails(proofSetID string) (*ProofSetDetails, error)
 	GetProofSetHeatmap(proofSetID string) ([]HeatmapEntry, error)
 	GetNetworkMetrics(ctx context.Context) (map[string]interface{}, error)
 	Search(ctx context.Context, query string, limit int) ([]map[string]interface{}, error)
-	GetProviderProofSets(providerID string, offset, limit int) ([]ProofSet, int, error)
+	GetProviderProofSets(providerID string, offset, limit int) ([]DataSet, int, error)
 	GetProviderActivities(providerID string, activityType string) ([]Activity, error)
 	GetProofSetEventLogs(proofSetID string, filter string, offset, limit int) ([]EventLog, int, error)
 	GetProofSetTxs(proofSetID string, filter string, offset, limit int) ([]Transaction, int, error)
@@ -45,7 +45,7 @@ type Provider struct {
 	LastSeen            time.Time `json:"lastSeen"`
 }
 
-type ProofSet struct {
+type DataSet struct {
 	ID                  int64     `json:"id"`
 	SetID               int64     `json:"setId"`
 	Owner               string    `json:"owner"`
@@ -77,7 +77,7 @@ type ProviderDetails struct {
 	NumRoots            int64      `json:"numRoots"`
 	FirstSeen           time.Time  `json:"firstSeen"`
 	LastSeen            time.Time  `json:"lastSeen"`
-	ProofSets           []ProofSet `json:"proofSets"`
+	ProofSets           []DataSet `json:"proofSets"`
 }
 
 type ProofSetDetails struct {