pdpv0: user initiated termination

cmd/curio/tasks/tasks.go

@@ -361,8 +361,9 @@ func StartTasks(ctx context.Context, dependencies *deps.Deps, shutdownChan chan
 			pdpDelete := pdpv0.NewDeleteDataSetTask(db, must.One(dependencies.EthClient.Val()), senderEth)
 			pdpChainDBStateSync := pdpv0.NewTaskChainSync(db, must.One(dependencies.EthClient.Val()), senderEth)
 			payTask := pay.NewSettleTask(db, must.One(dependencies.EthClient.Val()), senderEth) // Move this to a common section once PDP v1 is live
+			pdpClientTerminationSettle := pay.NewImmediateSettleTask(db, must.One(dependencies.EthClient.Val()), senderEth)
 			pdpSaveCacheTask := pdpv0.NewTaskPDPSaveCache(db, dependencies.CachedPieceReader, iStore)
-			activeTasks = append(activeTasks, pdpProveTask, pdpNotifTask, pdpPullPieceTask, pdpNextProvingPeriodTask, pdpInitProvingPeriodTask, pdpTerminate, pdpDelete, pdpChainDBStateSync, payTask, pdpSaveCacheTask)
+			activeTasks = append(activeTasks, pdpProveTask, pdpNotifTask, pdpPullPieceTask, pdpNextProvingPeriodTask, pdpInitProvingPeriodTask, pdpTerminate, pdpDelete, pdpChainDBStateSync, payTask, pdpClientTerminationSettle, pdpSaveCacheTask)
 		}
 
 		idxMax := taskhelp.Max(cfg.Subsystems.IndexingMaxTasks)

harmony/harmonydb/sql/20260520-pdp-v0-client-termination.sql

@@ -0,0 +1,150 @@
+-- Track whether a pdpv0 service termination was requested by a client-facing
+-- HTTP request or by Curio's internal/provider cleanup flow.
+DO $$
+BEGIN
+    IF NOT EXISTS (
+        SELECT 1
+        FROM information_schema.columns
+        WHERE table_name = 'pdp_delete_data_set'
+          AND table_schema = current_schema()
+          AND column_name = 'client_requested_termination'
+    ) THEN
+        ALTER TABLE pdp_delete_data_set
+            ADD COLUMN client_requested_termination BOOLEAN NOT NULL DEFAULT FALSE;
+    END IF;
+
+    IF NOT EXISTS (
+        SELECT 1
+        FROM information_schema.columns
+        WHERE table_name = 'pdp_delete_data_set'
+          AND table_schema = current_schema()
+          AND column_name = 'termination_requested_at'
+    ) THEN
+        ALTER TABLE pdp_delete_data_set
+            ADD COLUMN termination_requested_at TIMESTAMPTZ;
+    END IF;
+
+    IF NOT EXISTS (
+        SELECT 1
+        FROM information_schema.columns
+        WHERE table_name = 'pdp_delete_data_set'
+          AND table_schema = current_schema()
+          AND column_name = 'termination_extra_data'
+    ) THEN
+        ALTER TABLE pdp_delete_data_set
+            ADD COLUMN termination_extra_data BYTEA;
+    END IF;
+
+    IF NOT EXISTS (
+        SELECT 1
+        FROM information_schema.columns
+        WHERE table_name = 'pdp_delete_data_set'
+          AND table_schema = current_schema()
+          AND column_name = 'client_terminate_service_task_id'
+    ) THEN
+        ALTER TABLE pdp_delete_data_set
+            ADD COLUMN client_terminate_service_task_id BIGINT;
+    END IF;
+
+    IF NOT EXISTS (
+        SELECT 1
+        FROM information_schema.columns
+        WHERE table_name = 'pdp_delete_data_set'
+          AND table_schema = current_schema()
+          AND column_name = 'immediate_settle_task_id'
+    ) THEN
+        ALTER TABLE pdp_delete_data_set
+            ADD COLUMN immediate_settle_task_id BIGINT;
+    END IF;
+
+    IF NOT EXISTS (
+        SELECT 1
+        FROM information_schema.columns
+        WHERE table_name = 'pdp_delete_data_set'
+          AND table_schema = current_schema()
+          AND column_name = 'immediate_settle_tx_hash'
+    ) THEN
+        ALTER TABLE pdp_delete_data_set
+            ADD COLUMN immediate_settle_tx_hash TEXT;
+    END IF;
+
+    IF NOT EXISTS (
+        SELECT 1
+        FROM information_schema.columns
+        WHERE table_name = 'pdp_delete_data_set'
+          AND table_schema = current_schema()
+          AND column_name = 'after_immediate_settle'
+    ) THEN
+        ALTER TABLE pdp_delete_data_set
+            ADD COLUMN after_immediate_settle BOOLEAN NOT NULL DEFAULT FALSE;
+    END IF;
+
+    IF NOT EXISTS (
+        SELECT 1
+        FROM information_schema.columns
+        WHERE table_name = 'pdp_delete_data_set'
+          AND table_schema = current_schema()
+          AND column_name = 'immediate_settle_requested_at'
+    ) THEN
+        ALTER TABLE pdp_delete_data_set
+            ADD COLUMN immediate_settle_requested_at TIMESTAMPTZ;
+    END IF;
+
+    IF NOT EXISTS (
+        SELECT 1
+        FROM information_schema.columns
+        WHERE table_name = 'filecoin_payment_transactions'
+          AND table_schema = current_schema()
+          AND column_name = 'settle_reason'
+    ) THEN
+        ALTER TABLE filecoin_payment_transactions
+            ADD COLUMN settle_reason TEXT NOT NULL DEFAULT 'periodic';
+    END IF;
+END
+$$;
+
+DO $$
+BEGIN
+    IF NOT EXISTS (
+        SELECT 1
+        FROM pg_constraint
+        WHERE conname = 'pdp_delete_data_set_client_terminate_task_fk'
+    ) THEN
+        ALTER TABLE pdp_delete_data_set
+            ADD CONSTRAINT pdp_delete_data_set_client_terminate_task_fk
+            FOREIGN KEY (client_terminate_service_task_id)
+            REFERENCES harmony_task(id)
+            ON DELETE CASCADE;
+    END IF;
+
+    IF NOT EXISTS (
+        SELECT 1
+        FROM pg_constraint
+        WHERE conname = 'pdp_delete_data_set_client_extra_data_check'
+    ) THEN
+        ALTER TABLE pdp_delete_data_set
+            ADD CONSTRAINT pdp_delete_data_set_client_extra_data_check
+            CHECK (
+                client_requested_termination = FALSE
+                OR (
+                    termination_extra_data IS NOT NULL
+                    AND octet_length(termination_extra_data) > 0
+                )
+            );
+    END IF;
+END
+$$;
+
+DO $$
+BEGIN
+    IF NOT EXISTS (
+        SELECT 1
+        FROM pg_constraint
+        WHERE conname = 'filecoin_payment_transactions_settle_reason_check'
+    ) THEN
+        ALTER TABLE filecoin_payment_transactions
+            ADD CONSTRAINT filecoin_payment_transactions_settle_reason_check
+            CHECK (settle_reason IN ('periodic', 'pdpv0_client_termination'));
+    END IF;
+END
+$$;