views.py 8.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214
  1. from django.db.models import Q
  2. from django.shortcuts import render, redirect
  3. from django.contrib.auth import logout
  4. from django.views.decorators.http import require_POST
  5. from django.contrib.auth.decorators import login_required
  6. from allauth.socialaccount.models import SocialToken
  7. from django.http import HttpResponse
  8. from django.contrib.auth.models import User
  9. from django.contrib import messages
  10. from apps.main.models import Playlist
  11. from django.template import loader
  12. # Create your views here.
  13. def index(request):
  14. if request.user.is_anonymous:
  15. return render(request, 'index.html')
  16. else:
  17. return redirect('home')
  18. @require_POST
  19. def update_settings(request):
  20. print(request.POST)
  21. user = request.user
  22. username_input = request.POST['username'].strip()
  23. message_content = "Saved! Refresh to see changes!"
  24. message_type = "success"
  25. if username_input != user.username:
  26. if User.objects.filter(username__exact=username_input).count() != 0:
  27. message_type = "danger"
  28. message_content = f"Username {request.POST['username'].strip()} already taken"
  29. else:
  30. user.username = request.POST['username'].strip()
  31. user.save()
  32. message_content = f"Username updated to {username_input}!"
  33. return HttpResponse(loader.get_template("intercooler/messages.html").render(
  34. {"message_type": message_type, "message_content": message_content}))
  35. @login_required
  36. def delete_account(request):
  37. request.user.profile.delete()
  38. request.user.delete()
  39. request.session.flush()
  40. messages.success(request, "Account data deleted successfully.")
  41. return redirect('index')
  42. @login_required
  43. def log_out(request):
  44. request.session.flush() # delete all stored session keys
  45. logout(request) # log out authenticated user
  46. return redirect('/')
  47. @login_required
  48. def start_import(request):
  49. '''
  50. Initializes only the user's playlist data in the database. Returns the progress bar, which will
  51. keep calling continue_import
  52. :param request:
  53. :return:
  54. '''
  55. user_profile = request.user.profile
  56. if user_profile.yt_channel_id == "":
  57. Playlist.objects.getUserYTChannelID(request.user)
  58. if user_profile.access_token.strip() == "" or user_profile.refresh_token.strip() == "":
  59. user_social_token = SocialToken.objects.get(account__user=request.user)
  60. user_profile.access_token = user_social_token.token
  61. user_profile.refresh_token = user_social_token.token_secret
  62. user_profile.expires_at = user_social_token.expires_at
  63. request.user.save()
  64. result = Playlist.objects.getAllPlaylistsFromYT(request.user)
  65. channel_found = True
  66. if result["status"] == -1:
  67. print("User has no YT channel")
  68. channel_found = False
  69. return HttpResponse(loader.get_template('intercooler/progress_bar.html').render(
  70. {"channel_found": channel_found}
  71. ))
  72. elif result["status"] == -2:
  73. request.user.profile.import_in_progress = False
  74. request.user.save()
  75. print("User has no playlists on YT")
  76. return HttpResponse(loader.get_template('intercooler/progress_bar.html').render(
  77. {"total_playlists": 0,
  78. "playlists_imported": 0,
  79. "done": True,
  80. "progress": 100,
  81. "channel_found": channel_found}))
  82. else:
  83. return HttpResponse(loader.get_template('intercooler/progress_bar.html').render(
  84. {"total_playlists": result["num_of_playlists"],
  85. "playlist_name": result["first_playlist_name"],
  86. "playlists_imported": 0,
  87. "progress": 0,
  88. "channel_found": channel_found}
  89. ))
  90. @login_required
  91. def settings(request):
  92. if request.user.profile.yt_channel_id == "":
  93. Playlist.objects.getUserYTChannelID(request.user)
  94. return render(request, 'settings.html')
  95. @login_required
  96. def continue_import(request):
  97. if request.user.profile.import_in_progress is False:
  98. return redirect('home')
  99. num_of_playlists = request.user.profile.playlists.all().count()
  100. try:
  101. remaining_playlists = request.user.profile.playlists.filter(is_in_db=False)
  102. playlists_imported = num_of_playlists - remaining_playlists.count() + 1
  103. playlist = remaining_playlists.order_by("created_at")[0]
  104. playlist_name = playlist.name
  105. playlist_id = playlist.playlist_id
  106. Playlist.objects.getAllVideosForPlaylist(request.user, playlist.playlist_id)
  107. except:
  108. playlist_id = -1
  109. if playlist_id != -1:
  110. return HttpResponse(loader.get_template('intercooler/progress_bar.html').render(
  111. {"total_playlists": num_of_playlists,
  112. "playlists_imported": playlists_imported,
  113. "playlist_name": playlist_name,
  114. "progress": round((playlists_imported / num_of_playlists) * 100, 1),
  115. "channel_found": True}))
  116. else:
  117. # request.user.profile.just_joined = False
  118. request.user.profile.import_in_progress = False
  119. request.user.save()
  120. return HttpResponse(loader.get_template('intercooler/progress_bar.html').render(
  121. {"total_playlists": num_of_playlists,
  122. "playlists_imported": num_of_playlists,
  123. "done": True,
  124. "progress": 100,
  125. "channel_found": True}))
  126. @login_required
  127. def user_playlists_updates(request, action):
  128. if action == 'check-for-updates':
  129. user_playlists_on_UnTube = request.user.profile.playlists.filter(Q(is_user_owned=True) & Q(is_in_db=True))
  130. result = Playlist.objects.getAllPlaylistsFromYT(request.user)
  131. youtube_playlist_ids = result["playlist_ids"]
  132. untube_playlist_ids = []
  133. for playlist in user_playlists_on_UnTube:
  134. untube_playlist_ids.append(playlist.playlist_id)
  135. deleted_playlist_ids = []
  136. deleted_playlist_names = []
  137. for pl_id in untube_playlist_ids:
  138. if pl_id not in youtube_playlist_ids: # ie this playlist was deleted on youtube
  139. deleted_playlist_ids.append(pl_id)
  140. pl = request.user.profile.playlists.get(playlist_id__exact=pl_id)
  141. deleted_playlist_names.append(f"{pl.name} (had {pl.video_count} videos)")
  142. pl.delete()
  143. if result["num_of_playlists"] == user_playlists_on_UnTube.count() and len(deleted_playlist_ids) == 0:
  144. print("No new updates")
  145. playlists = []
  146. else:
  147. playlists = request.user.profile.playlists.filter(Q(is_user_owned=True) & Q(is_in_db=False))
  148. print(f"New updates found! {playlists.count()} newly added and {len(deleted_playlist_ids)} playlists deleted!")
  149. print(deleted_playlist_names)
  150. return HttpResponse(loader.get_template('intercooler/user_playlist_updates.html').render(
  151. {"playlists": playlists,
  152. "deleted_playlist_names": deleted_playlist_names}))
  153. elif action == 'init-update':
  154. unimported_playlists = request.user.profile.playlists.filter(Q(is_user_owned=True) & Q(is_in_db=False)).count()
  155. return HttpResponse(f"""
  156. <div hx-get="/updates/user-playlists/start-update" hx-trigger="load" hx-target="#user-pl-updates">
  157. <div class="alert alert-dismissible fade show" role="alert" style="background-color: cadetblue">
  158. <div class="d-flex justify-content-center mt-4 mb-3 ms-2" id="loading-sign" >
  159. <img src="/static/svg-loaders/spinning-circles.svg" width="40" height="40">
  160. <h5 class="mt-2 ms-2 text-black">Importing {unimported_playlists} new playlists into UnTube, please wait!</h5>
  161. </div>
  162. </div>
  163. </div>
  164. """)
  165. elif action == 'start-update':
  166. unimported_playlists = request.user.profile.playlists.filter(Q(is_user_owned=True) & Q(is_in_db=False))
  167. for playlist in unimported_playlists:
  168. Playlist.objects.getAllVideosForPlaylist(request.user, playlist.playlist_id)
  169. return HttpResponse("""
  170. <div class="alert alert-success alert-dismissible fade show d-flex justify-content-center" role="alert">
  171. <h4 class="">Successfully imported new playlists into UnTube! Refresh :)</h4>
  172. <button type="button" class="btn-close" data-bs-dismiss="alert" aria-la bel="Close"></button>
  173. </div>
  174. """)