From d495d77245e70d4ade14a22a33b0d2233e63aca2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Kasper=20Rynning-T=C3=B8nnesen?=
 <kasper.rynning-tonnesen@knowit.no>
Date: Tue, 3 Dec 2019 16:22:38 +0100
Subject: [PATCH] Made a channel page

---
 frontend/components/Channel.vue           |  35 +++++
 frontend/components/player/Player.vue     |   3 +-
 frontend/components/player/YouTube.vue    |  27 +++-
 frontend/components/playlist/Playlist.vue |  30 +++--
 frontend/components/playlist/Song.vue     |   4 +-
 frontend/mixins/Socket.js                 | 151 +++++++++++++++++++++-
 frontend/modules/playerModule.js          |   5 -
 frontend/modules/socketModule.js          |  21 +++
 frontend/routes.js                        |  40 +++---
 frontend/store.js                         |  14 +-
 10 files changed, 277 insertions(+), 53 deletions(-)
 create mode 100644 frontend/components/Channel.vue
 create mode 100644 frontend/modules/socketModule.js

diff --git a/frontend/components/Channel.vue b/frontend/components/Channel.vue
new file mode 100644
index 00000000..10b7481a
--- /dev/null
+++ b/frontend/components/Channel.vue
@@ -0,0 +1,35 @@
+<template>
+  <div>
+    <div class="parallel-containers">
+      <Player class="player" />
+      <Playlist class="playlist" />
+    </div>
+  </div>
+</template>
+
+<script>
+import store from "@/store";
+import Player from "@/components/player/Player";
+import Playlist from "@/components/playlist/Playlist";
+
+export default {
+  components: {
+    Player,
+    Playlist
+  }
+};
+</script>
+
+<style lang="scss" scoped>
+.parallel-containers {
+  display: flex;
+  flex-direction: row;
+
+  & .player {
+    width: 100%;
+  }
+  & .playlist {
+    width: 40vw;
+  }
+}
+</style>
\ No newline at end of file
diff --git a/frontend/components/player/Player.vue b/frontend/components/player/Player.vue
index c8c51045..526a09dc 100644
--- a/frontend/components/player/Player.vue
+++ b/frontend/components/player/Player.vue
@@ -1,6 +1,5 @@
 <template>
   <div class="conatiner">
-    <h1>Player</h1>
     <YouTube
       @end="end('youtube')"
       @pause="pause('youtube')"
