create and store card data (#41)

* ability to stream a file to the drone server

command/daemon/daemon.go

@@ -22,6 +22,7 @@ import (
 	"github.com/drone/runner-go/pipeline/reporter/history"
 	"github.com/drone/runner-go/pipeline/reporter/remote"
 	"github.com/drone/runner-go/pipeline/runtime"
+	"github.com/drone/runner-go/pipeline/uploader"
 	"github.com/drone/runner-go/poller"
 	"github.com/drone/runner-go/registry"
 	"github.com/drone/runner-go/secret"
@@ -109,6 +110,7 @@ func (c *daemonCommand) run(*kingpin.ParseContext) error {
 	}
 
 	remote := remote.New(cli)
+	upload := uploader.New(cli)
 	tracer := history.New(remote)
 	hook := loghistory.New()
 	logrus.AddHook(hook)
@@ -182,6 +184,7 @@ func (c *daemonCommand) run(*kingpin.ParseContext) error {
 		Exec: runtime.NewExecer(
 			tracer,
 			remote,
+			upload,
 			engine,
 			config.Runner.Procs,
 		).Exec,

command/daemon/process.go

@@ -9,6 +9,7 @@ import (
 	"github.com/drone-runners/drone-runner-docker/engine/compiler"
 	"github.com/drone-runners/drone-runner-docker/engine/linter"
 	"github.com/drone-runners/drone-runner-docker/engine/resource"
+	"github.com/drone/runner-go/pipeline/uploader"
 
 	"github.com/drone/runner-go/client"
 	"github.com/drone/runner-go/environ/provider"
@@ -62,6 +63,7 @@ func (c *processCommand) run(*kingpin.ParseContext) error {
 	}
 
 	remote := remote.New(cli)
+	upload := uploader.New(cli)
 
 	runner := &runtime.Runner{
 		Client:   cli,
@@ -118,6 +120,7 @@ func (c *processCommand) run(*kingpin.ParseContext) error {
 		Exec: runtime.NewExecer(
 			remote,
 			remote,
+			upload,
 			engine,
 			config.Runner.Procs,
 		).Exec,

command/exec.go

@@ -18,6 +18,7 @@ import (
 	"github.com/drone-runners/drone-runner-docker/engine/compiler"
 	"github.com/drone-runners/drone-runner-docker/engine/linter"
 	"github.com/drone-runners/drone-runner-docker/engine/resource"
+
 	"github.com/drone/drone-go/drone"
 	"github.com/drone/envsubst"
 	"github.com/drone/runner-go/environ"
@@ -238,6 +239,7 @@ func (c *execCommand) run(*kingpin.ParseContext) error {
 	err = runtime.NewExecer(
 		pipeline.NopReporter(),
 		console.New(c.Pretty),
+		pipeline.NopUploader(),
 		engine,
 		c.Procs,
 	).Exec(ctx, spec, state)