与前端训练营的日子 -- Week19

mkdir server ## 创建一个文件夹，名为servercd server ## 进入server文件夹目录npx express-generator ## 通过express-generator进行初始化项目(注意当前路径是在server文件夹目录下)npm install ## 安装需要的依赖(注意当前路径是在server文件夹目录下)

var createError = require('http-errors');var express = require('express');var path = require('path');var cookieParser = require('cookie-parser');var logger = require('morgan');
var app = express();
app.use(logger('dev'));app.use(express.json());app.use(express.urlencoded({ extended: false }));app.use(cookieParser());app.use(express.static(path.join(__dirname, 'public')));
// catch 404 and forward to error handlerapp.use(function(req, res, next) {  next(createError(404));});
// error handlerapp.use(function(err, req, res, next) {  // set locals, only providing error in development  res.locals.message = err.message;  res.locals.error = req.app.get('env') === 'development' ? err : {};
  // render the error page  res.status(err.status || 500);  res.render('error');});
module.exports = app;

let http = require("http");let unzipper = require("unzipper");
http.createServer(function (request, response) {		// 解压文件并复制到本地服务器,注意这是测试整个发布链路		request.pipe(unzipper.Extract({ path: '../server/public/' }));}).listen(8082);

let http = require("http");let archiver = require("archiver");
let request = http.request({    hostname: "127.0.0.1",    port: 8082,    method: "POST",    headers: {        'Content-Type': 'application/octet-stream',    }}, response => {    console.log(response);});
const archive = archiver('zip', {    zlib: { level: 9 } // Sets the compression level.});
archive.directory('./sample/', false);archive.finalize();archive.pipe(request);

let http = require("http");let https = require("https");let unzipper = require("unzipper");let querystring = require('querystring');
// 2. auth路由：接收code,用code+client_id+client_secret请求获得token
function auth(request, response) {    let query = querystring.parse(request.url.match(/^\/auth\?([\s\S]+)$/)[1]);    getToken(query.code, function (info) {      // 通过<a></a>标签将标签回传给publish-tool        response.write(`<a href='http://localhost:8083/?token=${info.access_token}'>publish</a>`)        response.end();    });}
function getToken(code, callback) {  // 省略部分代码    let request = https.request({        hostname: "github.com",        path: `/login/oauth/access_token?code=${code}&client_id=${client_id}&client_secret=${client_secret}`,        port: 443,        method: "POST"    }, function (response) {        let body = "";        response.on('data', chunk => {            body += (chunk.toString());        })        response.on('end', chunk => {            callback(querystring.parse(body));        })    });    request.end();}
// 4. publish路由：用token获取用户信息，检查权限，接受发布
function publish(request, response) {    let query = querystring.parse(request.url.match(/^\/publish\?([\s\S]+)$/)[1]);    if (query.token.length > 0) {        getUser(query.token, info => {            if (info.login === "Sammmmmmm") {                request.pipe(unzipper.Extract({ path: '../server/public/' }));                request.on('end', function () {                    response.end("success !");                })              }        });    }}
function getUser(token, callback) {
    let request = https.request({        hostname: "api.github.com",        path: `/user`,        port: 443,        method: "GET",        headers: {            Authorization: `token ${token}`,            "User-Agent": 'toy-publish-by-samdev'        }    }, function (response) {        let body = "";        response.on('data', chunk => {            body += (chunk.toString());        })        response.on('end', chunk => {            callback(JSON.parse(body));        })    });    request.end();}
http.createServer(function (request, response) {
    if (request.url.match(/^\/auth\?/)) {        return auth(request, response);    }    if (request.url.match(/^\/publish\?/)) {        return publish(request, response);    }
}).listen(8082);

let http = require("http");let archiver = require("archiver");let child_process = require("child_process");let querystring = require("querystring");
// 1. 打开 https://github.com/login/oauth/authorize，获取code
child_process.exec(`open https://github.com/login/oauth/authorize?client_id=${client_id}`);
// 3. 再创建一个server，接收token，后点击发布，将文件传到publish-serverhttp.createServer(function (request, response){    let query = querystring.parse(request.url.match(/^\/\?([\s\S]+)$/)[1]);    pubulish(query.token);}).listen(8083);
function pubulish(token) {    let request = http.request({        hostname: "127.0.0.1",        port: 8082,        method: "POST",        path: "/publish?token=" + token,        headers: {            'Content-Type': 'application/octet-stream',        }    }, response => {        console.log(response);    });        const archive = archiver('zip', {        zlib: { level: 9 } // Sets the compression level.    });      archive.directory('./sample/', false);    archive.finalize();    archive.pipe(request);}