universe+tapdb: add SQL statement to delete proof sync log entries

Author: ffranr

tapdb/sqlc/querier.go

@@ -460,4 +460,24 @@ WHERE (log.sync_direction = sqlc.narg('sync_direction')
            OR sqlc.narg('leaf_minting_point_bytes') IS NULL)
         AND
       (leaf.script_key_bytes = sqlc.narg('leaf_script_key_bytes')
-           OR sqlc.narg('leaf_script_key_bytes') IS NULL);
+           OR sqlc.narg('leaf_script_key_bytes') IS NULL);
+
+-- name: DeleteFederationProofSyncLog :exec
+WITH selected_server_id AS (
+    -- Select the server ids from the universe_servers table for the specified
+    -- hosts.
+    SELECT id
+    FROM universe_servers
+    WHERE
+        (server_host = sqlc.narg('server_host')
+            OR sqlc.narg('server_host') IS NULL)
+)
+DELETE FROM federation_proof_sync_log
+WHERE
+    servers_id IN (SELECT id FROM selected_server_id) AND
+    (status = sqlc.narg('status')
+        OR sqlc.narg('status') IS NULL) AND
+    (timestamp >= sqlc.narg('min_timestamp')
+        OR sqlc.narg('min_timestamp') IS NULL) AND
+    (attempt_counter >= sqlc.narg('min_attempt_counter')
+        OR sqlc.narg('min_attempt_counter') IS NULL);

tapdb/sqlc/queries/universe.sql

@@ -32,6 +32,9 @@ type (
 	// logs.
 	QueryFedProofSyncLogParams = sqlc.QueryFederationProofSyncLogParams
 
+	// DeleteFedProofSyncLogParams is used to delete proof sync log entries.
+	DeleteFedProofSyncLogParams = sqlc.DeleteFederationProofSyncLogParams
+
 	// ProofSyncLogEntry is a single entry from the proof sync log.
 	ProofSyncLogEntry = sqlc.QueryFederationProofSyncLogRow
 
@@ -92,6 +95,10 @@ type FederationProofSyncLogStore interface {
 	// given proof leaf.
 	QueryFederationProofSyncLog(ctx context.Context,
 		arg QueryFedProofSyncLogParams) ([]ProofSyncLogEntry, error)
+
+	// DeleteFederationProofSyncLog deletes proof sync log entries.
+	DeleteFederationProofSyncLog(ctx context.Context,
+		arg DeleteFedProofSyncLogParams) error
 }
 
 // FederationSyncConfigStore is used to manage the set of Universe servers as
@@ -565,6 +572,37 @@ func fetchProofSyncLogEntry(ctx context.Context, entry ProofSyncLogEntry,
 	}, nil
 }
 
+// DeleteProofsSyncLogEntries deletes a set of proof sync log entries.
+func (u *UniverseFederationDB) DeleteProofsSyncLogEntries(ctx context.Context,
+	servers ...universe.ServerAddr) error {
+
+	var writeTx UniverseFederationOptions
+
+	err := u.db.ExecTx(ctx, &writeTx, func(db UniverseServerStore) error {
+		// Delete proof sync log entries which are associated with each
+		// server.
+		for i := range servers {
+			server := servers[i]
+
+			err := db.DeleteFederationProofSyncLog(
+				ctx, DeleteFedProofSyncLogParams{
+					ServerHost: sqlStr(server.HostStr()),
+				},
+			)
+			if err != nil {
+				return err
+			}
+		}
+
+		return nil
+	})
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
 // UpsertFederationSyncConfig upserts both the global and universe specific
 // federation sync configs.
 func (u *UniverseFederationDB) UpsertFederationSyncConfig(

tapdb/sqlc/universe.sql.go

@@ -859,6 +859,10 @@ type FederationProofSyncLog interface {
 	// returns all log entries with sync status pending.
 	FetchPendingProofsSyncLog(ctx context.Context,
 		syncDirection *SyncDirection) ([]*ProofSyncLogEntry, error)
+
+	// DeleteProofsSyncLogEntries deletes proof sync log entries.
+	DeleteProofsSyncLogEntries(ctx context.Context,
+		servers ...ServerAddr) error
 }
 
 // FederationDB is used for CRUD operations related to federation logs and