feat(issue-60): support uploading content to journeys

Author: Zaba505

services/poc/app/app.go

@@ -8,6 +8,7 @@ package app
 import (
 	"context"
 
+	"github.com/z5labs/journeys/services/poc/storage"
 	"github.com/z5labs/journeys/services/poc/ui"
 
 	"github.com/dgraph-io/dgo/v240"
@@ -23,6 +24,14 @@ type Config struct {
 	Dgraph struct {
 		Address string `config:"address"`
 	} `config:"dgraph"`
+
+	Minio struct {
+		Endpoint  string `config:"endpoint"`
+		AccessKey string `config:"access_key"`
+		SecretKey string `config:"secret_key"`
+		Bucket    string `config:"bucket"`
+		UseSSL    bool   `config:"use_ssl"`
+	} `config:"minio"`
 }
 
 func Init(ctx context.Context, cfg Config) (*rest.Api, error) {
@@ -41,6 +50,21 @@ func Init(ctx context.Context, cfg Config) (*rest.Api, error) {
 		return nil, err
 	}
 
+	minioClient, err := storage.NewMinioClient(
+		cfg.Minio.Endpoint,
+		cfg.Minio.AccessKey,
+		cfg.Minio.SecretKey,
+		cfg.Minio.Bucket,
+		cfg.Minio.UseSSL,
+	)
+	if err != nil {
+		return nil, err
+	}
+
+	if err := minioClient.EnsureBucket(ctx); err != nil {
+		return nil, err
+	}
+
 	api := rest.NewApi(
 		cfg.OpenApi.Title,
 		cfg.OpenApi.Version,
@@ -49,6 +73,9 @@ func Init(ctx context.Context, cfg Config) (*rest.Api, error) {
 		ui.GetJourneyForm(dgraph),
 		ui.CancelJourneyForm(dgraph),
 		ui.CreateJourney(dgraph),
+		ui.GetContentUploadForm(dgraph),
+		ui.UploadContent(dgraph, minioClient),
+		ui.GetContentPreview(dgraph, minioClient),
 	)
 
 	return api, nil

services/poc/app/schema.go

@@ -10,9 +10,30 @@ type Journey {
 	journey.id: string
 	journey.title: string
 	journey.created_at: datetime
+	journey.content: [uid]
+}
+
+type Content {
+	content.id: string
+	content.type: string
+	content.minio_key: string
+	content.title: string
+	content.description: string
+	content.uploaded_at: datetime
+	content.file_size: int
+	content.mime_type: string
 }
 
 journey.id: string @index(exact) .
 journey.title: string .
 journey.created_at: datetime .
+journey.content: [uid] @reverse .
+content.id: string @index(exact) .
+content.type: string @index(exact) .
+content.minio_key: string .
+content.title: string .
+content.description: string .
+content.uploaded_at: datetime .
+content.file_size: int .
+content.mime_type: string .
 `

services/poc/config.yaml

@@ -37,3 +37,4 @@ minio:
   access_key: {{env "MINIO_ACCESS_KEY" | default "minioadmin"}}
   secret_key: {{env "MINIO_SECRET_KEY" | default "minioadmin"}}
   bucket: {{env "MINIO_BUCKET" | default "onebrc"}}
+  use_ssl: {{env "MINIO_USE_SSL" | default "false"}}

services/poc/storage/minio.go

@@ -0,0 +1,70 @@
+// Copyright (c) 2025 Z5labs and Contributors
+//
+// This software is released under the MIT License.
+// https://opensource.org/licenses/MIT
+
+package storage
+
+import (
+	"context"
+	"io"
+	"time"
+
+	"github.com/minio/minio-go/v7"
+	"github.com/minio/minio-go/v7/pkg/credentials"
+)
+
+type MinioClient struct {
+	client *minio.Client
+	bucket string
+}
+
+func NewMinioClient(endpoint, accessKey, secretKey, bucket string, useSSL bool) (*MinioClient, error) {
+	client, err := minio.New(endpoint, &minio.Options{
+		Creds:  credentials.NewStaticV4(accessKey, secretKey, ""),
+		Secure: useSSL,
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	return &MinioClient{
+		client: client,
+		bucket: bucket,
+	}, nil
+}
+
+func (m *MinioClient) EnsureBucket(ctx context.Context) error {
+	exists, err := m.client.BucketExists(ctx, m.bucket)
+	if err != nil {
+		return err
+	}
+
+	if !exists {
+		err = m.client.MakeBucket(ctx, m.bucket, minio.MakeBucketOptions{})
+		if err != nil {
+			return err
+		}
+	}
+
+	return nil
+}
+
+func (m *MinioClient) UploadFile(ctx context.Context, objectKey string, reader io.Reader, size int64, contentType string) error {
+	_, err := m.client.PutObject(ctx, m.bucket, objectKey, reader, size, minio.PutObjectOptions{
+		ContentType: contentType,
+	})
+	return err
+}
+
+func (m *MinioClient) GetFileURL(ctx context.Context, objectKey string, expiry time.Duration) (string, error) {
+	url, err := m.client.PresignedGetObject(ctx, m.bucket, objectKey, expiry, nil)
+	if err != nil {
+		return "", err
+	}
+	return url.String(), nil
+}
+
+func (m *MinioClient) DeleteFile(ctx context.Context, objectKey string) error {
+	return m.client.RemoveObject(ctx, m.bucket, objectKey, minio.RemoveObjectOptions{})
+}

services/poc/ui/get_content_preview.go

@@ -0,0 +1,91 @@
+// Copyright (c) 2025 Z5labs and Contributors
+//
+// This software is released under the MIT License.
+// https://opensource.org/licenses/MIT
+
+package ui
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"net/http"
+	"time"
+
+	"github.com/z5labs/journeys/services/poc/storage"
+
+	"github.com/dgraph-io/dgo/v240"
+	"github.com/z5labs/humus/rest"
+)
+
+type contentPreviewHandler struct {
+	dgraph *dgo.Dgraph
+	minio  *storage.MinioClient
+}
+
+func GetContentPreview(dgraph *dgo.Dgraph, minio *storage.MinioClient) rest.ApiOption {
+	h := &contentPreviewHandler{
+		dgraph: dgraph,
+		minio:  minio,
+	}
+
+	return rest.Operation(
+		http.MethodGet,
+		rest.BasePath("/app/content").Param("contentID").Segment("preview"),
+		h,
+	)
+}
+
+func (h *contentPreviewHandler) Handle(ctx context.Context, req *rest.EmptyRequest) (*HtmlResponse, error) {
+	contentID := rest.PathParamValue(ctx, "contentID")
+	if contentID == "" {
+		return nil, fmt.Errorf("content ID is required")
+	}
+
+	query := `query getContent($contentID: string) {
+		content(func: eq(content.id, $contentID)) {
+			content.minio_key
+		}
+	}`
+
+	vars := map[string]string{"contentID": contentID}
+	resp, err := h.dgraph.NewReadOnlyTxn().QueryWithVars(ctx, query, vars)
+	if err != nil {
+		return nil, fmt.Errorf("failed to query content: %w", err)
+	}
+
+	var result struct {
+		Content []struct {
+			MinioKey string `json:"content.minio_key"`
+		} `json:"content"`
+	}
+	if err := json.Unmarshal(resp.Json, &result); err != nil {
+		return nil, fmt.Errorf("failed to unmarshal content: %w", err)
+	}
+
+	if len(result.Content) == 0 {
+		return nil, fmt.Errorf("content not found")
+	}
+
+	minioKey := result.Content[0].MinioKey
+
+	presignedURL, err := h.minio.GetFileURL(ctx, minioKey, 15*time.Minute)
+	if err != nil {
+		return nil, fmt.Errorf("failed to get presigned URL: %w", err)
+	}
+
+	redirectHTML := fmt.Sprintf(`<!DOCTYPE html>
+<html>
+<head>
+    <meta http-equiv="refresh" content="0; url=%s">
+</head>
+<body>
+    <p>Redirecting...</p>
+</body>
+</html>`, presignedURL)
+
+	return &HtmlResponse{
+		ContentType: "text/html; charset=utf-8",
+		Body:        []byte(redirectHTML),
+	}, nil
+}

services/poc/ui/get_content_upload_form.go

@@ -0,0 +1,64 @@
+// Copyright (c) 2025 Z5labs and Contributors
+//
+// This software is released under the MIT License.
+// https://opensource.org/licenses/MIT
+
+package ui
+
+import (
+	"bytes"
+	"context"
+	_ "embed"
+	"fmt"
+	"html/template"
+	"net/http"
+
+	"github.com/dgraph-io/dgo/v240"
+	"github.com/z5labs/humus/rest"
+)
+
+//go:embed templates/content_upload_form.html
+var contentUploadFormTemplate string
+
+type contentUploadFormHandler struct {
+	dgraph   *dgo.Dgraph
+	template *template.Template
+}
+
+func GetContentUploadForm(dgraph *dgo.Dgraph) rest.ApiOption {
+	tmpl, err := template.New("content_upload_form.html").Parse(contentUploadFormTemplate)
+	if err != nil {
+		panic(err)
+	}
+
+	h := &contentUploadFormHandler{
+		dgraph:   dgraph,
+		template: tmpl,
+	}
+
+	return rest.Operation(
+		http.MethodGet,
+		rest.BasePath("/app/journey").Param("journeyID").Segment("content").Segment("form"),
+		h,
+	)
+}
+
+func (h *contentUploadFormHandler) Handle(ctx context.Context, req *rest.EmptyRequest) (*HtmlResponse, error) {
+	journeyID := rest.PathParamValue(ctx, "journeyID")
+	if journeyID == "" {
+		return nil, fmt.Errorf("journey ID is required")
+	}
+
+	var buf bytes.Buffer
+	err := h.template.Execute(&buf, map[string]string{
+		"JourneyID": journeyID,
+	})
+	if err != nil {
+		return nil, fmt.Errorf("failed to render template: %w", err)
+	}
+
+	return &HtmlResponse{
+		ContentType: "text/html; charset=utf-8",
+		Body:        buf.Bytes(),
+	}, nil
+}