sdk/feedback_view_controller.go at main · urnetwork/sdk · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
package sdk

import (
	"context"
	"sync"

	"github.com/urnetwork/glog"

	"github.com/urnetwork/connect"
)

type IsSendingFeedbackListener interface {
	StateChanged(bool)
}

type FeedbackViewController struct {
	ctx    context.Context
	cancel context.CancelFunc
	device Device

	stateLock sync.Mutex

	isSendingFeedback bool

	isSendingFeedbackListeners *connect.CallbackList[IsSendingFeedbackListener]
}

func newFeedbackViewController(ctx context.Context, device Device) *FeedbackViewController {
	cancelCtx, cancel := context.WithCancel(ctx)

	vc := &FeedbackViewController{
		ctx:    cancelCtx,
		cancel: cancel,
		device: device,

		isSendingFeedback:          false,
		isSendingFeedbackListeners: connect.NewCallbackList[IsSendingFeedbackListener](),
	}
	return vc
}

func (vc *FeedbackViewController) Start() {}

func (vc *FeedbackViewController) Stop() {}

func (vc *FeedbackViewController) Close() {
	glog.Info("[fbvc]close")

	vc.cancel()
}

func (vc *FeedbackViewController) AddIsSendingFeedbackListener(listener IsSendingFeedbackListener) Sub {
	callbackId := vc.isSendingFeedbackListeners.Add(listener)
	return newSub(func() {
		vc.isSendingFeedbackListeners.Remove(callbackId)
	})
}

func (vc *FeedbackViewController) isSendingFeedbackChanged(isSending bool) {
	for _, listener := range vc.isSendingFeedbackListeners.Get() {
		connect.HandleError(func() {
			listener.StateChanged(isSending)
		})
	}
}

func (vc *FeedbackViewController) setIsSendingFeedback(isSending bool) {
	func() {
		vc.stateLock.Lock()
		defer vc.stateLock.Unlock()

		vc.isSendingFeedback = isSending
	}()

	vc.isSendingFeedbackChanged(isSending)
}

func (vc *FeedbackViewController) SendFeedback(
	msg string,
	starCount int,
) {

	if !vc.isSendingFeedback {

		vc.setIsSendingFeedback(true)

		args := &FeedbackSendArgs{
			Needs: &FeedbackSendNeeds{
				Other: msg,
			},
			StarCount: starCount,
		}

		vc.device.GetApi().SendFeedback(args, SendFeedbackCallback(connect.NewApiCallback[*FeedbackSendResult](
			func(result *FeedbackSendResult, err error) {

				vc.setIsSendingFeedback(false)

			},
		)))

	}

}