[feature] support processing of (many) more media types

README.md

@@ -261,6 +261,7 @@ The following open source libraries, frameworks, and tools are used by GoToSocia
   - [gruf/go-debug](https://codeberg.org/gruf/go-debug); debug build tag. [MIT License](https://spdx.org/licenses/MIT.html).
   - [gruf/go-errors](https://codeberg.org/gruf/go-errors); context-like error w/ value wrapping  [MIT License](https://spdx.org/licenses/MIT.html).
   - [gruf/go-fastcopy](https://codeberg.org/gruf/go-fastcopy); performant (buffer pooled) I/O copying [MIT License](https://spdx.org/licenses/MIT.html).
+  - [gruf/go-ffmpreg](https://codeberg.org/gruf/go-ffmpreg); embedded ffmpeg / ffprobe WASM binaries [GPL-3.0 License](https://spdx.org/licenses/GPL-3.0-only.html).
   - [gruf/go-kv](https://codeberg.org/gruf/go-kv); log field formatting. [MIT License](https://spdx.org/licenses/MIT.html).
   - [gruf/go-list](https://codeberg.org/gruf/go-list); generic doubly linked list. [MIT License](https://spdx.org/licenses/MIT.html).
   - [gruf/go-mutexes](https://codeberg.org/gruf/go-mutexes); safemutex & mutex map. [MIT License](https://spdx.org/licenses/MIT.html).

cmd/gotosocial/action/server/server.go

@@ -24,19 +24,22 @@ import (
 	"net/http"
 	"os"
 	"os/signal"
+	"runtime"
 	"strings"
 	"syscall"
 	"time"
 
 	"github.com/KimMachineGun/automemlimit/memlimit"
 	"github.com/gin-gonic/gin"
+	"github.com/ncruces/go-sqlite3"
 	"github.com/superseriousbusiness/gotosocial/cmd/gotosocial/action"
 	"github.com/superseriousbusiness/gotosocial/internal/api"
 	apiutil "github.com/superseriousbusiness/gotosocial/internal/api/util"
 	"github.com/superseriousbusiness/gotosocial/internal/cleaner"
 	"github.com/superseriousbusiness/gotosocial/internal/filter/spam"
 	"github.com/superseriousbusiness/gotosocial/internal/filter/visibility"
 	"github.com/superseriousbusiness/gotosocial/internal/gtserror"
+	"github.com/superseriousbusiness/gotosocial/internal/media/ffmpeg"
 	"github.com/superseriousbusiness/gotosocial/internal/messages"
 	"github.com/superseriousbusiness/gotosocial/internal/metrics"
 	"github.com/superseriousbusiness/gotosocial/internal/middleware"
@@ -66,14 +69,15 @@ import (
 
 // Start creates and starts a gotosocial server
 var Start action.GTSAction = func(ctx context.Context) error {
-	if _, err := maxprocs.Set(maxprocs.Logger(nil)); err != nil {
-		log.Warnf(ctx, "could not set CPU limits from cgroup: %s", err)
-	}
-
-	if _, err := memlimit.SetGoMemLimitWithOpts(); err != nil {
-		if !strings.Contains(err.Error(), "cgroup mountpoint does not exist") {
-			log.Warnf(ctx, "could not set Memory limits from cgroup: %s", err)
-		}
+	// Set GOMAXPROCS / GOMEMLIMIT
+	// to match container limits.
+	setLimits(ctx)
+
+	// Compile WASM modules ahead of first use
+	// to prevent unexpected initial slowdowns.
+	log.Info(ctx, "precompiling WebAssembly")
+	if err := precompileWASM(ctx); err != nil {
+		return err
 	}
 
 	var (
@@ -429,3 +433,30 @@ var Start action.GTSAction = func(ctx context.Context) error {
 
 	return nil
 }
+
+func setLimits(ctx context.Context) {
+	if _, err := maxprocs.Set(maxprocs.Logger(nil)); err != nil {
+		log.Warnf(ctx, "could not set CPU limits from cgroup: %s", err)
+	}
+
+	if _, err := memlimit.SetGoMemLimitWithOpts(); err != nil {
+		if !strings.Contains(err.Error(), "cgroup mountpoint does not exist") {
+			log.Warnf(ctx, "could not set Memory limits from cgroup: %s", err)
+		}
+	}
+}
+
+func precompileWASM(ctx context.Context) error {
+	// TODO: make max number instances configurable
+	maxprocs := runtime.GOMAXPROCS(0)
+	if err := sqlite3.Initialize(); err != nil {
+		return gtserror.Newf("error compiling sqlite3: %w", err)
+	}
+	if err := ffmpeg.InitFfmpeg(ctx, maxprocs); err != nil {
+		return gtserror.Newf("error compiling ffmpeg: %w", err)
+	}
+	if err := ffmpeg.InitFfprobe(ctx, maxprocs); err != nil {
+		return gtserror.Newf("error compiling ffprobe: %w", err)
+	}
+	return nil
+}

cmd/process-emoji/main.go

@@ -0,0 +1,122 @@
+// GoToSocial
+// Copyright (C) GoToSocial Authors [email protected]
+// SPDX-License-Identifier: AGPL-3.0-or-later
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Affero General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU Affero General Public License for more details.
+//
+// You should have received a copy of the GNU Affero General Public License
+// along with this program.  If not, see <http://www.gnu.org/licenses/>.
+
+package main
+
+import (
+	"context"
+	"io"
+	"os"
+	"os/signal"
+	"syscall"
+
+	"codeberg.org/gruf/go-storage/memory"
+	"github.com/superseriousbusiness/gotosocial/internal/config"
+	"github.com/superseriousbusiness/gotosocial/internal/db/bundb"
+	"github.com/superseriousbusiness/gotosocial/internal/log"
+	"github.com/superseriousbusiness/gotosocial/internal/media"
+	"github.com/superseriousbusiness/gotosocial/internal/state"
+	"github.com/superseriousbusiness/gotosocial/internal/storage"
+	"github.com/superseriousbusiness/gotosocial/internal/util"
+)
+
+func main() {
+	ctx := context.Background()
+	ctx, cncl := signal.NotifyContext(ctx, syscall.SIGTERM, syscall.SIGINT)
+	defer cncl()
+
+	if len(os.Args) != 3 {
+		log.Panic(ctx, "Usage: go run ./cmd/process-emoji <input-file> <output-static>")
+	}
+
+	var st storage.Driver
+	st.Storage = memory.Open(10, true)
+
+	var state state.State
+	state.Storage = &st
+
+	state.Caches.Init()
+
+	var err error
+
+	config.SetHost("example.com")
+	config.SetStorageBackend("disk")
+	config.SetStorageLocalBasePath("/tmp/gotosocial")
+	config.SetDbType("sqlite")
+	config.SetDbAddress(":memory:")
+
+	state.DB, err = bundb.NewBunDBService(ctx, &state)
+	if err != nil {
+		log.Panic(ctx, err)
+	}
+
+	if err := state.DB.CreateInstanceAccount(ctx); err != nil {
+		log.Panicf(ctx, "error creating instance account: %s", err)
+	}
+
+	if err := state.DB.CreateInstanceInstance(ctx); err != nil {
+		log.Panicf(ctx, "error creating instance instance: %s", err)
+	}
+
+	if err := state.DB.CreateInstanceApplication(ctx); err != nil {
+		log.Panicf(ctx, "error creating instance application: %s", err)
+	}
+
+	mgr := media.NewManager(&state)
+
+	processing, err := mgr.CreateEmoji(ctx,
+		"emoji",
+		"example.com",
+		func(ctx context.Context) (reader io.ReadCloser, err error) {
+			return os.Open(os.Args[1])
+		},
+		media.AdditionalEmojiInfo{
+			URI: util.Ptr("example.com/emoji"),
+		},
+	)
+	if err != nil {
+		log.Panic(ctx, err)
+	}
+
+	emoji, err := processing.Load(ctx)
+	if err != nil {
+		log.Panic(ctx, err)
+	}
+
+	copyFile(ctx, &st, emoji.ImageStaticPath, os.Args[2])
+}
+
+func copyFile(ctx context.Context, st *storage.Driver, key string, path string) {
+	rc, err := st.GetStream(ctx, key)
+	if err != nil {
+		log.Panic(ctx, err)
+	}
+	defer rc.Close()
+
+	_ = os.Remove(path)
+
+	output, err := os.Create(path)
+	if err != nil {
+		log.Panic(ctx, err)
+	}
+	defer output.Close()
+
+	_, err = io.Copy(output, rc)
+	if err != nil {
+		log.Panic(ctx, err)
+	}
+}

cmd/process-media/main.go

@@ -0,0 +1,124 @@
+// GoToSocial
+// Copyright (C) GoToSocial Authors [email protected]
+// SPDX-License-Identifier: AGPL-3.0-or-later
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Affero General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU Affero General Public License for more details.
+//
+// You should have received a copy of the GNU Affero General Public License
+// along with this program.  If not, see <http://www.gnu.org/licenses/>.
+
+package main
+
+import (
+	"context"
+	"io"
+	"os"
+	"os/signal"
+	"syscall"
+
+	"codeberg.org/gruf/go-storage/memory"
+	"github.com/superseriousbusiness/gotosocial/internal/config"
+	"github.com/superseriousbusiness/gotosocial/internal/db/bundb"
+	"github.com/superseriousbusiness/gotosocial/internal/log"
+	"github.com/superseriousbusiness/gotosocial/internal/media"
+	"github.com/superseriousbusiness/gotosocial/internal/state"
+	"github.com/superseriousbusiness/gotosocial/internal/storage"
+)
+
+func main() {
+	ctx := context.Background()
+	ctx, cncl := signal.NotifyContext(ctx, syscall.SIGTERM, syscall.SIGINT)
+	defer cncl()
+
+	if len(os.Args) != 4 {
+		log.Panic(ctx, "Usage: go run ./cmd/process-media <input-file> <output-processed> <output-thumbnail>")
+	}
+
+	var st storage.Driver
+	st.Storage = memory.Open(10, true)
+
+	var state state.State
+	state.Storage = &st
+
+	state.Caches.Init()
+
+	var err error
+
+	config.SetHost("example.com")
+	config.SetStorageBackend("disk")
+	config.SetStorageLocalBasePath("/tmp/gotosocial")
+	config.SetDbType("sqlite")
+	config.SetDbAddress(":memory:")
+
+	state.DB, err = bundb.NewBunDBService(ctx, &state)
+	if err != nil {
+		log.Panic(ctx, err)
+	}
+
+	if err := state.DB.CreateInstanceAccount(ctx); err != nil {
+		log.Panicf(ctx, "error creating instance account: %s", err)
+	}
+
+	if err := state.DB.CreateInstanceInstance(ctx); err != nil {
+		log.Panicf(ctx, "error creating instance instance: %s", err)
+	}
+
+	if err := state.DB.CreateInstanceApplication(ctx); err != nil {
+		log.Panicf(ctx, "error creating instance application: %s", err)
+	}
+
+	account, err := state.DB.GetInstanceAccount(ctx, "")
+	if err != nil {
+		log.Panic(ctx, err)
+	}
+
+	mgr := media.NewManager(&state)
+
+	processing, err := mgr.CreateMedia(ctx,
+		account.ID,
+		func(ctx context.Context) (reader io.ReadCloser, err error) {
+			return os.Open(os.Args[1])
+		},
+		media.AdditionalMediaInfo{},
+	)
+	if err != nil {
+		log.Panic(ctx, err)
+	}
+
+	media, err := processing.Load(ctx)
+	if err != nil {
+		log.Panic(ctx, err)
+	}
+
+	copyFile(ctx, &st, media.File.Path, os.Args[2])
+	copyFile(ctx, &st, media.Thumbnail.Path, os.Args[3])
+}
+
+func copyFile(ctx context.Context, st *storage.Driver, key string, path string) {
+	rc, err := st.GetStream(ctx, key)
+	if err != nil {
+		log.Panic(ctx, err)
+	}
+	defer rc.Close()
+
+	_ = os.Remove(path)
+
+	output, err := os.Create(path)
+	if err != nil {
+		log.Panic(ctx, err)
+	}
+	defer output.Close()
+
+	_, err = io.Copy(output, rc)
+	if err != nil {
+		log.Panic(ctx, err)
+	}
+}

docs/configuration/media.md

@@ -7,25 +7,24 @@
 ##### MEDIA CONFIG #####
 ########################
 
-# Config pertaining to media uploads (videos, image, image descriptions, emoji).
+# Config pertaining to media uploads (media, image descriptions, emoji).
 
-# Size. Maximum allowed image upload size in bytes.
+# Size. Max size in bytes of media uploads via API.
 #
 # Raising this limit may cause other servers to not fetch media
 # attached to a post.
 #
-# Examples: [2097152, 10485760, 10MB, 10MiB]
-# Default: 10MiB (10485760 bytes)
-media-image-max-size: 10MiB
+# Examples: [2097152, 10485760, 40MB, 40MiB]
+# Default: 40MiB (41943040 bytes)
+media-local-max-size: 40MiB
 
-# Size. Maximum allowed video upload size in bytes.
+# Size. Max size in bytes of media to download from other instances.
 #
-# Raising this limit may cause other servers to not fetch media
-# attached to a post.
+# Lowering this limit may cause your instance not to fetch post media.
 #
 # Examples: [2097152, 10485760, 40MB, 40MiB]
 # Default: 40MiB (41943040 bytes)
-media-video-max-size: 40MiB
+media-remote-max-size: 40MiB
 
 # Int. Minimum amount of characters required as an image or video description.
 # Examples: [500, 1000, 1500]