Jellystat/backend/stats.js

// api.js
const express = require("express");
const db = require("./db");
const axios=require("axios");

const router = express.Router();
const https = require('https');



const agent = new https.Agent({
  rejectUnauthorized: (process.env.REJECT_SELF_SIGNED_CERTIFICATES || 'true').toLowerCase() ==='true'
});
const axios_instance = axios.create({
  httpsAgent: agent
});



router.get("/getLibraryOverview", async (req, res) => {
  try {
    const { rows } = await db.query("SELECT * FROM jf_library_count_view");
    res.send(rows);
  } catch (error) {
    res.status(503);
    res.send(error);
  }
});

router.post("/getMostViewedSeries", async (req, res) => {
  try {
    const { days } = req.body;
    let _days = days;
    if (days === undefined) {
      _days = 30;
    }
    const { rows } = await db.query(
      `select * from fs_most_played_items(${_days-1},'Series') limit 5`
    );
    res.send(rows);
  } catch (error) {
    res.status(503);
    res.send(error);
  }
});

router.post("/getMostViewedMovies", async (req, res) => {
  try {
    const { days } = req.body;
    let _days = days;
    if (days === undefined) {
      _days = 30;
    }
    const { rows } = await db.query(
      `select * from fs_most_played_items(${_days-1},'Movie') limit 5`
    );
    res.send(rows);
  } catch (error) {
    console.log('/getMostViewedMovies');
    console.log(error);
    res.status(503);
    res.send(error);
  }
});

router.post("/getMostViewedMusic", async (req, res) => {
  try {
    const { days } = req.body;
    let _days = days;
    if (days === undefined) {
      _days = 30;
    }
    const { rows } = await db.query(
      `select * from fs_most_played_items(${_days-1},'Audio') limit 5`
    );
    res.send(rows);
  } catch (error) {
    res.status(503);
    res.send(error);
  }
});

router.post("/getMostViewedLibraries", async (req, res) => {
  try {
    const { days } = req.body;
    let _days = days;
    if (days === undefined) {
      _days = 30;
    }
    const { rows } = await db.query(
      `select * from fs_most_viewed_libraries(${_days-1})`
    );
    res.send(rows);
  } catch (error) {
    res.status(503);
    res.send(error);
  }
});

router.post("/getMostUsedClient", async (req, res) => {
  try {
    const { days } = req.body;
    let _days = days;
    if (days === undefined) {
      _days = 30;
    }
    const { rows } = await db.query(
      `select * from fs_most_used_clients(${_days-1}) limit 5`
    );
    res.send(rows);
  } catch (error) {
    res.status(503);
    res.send(error);
  }
});

router.post("/getMostActiveUsers", async (req, res) => {
  try {
    const { days } = req.body;
    let _days = days;
    if (days === undefined) {
      _days = 30;
    }
    const { rows } = await db.query(
      `select * from fs_most_active_user(${_days-1}) limit 5`
    );
    res.send(rows);
  } catch (error) {
    res.status(503);
    res.send(error);
  }
});

router.post("/getMostPopularMovies", async (req, res) => {
  try {
    const { days } = req.body;
    let _days = days;
    if (days === undefined) {
      _days = 30;
    }
    const { rows } = await db.query(
      `select * from fs_most_popular_items(${_days-1},'Movie') limit 5`
    );
    res.send(rows);
  } catch (error) {
    res.status(503);
    res.send(error);
  }
});

router.post("/getMostPopularSeries", async (req, res) => {
  try {
    const { days } = req.body;
    let _days = days;
    if (days === undefined) {
      _days = 30;
    }
    const { rows } = await db.query(
      `select * from fs_most_popular_items(${_days-1},'Series') limit 5`
    );
    res.send(rows);
  } catch (error) {
    res.status(503);
    res.send(error);
  }
});

router.post("/getMostPopularMusic", async (req, res) => {
  try {
    const { days } = req.body;
    let _days = days;
    if (days === undefined) {
      _days = 30;
    }
    const { rows } = await db.query(
      `select * from fs_most_popular_items(${_days-1},'Audio') limit 5`
    );
    res.send(rows);
  } catch (error) {
    res.status(503);
    res.send(error);
  }
});

