AynaLivePlayer/internal/source/login.go

package source

import (
	"AynaLivePlayer/core/events"
	"AynaLivePlayer/global"
	"AynaLivePlayer/pkg/eventbus"
	"github.com/AynaLivePlayer/miaosic"
)

func handleSourceLogin() {
	err := global.EventBus.Subscribe("",
		events.CmdMiaosicQrLogin, "internal.media_provider.qrlogin_handler", func(event *eventbus.Event) {
			data := event.Data.(events.CmdMiaosicQrLoginData)
			log.Infof("trying login %s", data.Provider)
			pvdr, ok := miaosic.GetProvider(data.Provider)
			if !ok {
				_ = global.EventBus.Reply(
					event, events.ReplyMiaosicQrLogin,
					events.ReplyMiaosicQrLoginData{
						Session: miaosic.QrLoginSession{},
						Error:   miaosic.ErrorNoSuchProvider,
					})
				return
			}
			result, ok := pvdr.(miaosic.Loginable)
			if !ok {
				_ = global.EventBus.Reply(
					event, events.ReplyMiaosicQrLogin,
					events.ReplyMiaosicQrLoginData{
						Session: miaosic.QrLoginSession{},
						Error:   miaosic.ErrNotImplemented,
					})
				return
			}
			var session miaosic.QrLoginSession
			sess, err := result.QrLogin()
			if err == nil && sess != nil {
				session = *sess
			}
			_ = global.EventBus.Reply(
				event, events.ReplyMiaosicQrLogin,
				events.ReplyMiaosicQrLoginData{
					Session: session,
					Error:   err,
				})
		})
	if err != nil {
		log.ErrorW("Subscribe miaosic qrlogin failed", "error", err)
	}
	err = global.EventBus.Subscribe("",
		events.CmdMiaosicQrLoginVerify, "internal.media_provider.qrloginverify_handler", func(event *eventbus.Event) {
			data := event.Data.(events.CmdMiaosicQrLoginVerifyData)
			log.Infof("trying login verify %s", data.Provider)
			pvdr, ok := miaosic.GetProvider(data.Provider)
			if !ok {
				_ = global.EventBus.Reply(
					event, events.ReplyMiaosicQrLoginVerify,
					events.ReplyMiaosicQrLoginVerifyData{
						Result: miaosic.QrLoginResult{},
						Error:  miaosic.ErrorNoSuchProvider,
					})
				return
			}
			loginable, ok := pvdr.(miaosic.Loginable)
			if !ok {
				_ = global.EventBus.Reply(
					event, events.ReplyMiaosicQrLoginVerify,
					events.ReplyMiaosicQrLoginVerifyData{
						Result: miaosic.QrLoginResult{},
						Error:  miaosic.ErrNotImplemented,
					})
				return
			}
			var result miaosic.QrLoginResult
			res, err := loginable.QrLoginVerify(&data.Session)
			if err == nil && res != nil {
				result = *res
			}
			_ = global.EventBus.Reply(
				event, events.ReplyMiaosicQrLoginVerify,
				events.ReplyMiaosicQrLoginVerifyData{
					Result: result,
					Error:  err,
				})
		})
	if err != nil {
		log.ErrorW("Subscribe miaosic qrloginverify failed", "error", err)
	}
}