Merge pull request #24 from xeyossr/fix/rpc-reconnect

RPC Reconnect

Author: axrona

aur/.SRCINFO

@@ -1,6 +1,6 @@
 pkgbase = anitr-cli
 	pkgdesc = 🚀 Terminalde Türkçe altyazılı anime arama ve izleme aracı
-	pkgver = 4.5.1
+	pkgver = 4.5.2
 	pkgrel = 1
 	url = https://github.com/xeyossr/anitr-cli
 	arch = any
@@ -12,7 +12,7 @@ pkgbase = anitr-cli
 	optdepends = rofi-wayland: Wayland kullanıcıları için GUI
 	optdepends = yt-dlp: Anime indirme özelliği için
 	optdepends = youtube-dl: Anime indirme özelliği için
-	source = anitr-cli-4.5.1.tar.gz::https://github.com/xeyossr/anitr-cli/archive/refs/tags/v4.5.1.tar.gz
+	source = anitr-cli-4.5.2.tar.gz::https://github.com/xeyossr/anitr-cli/archive/refs/tags/v4.5.2.tar.gz
 	sha256sums = SKIP
 
 pkgname = anitr-cli

aur/PKGBUILD

@@ -1,7 +1,7 @@
 # Maintainer: xeyossr
 # Description: 🚀 Terminalde Türkçe altyazılı anime arama ve izleme aracı
 pkgname=anitr-cli
-pkgver=4.5.1
+pkgver=4.5.2
 pkgrel=1
 pkgdesc="🚀 Terminalde Türkçe altyazılı anime arama ve izleme aracı"
 arch=('any')

go.mod

