Add API2 relative Location proof

Author: kvz

examples/api2-devdock-tus-relative-location-resolution/main.go

@@ -0,0 +1,125 @@
+//go:build api2devdock
+
+package main
+
+import (
+	"bytes"
+	"context"
+	"fmt"
+	"net/http"
+	"net/url"
+	"time"
+
+	tusgo "github.com/bdragon300/tusgo"
+	"github.com/bdragon300/tusgo/examples/api2devdock"
+)
+
+func uploadWithRelativeLocationResolution(
+	ctx context.Context,
+	conformanceScenario map[string]interface{},
+) (map[string]interface{}, error) {
+	endpointURLValue, err := api2devdock.TusConformanceInputStringOption(
+		conformanceScenario,
+		"endpointUrl",
+	)
+	if err != nil {
+		return nil, err
+	}
+	endpointOrigin, err := url.Parse(endpointURLValue)
+	if err != nil {
+		return nil, err
+	}
+	metadata, err := api2devdock.TusConformanceInputStringMapOption(
+		conformanceScenario,
+		"metadata",
+	)
+	if err != nil {
+		return nil, err
+	}
+	content, err := api2devdock.TusConformanceInputSourceBytes(conformanceScenario)
+	if err != nil {
+		return nil, err
+	}
+	capabilityPlan, err := api2devdock.TusConformanceServerCapabilities(conformanceScenario)
+	if err != nil {
+		return nil, err
+	}
+
+	conformanceServer, err := api2devdock.NewTusConformancePlanServer(
+		conformanceScenario,
+		endpointOrigin,
+	)
+	if err != nil {
+		return nil, err
+	}
+	defer conformanceServer.Close()
+	localEndpointURL, err := conformanceServer.EndpointURL()
+	if err != nil {
+		return nil, err
+	}
+
+	client := tusgo.NewClient(http.DefaultClient, localEndpointURL).WithContext(ctx)
+	client.Capabilities = &tusgo.ServerCapabilities{
+		Extensions:       capabilityPlan.ExtensionNames,
+		ProtocolVersions: capabilityPlan.ProtocolVersions,
+	}
+	upload, err := client.UploadWithURLStorage(tusgo.URLStorageUploadOptions{
+		Context:     ctx,
+		Fingerprint: "api2-go-relative-location-conformance-fingerprint",
+		Metadata:    metadata,
+		Size:        int64(len(content)),
+		Source:      bytes.NewReader(content),
+		Storage:     tusgo.NewMemoryURLStorage(),
+	})
+	if err != nil {
+		return nil, err
+	}
+	if upload == nil || upload.Location == "" {
+		return nil, fmt.Errorf("relative-location TUS upload did not expose an upload URL")
+	}
+	if err := conformanceServer.AssertExhausted(); err != nil {
+		return nil, err
+	}
+
+	result, err := conformanceServer.Result()
+	if err != nil {
+		return nil, err
+	}
+	canonicalUploadURL, err := conformanceServer.CanonicalURL(upload.Location)
+	if err != nil {
+		return nil, err
+	}
+	result["uploadUrl"] = canonicalUploadURL
+
+	return result, nil
+}
+
+func main() {
+	ctx, cancel := context.WithTimeout(context.Background(), 90*time.Second)
+	defer cancel()
+
+	scenario, err := api2devdock.LoadScenario(
+		"examples/api2-devdock-tus-relative-location-resolution/api2-scenario.json",
+	)
+	if err != nil {
+		api2devdock.Fail("load scenario: %v", err)
+	}
+	conformanceScenario, err := api2devdock.TusConformanceScenario(scenario)
+	if err != nil {
+		api2devdock.Fail("read conformance scenario: %v", err)
+	}
+
+	result, err := uploadWithRelativeLocationResolution(ctx, conformanceScenario)
+	if err != nil {
+		api2devdock.Fail("relative Location resolution: %v", err)
+	}
+	if err := api2devdock.WriteResult(result); err != nil {
+		api2devdock.Fail("write result: %v", err)
+	}
+
+	scenarioID, err := api2devdock.ScenarioID(scenario)
+	if err != nil {
+		api2devdock.Fail("read scenario id: %v", err)
+	}
+	fmt.Printf("Go TUS SDK devdock scenario %s resolved %s\n", scenarioID, result["uploadUrl"])
+}