insta.js

let superagent = require('superagent');
require('superagent-proxy')(superagent);
let random_useragent = require('random-useragent');
let md5 = require('md5');
let _ = require('lodash');


var insta = new function () {
    //USING HTTP BECAUSE OF THE PROXY!!!! TEST STRESSING IF NEED CHANGE TO HTTPS ON THE FUTURE
    this.rootURL = 'https://www.instagram.com/';
    this.graphqlURL = 'https://www.instagram.com/graphql/query/';
    // this.topSearchURL = "https://www.instagram.com/web/search/topsearch/"
    this.searchUserUrl = "https://www.instagram.com/${username}/?__a=1";

    this.query = {
        getPostLikes: "e0f59e4a1c8d78d0161873bc2ee7ec44",
        getUserPosts: "66eb9403e44cc12e5b5ecda48b667d41",
        getUserFollowers: "c76146de99bb02f6415203be841dd25a",
        getPostDetails: "49699cdb479dd5664863d4b647ada1f7",
        getCovers: "aec5501414615eca36a9acf075655b1e",
        defaultPageSize: 50
    }

    this.instance = function (params={}) {
        this.proxy = params.proxy;
        this.timeout = params.timeout;
        this.retry = params.retry;
        return this;
    }

    this.makeRequest = function ({ queryHash, queryVariables }) {
        console.log(`${this.graphqlURL}?query_hash=${queryHash}&variables=${JSON.stringify(queryVariables)}`);

        return superagent.get(`${this.graphqlURL}?query_hash=${queryHash}&variables=${JSON.stringify(queryVariables)}`)
            .set({ 'user-agent': random_useragent.getRandom() })
            .set('Accept', 'application/json')
            .proxy(this.proxy)
            .timeout({
                response: this.timeout,  //seconds for the server to start sending,
                deadline: this.timeout, //file to finish loading.
            })
            .retry(this.retry)
            .then(res => { return res.body; })
    }

    this.buildPagination = function ({ queryVariables, limit, end_cursor, data = [] }) {
        let pagesize = this.query.defaultPageSize;
        let remaining;
        let hasLimit = false;
        if(limit){
           hasLimit = true;
           remaining = limit - data.length;
           if (remaining <= pagesize) {
               pagesize = remaining;
           }
        }
        
        queryVariables.first = pagesize;
        if (end_cursor) {
            queryVariables.after = end_cursor;
        }
        
        return { hasLimit, remaining, pagesize }
    }

    this.defaultQuery = function ({ 
        queryHash,
        queryVariables,
        singleResult,
        edgeKey,
        limit,
        end_cursor,
        data = []
    }) {

        let pagination = this.buildPagination({
            queryVariables, limit, end_cursor, data
        });
        
        return this.makeRequest({ queryHash, queryVariables }).then(res => {
            // console.log(res);
            let edge = _.get(res, `${edgeKey}`);
            
            if(singleResult){
                return edge;
            }
            if (edge) {
                data = data.concat(edge.edges);
                if (
                    edge.page_info && edge.page_info.has_next_page &&
                    (!pagination.hasLimit || pagination.remaining > pagination.pagesize)
                ) {
                    return this.defaultQuery({
                        queryHash,
                        queryVariables,
                        edgeKey,
                        limit: limit,
                        end_cursor: edge.page_info.end_cursor,
                        data: data
                    })
                } else {
                    return data;
                }
            } else {
                return data;
            }
        })
    }

    /**
     * 
     * 
     * 
     * 
     * QUERY FUNCTIONS
     * 
     * 
     * 
     *
     */

    this.getUserProfile = function ({ identifier }) {
        let searchUrl = this.searchUserUrl.replace("${username}", identifier);
        // console.log(`${searchUrl}`);
        

        return superagent.get(`${searchUrl}`)
            .set({ 'user-agent': random_useragent.getRandom() })
            .set('Accept', 'application/json')
            .proxy(this.proxy)
            .timeout({
                response: this.timeout,  //seconds for the server to start sending,
                deadline: this.timeout, //file to finish loading.
            })
            .retry(this.retry)
            .then(res => res.body)
            .then(res => {
                return res.graphql.user;
            })
        
    }
    this.getUsername = function ({ identifier}) {
        return this.defaultQuery({
            queryHash: this.query.getCovers,
            queryVariables: { "user_id": identifier, "include_reel": true },
            singleResult: true,
            edgeKey: 'data.user.reel.user.username',
        })
    }

    this.getPostLikes = function ({ identifier, limit, end_cursor, data = [] }) {
        return this.defaultQuery({
            queryHash: this.query.getPostLikes,
            queryVariables: { "shortcode": identifier, "include_reel": true },
            edgeKey: 'data.shortcode_media.edge_liked_by',
            limit,
            end_cursor,
            data
        })
    }

    this.getUserPosts = function ({ identifier, limit, end_cursor, data = [] }) {
        return this.defaultQuery({
            queryHash: this.query.getUserPosts,
            queryVariables: { "id": identifier },
            edgeKey: 'data.user.edge_owner_to_timeline_media',
            limit,
            end_cursor,
            data
        })
    }

    this.getUserFollowers = function ({ identifier, limit, end_cursor, data = [] }) {
        return this.defaultQuery({
            queryHash: this.query.getUserFollowers,
            queryVariables: { "id": identifier, "first": limit },
            edgeKey: 'data.user.edge_followed_by',
            singleResult: true,
            limit,
            end_cursor,
            data
        })
    }

    this.getPostDetails = function ({ identifier, limit, end_cursor, data = [] }) {
        return this.defaultQuery({
            queryHash: this.query.getPostDetails,
            queryVariables:  { "shortcode":identifier },
            edgeKey: 'data.shortcode_media',
            singleResult: true,
            limit,
            end_cursor,
            data
        })
    }

}

module.exports = insta;