fix(tasks): add deal id string to finalized task (#284)

Add a deal id as string to finalized task, since we can't otherwise fetch with graphql. Also removes unneeded docker env var and minor fix to make sure controller test & state test do not conflict.
filecoin-project · Jul 9, 2021 · b6bdda1 · b6bdda1
1 parent e710716
commit b6bdda1
Showing 7 changed files with 164 additions and 8 deletions.
diff --git a/Dockerfile b/Dockerfile
@@ -26,5 +26,4 @@ ENV DEALBOT_LOG_JSON=true
 ENV DEALBOT_WORKERS=10
 ENV STAGE_TIMEOUT=DefaultStorage=48h,DefaultRetrieval=48h
 ENV DEALBOT_MIN_FIL=-1
-ENV DEALBOT_DAEMON_DRIVER=kubernetes
 ENTRYPOINT ["/dealbot"]
diff --git a/controller/graphql/schema.go b/controller/graphql/schema.go
diff --git a/controller/http_test.go b/controller/http_test.go
@@ -373,7 +373,7 @@ type harness struct {
 	serveErr   chan error
 }
 
-const defaultPGPort = 5434
+const defaultPGPort = 5435
 
 func newHarness(ctx context.Context, t *testing.T, connector state.DBConnector, migrator state.Migrator) *harness {
 	h := &harness{ctx: ctx}

diff --git a/tasks/gen.go b/tasks/gen.go
@@ -143,6 +143,7 @@ func main() {
 		schema.SpawnStructField("Size", "Int", true, true),
 		schema.SpawnStructField("PayloadCID", "String", true, true),
 		schema.SpawnStructField("ProposalCID", "String", true, true),
+		schema.SpawnStructField("DealIDString", "String", true, true),
 	}, schema.SpawnStructRepresentationMap(map[string]string{})))
 	ts.Accumulate(schema.SpawnList("FinishedTasks", "FinishedTask", false))
 	ts.Accumulate(schema.SpawnLinkReference("Link_FinishedTask", "FinishedTask"))

diff --git a/tasks/ipldsch_satisfaction.go b/tasks/ipldsch_satisfaction.go
diff --git a/tasks/ipldsch_types.go b/tasks/ipldsch_types.go