質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

ただいまの
回答率

90.12%

routes/indexでのsocket.io

解決済

回答 1

投稿 編集

  • 評価
  • クリップ 0
  • VIEW 1,161

Run_ner

score 14

node.js(Express)でTwitter認証したらtwitterのstreamingを開始し、リアルタイムでページに表示するコードを書こうとしたのですが、何故か動きません。

Node.jsの経験がまだ2日程度なのでコードはぐちゃぐちゃで申し訳ないのですが、以下に載せさせて頂きます。

(起動はbin/www)

app.js

var TWITTER_CONSUMER_KEY = "xxxx";
var TWITTER_CONSUMER_SECRET = "xxxx";

var express = require("express");
var path = require("path");
var logger = require("morgan");
var cookieParser = require("cookie-parser");
var bodyParser = require("body-parser");

var app = express();

var session = require("express-session");



var passport = require("passport");
var TwitterStrategy = require("passport-twitter").Strategy;
var TWITTER_CALLBACK_URL = "http://127.0.0.1:3000/oauth/callback/";

app.set("consumerkey",TWITTER_CONSUMER_KEY);
app.set("consumerSecret",TWITTER_CONSUMER_SECRET);

app.set("passport", passport); 

passport.serializeUser(function(user, done) {
    done(null, user);
});

passport.deserializeUser(function(obj, done) {
    done(null, obj);
});

passport.use(new TwitterStrategy({
        consumerKey: TWITTER_CONSUMER_KEY,
        consumerSecret: TWITTER_CONSUMER_SECRET,
        callbackURL: TWITTER_CALLBACK_URL
    },
    function(token, tokenSecret, profile, done) {
        app.set("token", token);
        app.set("tokenSecret", tokenSecret); 
        console.log(token);
        process.nextTick(function() {
            return done(null, profile);
        });
    }
));


app.set("views", path.join(__dirname, "views"));
app.set("view engine", "ejs");

app.use(logger("dev"));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded());
app.use(cookieParser());
app.use(express.static(path.join(__dirname, "public")));
app.use(express.static(__dirname + '/public'));


app.use(session({
    secret: "SECRET"
}));

app.use(passport.initialize());
app.use(passport.session());


module.exports = app;


var routes = require("./routes/");

routes/index.js

var app = module.parent.exports;
var http = require('http');
var passport = app.get("passport");
var twitter = require('ntwitter');
var io = require('socket.io');

app.get('/', function(req, res) {
  res.render('index', {
    title: 'streaming'
  });
});


app.get("/oauth", passport.authenticate("twitter"));


app.get("/oauth/callback",
    passport.authenticate("twitter", {
        successRedirect: "/streaming",
        failureRedirect: "/"
    }));
app.get("/streaming", function(req,res){
    var tw = new twitter({
      consumer_key: app.get("consumerkey"),
      consumer_secret: app.get("consumerSecret"),
      access_token_key: app.get("token"),
      access_token_secret: app.get("tokenSecret")
    });

io.sockets.on("connection", function(socket) {
    console.log("hello");
        tw.stream('statuses/sample',  function(stream) {
            stream.on("data", function(data) {
                socket.emit("stream", data);
                console.log(data.text);
            });

            stream.on("end", function(res) {
                console.log(res);
            });

            stream.on("destroy", function(res) {
                console.log(res);
            });

        });
    });

    res.render("streaming",{title: "streaming"});
});


// ログアウト
app.get("/logout", function(req, res) {
    req.logout();
    res.redirect("/");
});
// --------------------------------------------------------



app.use(function(req, res, next) {
    var err = new Error("Not Found");
    err.status = 404;
    next(err);
});


if(app.get("env") === "development") {
    app.use(function(err, req, res, next) {
        res.status(err.status || 500);
        res.render("error", {
            message: err.message,
            error: err
        });
    });
}


app.use(function(err, req, res, next) {
    res.status(err.status || 500);
    res.render("error", {
        message: err.message,
        error: {}
    });
});


bin/www

#!/usr/bin/env node

/**
 * Module dependencies.
 */

var app = require('../app');
var debug = require('debug')('twi-streaming:server');
var http = require('http');

/**
 * Get port from environment and store in Express.
 */

var port = normalizePort(process.env.PORT || '3000');
app.set('port', port);

