Skip to content

Commit 3b96c2d

Browse files
unexport rm duplicate func for votes, misses and treasury txs
Signed-off-by: Philemon Ukane <ukanephilemon@gmail.com>
1 parent 236a470 commit 3b96c2d

File tree

3 files changed

+15
-15
lines changed

3 files changed

+15
-15
lines changed

db/dcrpg/indexing.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -394,16 +394,16 @@ func (pgb *ChainDB) deleteDuplicateAgendaVotes() (int64, error) {
394394
return deleteDuplicateAgendaVotes(pgb.db)
395395
}
396396

397-
func (pgb *ChainDB) DeleteDuplicateVotes() (int64, error) {
398-
return DeleteDuplicateVotes(pgb.db)
397+
func (pgb *ChainDB) deleteDuplicateVotes() (int64, error) {
398+
return deleteDuplicateVotes(pgb.db)
399399
}
400400

401-
func (pgb *ChainDB) DeleteDuplicateMisses() (int64, error) {
402-
return DeleteDuplicateMisses(pgb.db)
401+
func (pgb *ChainDB) deleteDuplicateMisses() (int64, error) {
402+
return deleteDuplicateMisses(pgb.db)
403403
}
404404

405-
func (pgb *ChainDB) DeleteDuplicateTreasuryTxs() (int64, error) {
406-
return DeleteDuplicateTreasuryTxs(pgb.db)
405+
func (pgb *ChainDB) deleteDuplicateTreasuryTxs() (int64, error) {
406+
return deleteDuplicateTreasuryTxs(pgb.db)
407407
}
408408

409409
// Indexes checks

db/dcrpg/queries.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -257,9 +257,9 @@ func deleteDuplicateAgendaVotes(db *sql.DB) (int64, error) {
257257
return sqlExec(db, internal.DeleteAgendaVotesDuplicateRows, execErrPrefix)
258258
}
259259

260-
// DeleteDuplicateVotes deletes rows in votes with duplicate tx_hash and
260+
// deleteDuplicateVotes deletes rows in votes with duplicate tx_hash and
261261
// block_hash leaving one row with the lowest id.
262-
func DeleteDuplicateVotes(db *sql.DB) (int64, error) {
262+
func deleteDuplicateVotes(db *sql.DB) (int64, error) {
263263
if isuniq, err := IsUniqueIndex(db, internal.IndexOfVotesTableOnHashes); err != nil && err != sql.ErrNoRows {
264264
return 0, err
265265
} else if isuniq {
@@ -269,9 +269,9 @@ func DeleteDuplicateVotes(db *sql.DB) (int64, error) {
269269
return sqlExec(db, internal.DeleteVotesDuplicateRows, execErrPrefix)
270270
}
271271

272-
// DeleteDuplicateMisses deletes rows in misses with duplicate ticket_hash and
272+
// deleteDuplicateMisses deletes rows in misses with duplicate ticket_hash and
273273
// block_hash leaving one row with the lowest id.
274-
func DeleteDuplicateMisses(db *sql.DB) (int64, error) {
274+
func deleteDuplicateMisses(db *sql.DB) (int64, error) {
275275
if isuniq, err := IsUniqueIndex(db, internal.IndexOfMissesTableOnHashes); err != nil && err != sql.ErrNoRows {
276276
return 0, err
277277
} else if isuniq {
@@ -281,9 +281,9 @@ func DeleteDuplicateMisses(db *sql.DB) (int64, error) {
281281
return sqlExec(db, internal.DeleteMissesDuplicateRows, execErrPrefix)
282282
}
283283

284-
// DeleteDuplicateTreasuryTxs deletes rows in misses with duplicate tx_hash and
284+
// deleteDuplicateTreasuryTxs deletes rows in misses with duplicate tx_hash and
285285
// block_hash leaving one row with the lowest id.
286-
func DeleteDuplicateTreasuryTxs(db *sql.DB) (int64, error) {
286+
func deleteDuplicateTreasuryTxs(db *sql.DB) (int64, error) {
287287
if isuniq, err := IsUniqueIndex(db, internal.IndexOfTreasuryTableOnTxHash); err != nil && err != sql.ErrNoRows {
288288
return 0, err
289289
} else if isuniq {

db/dcrpg/tables.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -220,13 +220,13 @@ func (pgb *ChainDB) deleteDuplicates(barLoad chan *dbtypes.ProgressBarLoad) erro
220220
{TableName: "agenda_votes", DropDupsFunc: pgb.deleteDuplicateAgendaVotes},
221221

222222
// Remove duplicate votes
223-
{TableName: "votes", DropDupsFunc: pgb.DeleteDuplicateVotes},
223+
{TableName: "votes", DropDupsFunc: pgb.deleteDuplicateVotes},
224224

225225
// Remove duplicate misses
226-
{TableName: "misses", DropDupsFunc: pgb.DeleteDuplicateMisses},
226+
{TableName: "misses", DropDupsFunc: pgb.deleteDuplicateMisses},
227227

228228
// Remove duplicate treasury txs
229-
{TableName: "treasury", DropDupsFunc: pgb.DeleteDuplicateTreasuryTxs},
229+
{TableName: "treasury", DropDupsFunc: pgb.deleteDuplicateTreasuryTxs},
230230
}
231231

232232
var err error

0 commit comments

Comments
 (0)