spotify-loader.js

'use strict';

// NODE_ENV=development node spotify-loader.js

// Load up my private env
require('./config/env/heroku')();

let config = require('./config/config'),
  mongoose = require('mongoose'),
  path = require('path'),
  chalk = require('chalk'),
  moment = require('moment'),
  SpotifyWebApi = require('spotify-web-api-node'),
  accounts = require('./spotify-playlist.json');

/**
 * Database, models, and helpers
 */

mongoose.connect(config.db, { useNewUrlParser: true, useUnifiedTopology: true }, function (err) {
  if (err) {
    console.error(chalk.red('Could not connect to MongoDB!'));
    console.log(chalk.red(err));
  }
});

require(path.resolve('./app/models/playlist.server.model.js'));
let Playlist = mongoose.model('Playlist');

let getPublishedDate = function (title) {
  let onlyDigits = title.replace(/([A-Z])\w+/g, '');
  let m = moment(onlyDigits);

  if (m.isValid()) {
    return m.format('MM.DD.YYYY');
  } else {
    return null;
  }
};

let create = function (title, tracks, done) {
  let playlist = new Playlist(tracks);

  playlist.title = title
  playlist.tracks = tracks;
  playlist.published_date = getPublishedDate(title);

  let upsertData = playlist.toObject();

  delete upsertData._id;

  Playlist.updateOne({
    title: playlist.title
  }, upsertData, {
    upsert: true
  },
    function (err) {
      if (err) {
        done(err);
      } else {
        done(playlist);
      }
    });
};

/**
 * Spotify Api
 */

let spotifyApi = new SpotifyWebApi({
  clientId: config.spotify.clientID,
  clientSecret: config.spotify.clientSecret,
  redirectUri: config.spotify.callbackURL
});

let savePlaylist = function (data) {

  let tracks = [];
  data.tracks.items.forEach(function (item) {
    tracks.push({
      id: item.track.id,
      name: item.track.name,
      artist: item.track.artists[0].name,
      added_at: item.added_at,
      open_url: item.track.external_urls.spotify,
      uri: item.track.uri
    });
  });

  let title = data.name;
  create(title, tracks, function (data) {
    console.log('[' + chalk.green(title) + ']' + ' saved!');
  });
};

/**
 **** Main entry point *****
 * Call out to Spotify and save all the playlist tracks
 */

spotifyApi.clientCredentialsGrant()
  .then(function (data) {
    console.log('The access token is ' + chalk.yellow(data.body['access_token']));

    // Save the access token so that it's used in future calls
    spotifyApi.setAccessToken(data.body['access_token']);

    // Loop over the accounts and save each playlist
    accounts.forEach(function (acct) {
      spotifyApi.getPlaylist(acct.playlist).then(function (data) {
        // Upsert to the database
        savePlaylist(data.body);
      })
        .catch(error => {
          console.log(error)
        });
    });

  })
  .catch(function (error) {
    console.log(chalk.red('Something went wrong when retrieving an access token'), error);
  });