guessit-go/guessit.go

package guessit

// #cgo pkg-config: python-3.9-embed
// #include <Python.h>
// import "C"
import (
	"fmt"
	"os"
	"strings"

	python3 "git.stein-ivar.net/steino/cpy3"

	"github.com/mitchellh/mapstructure"
)

type Match struct {
	// Main
	Type             string `mapstructure:"type,omitempty"`
	Title            string `mapstructure:"title,omitempty"`
	ReleaseGroup     string `mapstructure:"release_group,omitempty"`
	StreamingService string `mapstructure:"streaming_service,omitempty"`

	// Episode
	Season  int64 `mapstructure:"season,omitempty"`
	Episode int64 `mapstructure:"episode,omitempty"`
	Version int64 `mapstructure:"version,omitempty"`

	// Video
	ScreenSize string `mapstructure:"screen_size,omitempty"`
	Container  string `mapstructure:"container,omitempty"`

	// Audio
	AudioChannels string   `mapstructure:"audio_channels,omitempty"`
	AudioCodec    []string `mapstructure:"audio_codec,omitempty"`

	// Other
	Other []string `mapstructure:"other,omitempty"`
}

type Guessit struct {
	fn *python3.PyObject
}

func init() {
	python3.Py_Initialize()
	if !python3.Py_IsInitialized() {
		fmt.Println("Error initializing the python interpreter")
		os.Exit(1)
	}
}

func New() (*Guessit, error) {
	python3.PyErr_Clear()

	module := python3.PyImport_ImportModule("guessit") //ret val: new ref
	if !(module != nil && python3.PyErr_Occurred() == nil) {
		return nil, fmt.Errorf("failed to import module 'guessit'")
	}
	defer module.DecRef()

	dict := python3.PyModule_GetDict(module) //ret val: Borrowed
	if !(dict != nil && python3.PyErr_Occurred() == nil) {
		return nil, fmt.Errorf("could not get dict for module")
	}

	fn := python3.PyDict_GetItemString(dict, "guessit") //retval: Borrowed
	if !(fn != nil && python3.PyCallable_Check(fn)) {
		return nil, fmt.Errorf("could not find function 'guessit'")
	}

	return &Guessit{
		fn: fn,
	}, nil
}

func (g Guessit) Guessit(s string, options ...string) (out Match, err error) {
	python3.PyErr_Clear()

	if len(s) == 0 {
		err = fmt.Errorf("input string is empty")
		return
	}

	item := python3.PyUnicode_FromString(s)
	defer item.DecRef()

	opts := python3.PyUnicode_FromString(strings.Join(options[:], " "))
	defer opts.DecRef()

	testdataPy := g.fn.CallFunctionObjArgs(item, opts) //retval: New reference
	if !(testdataPy != nil && python3.PyErr_Occurred() == nil) {
		return
	}

	defer testdataPy.DecRef()

	size := python3.PyDict_Size(testdataPy)
	keys := python3.PyDict_Keys(testdataPy)
	defer keys.DecRef()

	vals := python3.PyDict_Values(testdataPy)
	defer vals.DecRef()

	tmpmap := make(map[string]interface{})
	for i := 0; i < size; i++ {
		kitem := python3.PyList_GetItem(keys, i)
		key := python3.PyUnicode_AsUTF8(kitem)
		kitem = nil

		val := python3.PyList_GetItem(vals, i)
		switch {
		case python3.PyLong_Check(val):
			tmpmap[key] = python3.PyLong_AsLongLong(val)
		case python3.PyUnicode_Check(val):
			tmpmap[key] = python3.PyUnicode_AsUTF8(val)
		case python3.PyList_Check(val):
			var tmp []string
			for i := 0; i < python3.PyList_Size(val); i++ {
				item := python3.PyList_GetItem(val, i)
				v := python3.PyUnicode_AsUTF8(item)
				tmp = append(tmp, v)
			}
			tmpmap[key] = tmp
		default:
		}
	}

	if _, ok := tmpmap["version"]; !ok {
		tmpmap["version"] = -1
	}

	config := &mapstructure.DecoderConfig{
		WeaklyTypedInput: true,
		Result:           &out,
	}

	decoder, err := mapstructure.NewDecoder(config)
	if err != nil {
		return
	}

	err = decoder.Decode(tmpmap)
	if err != nil {
		return
	}

	return
}