cmd

var PipeCTPData = &subcommands.Command{
	UsageLine: `pipe-ctp-data [FLAGS...]`,
	ShortDesc: "Pipe CTP Build data to Bigquery",
	LongDesc: `pipe-ctp-data command catches a set of CTP builds, and
	pipes the build data to Bigquery in the format of
	test_platform/analytics/TestPlanRun proto.`,
	CommandRun: func() subcommands.CommandRun {
		c := &pipeCTPDataRun{}
		c.authFlags.Register(&c.Flags, site.DefaultAuthOptions)

		c.Flags.StringVar(&c.inputPath, "input_json", "", "Path that contains JSON encoded test_platform.result_fow.CTPRequest")
		c.Flags.StringVar(&c.outputPath, "output_json", "", "Path to write JSON encoded test_platform.result_flow.CTPResponse to")
		return c
	},
}

var PipeTestRunnerData = &subcommands.Command{
	UsageLine: `pipe-test-runner-data [FLAGS...]`,
	ShortDesc: "Pipe Test Runner Build data to Bigquery",
	LongDesc: `pipe-test-runner-data command catches test runner builds, and
	and pipes their data to test_platform/analytics/TestRun as well as
	test_platform/analytics/TestCaseResult for analytics usage.`,
	CommandRun: func() subcommands.CommandRun {
		c := &pipeTestRunnerDataRun{}
		c.authFlags.Register(&c.Flags, site.DefaultAuthOptions)

		c.Flags.StringVar(&c.inputPath, "input_json", "", "Path that contains JSON encoded test_platform.result_fow.TestRunnerRequest")
		c.Flags.StringVar(&c.outputPath, "output_json", "", "Path to write JSON encoded test_platform.result_flow.TestRunnerResponse to")
		return c
	},
}

var Publish = &subcommands.Command{
	UsageLine: `publish [FLAGS...]`,
	ShortDesc: "Publish a Build ID",
	LongDesc: `Publish a Build ID to assigned Pub/Sub topic.
The build ID is stored in the message attribute having "build-id" as the key, same
with Buildbucket's Pub/Sub notification message.`,
	CommandRun: func() subcommands.CommandRun {
		c := &publishRun{}
		c.authFlags.Register(&c.Flags, site.DefaultAuthOptions)

		c.Flags.StringVar(&c.inputPath, "input_json", "", "Path that contains JSON encoded test_platform.result_flow.PublishRequest")
		c.Flags.StringVar(&c.outputPath, "output_json", "", "Path to write JSON encoded test_platform.result_flow.PublishResponse to")
		return c
	},
}