Implement Twitter Connect

src/api/serializers/user.ts

@@ -64,7 +64,10 @@ export default (
 	delete _user.password;
 	delete _user.token;
 	delete _user.username_lower;
-	delete _user.twitter;
+	if (_user.twitter) {
+		delete _user.twitter.accessToken;
+		delete _user.twitter.accessTokenSecret;
+	}
 
 	// Visible via only the official client
 	if (!opts.includeSecrets) {

src/api/service/twitter.ts

@@ -3,10 +3,18 @@ import * as express from 'express';
 //const Twitter = require('twitter');
 import autwh from 'autwh';
 import redis from '../../db/redis';
+import User from '../models/user';
+import serialize from '../serializers/user';
+import event from '../event';
 import config from '../../conf';
 
 module.exports = (app: express.Application) => {
-	if (config.twitter == null) return;
+	if (config.twitter == null) {
+		app.get('/connect/twitter', (req, res) => {
+			res.send('現在Twitterへ接続できません');
+		});
+		return;
+	}
 
 	const twAuth = autwh({
 		consumerKey: config.twitter.consumer_key,
@@ -24,9 +32,23 @@ module.exports = (app: express.Application) => {
 	app.get('/tw/cb', (req, res): any => {
 		if (res.locals.user == null) return res.send('plz signin');
 		redis.get(res.locals.user, async (_, ctx) => {
-			const tokens = await twAuth.done(JSON.parse(ctx), req.query.oauth_verifier);
-			console.log(tokens);
-			res.send('Authorized!');
+			const result = await twAuth.done(JSON.parse(ctx), req.query.oauth_verifier);
+
+			const user = await User.findOneAndUpdate({
+				token: res.locals.user
+			}, {
+				$set: {
+					twitter: result
+				}
+			});
+
+			res.send(`Twitter: @${result.screenName} を、Misskey: @${user.username} に接続しました！`);
+
+			// Publish i updated event
+			event(user._id, 'i_updated', await serialize(user, user, {
+				detail: true,
+				includeSecrets: true
+			}));
 		})
 	});
 };