/**
 * Create HTTP server.
 */

var server = http.createServer(app);

/**
 * Listen on provided port, on all network interfaces.
 */

var io = require('socket.io').listen(server);
app.set("server",server);
server.listen(port);
server.on('error', onError);
server.on('listening', onListening);

/**
 * Normalize a port into a number, string, or false.
 */

function normalizePort(val) {
  var port = parseInt(val, 10);

  if (isNaN(port)) {
    // named pipe
    return val;
  }

  if (port >= 0) {
    // port number
    return port;
  }

  return false;
}

/**
 * Event listener for HTTP server "error" event.
 */

function onError(error) {
  if (error.syscall !== 'listen') {
    throw error;
  }

  var bind = typeof port === 'string'
    ? 'Pipe ' + port
    : 'Port ' + port;

  // handle specific listen errors with friendly messages
  switch (error.code) {
    case 'EACCES':
      console.error(bind + ' requires elevated privileges');
      process.exit(1);
      break;
    case 'EADDRINUSE':
      console.error(bind + ' is already in use');
      process.exit(1);
      break;
    default:
      throw error;
  }
}

/**
 * Event listener for HTTP server "listening" event.
 */

function onListening() {
  var addr = server.address();
  var bind = typeof addr === 'string'
    ? 'pipe ' + addr
    : 'port ' + addr.port;
  debug('Listening on ' + bind);
}

view/streaming

<html>
<head>
    <link rel='stylesheet' href='/stylesheets/style.css' />
<script src="//ajax.googleapis.com/ajax/libs/jquery/1.10.2/jquery.min.js"></script>
<script type="text/javascript" src="//cdnjs.cloudflare.com/ajax/libs/underscore.js/1.5.2/underscore-min.js"></script>
<script src="/socket.io/socket.io.js"></script>
<script>
console.log("Hello,test page!!");
  var socket = io.connect();
  socket.on('streaming', function (data) {
    $(".TwitterList").append($("<li>").text(data.text));
  });
</script>
</head>
<body>
    <ul class="TwitterList">
    </ul>
</body>
</html>

いろんなサイトから得た情報を繋ぎ合わせただけなので無駄な部分もあるかと思いますが、どうか回答お願いします。
また、もっと効率が良い書き方があればご教授頂けると幸いです。

passportとntwitterを使用しています。

  • 気になる質問をクリップする

    クリップした質問は、後からいつでもマイページで確認できます。

    またクリップした質問に回答があった際、通知やメールを受け取ることができます。

    クリップを取り消します

  • 良い質問の評価を上げる

    以下のような質問は評価を上げましょう

    • 質問内容が明確
    • 自分も答えを知りたい
    • 質問者以外のユーザにも役立つ

    評価が高い質問は、TOPページの「注目」タブのフィードに表示されやすくなります。

    質問の評価を上げたことを取り消します

  • 評価を下げられる数の上限に達しました

    評価を下げることができません

    • 1日5回まで評価を下げられます
    • 1日に1ユーザに対して2回まで評価を下げられます

    質問の評価を下げる

    teratailでは下記のような質問を「具体的に困っていることがない質問」、「サイトポリシーに違反する質問」と定義し、推奨していません。

    • プログラミングに関係のない質問
    • やってほしいことだけを記載した丸投げの質問
    • 問題・課題が含まれていない質問
    • 意図的に内容が抹消された質問
    • 広告と受け取られるような投稿

    評価が下がると、TOPページの「アクティブ」「注目」タブのフィードに表示されにくくなります。

    質問の評価を下げたことを取り消します

    この機能は開放されていません

    評価を下げる条件を満たしてません

    評価を下げる理由を選択してください

    詳細な説明はこちら

    上記に当てはまらず、質問内容が明確になっていない質問には「情報の追加・修正依頼」機能からコメントをしてください。

    質問の評価を下げる機能の利用条件

    この機能を利用するためには、以下の事項を行う必要があります。

回答 1

check解決した方法

+3

routes/indexのコードをapp.jsに全て移したら解決しました

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

15分調べてもわからないことは、teratailで質問しよう!

  • ただいまの回答率 90.12%
  • 質問をまとめることで、思考を整理して素早く解決
  • テンプレート機能で、簡単に質問をまとめられる