diff --git a/app.js b/app.js index 8a73fde..6bac8cd 100644 --- a/app.js +++ b/app.js @@ -1,13 +1,21 @@ const Koa = require("koa"); const requter = require("./bin/router.js"); +jwt = require('jsonwebtoken'); +dbs = require("./bin/mongodb.js")('mongodb://localhost:27017/',"myblog") // console.log(requter) // import requter from "./bin/router" const app = new Koa(); +dbs.add('a','a').then((res)=>{ + console.log(res) +}).catch((err)=>{ + console.log(err) +}) + app.use(async (ctx,next)=>{ // await next(); console.log(ctx.url) // ctx.response.body = {a:1}; - next() + await next() console.log("执行") }); diff --git a/bin/mongodb.js b/bin/mongodb.js index e69de29..fcde83a 100644 --- a/bin/mongodb.js +++ b/bin/mongodb.js @@ -0,0 +1,177 @@ +var MongoClient = require('mongodb').MongoClient; +var dburl; +let add = (set,data,url = dburl) =>{ + return new Promise((resolve, reject) => { + MongoClient.connect(url.url, { useNewUrlParser: true }, function(err, db) { + if (err) throw err; + var dbo = db.db(url.dbname); + // var myobj = { name: "菜鸟教程", url: "www.runoob" }; + try { + dbo.collection(set).insertOne(data, function(err, res) { + if (err) throw err; + // console.log("文档插入成功"); + db.close(); + resolve({code:0}); + }); + } catch (error) { + reject({code:1,error}) + } + + }); + }) +} +let adds = (set,data,url = dburl) =>{ + return new Promise((resolve, reject) => { + MongoClient.connect(url.url, { useNewUrlParser: true }, function(err, db) { + if (err) throw err; + var dbo = db.db(url.dbname); + // var myobj = { name: "菜鸟教程", url: "www.runoob" }; + try { + dbo.collection(set).insertMany(data, function(err, res) { + if (err) throw err; + // console.log("文档插入成功"); + db.close(); + resolve({code:0,num:res.insertedCount}); + }); + } catch (error) { + reject({code:1,error}) + } + + }); + }) +} +let remove = (set,where,url = dburl) =>{ + return new Promise((resolve, reject) => { + MongoClient.connect(url.url, { useNewUrlParser: true }, function(err, db) { + if (err) throw err; + var dbo = db.db(url.dbname); + // var myobj = { name: "菜鸟教程", url: "www.runoob" }; + try { + dbo.collection(set).deleteOne(where, function(err, obj) { + if (err) throw err; + // console.log("文档插入成功"); + db.close(); + resolve({code:0}); + }); + } catch (error) { + reject({code:1,error}) + } + + }); + }) +} +let removes = (set,where,url = dburl) =>{ + return new Promise((resolve, reject) => { + MongoClient.connect(url.url, { useNewUrlParser: true }, function(err, db) { + if (err) throw err; + var dbo = db.db(url.dbname); + // var myobj = { name: "菜鸟教程", url: "www.runoob" }; + try { + dbo.collection(set).deleteMany(where, function(err, obj) { + if (err) throw err; + // console.log("文档插入成功"); + db.close(); + resolve({code:0,num:obj.result.n}); + }); + } catch (error) { + reject({code:1,error}) + } + + }); + }) +} +let find = (set,where = {},page = 0,num = 0,url = dburl) =>{ + return new Promise((resolve, reject) => { + if(num == 0){ + MongoClient.connect(url.url, { useNewUrlParser: true }, function(err, db) { + if (err) throw err; + var dbo = db.db(url.dbname); + // var myobj = { name: "菜鸟教程", url: "www.runoob" }; + try { + dbo.collection(set). find(where).toArray(function(err, result) { // 返回集合中所有数据 + if (err) throw err; + // console.log(result); + resolve({code:0,data:result}); + db.close(); + }); + } catch (error) { + reject({code:1,error}) + } + + }); + }else{ + MongoClient.connect(url.url, { useNewUrlParser: true }, function(err, db) { + if (err) throw err; + var dbo = db.db(url.dbname); + // var myobj = { name: "菜鸟教程", url: "www.runoob" }; + try { + dbo.collection(set). find(where).skip(num * page).limit(num).toArray(function(err, result) { // 返回集合中所有数据 + if (err) throw err; + // console.log(result); + resolve({code:0,data:result}); + db.close(); + }); + } catch (error) { + reject({code:1,error}) + } + + }); + } + + }) +} +let update = (set,where = {},data,url = dburl) =>{ + return new Promise((resolve, reject) => { + MongoClient.connect(url.url, { useNewUrlParser: true }, function(err, db) { + if (err) throw err; + var dbo = db.db(url.dbname); + // var myobj = { name: "菜鸟教程", url: "www.runoob" }; + data = {$set:data} + try { + dbo.collection(set).updateOne(where, data, function(err, res) { + if (err) throw err; + // console.log(result); + resolve({code:0}); + db.close(); + }); + } catch (error) { + reject({code:1,error}) + } + + }); + }) +} +let updates = (set,where = {},data,url = dburl) =>{ + return new Promise((resolve, reject) => { + MongoClient.connect(url.url, { useNewUrlParser: true }, function(err, db) { + if (err) throw err; + var dbo = db.db(url.dbname); + // var myobj = { name: "菜鸟教程", url: "www.runoob" }; + data = {$set:data} + try { + dbo.collection(set).updateMany(where, data, function(err, res) { + if (err) throw err; + // console.log("文档插入成功"); + db.close(); + resolve({code:0,num:res.result.nModified}); + }); + } catch (error) { + reject({code:1,error}) + } + + }); + }) +} + +module.exports = function (url,dbname){ + dburl = {url,dbname}; + return{ + add, + adds, + remove, + find, + update, + updates, + removes + } +} \ No newline at end of file diff --git a/bin/router.js b/bin/router.js index 6f0daf6..64f41b1 100644 --- a/bin/router.js +++ b/bin/router.js @@ -17,16 +17,16 @@ function addMapping(router, mapping) { } } -function addControllers(router,controllers_dir) { +function addControllers(router, controllers_dir) { let ostype = os.type() == "Windows_NT" let dir; - if(ostype){ - dir = __dirname.replace("\\bin","") - }else{ - dir = __dirname.replace("/bin","") + if (ostype) { + dir = __dirname.replace("\\bin", "") + } else { + dir = __dirname.replace("/bin", "") } - - var files = fs.readdirSync(dir +"/"+ controllers_dir); + + var files = fs.readdirSync(dir + "/" + controllers_dir); var js_files = files.filter((f) => { return f.endsWith('.js'); }); diff --git a/controllers/login.js b/controllers/login.js index fcb8023..2461120 100644 --- a/controllers/login.js +++ b/controllers/login.js @@ -1,10 +1,37 @@ + var login = async (ctx, next) => { // var name = ctx.params.name; // ctx.response.body = `

