Skip to content

Commit 5ff8b7f

Browse files
authored
fix: Add new actor version for tasks (#1277)
* Add new actor version for tasks * fix the unit test * Add more unit test for different version
1 parent 485c174 commit 5ff8b7f

File tree

3 files changed

+10
-0
lines changed

3 files changed

+10
-0
lines changed

chain/indexer/integrated/processor/state.go

+4
Original file line numberDiff line numberDiff line change
@@ -544,6 +544,7 @@ func MakeProcessors(api tasks.DataSource, indexerTasks []string) (*IndexerProces
544544
mineractors.VersionCodes()[actorstypes.Version9]: {minertask.BeneficiaryExtractor{}},
545545
mineractors.VersionCodes()[actorstypes.Version10]: {minertask.BeneficiaryExtractor{}},
546546
mineractors.VersionCodes()[actorstypes.Version11]: {minertask.BeneficiaryExtractor{}},
547+
mineractors.VersionCodes()[actorstypes.Version12]: {minertask.BeneficiaryExtractor{}},
547548
},
548549
))
549550
case tasktype.MinerCurrentDeadlineInfo:
@@ -591,6 +592,7 @@ func MakeProcessors(api tasks.DataSource, indexerTasks []string) (*IndexerProces
591592
mineractors.VersionCodes()[actorstypes.Version9]: {minertask.PreCommitInfoExtractorV9{}},
592593
mineractors.VersionCodes()[actorstypes.Version10]: {minertask.PreCommitInfoExtractorV9{}},
593594
mineractors.VersionCodes()[actorstypes.Version11]: {minertask.PreCommitInfoExtractorV9{}},
595+
mineractors.VersionCodes()[actorstypes.Version12]: {minertask.PreCommitInfoExtractorV9{}},
594596
},
595597
),
596598
minertask.PreCommitInfoExtractorV9{},
@@ -637,6 +639,7 @@ func MakeProcessors(api tasks.DataSource, indexerTasks []string) (*IndexerProces
637639
mineractors.VersionCodes()[actorstypes.Version9]: {minertask.V7SectorInfoExtractor{}},
638640
mineractors.VersionCodes()[actorstypes.Version10]: {minertask.V7SectorInfoExtractor{}},
639641
mineractors.VersionCodes()[actorstypes.Version11]: {minertask.V7SectorInfoExtractor{}},
642+
mineractors.VersionCodes()[actorstypes.Version12]: {minertask.V7SectorInfoExtractor{}},
640643
},
641644
),
642645
minertask.V7SectorInfoExtractor{},
@@ -725,6 +728,7 @@ func MakeProcessors(api tasks.DataSource, indexerTasks []string) (*IndexerProces
725728
verifregactors.VersionCodes()[actorstypes.Version9]: {verifregtask.ClaimExtractor{}},
726729
verifregactors.VersionCodes()[actorstypes.Version10]: {verifregtask.ClaimExtractor{}},
727730
verifregactors.VersionCodes()[actorstypes.Version11]: {verifregtask.ClaimExtractor{}},
731+
verifregactors.VersionCodes()[actorstypes.Version12]: {verifregtask.ClaimExtractor{}},
728732
},
729733
))
730734

chain/indexer/integrated/processor/state_internal_test.go

+3
Original file line numberDiff line numberDiff line change
@@ -105,6 +105,7 @@ func TestNewProcessor(t *testing.T) {
105105
miner.VersionCodes()[actorstypes.Version9]: {minertask.V7SectorInfoExtractor{}},
106106
miner.VersionCodes()[actorstypes.Version10]: {minertask.V7SectorInfoExtractor{}},
107107
miner.VersionCodes()[actorstypes.Version11]: {minertask.V7SectorInfoExtractor{}},
108+
miner.VersionCodes()[actorstypes.Version12]: {minertask.V7SectorInfoExtractor{}},
108109
}),
109110
minertask.V7SectorInfoExtractor{},
110111
),
@@ -125,6 +126,7 @@ func TestNewProcessor(t *testing.T) {
125126
miner.VersionCodes()[actorstypes.Version9]: {minertask.PreCommitInfoExtractorV9{}},
126127
miner.VersionCodes()[actorstypes.Version10]: {minertask.PreCommitInfoExtractorV9{}},
127128
miner.VersionCodes()[actorstypes.Version11]: {minertask.PreCommitInfoExtractorV9{}},
129+
miner.VersionCodes()[actorstypes.Version12]: {minertask.PreCommitInfoExtractorV9{}},
128130
},
129131
),
130132
minertask.PreCommitInfoExtractorV9{},
@@ -150,6 +152,7 @@ func TestNewProcessor(t *testing.T) {
150152
verifreg.VersionCodes()[actorstypes.Version9]: {verifregtask.ClaimExtractor{}},
151153
verifreg.VersionCodes()[actorstypes.Version10]: {verifregtask.ClaimExtractor{}},
152154
verifreg.VersionCodes()[actorstypes.Version11]: {verifregtask.ClaimExtractor{}},
155+
verifreg.VersionCodes()[actorstypes.Version12]: {verifregtask.ClaimExtractor{}},
153156
},
154157
)), proc.actorProcessors[tasktype.VerifiedRegistryClaim])
155158

chain/indexer/integrated/processor/state_test.go

+3
Original file line numberDiff line numberDiff line change
@@ -112,6 +112,7 @@ func TestMakeProcessorsActors(t *testing.T) {
112112
miner.VersionCodes()[actorstypes.Version9]: {minertask.V7SectorInfoExtractor{}},
113113
miner.VersionCodes()[actorstypes.Version10]: {minertask.V7SectorInfoExtractor{}},
114114
miner.VersionCodes()[actorstypes.Version11]: {minertask.V7SectorInfoExtractor{}},
115+
miner.VersionCodes()[actorstypes.Version12]: {minertask.V7SectorInfoExtractor{}},
115116
},
116117
),
117118
transformer: minertask.V7SectorInfoExtractor{},
@@ -139,6 +140,7 @@ func TestMakeProcessorsActors(t *testing.T) {
139140
miner.VersionCodes()[actorstypes.Version9]: {minertask.PreCommitInfoExtractorV9{}},
140141
miner.VersionCodes()[actorstypes.Version10]: {minertask.PreCommitInfoExtractorV9{}},
141142
miner.VersionCodes()[actorstypes.Version11]: {minertask.PreCommitInfoExtractorV9{}},
143+
miner.VersionCodes()[actorstypes.Version12]: {minertask.PreCommitInfoExtractorV9{}},
142144
},
143145
),
144146
transformer: minertask.PreCommitInfoExtractorV9{},
@@ -298,6 +300,7 @@ func TestMakeProcessorsActors(t *testing.T) {
298300
verifreg.VersionCodes()[actorstypes.Version9]: {verifregtask.ClaimExtractor{}},
299301
verifreg.VersionCodes()[actorstypes.Version10]: {verifregtask.ClaimExtractor{}},
300302
verifreg.VersionCodes()[actorstypes.Version11]: {verifregtask.ClaimExtractor{}},
303+
verifreg.VersionCodes()[actorstypes.Version12]: {verifregtask.ClaimExtractor{}},
301304
}),
302305
},
303306
}

0 commit comments

Comments
 (0)