router.get("/getPlaybackActivity", async (req, res) => {
  try {
    const { rows } = await db.query("SELECT * FROM jf_playback_activity");
    res.send(rows);
  } catch (error) {
    res.status(503);
    res.send(error);
  }
});

router.get("/getAllUserActivity", async (req, res) => {
  try {
    const { rows } = await db.query("SELECT * FROM jf_all_user_activity");
    res.send(rows);
  } catch (error) {
    res.send([]);
  }
});

router.post("/getUserDetails", async (req, res) => {
  try {
    const { userid } = req.body;
    const { rows } = await db.query(
      `select * from jf_users where "Id"='${userid}'`
    );
    res.send(rows[0]);
  } catch (error) {
    console.log(error);
    res.status(503);
    res.send(error);
  }
});

router.post("/getGlobalUserStats", async (req, res) => {
  try {
    const { hours,userid } = req.body;
    let _hours = hours;
    if (hours === undefined) {
      _hours = 24;
    }
    const { rows } = await db.query(
      `select * from fs_user_stats(${_hours},'${userid}')`
    );
    res.send(rows[0]);
  } catch (error) {
    console.log(error);
    res.status(503);
    res.send(error);
  }
});

router.post("/getUserLastPlayed", async (req, res) => {
  try {
    const { userid } = req.body;
    const { rows } = await db.query(
      `select * from fs_last_user_activity('${userid}') limit 15`
    );
    res.send(rows);
  } catch (error) {
    console.log(error);
    res.status(503);
    res.send(error);
  }
});

router.post("/getLibraryDetails", async (req, res) => {
  try {
    const { libraryid } = req.body;
    const { rows } = await db.query(
      `select * from jf_libraries where "Id"='${libraryid}'`
    );
    res.send(rows[0]);
  } catch (error) {
    console.log(error);
    res.status(503);
    res.send(error);
  }
});

router.post("/getGlobalLibraryStats", async (req, res) => {
  try {
    const { hours,libraryid } = req.body;
    let _hours = hours;
    if (hours === undefined) {
      _hours = 24;
    }
    const { rows } = await db.query(
      `select * from fs_library_stats(${_hours},'${libraryid}')`
    );
    res.send(rows[0]);
  } catch (error) {
    console.log(error);
    res.status(503);
    res.send(error);
  }
});


router.get("/getLibraryCardStats", async (req, res) => {
  try {
    const { rows } = await db.query("select * from js_library_stats_overview");
    res.send(rows);
  } catch (error) {
    res.status(503);
    res.send(error);
  }
});

router.get("/getLibraryMetadata", async (req, res) => {
  try {
    const { rows } = await db.query("select * from js_library_metadata");
    res.send(rows);
  } catch (error) {
    res.status(503);
    res.send(error);
  }
});

router.post("/getLibraryItemsWithStats", async (req, res) => {
  try{
    const  {libraryid}  = req.body;
    console.log(`ENDPOINT CALLED: /getLibraryItems: `+libraryid);
    const { rows } = await db.query(
      `SELECT * FROM jf_library_items_with_playcount_playtime where "ParentId"='${libraryid}'`
    );
    res.send(rows);
  

  }catch(error)
  {
    console.log(error);
  }

 
});


router.post("/getLibraryLastPlayed", async (req, res) => {
  try {
    const { libraryid } = req.body;
    const { rows } = await db.query(
      `select * from fs_last_library_activity('${libraryid}') limit 15`
    );
    res.send(rows);
  } catch (error) {
    console.log(error);
    res.status(503);
    res.send(error);
  }
});

router.get("/getRecentlyAdded", async (req, res) => {
  try {

    const { libraryid } = req.query;
    const { rows: config } = await db.query('SELECT * FROM app_config where "ID"=1');

    if (config.length===0 || config[0].JF_HOST === null || config[0].JF_API_KEY === null) {
      res.status(503);
      res.send({ error: "Config Details Not Found" });
      return;
    }

    const adminurl = `${config[0].JF_HOST}/Users`;

    const response = await axios_instance.get(adminurl, {
      headers: {
        "X-MediaBrowser-Token":  config[0].JF_API_KEY ,
      },
    });

    if(!response || typeof response.data !== 'object' || !Array.isArray(response.data))
    {
      res.status(503);
      res.send({ error: "Invalid Response from Users API Call.", user_response:response });
      return;
    }

    const adminUser = response.data.filter(
      (user) => user.Policy.IsAdministrator === true
    );
   

    let url=`${config[0].JF_HOST}/users/${adminUser[0].Id}/Items/latest`;
    if(libraryid)
    {
      url+=`?parentId=${libraryid}`;
    }

    
    
    const response_data = await axios_instance.get(url, {
      headers: {
        "X-MediaBrowser-Token":  config[0].JF_API_KEY ,
      },
    });
    res.send(response_data.data);
  } catch (error) {
    res.status(503);
    res.send(error);
  }
});




