How do I loop through thread.items? about instagram-private-api HOT 3 CLOSED

/* Express */
var express = require('express');
var path = require('path');
var app = express();
app.use(express.static(path.join(__dirname, 'public')));

app.get('/', function (req, res) {
    res.render("./index.html");
});

app.get('/view', function (req, res) {
    //res.render("./index.html");

    res.send("<h1>Messages</h1>" + + "<br></br> <a href='http://localhost:3000/view/'>Reload..</a>"));
    getDMS();
});

app.get('/dm', function (req, res) {
  res.send("Sent to " + req.query['user'] + " as " + req.query['text'] 
    + "<br></br> <a href='http://localhost:3000/view/'>View this conversation..</a>")
    sendDM(req.query['user'], req.query['text']);
});

app.listen(3000, function () {
  console.log('Example app listening on port 3000!');
});


/* Instagram API */
var PrivateAPI = require('instagram-private-api');
function sendDM(user, text) {
    var Client = PrivateAPI.Client.V1;
    var device = new Client.Device('SAMSUNG_GALAXY_S2', 'n0tabot');
    var cookiePath = './cookies/n0tabot.json';
    var session = new Client.Session(device, cookiePath);
    var promise = Client.Session.create(device, cookiePath, 'n0tabot', 'dhillon');
    promise.then(function(sessionInstance) {
        // Search for the User
        Client.Account.searchForUser(session, user)
         .then(function(accountInstance) {
            var userId = accountInstance.id;
            // Send a DM
            Client.Thread.configureText(session, userId, text)
             .then(function(threads) {
                var thread = threads[0];
                //thread.broadcastText(text);
                return thread.items; // -> see conversation
            });
         });
    });
}

function getDMS() {
    var ClientProxy = PrivateAPI.ProxyClient.V1;
    var server = new ClientProxy.Server('0.0.0.0', '8080', '8888');
    var session = new ClientProxy.Session(server);
    session.create('n0tabot', 'dhillon')
        .then(function(session) {
             ClientProxy.Thread.subscribeAll(session, function(thread){
                   // this -> socket connection
                   console.log(thread, "thread change");
              })
    });
}

/* Express */
var express = require('express');
var path = require('path');
var app = express();
var Promise = require('bluebird');

var EXPRESS_APP = 3000;
var PROXY_APP = 8080;
var PROXY_SOCKET = 8888;

app.use(express.static(path.join(__dirname, 'public')));

app.get('/threads', function (req, res) {
    getThreads().then(function(threads) {
       res.json(threads.map(function(t){return t.params}));
    })
});

app.get('/threads/:thread', function(req, res) {
    getThread(req.params.thread).then(function(thread){
        res.json(thread.params);
    })
})

app.listen(EXPRESS_APP, function () {
  console.log('Example app listening on port ' + EXPRESS_APP);
});


/* Instagram API */
var PrivateAPI = require('instagram-private-api');
var server = PrivateAPI.ProxyServer;

server.run({
    port: PROXY_APP,
    socketPort: PROXY_SOCKET,
    host: "127.0.0.1",
    databaseDir: './databases',
    cookiesDir: './cookies'
});

var ClientProxy = PrivateAPI.ProxyClient.V1;
var server = new ClientProxy.Server('127.0.0.1', PROXY_APP, PROXY_SOCKET);
var session = new ClientProxy.Session(server);

var promise = session.create('n0tabot', 'dhillon');
var session;

promise.then(function(sessionInstance) {
  session = sessionInstance;
  console.log("Session created!");

  //ClientProxy.Thread.subscribeAll(session, function(threads) {
  //   use socket.io (http://socket.io/docs/) in order to get notified when something in inbox
  //})

  //ClientProxy.Thread.subscribe(session, thread.id, function(thread) {
  //   use socket.io if you want to build realtime chat app, this will be called every
  //   time when someone respond to the thread, this wil poll only one thread, so it is much faster
  //   then subscribeAll which will poll for whole inbox
  //})
})

function getThreads() {
  if(!session) return Promise.resolve([]);
  return ClientProxy.Thread.all(session, 100);   
}

function getThread(id) {
  if(!session) return Promise.resolve({});
  return ClientProxy.Thread.show(session, id, 300); 
}