ZaparooProject · Anime0t4ku · Apr 13, 2025 · Apr 13, 2025 · Apr 13, 2025 · Apr 14, 2025
diff --git a/pkg/database/systemdefs/systemdefs.go b/pkg/database/systemdefs/systemdefs.go
@@ -231,6 +231,10 @@ const (
 	SystemNAOMI      = "NAOMI"
 	SystemNAOMI2     = "NAOMI2"
 	SystemVideo      = "Video"
+  SystemAudio   = "Audio"
+	SystemMovie   = "Movie"
+	SystemTV      = "TV"
+	SystemMusic   = "Music"
 	SystemGroovy     = "Groovy"
 )
 

diff --git a/pkg/platforms/libreelec/kodiapi.go b/pkg/platforms/libreelec/kodiapi.go
@@ -0,0 +1,149 @@
+package libreelec
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"github.com/ZaparooProject/zaparoo-core/pkg/config"
+	"github.com/ZaparooProject/zaparoo-core/pkg/platforms"
+	"github.com/rs/zerolog/log"
+	"io"
+	"net/http"
+	"strings"
+)
+
+type KodiAPIMethod string
+
+const (
+	KodiAPIMethodPlayerOpen KodiAPIMethod = "Player.Open"
+)
+
+type KodiPlayerOpenItemParams struct {
+	File string `json:"file"`
+}
+
+type KodiPlayerOpenParams struct {
+	Item KodiPlayerOpenItemParams `json:"item"`
+}
+
+type KodiAPIPayload struct {
+	JsonRPC string        `json:"jsonrpc"`
+	ID      int           `json:"id"`
+	Method  KodiAPIMethod `json:"method"`
+	Params  any           `json:"params"`
+}
+
+func apiRequest(cfg *config.Instance, method KodiAPIMethod, params any) ([]byte, error) {
+	req := KodiAPIPayload{
+		JsonRPC: "2.0",
+		ID:      1,
+		Method:  method,
+		Params:  params,
+	}
+
+	reqJson, err := json.Marshal(req)
+	if err != nil {
+		return nil, fmt.Errorf("failed to marshal request: %w", err)
+	}
+
+	kodiURL := "http://localhost:8080/jsonrpc" // TODO: allow setting from config
+	kodiReq, err := http.NewRequest("POST", kodiURL, bytes.NewBuffer(reqJson))
+	if err != nil {
+		return nil, fmt.Errorf("failed to create request: %w", err)
+	}
+
+	kodiReq.Header.Set("Content-Type", "application/json")
+	kodiReq.Header.Set("Accept", "application/json")
+
+	client := &http.Client{}
+	resp, err := client.Do(kodiReq)
+	if err != nil {
+		return nil, fmt.Errorf("failed to send request: %w", err)
+	}
+	defer func(Body io.ReadCloser) {
+		err := Body.Close()
+		if err != nil {
+			log.Warn().Err(err).Msg("failed to close response body")
+		}
+	}(resp.Body)
+
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return nil, fmt.Errorf("failed to read response body: %w", err)
+	}
+
+	return body, nil
+}
+
+func kodiLaunchRequest(cfg *config.Instance, path string) error {
+	params := KodiPlayerOpenParams{
+		Item: KodiPlayerOpenItemParams{
+			File: path,
+		},
+	}
+
+	_, err := apiRequest(cfg, KodiAPIMethodPlayerOpen, params)
+	return err
+}
+
+func kodiLaunchMovieRequest(cfg *config.Instance, path string) error {
+	// in this case, path would be something like kodi.move://some_id
+	// so we'll just trim that off and use the remaining text as the id
+	id := strings.TrimPrefix("kodi.movie://", path)
+
+	_, err := apiRequest(
+		cfg,
+		"", // TODO: replace with the correct method
+		id, // TODO: replace with your own params
+	)
+	return err
+}
+
+type KodiMovieScanResults struct {
+	// TODO: just using a fake response for the example, change this
+	Results []string `json:"results"`
+}
+
+func kodiScanMovies(
+	cfg *config.Instance,
+	systemId string, // the system id of the launcher this was called from
+	// results is any scan results which were found using the folder/extension
+	// scanning, which is run before the Scanner method. you must return this
+	// list with your own results appended. we pass these through in case a
+	// scanner method needs to process/modify existing scan results
+	// in this case, it will be empty, but it's good practice to handle it
+	results []platforms.ScanResult,
+) ([]platforms.ScanResult, error) {
+	// query for the list of movies available
+	resp, err := apiRequest(
+		cfg,
+		"",  // TODO: replace with the correct method
+		nil, // TODO: replace with your own params
+	)
+	if err != nil {
+		return nil, err
+	}
+
+	// the apiRequest function return raw bytes, so we parse them here (from json)
+	var scanResults KodiMovieScanResults
+	err = json.Unmarshal(resp, &scanResults)
+	if err != nil {
+		return nil, err
+	}
+
+	for _, movie := range scanResults.Results {
+		// here we are parsing the json result object, and creating a new set
+		// of objects that are suitable to be inserted into the media database
+		// and just appending them to the existing results list
+		results = append(results, platforms.ScanResult{
+			// this is the display name which will show in the app, be searchable
+			// and be queried from **launch.search commands
+			Name: movie, // TODO: come up with your own
+			// this is the path which should be stored on the card and will be
+			// forwarded to the launcher
+			Path: SchemeKodiMovie + "://" + movie, // TODO: come up with your own
+		})
+	}
+
+	return results, nil
+}
diff --git a/pkg/platforms/libreelec/platform.go b/pkg/platforms/libreelec/platform.go
@@ -22,12 +22,13 @@ package libreelec
 
 import (
 	"fmt"
-	widgetModels "github.com/ZaparooProject/zaparoo-core/pkg/configui/widgets/models"
 	"os"
 	"os/exec"
 	"path/filepath"
 	"time"
 
+	widgetModels "github.com/ZaparooProject/zaparoo-core/pkg/configui/widgets/models"
+
 	"github.com/ZaparooProject/zaparoo-core/pkg/readers/libnfc"
 	"github.com/ZaparooProject/zaparoo-core/pkg/readers/optical_drive"
 	"github.com/ZaparooProject/zaparoo-core/pkg/service/tokens"
@@ -42,6 +43,13 @@ import (
 	"github.com/ZaparooProject/zaparoo-core/pkg/readers"
 	"github.com/ZaparooProject/zaparoo-core/pkg/readers/file"
 	"github.com/ZaparooProject/zaparoo-core/pkg/readers/simple_serial"
+
+	"github.com/ZaparooProject/zaparoo-core/pkg/database/systemdefs"
+)
+
+const (
+	SchemeKodiMovie = "kodi.movie"
+	SchemeKodiTV    = "kodi.tv"
 )
 
 type Platform struct {
@@ -85,7 +93,9 @@ func (p *Platform) ScanHook(_ tokens.Token) error {
 }
 
 func (p *Platform) RootDirs(_ *config.Instance) []string {
-	return []string{}
+	return []string{
+		"/storage",
+	}
 }
 
 func (p *Platform) Settings() platforms.Settings {
@@ -152,6 +162,20 @@ func (p *Platform) LookupMapping(_ tokens.Token) (string, bool) {
 
 func (p *Platform) Launchers() []platforms.Launcher {
 	return []platforms.Launcher{
+		{
+			ID:         "KodiLocal",
+			SystemID:   systemdefs.SystemVideo,
+			Folders:    []string{"videos"},
+			Extensions: []string{".avi", ".mp4", ".mkv"},
+			Launch:     kodiLaunchRequest,
+		},
+		{
+			ID:       "KodiMovie",
+			SystemID: systemdefs.SystemMovie,
+			Schemes:  []string{SchemeKodiMovie},
+			Launch:   kodiLaunchMovieRequest,
+			Scanner:  kodiScanMovies,
+		},
 		{
 			ID:            "Generic",
 			Extensions:    []string{".sh"},