Hello, ${name}!

`; ctx.response.body="这是login" next() }; +var loginup = async (ctx,next) => { + + // ctx.body="这是login,post,name:" + ctx.request.body.name + // console.log("post") + //返回token + console.log(ctx.request.body.name == 'admin' , ctx.request.body.pwd == "123456") + if(ctx.request.body.name == 'admin' && ctx.request.body.pwd == "123456"){ + const token = jwt.sign({ + name: ctx.request.body.name, + _id: 1 + }, 'my_token', { expiresIn: '2h' }); + // jwt.verify("eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ8.eyJuYW1lIjoiYWRtaW4iLCJfaWQiOjEsImlhdCI6MTU3MzU1Mjg1MCwiZXhwIjoxNTczNTYwMDUwfQ.TmAMeDq58F9Tt6gIQ9uU_FUVk4CEOKM90tvzymJo4Oc", 'my_token', function (err, data) { + // if (err) console.log(err) + // console.log('解析的数据', data) + // }) + ctx.body={code:0,token} + }else{ + ctx.body={ + code:1, + msg:"密码错误" + } + } + + next() +} module.exports = { - 'GET /login': login + 'GET /login': login, + 'POST /login' : loginup }; diff --git a/package.json b/package.json index e0e9d00..bf191ea 100644 --- a/package.json +++ b/package.json @@ -9,6 +9,7 @@ "koa-bodyparser": "^4.2.1", "koa-jwt": "^3.6.0", "koa-router": "^7.4.0", + "mongodb": "^3.3.4", "nunjucks": "^3.2.0" } } diff --git a/yarn.lock b/yarn.lock index b6c4f43..a1fd5c9 100644 --- a/yarn.lock +++ b/yarn.lock @@ -151,6 +151,11 @@ braces@^2.3.1, braces@^2.3.2: split-string "^3.0.2" to-regex "^3.0.1" +bson@^1.1.1: + version "1.1.3" + resolved "https://registry.yarnpkg.com/bson/-/bson-1.1.3.tgz#aa82cb91f9a453aaa060d6209d0675114a8154d3" + integrity sha512-TdiJxMVnodVS7r0BdL42y/pqC9cL2iKynVwA0Ho3qbsQYr428veL3l7BQyuqiw+Q5SqqoT0m4srSY/BlZ9AxXg== + buffer-equal-constant-time@1.0.1: version "1.0.1" resolved "https://registry.yarnpkg.com/buffer-equal-constant-time/-/buffer-equal-constant-time-1.0.1.tgz#f8e71132f7ffe6e01a5c9697a4c6f3e48d5cc819" @@ -1024,6 +1029,11 @@ media-typer@0.3.0: resolved "https://registry.yarnpkg.com/media-typer/-/media-typer-0.3.0.tgz#8710d7af0aa626f8fffa1ce00168545263255748" integrity sha1-hxDXrwqmJvj/+hzgAWhUUmMlV0g= +memory-pager@^1.0.2: + version "1.5.0" + resolved "https://registry.yarnpkg.com/memory-pager/-/memory-pager-1.5.0.tgz#d8751655d22d384682741c972f2c3d6dfa3e66b5" + integrity sha512-ZS4Bp4r/Zoeq6+NLJpP+0Zzm0pR8whtGPf1XExKLJBAczGMnSi3It14OiNCStjQjM6NU1okjQGSxgEZN8eBYKg== + methods@^1.0.1: version "1.1.2" resolved "https://registry.yarnpkg.com/methods/-/methods-1.1.2.tgz#5529a4d67654134edcc5266656835b0f851afcee" @@ -1107,6 +1117,17 @@ mkdirp@^0.5.0, mkdirp@^0.5.1: dependencies: minimist "0.0.8" +mongodb@^3.3.4: + version "3.3.4" + resolved "https://registry.yarnpkg.com/mongodb/-/mongodb-3.3.4.tgz#f52eec4a04005101e63715d4d1f67bf784fa0aef" + integrity sha512-6fmHu3FJTpeZxacJcfjUGIP3BSteG0l2cxLkSrf1nnnS1OrlnVGiP9P/wAC4aB6dM6H4vQ2io8YDjkuPkje7AA== + dependencies: + bson "^1.1.1" + require_optional "^1.0.1" + safe-buffer "^5.1.2" + optionalDependencies: + saslprep "^1.0.0" + ms@2.0.0: version "2.0.0" resolved "https://registry.yarnpkg.com/ms/-/ms-2.0.0.tgz#5608aeadfc00be6c2901df5f9861788de0d597c8" @@ -1421,6 +1442,19 @@ repeat-string@^1.6.1: resolved "https://registry.yarnpkg.com/repeat-string/-/repeat-string-1.6.1.tgz#8dcae470e1c88abc2d600fff4a776286da75e637" integrity sha1-jcrkcOHIirwtYA//Sndihtp15jc= +require_optional@^1.0.1: + version "1.0.1" + resolved "https://registry.yarnpkg.com/require_optional/-/require_optional-1.0.1.tgz#4cf35a4247f64ca3df8c2ef208cc494b1ca8fc2e" + integrity sha512-qhM/y57enGWHAe3v/NcwML6a3/vfESLe/sGM2dII+gEO0BpKRUkWZow/tyloNqJyN6kXSl3RyyM8Ll5D/sJP8g== + dependencies: + resolve-from "^2.0.0" + semver "^5.1.0" + +resolve-from@^2.0.0: + version "2.0.0" + resolved "https://registry.yarnpkg.com/resolve-from/-/resolve-from-2.0.0.tgz#9480ab20e94ffa1d9e80a804c7ea147611966b57" + integrity sha1-lICrIOlP+h2egKgEx+oUdhGWa1c= + resolve-url@^0.2.1: version "0.2.1" resolved "https://registry.yarnpkg.com/resolve-url/-/resolve-url-0.2.1.tgz#2c637fe77c893afd2a663fe21aa9080068e2052a" @@ -1460,12 +1494,19 @@ safe-regex@^1.1.0: resolved "https://registry.yarnpkg.com/safer-buffer/-/safer-buffer-2.1.2.tgz#44fa161b0187b9549dd84bb91802f9bd8385cd6a" integrity sha512-YZo3K82SD7Riyi0E1EQPojLz7kpepnSQI9IyPbHHg1XXXevb5dJI7tpyN2ADxGcQbHG7vcyRHk0cbwqcQriUtg== +saslprep@^1.0.0: + version "1.0.3" + resolved "https://registry.yarnpkg.com/saslprep/-/saslprep-1.0.3.tgz#4c02f946b56cf54297e347ba1093e7acac4cf226" + integrity sha512-/MY/PEMbk2SuY5sScONwhUDsV2p77Znkb/q3nSVstq/yQzYJOH/Azh29p9oJLsl3LnQwSvZDKagDGBsBwSooag== + dependencies: + sparse-bitfield "^3.0.3" + sax@^1.2.4: version "1.2.4" resolved "https://registry.yarnpkg.com/sax/-/sax-1.2.4.tgz#2816234e2378bddc4e5354fab5caa895df7100d9" integrity sha512-NqVDv9TpANUjFm0N8uM5GxL36UgKi9/atZw+x7YFnQ8ckwFGKrl4xX4yWtrey3UJm5nP1kUbnYgLopqWNSRhWw== -semver@^5.3.0, semver@^5.6.0: +semver@^5.1.0, semver@^5.3.0, semver@^5.6.0: version "5.7.1" resolved "https://registry.yarnpkg.com/semver/-/semver-5.7.1.tgz#a954f931aeba508d307bbf069eff0c01c96116f7" integrity sha512-sauaDf/PZdVgrLTNYHRtpXa1iRiKcaebiKQ1BJdpQlWH2lCvexQdX55snPFyK7QzpudqbCI0qXFfOasHdyNDGQ== @@ -1546,6 +1587,13 @@ source-map@^0.5.6: resolved "https://registry.yarnpkg.com/source-map/-/source-map-0.5.7.tgz#8a039d2d1021d22d1ea14c80d8ea468ba2ef3fcc" integrity sha1-igOdLRAh0i0eoUyA2OpGi6LvP8w= +sparse-bitfield@^3.0.3: + version "3.0.3" + resolved "https://registry.yarnpkg.com/sparse-bitfield/-/sparse-bitfield-3.0.3.tgz#ff4ae6e68656056ba4b3e792ab3334d38273ca11" + integrity sha1-/0rm5oZWBWuks+eSqzM004JzyhE= + dependencies: + memory-pager "^1.0.2" + split-string@^3.0.1, split-string@^3.0.2: version "3.1.0" resolved "https://registry.yarnpkg.com/split-string/-/split-string-3.1.0.tgz#7cb09dda3a86585705c64b39a6466038682e8fe2"