@@ -17,7 +16,7 @@ import YouTube from "@/components/player/YouTube";
 
 export default {
   components: {
-    YouTube,
+    YouTube
   },
   data() {
     return {
diff --git a/frontend/components/player/YouTube.vue b/frontend/components/player/YouTube.vue
index 5e93a6a0..b1f1437a 100644
--- a/frontend/components/player/YouTube.vue
+++ b/frontend/components/player/YouTube.vue
@@ -12,7 +12,9 @@ export default {
       player: null,
       playerReady: false,
       currentPlaying: {},
-      currentIsThis: false
+      currentIsThis: false,
+      gettingPosition: false,
+      wasPaused: false
     };
   },
   computed: {
@@ -56,8 +58,10 @@ export default {
       if (this.player == null) {
         this.createYoutubeObjectWithId(this.nowPlaying.id);
       } else {
+        console.log("new np", this.currentPlaying.id, nowPlaying.id);
         if (this.currentPlaying.id != nowPlaying.id) {
           try {
+            console.log("loading");
             this.player.loadVideoById(nowPlaying.id, {
               start: nowPlaying.seek,
               end: nowPlaying.end
@@ -65,6 +69,7 @@ export default {
           } catch (e) {}
         } else {
           this.player.seekTo(nowPlaying.seek);
+          console.log("seeking");
         }
         this.currentPlaying = nowPlaying;
       }
@@ -128,7 +133,14 @@ export default {
     },
     onPlayerReady(event) {
       console.log("event from onPlayerReady", event);
+
+      this.player.setVolume(0);
       event.target.playVideo();
+      setInterval(() => {
+        console.log(
+          this.player.getCurrentTime() + " - " + this.player.getDuration()
+        );
+      }, 1000);
     },
     checkForInitialLoadAndSeek() {
       if (!this.initialLoad) {
@@ -142,6 +154,10 @@ export default {
       if (event.data === this.PLAYER_STATES.PLAYING) {
         console.log("playing");
         this.checkForInitialLoadAndSeek();
+        if (this.wasPaused) {
+          this.wasPaused = false;
+          this.$root.$options.methods.getPosition();
+        }
       } else if (event.data === this.PLAYER_STATES.ENDED) {
         console.log("ended");
         this.$root.$options.methods.songEnd();
@@ -149,6 +165,9 @@ export default {
         console.log("not started");
       } else if (event.data === this.PLAYER_STATES.BUFFERING) {
         console.log("buffering");
+      } else if (event.data === this.PLAYER_STATES.PAUSED) {
+        console.log("pasued");
+        this.wasPaused = true;
       }
     },
     errorHandler(error) {
@@ -159,8 +178,8 @@ export default {
 </script>
 
 <style lang="scss">
-#player {
-  width: 100vw !important;
-  height: 60vh;
+#youtubePlayer {
+  width: 100% !important;
+  height: 100%;
 }
 </style>
\ No newline at end of file
diff --git a/frontend/components/playlist/Playlist.vue b/frontend/components/playlist/Playlist.vue
index 90e11285..31ca3ec2 100644
--- a/frontend/components/playlist/Playlist.vue
+++ b/frontend/components/playlist/Playlist.vue
@@ -16,7 +16,7 @@
     <div class="pagination-buttons">
       <v-btn text @click="firstPage" :disabled="disabledPrev" class="first"><</v-btn>
       <v-btn text @click="prevPage" :disabled="disabledPrev">previous</v-btn>
-      <span>{{ page + 1 }} / {{ pages }}</span>
+      <span>{{ page + 1 }}&nbsp;/&nbsp;{{ pages }}</span>
       <v-btn text @click="nextPage" :disabled="disabledNext">next</v-btn>
       <v-btn text @click="lastPage" :disabled="disabledNext" class="last">></v-btn>
     </div>
@@ -40,14 +40,13 @@ import ContextMenu from "@/components/playlist/ContextMenu";
 export default {
   components: {
     Song,
-    ContextMenu,
+    ContextMenu
   },
   computed: {
     paginatedList: function() {
-      return this.playlist.slice(
-        this.page * this.perPage,
-        (1 + this.page) * this.perPage
-      );
+      return this.playlist
+        .filter(song => !song.now_playing)
+        .slice(this.page * this.perPage, (1 + this.page) * this.perPage);
     },
     disabledPrev: function() {
       return this.page == 0;
@@ -98,7 +97,7 @@ export default {
       contextMenuOpen: false,
       contextOnElement: {},
       page: 0,
-      perPage: 10,
+      perPage: 12
     };
   }
 };
@@ -108,23 +107,28 @@ export default {
 .playlist-conatiner {
   background-color: inherit;
   padding-top: 5px;
-  margin:auto;
+  margin: auto;
   width: 100%;
   background: #2d2d2d;
   height: 100vh;
   display: flex;
   flex-direction: column;
-  
+  position: relative;
 
-  & .playlist-element {
-    height: 100%;;
-  }
+  // & .playlist-element {
+  //   height: 100%;
+  // }
 
   .pagination-buttons {
     display: flex;
     justify-content: space-between;
     color: white;
     padding: 10px 0;
+    position: absolute;
+    bottom: 0;
+    right: 0;
+    left: 0;
+    margin: auto;
 
     & span {
       display: flex;
@@ -133,7 +137,7 @@ export default {
     }
 
     & button {
-      width: 35%;
+      width: 20%;
       height: 30px;
       background: transparent;
       color: white;
diff --git a/frontend/components/playlist/Song.vue b/frontend/components/playlist/Song.vue
index c32e26c9..af13000a 100644
--- a/frontend/components/playlist/Song.vue
+++ b/frontend/components/playlist/Song.vue
@@ -75,6 +75,8 @@ export default {
       if (e.target.className === "more-info-button") {
         return;
       }
+
+      this.$root.$options.methods.vote(this.id);
       console.log("Clicked on song with info", this.title, this.id);
     }
   }
@@ -92,7 +94,7 @@ export default {
   display: flex;
   flex-direction: row;
   box-shadow: 0px 0px 2px #000000;
-  background: #FFFFFF20;
+  background: #ffffff20;
   border-radius: 5px;
   margin: 5px 5px;
   cursor: pointer;
diff --git a/frontend/mixins/Socket.js b/frontend/mixins/Socket.js
index c75016d0..bfb3933d 100644
--- a/frontend/mixins/Socket.js
+++ b/frontend/mixins/Socket.js
@@ -4,7 +4,6 @@ import io from "socket.io-client";
 export default {
   data() {
     return {
-      socket: null,
       alreadyCreated: false
     };
   },
@@ -15,6 +14,7 @@ export default {
     }
     this.socket = io("localhost:8080");
     console.log("mounted");
+    console.log(this.socket);
     this.addListeners();
     this.alreadyCreated = true;
   },
@@ -24,23 +24,70 @@ export default {
     },
     channel: function() {
       return store.getters["playerModule/channel"];
+    },
+    socket: {
+      set: function(socket) {
+        store.dispatch("socketModule/setSocket", socket);
+      },
+      get: function() {
+        console.log(store);
+        return store.getters["socketModule/socket"];
+      }
     }
   },
   methods: {
     emitToBackend(event, msg) {
-      this.socket.emit(event, msg);
+      store.getters["socketModule/socket"].emit(event, msg);
     },
     songEnd() {
-      this.socket.emit("end", { id: this.nowPlaying, channel: this.channel });
+      const nowPlaying = store.getters["playerModule/nowPlaying"];
+      const channel = store.getters["playerModule/channel"];
+      store.getters["socketModule/socket"].emit("end", {
+        id: nowPlaying.id,
+        channel: channel
+      });
     },
     getPosition() {
-      this.socket.emit("pos", { channel: this.channel });
+      store.getters["socketModule/socket"].emit("pos", {
+        channel: store.getters["playerModule/channel"]
+      });
+    },
+    vote(id) {
+      store.getters["socketModule/socket"].emit("vote", {
+        channel: store.getters["playerModule/channel"],
+        id: id,
+        type: "pos"
+      });
     },
     addListeners() {
+      console.log(this.socket);
       this.socket.on("channel", msg => {
         console.log("list", msg);
         if (msg.type == "list") {
+          msg.playlist.sort(
+            predicate(
+              {
+                name: "votes",
+                reverse: true
+              },
+              {
+                name: "added",
+                reverse: false
+              },
+              {
+                name: "title",
+                reverse: false
+              }
+            )
+          );
           store.dispatch("playerModule/setPlaylist", msg.playlist);
+        } else if (msg.type == "vote") {
+          const playlist = store.getters["playerModule/playlist"];
+          let songToUpdate = playlist.find(song => song.id == msg.value);
+          console.log(songToUpdate);
+          songToUpdate.votes += 1;
+          songToUpdate.added = msg.time;
+          store.dispatch("playerModule/setPlaylist", playlist);
         }
       });
 
@@ -51,24 +98,57 @@ export default {
         }
       });
       this.socket.on("np", msg => {
+        console.log("got now playing");
+        const playlist = store.getters["playerModule/playlist"];
+        const currentPlaying = playlist.find(song => song.now_playing == true);
         if (msg.np.length == 0) {
           return;
         }
         if (msg.conf.length == 0) {
           return;
         }
+
         let nowPlaying = msg.np[0];
         let channelSettings = msg.conf[0];
         let timeSinceStart =
           msg.time - channelSettings.startTime + nowPlaying.start;
         nowPlaying.seek = timeSinceStart;
 
+        const newNowPlaying = playlist.find(song => song.id == nowPlaying.id);
+        newNowPlaying.now_playing = true;
+        if (
+          currentPlaying != undefined &&
+          currentPlaying.id != newNowPlaying.id
+        ) {
+          currentPlaying.now_playing = false;
+          currentPlaying.added = channelSettings.startTime;
+          console.log(currentPlaying);
+        }
+
+        playlist.sort(
+          predicate(
+            {
+              name: "votes",
+              reverse: true
+            },
+            {
+              name: "added",
+              reverse: false
+            },
+            {
+              name: "title",
+              reverse: false
+            }
+          )
+        );
+
+        store.dispatch("playerModule/setPlaylist", playlist);
         store.dispatch("playerModule/setNowPlaying", nowPlaying);
         store.dispatch("playerModule/setChannelSettings", channelSettings);
       });
 
       this.socket.on("update_required", msg => {
-        console.log("update required");
+        console.log("update required", msg);
       });
       this.socket.on("connect", msg => {
         this.socket.emit("list", {
@@ -79,3 +159,64 @@ export default {
     }
   }
 };
+
+function predicate() {
+  var fields = [],
+    n_fields = arguments.length,
+    field,
+    name,
+    cmp;
+
+  var default_cmp = function(a, b) {
+      if (a == undefined) a = 0;
+      if (b == undefined) b = 0;
+      if (a === b) return 0;
+      return a < b ? -1 : 1;
+    },
+    getCmpFunc = function(primer, reverse) {
+      var dfc = default_cmp,
+        // closer in scope
+        cmp = default_cmp;
+      if (primer) {
+        cmp = function(a, b) {
+          return dfc(primer(a), primer(b));
+        };
+      }
+      if (reverse) {
+        return function(a, b) {
+          return -1 * cmp(a, b);
+        };
+      }
+      return cmp;
+    };
+
+  // preprocess sorting options
+  for (var i = 0; i < n_fields; i++) {
+    field = arguments[i];
+    if (typeof field === "string") {
+      name = field;
+      cmp = default_cmp;
+    } else {
+      name = field.name;
+      cmp = getCmpFunc(field.primer, field.reverse);
+    }
+    fields.push({
+      name: name,
+      cmp: cmp
+    });
+  }
+
+  // final comparison function
+  return function(A, B) {
+    var name, result;
+    for (var i = 0; i < n_fields; i++) {
+      result = 0;
+      field = fields[i];
+      name = field.name;
+
+      result = field.cmp(A[name], B[name]);
+      if (result !== 0) break;
+    }
+    return result;
+  };
+}
diff --git a/frontend/modules/playerModule.js b/frontend/modules/playerModule.js
index bec45995..a4644555 100644
--- a/frontend/modules/playerModule.js
+++ b/frontend/modules/playerModule.js
@@ -1,4 +1,3 @@
-
 export default {
   namespaced: true,
   state: {
@@ -18,16 +17,12 @@ export default {
       PLAYING: 1,
       UNSTARTED: -1
     },
-    socket: null,
     channel: "summér"
   },
   getters: {
     channel: state => {
       return state.channel;
     },
-    socket: state => {
-      return state.socket
-    },
     PLAYER_STATES: state => {
       return state.PLAYER_STATES;
     },
diff --git a/frontend/modules/socketModule.js b/frontend/modules/socketModule.js
new file mode 100644
index 00000000..dfa5b52e
--- /dev/null
+++ b/frontend/modules/socketModule.js
@@ -0,0 +1,21 @@
+export default {
+  namespaced: true,
+  state: {
+    socket: null
+  },
+  getters: {
+    socket: state => {
+      return state.socket;
+    }
+  },
+  mutations: {
+    SET_SOCKET: (state, socket) => {
+      state.socket = socket;
+    }
+  },
+  actions: {
+    setSocket({ commit }, socket) {
+      commit("SET_SOCKET", socket);
+    }
+  }
+};
diff --git a/frontend/routes.js b/frontend/routes.js
index 9ad47aab..930d8f2b 100644
--- a/frontend/routes.js
+++ b/frontend/routes.js
@@ -1,25 +1,31 @@
-import Vue from 'vue'
-import VueRouter from 'vue-router';
+import Vue from "vue";
+import VueRouter from "vue-router";
 
-Vue.use(VueRouter)
+Vue.use(VueRouter);
 
 let routes = [
   {
-    name: 'player',
-    path: '/player',
-    component: (resolve) => require(['./components/player/Player.vue'], resolve)
+    name: "player",
+    path: "/player",
+    component: resolve => require(["./components/player/Player.vue"], resolve)
   },
   {
-    name: 'styleguide',
-    path: '/styleguide',
-    component: (resolve) => require(['./components/Styleguide.vue'], resolve)
+    name: "styleguide",
+    path: "/styleguide",
+    component: resolve => require(["./components/Styleguide.vue"], resolve)
   },
 
   {
-    name: 'playlist',
-    path: '/playlist',
-    component: (resolve) => require(['./components/playlist/Playlist.vue'], resolve)
+    name: "playlist",
+    path: "/playlist",
+    component: resolve =>
+      require(["./components/playlist/Playlist.vue"], resolve)
   },
+  {
+    name: "channel",
+    path: "/channel",
+    component: resolve => require(["./components/Channel.vue"], resolve)
+  }
   // {
   //   name: '404',
   //   path: '/404',
@@ -27,11 +33,11 @@ let routes = [
   // }
 ];
 
-const router =  new VueRouter({
-  mode: 'hash',
-  base: '/',
+const router = new VueRouter({
+  mode: "hash",
+  base: "/",
   routes,
-  linkActiveClass: 'is-active'
+  linkActiveClass: "is-active"
 });
 
-export default router;
\ No newline at end of file
+export default router;
diff --git a/frontend/store.js b/frontend/store.js
index 739fa3ad..a6b5cc41 100644
--- a/frontend/store.js
+++ b/frontend/store.js
@@ -1,14 +1,16 @@
-import Vue from 'vue';
-import Vuex from 'vuex';
+import Vue from "vue";
+import Vuex from "vuex";
 
-import playerModule from '@/modules/playerModule';
+import playerModule from "@/modules/playerModule";
+import socketModule from "@/modules/socketModule";
 
 Vue.use(Vuex);
 
 const store = new Vuex.Store({
   modules: {
-    playerModule
+    playerModule,
+    socketModule
   }
-})
+});
 
-export default store;
\ No newline at end of file
+export default store;