| 1
+2
+3
+4
+5
+6
+7
+8
+9
+10
+11
+12
+13
+14
+15
+16
+17
+18
+19
+20
+21
+22
+23
+24
+25
+26
+27
+28
+29
+30
+31
+32
+33
+34
+35
+36
+37
+38
+39
+40
+41
+42
+43
+44
+45
+46
+47
+48
+49
+50
+51
+52
+53
+54
+55
+56
+57
+58
+59
+60
+61
+62
+63
+64
+65
+66
+67
+68
+69
+70
+71
+72
+73
+74
+75
+76
+77
+78
+79
+80
+81
+82
+83
+84
+85
+86
+87
+88
+89
+90
+91
+92
+93
+94
+95
+96
+97
+98
+99
+100
+101
+102
+103
+104
+105
+106
+107
+108
+109
+110
+111
+112
+113
+114
+115
+116
+117
+118
+119
+120
+121
+122
+123
+124
+125
+126
+127
+128
+129
+130
+131
+132
+133
+134
+135
+136
+137
+138
+139
+140
+141
+142
+143
+144
+145
+146
+147
+148
+149
+150
+151
+152
+153
+154
+155
+156
+157
+158
+159
+160
+161
+162
+163
+164
+165
+166
+167
+168
+169
+170
+171
+172
+173
+174
+175
+176
+177
+178
+179
+180
+181
+182
+183
+184
+185
+186
+187
+188
+189
+190
+191
+192
+193
+194
+195
+196
+197
+198
+199
+200
+201
+202
+203
+204
+205
+206
+207
+208
+209
+210
+211
+212
+213
+214
+215
+216
+217
+218
+219
+220
+221
+222
+223
+224
+225
+226
+227
+228
+229
+230
+231
+232
+233
+234
+235
+236
+237
+238
+239
+240
+241
+242
+243
+244
+245
+246
+247
+248
+249
+250
+251
+252
+253
+254
+255
+256
+257
+258
+259
+260
+261
+262
+263
+264
+265
+266
+267
+268
+269
+270
+271
+272
+273
+274
+275
+276
+277
+278
+279
+280
+281
+282
+283
+284
+285
+286 | 2x
+2x
+2x
+2x
+2x
+2x
+2x
+2x
+2x
+2x
+2x
+2x
+2x
+
+
+
+
+1x
+1x
+
+1x
+
+
+
+
+
+
+
+
+
+
+1x
+
+
+1x
+
+
+1x
+
+
+1x
+
+
+
+1x
+1x
+
+1x
+
+
+
+
+
+
+
+
+
+57x
+1x
+
+1x
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+1x
+
+
+
+
+
+
+1x
+1x
+
+1x
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+1x
+1x
+
+1x
+
+
+
+
+1x
+1x
+1x
+1x
+
+
+
+
+1x
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+1x
+
+
+
+
+
+
+1x
+
+
+
+
+
+1x
+
+
+
+1x
+1x
+
+
+
+1x
+1x
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+5x
+5x
+5x
+5x
+5x
+1x
+1x
+
+4x
+1x
+1x
+
+3x
+3x
+2x
+2x
+
+1x
+
+
+
+1x
+1x
+
+
+
+
+
+
+
+
+
+
+
+
+
+1x
+
+1x
+
+1x
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+1x
+1x
+
+
+
+
+2x | const YoutubeService = require("../services/YoutubeService")
+const { Op } = require("sequelize");
+const moment = require('moment');
+const ChannelViews = require(`../models`).ChannelViews
+const Channel = require(`../models`).Channel
+const User = require(`../models`).User
+const { sequelize } = require('../models');
+const summarizeJSON = require("../services/GeminiService");
+const { signToken } = require("../helpers/jwt");
+const { checkPassword } = require("../helpers/bcryptjs");
+const { Sequelize } = require('sequelize');
+const {OAuth2Client} = require('google-auth-library');
+const client = new OAuth2Client();
+
+
+class channelController {
+ static async getAllChannels(req, res, next) {
+ try {
+ let { title, tag, orderByCreatedAt, page = 1, orderByGrowth, orderByViewCount } = req.query
+
+ let options = {
+ include: {
+ model: ChannelViews,
+ attributes: {
+ include: [
+ [Sequelize.literal('(SELECT row_to_json(cv) FROM (SELECT * FROM "ChannelViews" WHERE "ChannelViews"."channelId" = "Channel"."channelId") cv)'), 'all_columns']
+ ]
+ }
+ }
+ }
+
+ Iif (title) {
+ options.where = { title: { [Op.iLike]: `%${title}%` } };
+ }
+ Iif (tag) {
+ options.include.where = { tag: { [Op.iLike]: `%${title}%` } }
+ }
+ Iif (orderByCreatedAt) {
+ options.order = [['createdAt', `${orderByCreatedAt}`]]
+ }
+ Iif (orderByViewCount) {
+ options.order = [['viewCount', `DESC`]]
+ }
+
+ let allResults = await Channel.findAll(options)
+ console.log(allResults[0])
+
+ const dateColumns = await sequelize.query(
+ `SELECT column_name
+ FROM information_schema.columns
+ WHERE table_name = 'ChannelViews'
+ AND column_name ~ '^\\d{4}-\\d{2}-\\d{2}$'
+ ORDER BY column_name DESC`,
+ {
+ raw: true,
+ }
+ );
+ const columnNames = dateColumns[0].map(col => col.column_name);
+ const previousDate = columnNames[1];
+
+ for (let channel of allResults) {
+ const previousDateViews = await sequelize.query(
+ `SELECT "${previousDate}"
+ FROM "ChannelViews"
+ WHERE "channelId" = '${channel.channelId}'`,
+ {raw: true}
+ )
+ if(previousDateViews[0][0] == null || !previousDateViews[0][0][previousDate]){
+ channel.dataValues.growth = 0
+ continue
+ }
+ channel.dataValues.growth = channel.viewCount - previousDateViews[0][0][previousDate];
+ }
+
+
+ Iif (orderByGrowth) {
+ allResults.sort((a, b) =>
+ orderByGrowth.toUpperCase() === 'DESC' ? b.dataValues.growth - a.dataValues.growth : a.dataValues.growth - b.dataValues.growth
+ );
+ }
+
+ // pagination
+ const totalCount = allResults.length;
+ const paginatedResults = allResults.slice((page - 1) * 25, page * 25);
+
+ res.status(200).json({
+ result: paginatedResults,
+ page: page,
+ maxPage: Math.ceil(totalCount / 25),
+ })
+ } catch (error) {
+ console.log(error)
+ res.status(500).json({ message: "Internal Service Error" })
+ }
+ }
+
+ static async getOneChannel(req, res, next) {
+ try {
+ const { channelId } = req.params
+ let result = await Channel.findOne({where:{channelId}})
+ if (!result) {
+ res.send("Channel not found")
+ }
+ let geminiText = await summarizeJSON(result)
+
+ res.status(200).send({found: result, AIText: geminiText})
+ } catch (error) {
+ console.log(error)
+ res.status(500).json({ message: "Internal Service Error" })
+ }
+ }
+
+ static async AddChannel(req, res) {
+ try {
+ let user = await User.findByPk(req.user.id)
+
+ Iif (!user.id || user.role != "admin") {
+ res.status(403).json({message:"You must be an admin to do that"})
+ return
+ }
+
+ const today = moment().format('YYYY-MM-DD');
+ let { link, tag } = req.body
+ let result = await YoutubeService.getChannelIdFromLink(link)
+ Iif(result == null){
+ res.status(404).json({message:"Sorry, we can't find that channel!"})
+ return
+ }
+
+ let addToChannel = await Channel.create({
+ channelId: result.id,
+ title: result.snippet.title,
+ description: result.snippet.description.substring(0,255),
+ customUrl: result.snippet.customUrl,
+ publishedAt: result.snippet.publishedAt,
+ thumbnails: result.snippet.thumbnails.high.url,
+ country: result.snippet.country,
+ viewCount: result.statistics.viewCount,
+ subscriberCount: result.statistics.subscriberCount,
+ videoCount: result.statistics.videoCount
+ })
+
+
+
+ let addToChannelViews = await ChannelViews.create({
+ channelName: result.snippet.title,
+ channelId: result.id,
+ tag
+ })
+
+ let updateQuery =
+ `UPDATE "ChannelViews"
+ SET "${today}" = ${result.statistics.viewCount}
+ WHERE "channelId" = '${result.id}'
+ RETURNING *;
+ `
+
+ await sequelize.query(updateQuery, { raw: true })
+
+ res.status(201).json({ message: `${result.snippet.title} added!`})
+ } catch (error) {
+ console.log(error)
+ Iif (error.name == 'SequelizeUniqueConstraintError') {
+ res.status(400).json({ message: "Channel already exists" })
+ return
+ }
+ console.log(error.name)
+ res.status(500).json({ message: error })
+ }
+ }
+ static async EditChannel(req, res) {
+ try {
+ let user = await User.findByPk(req.user.id)
+
+ if (!user.id || user.role != "admin") {
+ res.status(403).json({message:"You must be an admin to do that"})
+ return
+ }
+ let { channelId } = req.params
+ let { tag } = req.body
+ let channel = await ChannelViews.findOne({where:{channelId}})
+ if(!channel){
+ res.status(404).json({message:"Cannot find channel"})
+ return
+ }
+ console.log(channel.channelName)
+ let updated = await channel.update({tag})
+
+ res.status(200).json({ message: "Edit Success!", result:updated})
+ } catch (error) {
+ console.log(error)
+ res.status(500).json({ message: "Internal Service Error" })
+ }
+ }
+
+ static async DeleteChannel(req, res) {
+ try {
+ let user = await User.findByPk(req.user.id)
+
+ if (!user.id || user.role != "admin") {
+ res.status(403).json({message:"You must be an admin to do that"})
+ return
+ }
+
+ let { channelId } = req.params
+
+ await ChannelViews.destroy({
+ where: { channelId },
+ });
+ await Channel.destroy({
+ where: { channelId },
+ });
+ res.status(200).json({ message: "Delete Success!" })
+ } catch (error) {
+ console.log(error)
+
+ res.status(500).json({ message: "Internal Service Error" })
+ }
+ }
+
+ static async login(req, res) {
+ try {
+ let {username,password} = req.body
+ console.log("username: ", username)
+ console.log("password: ", password)
+ if(!username){
+ res.status(400).json({message:"Username is required"})
+ return
+ }
+ if(!password){
+ res.status(400).json({message:"Password is required"})
+ return
+ }
+ let user = await User.findOne({where: {username:username}})
+ if(!user){
+ res.status(401).json({message:"Invalid Username/Password"})
+ return
+ }
+ Iif(!checkPassword(password, user.password)){
+ res.status(401).json({message:"Invalid Username/Password"})
+ return
+ }
+ let token = signToken({id:user.id})
+ res.status(200).json({access_token: token})
+
+ } catch (err) {
+ if (err.name == "SequelizeValidationError") {
+ let message = err.errors.map(e => e.message)
+ res.status(400).send(message)
+ return
+ }
+ console.log(err)
+ res.status(500).json({message: "Internal server error"})
+ }
+ }
+
+ static async googleLogin(req,res){
+ try {
+
+ const { googleToken } = req.body
+ // console.log(googleToken, "<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<")
+ const ticket = await client.verifyIdToken({
+ idToken: googleToken,
+ audience: process.env.CLIENT_ID,
+ });
+ const payload = ticket.getPayload();
+ const userid = payload['sub'];
+
+ const [user, created] = await User.findOrCreate({
+ where: { username: payload.email },
+ hooks: false,
+ defaults: {
+ username: payload.email,
+ password: Math.random().toString(),
+ role: "user",
+ },});
+ let token = signToken({id:user.id})
+ res.status(created ? 201 : 200).json({access_token: token})
+ } catch (error) {
+ console.log(error)
+ res.status(500).json({message: "Internal server error"})
+ }
+ }
+
+}
+module.exports = channelController |
+