@@ -177,7 +177,7 @@ func (p *PDPService) handleCreateDataSet(w http.ResponseWriter, r *http.Request)
177177 return
178178 }
179179
180- // Step 4: BREAKING CHANGE - createDataSet() has been removed in PDP v2.2.0
180+ // createDataSet() has been removed in PDP v2.2.0
181181 // Datasets are now created implicitly when the first piece is added via addPieces()
182182 // To create a dataset, use the /api/pdp/add-pieces endpoint instead.
183183
@@ -187,27 +187,6 @@ func (p *PDPService) handleCreateDataSet(w http.ResponseWriter, r *http.Request)
187187 log .Warnw ("Attempt to use deprecated createDataSet endpoint" ,
188188 "service" , serviceLabel ,
189189 "recordKeeper" , recordKeeperAddr .Hex ())
190-
191- // NOTE: The code below has been removed due to PDP v2.2.0 breaking changes
192- // If you need to re-enable dataset creation, implement it via addPieces with the first piece
193-
194- /* OLD CODE FOR REFERENCE:
195- txHashLower := strings.ToLower(txHash.Hex())
196- log.Infow("PDP CreateDataSet: Inserting transaction tracking",
197- "txHash", txHashLower,
198- "service", serviceLabel,
199- "recordKeeper", recordKeeperAddr.Hex())
200- err = p.insertMessageWaitsAndDataSetCreate(ctx, txHashLower, serviceLabel)
201- if err != nil {
202- log.Errorf("Failed to insert into message_waits_eth and pdp_data_set_creates: %+v", err)
203- http.Error(w, "Internal server error", http.StatusInternalServerError)
204- return
205- }
206-
207- // Step 7: Respond with 201 Created and Location header
208- w.Header().Set("Location", path.Join("/pdp/data-sets/created", txHashLower))
209- w.WriteHeader(http.StatusCreated)
210- */
211190}
212191
213192// getSenderAddress retrieves the sender address from the database where role = 'pdp' limit 1
0 commit comments