@@ -8,9 +8,9 @@ require (
 	github.com/charmbracelet/bubbles v0.21.0
 	github.com/charmbracelet/bubbletea v1.3.6
 	github.com/charmbracelet/lipgloss v1.1.0
-	github.com/hugolgst/rich-go v0.0.0-20240715122152-74618cc1ace2
 	github.com/muesli/reflow v0.3.0
 	github.com/spf13/cobra v1.9.1
+	github.com/xeyossr/go-discordrpc v1.0.0
 )
 
 require (

go.sum

@@ -27,8 +27,6 @@ github.com/charmbracelet/x/term v0.2.1/go.mod h1:oQ4enTYFV7QN4m0i9mzHrViD7TQKvNE
 github.com/cpuguy83/go-md2man/v2 v2.0.6/go.mod h1:oOW0eioCTA6cOiMLiUPZOpcVxMig6NIQQ7OS05n1F4g=
 github.com/erikgeiser/coninput v0.0.0-20211004153227-1c3628e74d0f h1:Y/CXytFA4m6baUTXGLOoWe4PQhGxaX0KpnayAqC48p4=
 github.com/erikgeiser/coninput v0.0.0-20211004153227-1c3628e74d0f/go.mod h1:vw97MGsxSvLiUE2X8qFplwetxpGLQrlU1Q9AUEIzCaM=
-github.com/hugolgst/rich-go v0.0.0-20240715122152-74618cc1ace2 h1:9qOViOQGFIP5ar+2NorfAIsfuADEKXtklySC0zNnYf4=
-github.com/hugolgst/rich-go v0.0.0-20240715122152-74618cc1ace2/go.mod h1:nGaW7CGfNZnhtiFxMpc4OZdqIexGXjUlBnlmpZmjEKA=
 github.com/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2s0bqwp9tc8=
 github.com/inconshreveable/mousetrap v1.1.0/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw=
 github.com/kylelemons/godebug v1.1.0 h1:RPNrshWIDI6G2gRW9EHilWtl7Z6Sb1BR0xunSBf0SNc=
@@ -61,6 +59,8 @@ github.com/spf13/cobra v1.9.1 h1:CXSaggrXdbHK9CF+8ywj8Amf7PBRmPCOJugH954Nnlo=
 github.com/spf13/cobra v1.9.1/go.mod h1:nDyEzZ8ogv936Cinf6g1RU9MRY64Ir93oCnqb9wxYW0=
 github.com/spf13/pflag v1.0.6 h1:jFzHGLGAlb3ruxLB8MhbI6A8+AQX/2eW4qeyNZXNp2o=
 github.com/spf13/pflag v1.0.6/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
+github.com/xeyossr/go-discordrpc v1.0.0 h1:5Vr3hGWxvB3+wyddZXmu76yrB7kaJy/S7vRQERzL2G0=
+github.com/xeyossr/go-discordrpc v1.0.0/go.mod h1:SvAeJIAdkhljZMtunSVc42bLfbOlJgoURLsCr7pCk4s=
 github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e h1:JVG44RsyaB9T2KIHavMF/ppJZNG9ZpyihvCd0w101no=
 github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e/go.mod h1:RbqR21r5mrJuqunuUZ/Dhy/avygyECGrLceyNeo4LiM=
 golang.org/x/exp v0.0.0-20220909182711-5c715a9e8561 h1:MDc5xs78ZrZr3HMQugiXOAkSZtfTpbJLDr/lwfgO53E=

internal/rpc/discord.go

@@ -3,34 +3,40 @@ package rpc
 import (
 	"fmt"
 
-	"github.com/hugolgst/rich-go/client"
 	"github.com/xeyossr/anitr-cli/internal"
+	"github.com/xeyossr/go-discordrpc/client"
 )
 
-// ClientLogin, Discord RPC'ye giriş yapmaya çalışır ve başarı durumunu döner.
-func ClientLogin() (bool, error) {
-	// Discord RPC'ye giriş yapmayı dene
-	err := client.Login("1383421771159572600")
-	if err != nil {
-		return false, fmt.Errorf("discord rpc login başarısız: %v", err) // Giriş hatası
+var discordClient *client.Client
+
+// getClient, Tek bir Discord RPC istemci sağlar
+func getClient() *client.Client {
+	if discordClient == nil {
+		discordClient = client.NewClient("1383421771159572600")
 	}
+	return discordClient
+}
 
-	return true, nil // Başarılı giriş
+// ClientLogin, Discord RPC'ye giriş yapmaya çalışır ve başarı durumunu döner.
+func ClientLogin() error {
+	c := getClient()
+	if err := c.Login(); err != nil {
+		return fmt.Errorf("discord rpc login failed: %w", err)
+	}
+	return nil
 }
 
 // DiscordRPC, Discord'a RPC (Remote Procedure Call) aktivitesi güncellemeleri gönderir.
-func DiscordRPC(params internal.RPCParams, loggedIn bool) (bool, error) {
-	// Eğer Discord'a giriş yapılmamışsa, giriş yap
-	if !loggedIn {
-		ok, err := ClientLogin()
-		if err != nil || !ok {
-			return false, fmt.Errorf("discord rpc login başarısız: %v", err)
-		}
-		loggedIn = true
+func DiscordRPC(params internal.RPCParams) error {
+	c := getClient()
+
+	// Giriş yapıldığından emin ol
+	if err := ClientLogin(); err != nil {
+		return err
 	}
 
 	// Discord aktivitesini ayarla
-	err := client.SetActivity(client.Activity{
+	err := c.SetActivity(client.Activity{
 		State:      params.State,      // Aktivite durumu
 		Details:    params.Details,    // Aktivite detayları
 		LargeImage: params.LargeImage, // Büyük resim
@@ -44,36 +50,36 @@ func DiscordRPC(params internal.RPCParams, loggedIn bool) (bool, error) {
 			},
 		},
 	})
-	// Eğer aktivite güncelleme hatalıysa
-	if err != nil {
-		loggedIn = false
-		ok, err := ClientLogin()
-		if err != nil || !ok {
-			return false, fmt.Errorf("discord rpc yeniden login başarısız: %v", err)
-		}
 
-		err = client.SetActivity(client.Activity{
-			State:      params.State,
-			Details:    params.Details,
-			LargeImage: params.LargeImage,
-			LargeText:  params.LargeText,
-			SmallImage: params.SmallImage,
-			SmallText:  params.SmallText,
-			Buttons: []*client.Button{
-				{
-					Label: "GitHub",
-					Url:   "https://github.com/xeyossr/anitr-cli",
-				},
-			},
-		})
-		if err != nil {
-			return false, fmt.Errorf("discord rpc retry setactivity başarısız: %v", err)
-		}
+	if err == nil {
+		return nil
+	}
+
+	// Eğer hata oluşursa yeniden bağlan
+	_ = c.Logout()
+	if err := ClientLogin(); err != nil {
+		return fmt.Errorf("discord rpc retry login failed: %w", err)
+	}
 
-		loggedIn = true
+	// Tekrar dene
+	if err := c.SetActivity(client.Activity{
+		State:      params.State,
+		Details:    params.Details,
+		LargeImage: params.LargeImage,
+		LargeText:  params.LargeText,
+		SmallImage: params.SmallImage,
+		SmallText:  params.SmallText,
+		Buttons: []*client.Button{
+			{
+				Label: "GitHub",
+				Url:   "https://github.com/xeyossr/anitr-cli",
+			},
+		},
+	}); err != nil {
+		return fmt.Errorf("discord rpc retry set activity failed: %w", err)
 	}
 
-	return loggedIn, nil // Başarılı RPC güncellemesi
+	return nil
 }
 
 // RPCDetails, Discord RPC için gerekli parametreleri hazırlar ve döner.

main.go

@@ -335,7 +335,7 @@ func mainMenu(cfx *App) {
 
 			// Bölümleri al
 			episodes, episodeNames, isMovie, selectedSeasonIndex, err := getEpisodesAndNames(
-				*cfx.source, false, animeId, animeSlug, historySelectedAnime, cfx.logger,
+				*cfx.source, false, animeId, animeSlug, historySelectedAnime,
 			)
 			if err != nil {
 				cfx.logger.LogError(err)
@@ -680,7 +680,7 @@ func getAnimeIDs(source models.AnimeSource, selectedAnime models.Anime) (int, st
 }
 
 // Seçilen animeye ait bölümleri getirir, isim listesi oluşturur ve movie olup olmadığını döner
-func getEpisodesAndNames(source models.AnimeSource, isMovie bool, selectedAnimeID int, selectedAnimeSlug string, selectedAnimeName string, logger *utils.Logger) ([]models.Episode, []string, bool, int, error) {
+func getEpisodesAndNames(source models.AnimeSource, isMovie bool, selectedAnimeID int, selectedAnimeSlug string, selectedAnimeName string) ([]models.Episode, []string, bool, int, error) {
 	var (
 		episodes            []models.Episode
 		episodeNames        []string
@@ -765,12 +765,6 @@ func playAnimeLoop(
 		selectedEpisodeIndex = lastEpisodeIdx + 1
 	}
 
-	// Discord RPC için giriş yap
-	loggedIn, err := rpc.ClientLogin()
-	if err != nil || !loggedIn {
-		logger.LogError(err)
-	}
-
 	for {
 		ui.ClearScreen()
 
@@ -912,7 +906,7 @@ func playAnimeLoop(
 			close(done)
 
 			if !disableRPC {
-				go updateDiscordRPC(socketPath, episodeNames, selectedEpisodeIndex, selectedAnimeName, selectedSource, posterURL, logger, &loggedIn)
+				go updateDiscordRPC(socketPath, episodeNames, selectedEpisodeIndex, selectedAnimeName, selectedSource, posterURL, logger)
 			}
 
 			var selectedAnimeId string
@@ -1182,7 +1176,7 @@ func playAnimeLoop(
 				choice, err := showSelection(App{uiMode: &uiMode, rofiFlags: &rofiFlags}, []string{"Bu kaynakla devam et", "Kaynak değiştir", "Çık"}, fmt.Sprintf("Arama kaynağı: %s", selectedSource))
 
 				if errors.Is(err, tui.ErrGoBack) {
-					continue
+					break
 				}
 
 				if err != nil {
@@ -1217,7 +1211,7 @@ func playAnimeLoop(
 }
 
 // Discord RPC'yi güncelleyerek anime oynatma durumunu Discord'a yansıtır
-func updateDiscordRPC(socketPath string, episodeNames []string, selectedEpisodeIndex int, selectedAnimeName, selectedSource, posterURL string, logger *utils.Logger, loggedIn *bool) {
+func updateDiscordRPC(socketPath string, episodeNames []string, selectedEpisodeIndex int, selectedAnimeName, selectedSource, posterURL string, logger *utils.Logger) {
 	// 5 saniyede bir discord RPC güncellemesi yapmak için zamanlayıcı başlatılır
 	ticker := time.NewTicker(5 * time.Second)
 	defer ticker.Stop()
@@ -1265,23 +1259,22 @@ func updateDiscordRPC(socketPath string, episodeNames []string, selectedEpisodeI
 		state := fmt.Sprintf("%s (%s / %s)", episodeNames[selectedEpisodeIndex], formatTime(timePos), formatTime(duration))
 		// Eğer video duraklatıldıysa, duraklatma bilgisini ekle
 		if isPaused {
-			state = fmt.Sprintf("%s (%s / %s) (Paused)", episodeNames[selectedEpisodeIndex], formatTime(timePos), formatTime(duration))
+			state += " (Paused)"
 		}
 
-		// Discord RPC için parametreleri ayarla ve RPC'yi güncelle
-		var err2 error
-		*loggedIn, err2 = rpc.DiscordRPC(internal.RPCParams{
+		// RPC parametreleri
+		params := internal.RPCParams{
 			Details:    selectedAnimeName,
 			State:      state,
 			SmallImage: strings.ToLower(selectedSource),
 			SmallText:  selectedSource,
 			LargeImage: posterURL,
 			LargeText:  selectedAnimeName,
-		}, *loggedIn)
+		}
 
-		// Discord RPC güncelleme hatası varsa logla
-		if err2 != nil {
-			logger.LogError(fmt.Errorf("DiscordRPC hatası: %w", err2))
+		// Discord RPC güncelle
+		if err := rpc.DiscordRPC(params); err != nil {
+			logger.LogError(fmt.Errorf("DiscordRPC hatası: %w", err))
 			continue
 		}
 	}
@@ -1346,7 +1339,7 @@ func app(cfx *App) error {
 
 		// Anime bölümleri alınır
 		episodes, episodeNames, isMovie, selectedSeasonIndex, err := getEpisodesAndNames(
-			*cfx.source, isMovie, selectedAnimeID, selectedAnimeSlug, selectedAnime.Title, cfx.logger,
+			*cfx.source, isMovie, selectedAnimeID, selectedAnimeSlug, selectedAnime.Title,
 		)
 		// Hata durumunda kullanıcıya seçenek sunulur
 		if err != nil {