router.post("/getViewsOverTime", async (req, res) => {
  try {
    const { days } = req.body;
    let _days = days;
    if (days=== undefined) {
      _days = 30;
    }
    const { rows:stats } = await db.query(
      `select * from fs_watch_stats_over_time('${_days}')`
    );

    const { rows:libraries } = await db.query(
      `select distinct "Id","Name" from jf_libraries`
    );

    
const reorganizedData = {};

stats.forEach((item) => {
  const library = item.Library;
  const count = item.Count;
  const date = new Date(item.Date).toLocaleDateString('en-US', {
    year: 'numeric',
    month: 'short',
    day: '2-digit'
  });


  if (!reorganizedData[date]) {
    reorganizedData[date] = {
      Key:date
    };
  }
  
  reorganizedData[date]= { ...reorganizedData[date], [library]: count};
});
const finalData = {libraries:libraries,stats:Object.values(reorganizedData)};
    res.send(finalData);
  } catch (error) {
    console.log(error);
    res.status(503);
    res.send(error);
  }
});

router.post("/getViewsByDays", async (req, res) => {
  try {
    const { days } = req.body;
    let _days = days;
    if (days=== undefined) {
      _days = 30;
    }
    const { rows:stats } = await db.query(
      `select * from fs_watch_stats_popular_days_of_week('${_days}')`
    );

    const { rows:libraries } = await db.query(
      `select distinct "Id","Name" from jf_libraries`
    );

    
const reorganizedData = {};

stats.forEach((item) => {
  const library = item.Library;
  const count = item.Count;
  const day = item.Day;


  if (!reorganizedData[day]) {
    reorganizedData[day] = {
      Key:day
    };
  }
  
  reorganizedData[day]= { ...reorganizedData[day], [library]: count};
});
const finalData = {libraries:libraries,stats:Object.values(reorganizedData)};
    res.send(finalData);
  } catch (error) {
    console.log(error);
    res.status(503);
    res.send(error);
  }
});


router.post("/getViewsByHour", async (req, res) => {
  try {
    const { days } = req.body;
    let _days = days;
    if (days=== undefined) {
      _days = 30;
    }
    const { rows:stats } = await db.query(
      `select * from fs_watch_stats_popular_hour_of_day('${_days}')`
    );

    const { rows:libraries } = await db.query(
      `select distinct "Id","Name" from jf_libraries`
    );

    
const reorganizedData = {};

stats.forEach((item) => {
  const library = item.Library;
  const count = item.Count;
  const hour = item.Hour;


  if (!reorganizedData[hour]) {
    reorganizedData[hour] = {
      Key:hour
    };
  }
  
  reorganizedData[hour]= { ...reorganizedData[hour], [library]: count};
});
const finalData = {libraries:libraries,stats:Object.values(reorganizedData)};
    res.send(finalData);
  } catch (error) {
    console.log(error);
    res.status(503);
    res.send(error);
  }
});

router.post("/getGlobalItemStats", async (req, res) => {
  try {
    const { hours,itemid } = req.body;
    let _hours = hours;
    if (hours === undefined) {
      _hours = 24;
    }
    const { rows } = await db.query(
      `select count(*)"Plays",
      sum("PlaybackDuration") total_playback_duration
      from jf_playback_activity jf_playback_activity
      where 
      ("EpisodeId"='${itemid}' OR "SeasonId"='${itemid}' OR "NowPlayingItemId"='${itemid}')
      AND jf_playback_activity."ActivityDateInserted" BETWEEN CURRENT_DATE - INTERVAL '1 hour' * ${_hours} AND NOW();`
    );
    res.send(rows[0]);
  } catch (error) {
    console.log(error);
    res.status(503);
    res.send(error);
  }
});




module.exports = router;