soundr/soundr.go

package main

import (
	"encoding/json"
	"errors"
	"fmt"
	"log"
	"net/http"
	"os"

	"github.com/faiface/beep"
	"github.com/getsentry/sentry-go"
)

type playback struct {
	File     string
	IsLoaded bool
	Streamer beep.StreamSeeker
	Control  *beep.Ctrl
	Loop     bool
	Format   beep.Format
	Done     chan bool
}

type playbackWebReturn struct {
	File     string
	IsLoaded bool
	Id       int
}

type streamBuf struct {
	Streamer beep.Streamer
	Format   beep.Format
	Buffer   *beep.Buffer
}

type Configuration struct {
	Port        int
	AllowSentry bool
}

var playbacks map[int]playback

var streamMap map[string]streamBuf

func main() {

	fmt.Println("Welcome to Soundr!")

	playbacks = make(map[int]playback)
	streamMap = make(map[string]streamBuf)

	// Create /sounds if not exists
	if _, err := os.Stat("./sounds"); os.IsNotExist(err) {
		fmt.Println("Created /sounds folder")
		os.Mkdir("./sounds", 0777)
	}

	// Handle config
	fmt.Println("Opening conf.json")
	file, fOpenError := os.Open("conf.json") // Try to open the file

	if errors.Is(fOpenError, os.ErrNotExist) { // If it does not exist, create it
		fmt.Println("Creating conf.json")
		file, fOpenError = os.Create("conf.json")
		if fOpenError != nil {
			log.Fatal(fOpenError)
		}
		defer file.Close()
		fmt.Println("Writing to conf.json")
		// Write the default config to the file
		json.NewEncoder(file).Encode(Configuration{
			Port:        8080,
			AllowSentry: true,
		})
		fmt.Println("Wrote to conf.json")
	}
	defer file.Close()
	// Decode the config
	decoder := json.NewDecoder(file)
	configuration := Configuration{}
	err := decoder.Decode(&configuration)

	if configuration.AllowSentry {
		err := sentry.Init(sentry.ClientOptions{
			Dsn: "https://0eae4896cb23446b99a8a5b9f9da75f1@sentry.thegreydiamond.de/8",
			// Enable printing of SDK debug messages.
			// Useful when getting started or trying to figure something out.
			// Debug: true,
		})
		if err != nil {
			log.Fatalf("sentry.Init: %s", err)
		}
	}

	if err != nil {
		fmt.Println("error:", err)
	}

	// Web server stuff
	// Play route, takes file as parameter, file is base64 encoded
	http.HandleFunc("/v1/play", handlePlay)
	// Buffer route, buffers file
	http.HandleFunc("/v1/buffer", handleBuffer)
	http.HandleFunc("/v1/bufferAll", handleBufferAll)
	http.HandleFunc("/v1/stop", handleStop)
	http.HandleFunc("/v1/stopAll", handleStopAll)
	http.HandleFunc("/v1/current", handleCurrent)
	http.HandleFunc("/v1/list", handleListing)
	http.HandleFunc("/v1/remaining", handleRemaining)
	http.HandleFunc("/", handleRoot)

	fmt.Println("Listening on port " + fmt.Sprint(configuration.Port))
	log.Fatal(http.ListenAndServe(":"+fmt.Sprint(configuration.Port), nil))
}