2
0

views.py 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377
  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 .models import Untube
  12. from django.template import loader
  13. # Create your views here.
  14. def index(request):
  15. if Untube.objects.all().count() == 0:
  16. untube = Untube.objects.create()
  17. untube.save()
  18. if not request.session.exists(request.session.session_key):
  19. request.session.create()
  20. request.session['liked_untube'] = False
  21. if request.user.is_anonymous:
  22. return render(request, 'index.html', {"likes": Untube.objects.all().first().page_likes,
  23. "users_joined": User.objects.all().count()})
  24. else:
  25. return redirect('home')
  26. @login_required
  27. def profile(request):
  28. user_playlists = request.user.playlists.all()
  29. watching = user_playlists.filter(marked_as="watching")
  30. total_num_playlists = user_playlists.count()
  31. statistics = {
  32. "public_x": 0,
  33. "private_x": 0,
  34. "favorites_x": 0,
  35. "watching_x": 0,
  36. "imported_x": 0
  37. }
  38. if total_num_playlists != 0:
  39. # x means percentage
  40. statistics["public_x"] = round(user_playlists.filter(is_private_on_yt=False).count() / total_num_playlists,
  41. 1) * 100
  42. statistics["private_x"] = round(user_playlists.filter(is_private_on_yt=True).count() / total_num_playlists,
  43. 1) * 100
  44. statistics["favorites_x"] = round(user_playlists.filter(is_favorite=True).count() / total_num_playlists,
  45. 1) * 100
  46. statistics["watching_x"] = round(user_playlists.filter(marked_as="watching").count() / total_num_playlists,
  47. 1) * 100
  48. statistics["imported_x"] = round(user_playlists.filter(is_user_owned=False).count() / total_num_playlists,
  49. 1) * 100
  50. return render(request, 'profile.html', {
  51. "total_num_playlists": total_num_playlists,
  52. "statistics": statistics,
  53. "watching": watching})
  54. @login_required
  55. def settings(request):
  56. return render(request, 'settings.html')
  57. @require_POST
  58. def update_settings(request):
  59. print(request.POST)
  60. user = request.user
  61. username_input = request.POST['username'].strip()
  62. message_content = "Saved!"
  63. message_type = "success"
  64. if username_input != user.username:
  65. if User.objects.filter(username__exact=username_input).count() != 0:
  66. message_type = "danger"
  67. message_content = f"Username {request.POST['username'].strip()} already taken"
  68. else:
  69. user.username = request.POST['username'].strip()
  70. # user.save()
  71. message_content = f"Username updated to {username_input}!"
  72. if 'open search in new tab' in request.POST:
  73. user.profile.open_search_new_tab = True
  74. else:
  75. user.profile.open_search_new_tab = False
  76. if 'enable gradient bg' in request.POST:
  77. user.profile.enable_gradient_bg = True
  78. else:
  79. user.profile.enable_gradient_bg = False
  80. user.save()
  81. return HttpResponse(loader.get_template("intercooler/messages.html").render(
  82. {"message_type": message_type, "message_content": message_content, "refresh_page": True}))
  83. @login_required
  84. def delete_account(request):
  85. request.user.playlists.all().delete()
  86. request.user.videos.all().delete()
  87. request.user.playlist_tags.all().delete()
  88. request.user.profile.delete()
  89. request.user.delete()
  90. request.session.flush()
  91. messages.success(request, "Account data deleted successfully.")
  92. return redirect('index')
  93. @login_required
  94. def log_out(request):
  95. request.session.flush() # delete all stored session keys
  96. logout(request) # log out authenticated user
  97. if "troll" in request.GET:
  98. print("TROLLED")
  99. messages.success(request, "Hee Hee")
  100. else:
  101. messages.success(request, "Successfully logged out. Hope to see you back again!")
  102. return redirect('/')
  103. def cancel_import(request):
  104. user_profile = request.user.profile
  105. if user_profile.access_token.strip() == "" or user_profile.refresh_token.strip() == "":
  106. user_social_token = SocialToken.objects.get(account__user=request.user)
  107. user_profile.access_token = user_social_token.token
  108. user_profile.refresh_token = user_social_token.token_secret
  109. user_profile.expires_at = user_social_token.expires_at
  110. # request.user.save()
  111. user_profile.imported_yt_playlists = False
  112. user_profile.show_import_page = False
  113. user_profile.save()
  114. return redirect('home')
  115. def import_user_yt_playlists(request):
  116. request.user.profile.show_import_page = True
  117. request.user.profile.save(update_fields=['show_import_page'])
  118. return render(request, 'import_in_progress.html')
  119. @login_required
  120. def start_import(request):
  121. """
  122. Initializes only the user's playlist data in the database. Returns the progress bar, which will
  123. keep calling continue_import
  124. :param request:
  125. :return:
  126. """
  127. user_profile = request.user.profile
  128. if user_profile.access_token.strip() == "" or user_profile.refresh_token.strip() == "":
  129. user_social_token = SocialToken.objects.get(account__user=request.user)
  130. user_profile.access_token = user_social_token.token
  131. user_profile.refresh_token = user_social_token.token_secret
  132. user_profile.expires_at = user_social_token.expires_at
  133. request.user.save()
  134. result = Playlist.objects.initializePlaylist(request.user)
  135. if result["status"] == -1:
  136. print("User has no YT channel")
  137. return HttpResponse(loader.get_template('intercooler/progress_bar.html').render(
  138. {
  139. "channel_found": False,
  140. "error_message": result["error_message"]
  141. }
  142. ))
  143. elif result["status"] == -2:
  144. user_profile.import_in_progress = False
  145. user_profile.imported_yt_playlists = True
  146. user_profile.show_import_page = True
  147. user_profile.save()
  148. print("User has no playlists on YT")
  149. if request.user.profile.yt_channel_id == "":
  150. Playlist.objects.getUserYTChannelID(request.user)
  151. Playlist.objects.initializePlaylist(request.user, "LL")
  152. return HttpResponse(loader.get_template('intercooler/progress_bar.html').render(
  153. {"total_playlists": 0,
  154. "playlists_imported": 0,
  155. "done": True,
  156. "progress": 100,
  157. "channel_found": True}))
  158. else:
  159. if request.user.profile.yt_channel_id == "":
  160. Playlist.objects.getUserYTChannelID(request.user)
  161. Playlist.objects.initializePlaylist(request.user, "LL")
  162. user_profile.import_in_progress = True
  163. user_profile.save()
  164. return HttpResponse(loader.get_template('intercooler/progress_bar.html').render(
  165. {"total_playlists": result["num_of_playlists"],
  166. "playlist_name": result["first_playlist_name"],
  167. "playlists_imported": 0,
  168. "progress": 0,
  169. "channel_found": True}
  170. ))
  171. @login_required
  172. def continue_import(request):
  173. if request.user.profile.import_in_progress is False:
  174. return redirect('home')
  175. num_of_playlists = request.user.playlists.filter(Q(is_user_owned=True)).exclude(playlist_id="LL").count()
  176. print("NUM OF PLAYLISTS", num_of_playlists)
  177. try:
  178. remaining_playlists = request.user.playlists.filter(Q(is_user_owned=True) & Q(is_in_db=False)).exclude(
  179. playlist_id="LL")
  180. print(remaining_playlists.count(), "REMAINING PLAYLISTS")
  181. playlists_imported = num_of_playlists - remaining_playlists.count() + 1
  182. playlist = remaining_playlists.order_by("created_at")[0]
  183. playlist_name = playlist.name
  184. playlist_id = playlist.playlist_id
  185. Playlist.objects.getAllVideosForPlaylist(request.user, playlist_id)
  186. except:
  187. print("NO REMAINING PLAYLISTS")
  188. playlist_id = -1
  189. if playlist_id != -1:
  190. return HttpResponse(loader.get_template('intercooler/progress_bar.html').render(
  191. {"total_playlists": num_of_playlists,
  192. "playlists_imported": playlists_imported,
  193. "playlist_name": playlist_name,
  194. "progress": round((playlists_imported / num_of_playlists) * 100, 1),
  195. "channel_found": True}))
  196. else:
  197. # request.user.profile.just_joined = False
  198. request.user.profile.import_in_progress = False
  199. request.user.profile.imported_yt_playlists = True
  200. request.user.profile.show_import_page = True # set back to true again so as to show users the welcome screen on 'home'
  201. request.user.save()
  202. user_pl_count = request.user.playlists.filter(Q(is_user_owned=True) & Q(is_in_db=True)).exclude(
  203. playlist_id="LL").count()
  204. return HttpResponse(loader.get_template('intercooler/progress_bar.html').render(
  205. {"total_playlists": user_pl_count,
  206. "playlists_imported": user_pl_count,
  207. "done": True,
  208. "progress": 100,
  209. "channel_found": True}))
  210. @login_required
  211. def user_playlists_updates(request, action):
  212. """
  213. Gets all user created playlist's ids from YouTube and checks them with the user playlists imported on UnTube.
  214. If any playlist id is on UnTube but not on YouTube, deletes the playlist from YouTube.
  215. If any new playlist id, imports it to UnTube
  216. """
  217. if action == 'check-for-updates':
  218. user_playlists_on_UnTube = request.user.playlists.filter(Q(is_user_owned=True) & Q(is_in_db=True)).exclude(
  219. playlist_id="LL")
  220. result = Playlist.objects.initializePlaylist(request.user)
  221. print(result)
  222. youtube_playlist_ids = result["playlist_ids"]
  223. untube_playlist_ids = []
  224. for playlist in user_playlists_on_UnTube:
  225. untube_playlist_ids.append(playlist.playlist_id)
  226. deleted_playlist_ids = []
  227. deleted_playlist_names = []
  228. for pl_id in untube_playlist_ids:
  229. if pl_id not in youtube_playlist_ids: # ie this playlist was deleted on youtube
  230. deleted_playlist_ids.append(pl_id)
  231. pl = request.user.playlists.get(playlist_id__exact=pl_id)
  232. deleted_playlist_names.append(f"{pl.name} (had {pl.video_count} videos)")
  233. pl.delete()
  234. if result["num_of_playlists"] == user_playlists_on_UnTube.count() and len(deleted_playlist_ids) == 0:
  235. print("No new updates")
  236. playlists = []
  237. else:
  238. playlists = request.user.playlists.filter(Q(is_user_owned=True) & Q(is_in_db=False)).exclude(playlist_id="LL")
  239. print(
  240. f"New updates found! {playlists.count()} newly added and {len(deleted_playlist_ids)} playlists deleted!")
  241. print(deleted_playlist_names)
  242. return HttpResponse(loader.get_template('intercooler/user_playlist_updates.html').render(
  243. {"playlists": playlists,
  244. "deleted_playlist_names": deleted_playlist_names}))
  245. elif action == 'init-update':
  246. unimported_playlists = request.user.playlists.filter(Q(is_user_owned=True) & Q(is_in_db=False)).exclude(playlist_id="LL").count()
  247. return HttpResponse(f"""
  248. <div hx-get="/updates/user-playlists/start-update" hx-trigger="load" hx-target="#user-pl-updates">
  249. <div class="alert alert-dismissible fade show" role="alert" style="background-color: cadetblue">
  250. <div class="d-flex justify-content-center mt-4 mb-3 ms-2" id="loading-sign" >
  251. <img src="/static/svg-loaders/spinning-circles.svg" width="40" height="40">
  252. <h5 class="mt-2 ms-2 text-black">Importing {unimported_playlists} new playlists into UnTube, please wait!</h5>
  253. </div>
  254. </div>
  255. </div>
  256. """)
  257. elif action == 'start-update':
  258. unimported_playlists = request.user.playlists.filter(Q(is_user_owned=True) & Q(is_in_db=False)).exclude(playlist_id="LL")
  259. for playlist in unimported_playlists:
  260. Playlist.objects.getAllVideosForPlaylist(request.user, playlist.playlist_id)
  261. return HttpResponse("""
  262. <div class="alert alert-success alert-dismissible fade show d-flex justify-content-center" role="alert">
  263. <h4 class="">Successfully imported new playlists into UnTube! Refresh :)</h4>
  264. <button type="button" class="btn-close" data-bs-dismiss="alert" aria-la bel="Close"></button>
  265. </div>
  266. """)
  267. @login_required
  268. def get_user_liked_videos_playlist(request):
  269. if not request.user.playlists.filter(Q(playlist_id="LL") & Q(is_in_db=True)).exists():
  270. Playlist.objects.initializePlaylist(request.user, "LL")
  271. Playlist.objects.getAllVideosForPlaylist(request.user, "LL")
  272. messages.success(request, "Successfully imported your Liked Videos playlist!")
  273. return HttpResponse("""
  274. <script>
  275. window.location.reload();
  276. </script>
  277. """)
  278. ### FOR INDEX.HTML
  279. @require_POST
  280. def like_untube(request):
  281. untube = Untube.objects.all().first()
  282. untube.page_likes += 1
  283. untube.save()
  284. request.session['liked_untube'] = True
  285. request.session.save()
  286. return HttpResponse(f"""
  287. <a hx-post="/unlike-untube/" hx-swap="outerHTML" style="text-decoration: none; color: black">
  288. <i class="fas fa-heart" style="color: #d02e2e"></i> {untube.page_likes} likes (p.s glad you liked it!)
  289. </a>
  290. """)
  291. @require_POST
  292. def unlike_untube(request):
  293. untube = Untube.objects.all().first()
  294. untube.page_likes -= 1
  295. untube.save()
  296. request.session['liked_untube'] = False
  297. request.session.save()
  298. return HttpResponse(f"""
  299. <a hx-post="/like-untube/" hx-swap="outerHTML" style="text-decoration: none; color: black">
  300. <i class="fas fa-heart"></i> {untube.page_likes} likes (p.s :/)
  301. </a>
  302. """)