added post-create hook

added test for handler.UploadCreated

go fmt .

.hooks/post-create

@@ -0,0 +1,9 @@
+#!/bin/bash
+
+id="$TUS_ID"
+offset="$TUS_OFFSET"
+size="$TUS_SIZE"
+progress=$((100 * $offset/$size))
+
+echo "Upload created with ID ${id} and size ${size}"
+cat /dev/stdin | jq .

cmd/tusd/cli/hooks.go

@@ -22,6 +22,7 @@ const (
 	HookPostFinish    HookType = "post-finish"
 	HookPostTerminate HookType = "post-terminate"
 	HookPostReceive   HookType = "post-receive"
+	HookPostCreate    HookType = "post-create"
 	HookPreCreate     HookType = "pre-create"
 )
 
@@ -52,6 +53,8 @@ func SetupPostHooks(handler *tusd.Handler) {
 				invokeHook(HookPostTerminate, info)
 			case info := <-handler.UploadProgress:
 				invokeHook(HookPostReceive, info)
+			case info := <-handler.UploadCreated:
+				invokeHook(HookPostCreate, info)
 			}
 		}
 	}()
@@ -66,6 +69,8 @@ func invokeHook(typ HookType, info tusd.FileInfo) {
 
 func invokeHookSync(typ HookType, info tusd.FileInfo, captureOutput bool) ([]byte, error) {
 	switch typ {
+	case HookPostCreate:
+		logEv("UploadCreated", "id", info.ID, "size", strconv.FormatInt(info.Size, 10))
 	case HookPostFinish:
 		logEv("UploadFinished", "id", info.ID, "size", strconv.FormatInt(info.Size, 10))
 	case HookPostTerminate:

cmd/tusd/cli/serve.go

@@ -18,6 +18,7 @@ func Serve() {
 		NotifyCompleteUploads:   true,
 		NotifyTerminatedUploads: true,
 		NotifyUploadProgress:    true,
+		NotifyUploadCreated:     true,
 	})
 	if err != nil {
 		stderr.Fatalf("Unable to create handler: %s", err)

config.go

@@ -34,6 +34,9 @@ type Config struct {
 	// NotifyUploadProgress indicates whether sending notifications about
 	// the upload progress using the UploadProgress channel should be enabled.
 	NotifyUploadProgress bool
+	// NotifyUploadCreated indicates whether sending notifications about
+	// the upload having been created using the UploadCreated channel should be enabled.
+	NotifyUploadCreated bool
 	// Logger is the logger to use internally, mostly for printing requests.
 	Logger *log.Logger
 	// Respect the X-Forwarded-Host, X-Forwarded-Proto and Forwarded headers

post_test.go

@@ -7,8 +7,9 @@ import (
 	"testing"
 
 	"github.com/golang/mock/gomock"
-
 	. "github.com/tus/tusd"
+
+	"github.com/stretchr/testify/assert"
 )
 
 func TestPost(t *testing.T) {
@@ -24,8 +25,12 @@ func TestPost(t *testing.T) {
 		handler, _ := NewHandler(Config{
 			DataStore:           store,
 			BasePath:            "https://buy.art/files/",
+			NotifyUploadCreated: true,
 		})
 
+		c := make(chan FileInfo, 1)
+		handler.UploadCreated = c
+
 		(&httpTest{
 			Method: "POST",
 			ReqHeader: map[string]string{
@@ -39,6 +44,12 @@ func TestPost(t *testing.T) {
 				"Location": "https://buy.art/files/foo",
 			},
 		}).Run(handler, t)
+
+		info := <-c
+
+		a := assert.New(t)
+		a.Equal("foo", info.ID)
+		a.Equal(int64(300), info.Size)
 	})
 
 	SubTest(t, "CreateExceedingMaxSizeFail", func(t *testing.T, store *MockFullDataStore) {

unrouted_handler.go

@@ -94,6 +94,12 @@ type UnroutedHandler struct {
 	// happen if the NotifyUploadProgress field is set to true in the Config
 	// structure.
 	UploadProgress chan FileInfo
+	// UploadCreated is used to send notifications about the uploads having been
+	// created. It triggers post creation and therefore has all the FileInfo incl.
+	// the ID available already. It facilitates the post-create hook. Sending to
+	// this channel will only happen if the NotifyUploadCreated field is set to
+	// true in the Config structure.
+	UploadCreated chan FileInfo
 	// Metrics provides numbers of the usage for this handler.
 	Metrics Metrics
 }
@@ -124,6 +130,7 @@ func NewUnroutedHandler(config Config) (*UnroutedHandler, error) {
 		CompleteUploads:   make(chan FileInfo),
 		TerminatedUploads: make(chan FileInfo),
 		UploadProgress:    make(chan FileInfo),
+		UploadCreated:     make(chan FileInfo),
 		logger:            config.Logger,
 		extensions:        extensions,
 		Metrics:           newMetrics(),
@@ -284,6 +291,11 @@ func (handler *UnroutedHandler) PostFile(w http.ResponseWriter, r *http.Request)
 	go handler.Metrics.incUploadsCreated()
 	handler.log("UploadCreated", "id", id, "size", i64toa(size), "url", url)
 
+	if handler.config.NotifyUploadCreated {
+		info.ID = id
+		handler.UploadCreated <- info
+	}
+
 	if isFinal {
 		if err := handler.composer.Concater.ConcatUploads(id, partialUploads); err != nil {
 			handler.sendError(w, r, err)