runtime.go RawHistoryFolder

1package pipewire
2
3import (
4	"errors"
5
6	"github.com/bnema/purego-pipewire/internal/capi"
7	"github.com/bnema/purego-pipewire/internal/core"
8)
9
10// runtimeWrapper wraps the internal core.Runtime to implement the public Runtime interface.
11type runtimeWrapper struct {
12	inner *core.Runtime
13}
14
15func (rw runtimeWrapper) Init() error {
16	return rw.inner.Init()
17}
18
19func (rw runtimeWrapper) Deinit() {
20	rw.inner.Deinit()
21}
22
23func (rw runtimeWrapper) NewMainLoop() (MainLoop, error) {
24	ml, err := rw.inner.NewMainLoop()
25	if err != nil {
26		return nil, err
27	}
28	return mainLoopWrapper{inner: ml}, nil
29}
30
31// mainLoopWrapper wraps the internal core.MainLoop to implement the public MainLoop interface.
32type mainLoopWrapper struct {
33	inner *core.MainLoop
34}
35
36func (mlw mainLoopWrapper) Run() int32 {
37	return mlw.inner.Run()
38}
39
40func (mlw mainLoopWrapper) Destroy() {
41	mlw.inner.Destroy()
42}
43
44// Init initializes the PipeWire runtime and returns a Runtime instance.
45// This function must be called before using any other PipeWire functionality.
46// Returns an error if the PipeWire libraries cannot be loaded.
47func Init() (Runtime, error) {
48	if err := capi.Register(); err != nil {
49		return nil, err
50	}
51	capiInstance := capi.Default()
52	if capiInstance == nil {
53		return nil, errors.New("failed to get default CAPI instance")
54	}
55	r := core.NewRuntime(capiInstance)
56	if err := r.Init(); err != nil {
57		return nil, err
58	}
59	return runtimeWrapper{inner: r}, nil
60}