How to use _connect method in qawolf

Best JavaScript code snippet using qawolf

dal.js

Source:dal.js Github

copy

Full Screen

...44 });45 }46 }47 async create (desc) {48 this._connect();49 const results = await this._run(`SELECT * FROM version LIMIT 1`, []);50 if (results.length > 0) {51 throw 'Version # already exists';52 }53 await this._run(`INSERT INTO version VALUES (?)`, [desc.version]);54 this._close();55 }56 async update (desc) {57 this._connect();58 const results = await this._run(`SELECT * FROM version LIMIT 1`);59 if (results.length > 0) {60 await this._run(`UPDATE version SET version = ?`, [desc.version]);61 }62 else {63 await this._run(`INSERT INTO version VALUES (?)`, [desc.version]);64 }65 this._close();66 }67 68 async read () {69 this._connect();70 const rows = await this._run(`SELECT * FROM version LIMIT 1`);71 if (rows.length > 0) { 72 return {version: rows[0].version}73 }74 }75}76class Tags {77 constructor (folder) {78 this._fname = path.join(folder, _IMAGES_DB);79 }80 _connect () {81 this._db = new sqlite3.Database(this._fname);82 }83 _close () {84 if (this._db) {85 this._db.close();86 }87 }88 _run (sql, params) {89 // allow queries to be using asynchronously90 if (this._db) { 91 return new Promise((resolve, reject) => {92 this._db.all(sql, params, function (error, rows) {93 if (error)94 reject(error);95 else96 resolve(rows);97 });98 });99 }100 }101 async create (desc) {102 this._connect();103 const rows = await this._run(`SELECT * FROM tags WHERE uuid = ? and tag = ? LIMIT 1`,104 [desc.uuid, desc.tag]);105 if (rows.length > 0) {106 throw `UUID ${desc.uuid} and tag ${desc.tag} already exist`;107 }108 await this._run(`INSERT INTO tags VALUES (?, ?)`, [desc.uuid, desc.tag]);109 this._close();110 }111 async delete (uuid, tag) {112 this._connect();113 await this._run(`DELETE FROM tags WHERE uuid = ? AND tag = ?`, [uuid, tag]);114 this._close();115 }116 async delete_all_by_uuid (uuid) {117 this._connect();118 await this._run(`DELETE FROM tags WHERE uuid = ?`, [uuid]);119 this._close();120 }121 async read_by_uuid (uuid) {122 this._connect();123 const rows = await this._run(`SELECT * FROM tags WHERE uuid = ?`, [uuid]);124 this._close();125 return rows;126 }127 async read_by_uuids (uuids) {128 this._connect();129 if (uuids.length > 990) {130 throw `About to hit the limit of the number of uuids that can be looked up at once`;131 }132 const uuid_str = uuids.map(r => '?').join(', ');133 const rows = await this._run(`SELECT * FROM tags WHERE uuid IN (${uuid_str})`, uuids);134 this._close();135 return rows;136 }137 async read_all_tags () {138 this._connect();139 let rows = await this._run(`SELECT distinct tag FROM tags`);140 // rows = rows.map(r => ({tag: r.tag}));141 this._close();142 return rows;143 }144}145class Images {146 147 constructor (folder) {148 this._fname = path.join(folder, _IMAGES_DB);149 }150 _connect () {151 this._db = new sqlite3.Database(this._fname);152 }153 _close () {154 if (this._db) {155 this._db.close();156 }157 }158 _run (sql, params) {159 // allow queries to be using asynchronously160 if (this._db) { 161 return new Promise((resolve, reject) => {162 this._db.all(sql, params, function (error, rows) {163 if (error)164 reject(error);165 else166 resolve(rows);167 });168 });169 }170 }171 async create (desc) {172 this._connect();173 const timestamp = toISO(new Date());174 let rows = await this._run(`SELECT * FROM images WHERE uuid = ? LIMIT 1`, [desc.uuid])175 if (rows.length > 0) {176 throw `UUID ${desc.uuid} already exists`;177 }178 await this._run(`INSERT INTO images VALUES (?, ?, ?, ?, ?, ?, ?)`, [179 desc.uuid,180 desc.extension,181 desc.content.join('\n\n'),182 timestamp,183 timestamp,184 null,185 desc.draft ? 1 : 0186 ]);187 this._close();188 }189 async update (desc) {190 this._connect();191 const timestamp = toISO(new Date());192 let rows = await this._run(`SELECT * FROM images WHERE uuid = ? LIMIT 1`, [desc.uuid]);193 if (rows.length > 0) {194 await this._run(`DELETE FROM images WHERE uuid = ?`, [desc.uuid]);195 }196 await this._run(`INSERT INTO images VALUES (?, ?, ?, ?, ?, ?, ?)`, [197 desc.uuid,198 desc.extension,199 desc.content.join('\n\n'),200 toISO(desc.date_created),201 timestamp,202 desc.date_published && desc.draft == 0 ? toISO(desc.date_published) : null,203 desc.draft ? 1 : 0204 ]);205 this._close();206 }207 async delete (uuid) {208 this._connect();209 await this._run(`DELETE FROM images WHERE uuid = ?`, [uuid]);210 this._close();211 }212 _process_row (r) {213 return { uuid: r.uuid,214 extension: r.extension,215 content: r.content.split('\n\n'),216 date_created: new Date(r.date_created),217 date_updated: new Date(r.date_updated),218 date_published: r.date_published ? new Date(r.date_published) : null,219 draft: r.draft ? true : false }220 }221 async count_all () {222 this._connect();223 const rows = await this._run(`SELECT count(*) as ct FROM images WHERE draft = 0`);224 this._close();225 return rows[0];226 }227 async count_all_drafts () {228 this._connect();229 const rows = await this._run(`SELECT count(*) as ct FROM images WHERE draft = 1 AND content IS NOT NULL AND content <> ''`);230 this._close();231 return rows[0];232 }233 async count_all_new () {234 this._connect();235 const rows = await this._run(`SELECT count(*) as ct FROM images WHERE draft = 1 AND (content IS NULL OR content = '')`);236 this._close();237 return rows[0];238 }239 async count_all_by_tag (tag) {240 this._connect();241 const rows = await this._run(`SELECT count(*) as ct FROM images WHERE uuid IN (SELECT uuid FROM tags WHERE tag = ?) AND draft = 0`, [tag]);242 this._close();243 return rows[0];244 }245 async read_all (offset, limit) {246 if (offset === 'undefined') {247 offset = 0;248 }249 if (limit === 'undefined') {250 limit = 10;251 }252 this._connect();253 let results = await this._run(`SELECT * FROM images WHERE draft = 0 ORDER BY datetime(date_published) desc LIMIT ? OFFSET ?`, [limit, offset]);254 results = results.map(r => this._process_row(r));255 this._close();256 return results;257 }258 async read_all_by_tag (tag, offset, limit) {259 if (offset === 'undefined') {260 offset = 0;261 }262 if (limit === 'undefined') {263 limit = 10;264 }265 this._connect();266 let results = await this._run(`SELECT * FROM images WHERE uuid IN (SELECT uuid FROM tags WHERE tag = ?) AND draft = 0 ORDER BY datetime(date_published) desc LIMIT ? OFFSET ?`, [tag, limit, offset]);267 results = results.map(r => this._process_row(r));268 this._close();269 return results;270 }271 async read_all_drafts (offset, limit) {272 if (offset === 'undefined') {273 offset = 0;274 }275 if (limit === 'undefined') {276 limit = 10;277 }278 this._connect();279 let results = await this._run(`SELECT * FROM images WHERE draft = 1 AND content IS NOT NULL AND content <> '' ORDER BY datetime(date_updated) desc LIMIT ? OFFSET ?`, [limit, offset]);280 results = results.map(r => this._process_row(r));281 this._close();282 return results;283 }284 async read_all_new (offset, limit) {285 if (offset === 'undefined') {286 offset = 0;287 }288 if (limit === 'undefined') {289 limit = 10;290 }291 this._connect();292 let results = await this._run(`SELECT * FROM images WHERE draft = 1 AND (content IS NULL OR content = '') ORDER BY datetime(date_updated) desc LIMIT ? OFFSET ?`, [limit, offset]);293 results = results.map(r => this._process_row(r));294 this._close();295 return results;296 }297 async read (uuid) {298 this._connect();299 const results = await this._run(`SELECT * FROM images WHERE uuid = ?` , [uuid]);300 if (results.length > 0) {301 if (results.length > 1) {302 throw `Too many rows ${results.length} for UUID ${uuid}`;303 }304 return this._process_row(results[0]);305 }306 }307}308class Notes {309 310 constructor (folder) {311 this._fname = path.join(folder, _IMAGES_DB);312 }313 _connect () {314 this._db = new sqlite3.Database(this._fname);315 }316 _close () {317 if (this._db) {318 this._db.close();319 }320 }321 _run (sql, params) {322 // allow queries to be using asynchronously323 if (this._db) { 324 return new Promise((resolve, reject) => {325 this._db.all(sql, params, function (error, rows) {326 if (error)327 reject(error);328 else329 resolve(rows);330 });331 });332 }333 }334 async create (desc) {335 this._connect();336 const timestamp = toISO(new Date());337 let rows = await this._run(`SELECT * FROM notes WHERE uuid = ? LIMIT 1`, [desc.uuid])338 if (rows.length > 0) {339 throw `UUID ${desc.uuid} already exists`;340 }341 await this._run(`INSERT INTO notes VALUES (?, ?, ?)`, [342 desc.uuid,343 desc.content.join('\n\n'),344 timestamp345 ]);346 this._close();347 }348 async update (desc) {349 this._connect();350 const timestamp = toISO(new Date());351 let rows = await this._run(`SELECT * FROM notes WHERE uuid = ? LIMIT 1`, [desc.uuid]);352 if (rows.length > 0) {353 await this._run(`UPDATE notes SET content = ?, date_updated = ? WHERE uuid = ?`,354 [desc.content.join('\n\n'), timestamp, desc.uuid])355 }356 else { 357 await this._run(`INSERT INTO notes VALUES (?, ?, ?)`, [358 desc.uuid,359 desc.content.join('\n\n'),360 timestamp361 ]);362 }363 this._close();364 }365 async delete (uuid) {366 this._connect();367 await this._run(`DELETE FROM notes WHERE uuid = ?`, [uuid]);368 this._close();369 }370 _process_row (r) {371 return {372 uuid: r.uuid,373 content: r.content.split('\n\n'),374 date_updated: new Date(r.date_updated)375 }376 }377 async count_all () {378 this._connect();379 const rows = await this._run(`SELECT count(*) as ct FROM notes`);380 this._close();381 return rows[0];382 }383 async read_all (offset, limit) {384 if (offset === 'undefined') {385 offset = 0;386 }387 if (limit === 'undefined') {388 limit = 10;389 }390 this._connect();391 let results = await this._run(`SELECT * FROM notes ORDER BY datetime(date_updated) desc LIMIT ? OFFSET ?`, [limit, offset]);392 results = results.map(r => this._process_row(r));393 this._close();394 return results;395 }396 async read (uuid) {397 this._connect();398 const results = await this._run(`SELECT * FROM notes WHERE uuid = ?` , [uuid]);399 if (results.length > 0) {400 if (results.length > 1) {401 throw `Too many rows ${results.length} for UUID ${uuid}`;402 }403 return this._process_row(results[0]);404 }405 }406}407module.exports = {408 Version: Version,409 Tags: Tags,410 Images: Images,411 Notes: Notes,...

Full Screen

Full Screen

mongoClient.js

Source:mongoClient.js Github

copy

Full Screen

1"use strict"2var {MongoClient,ObjectID} = require('mongodb');3var assert = require('assert');4var log4js = require('log4js');5var logger = log4js.getLogger();6class MongoDb {7 constructor(host, port, db, user, pw){8 return new Promise((done, fail) => {9 var auth = (user && pw) ? (user+':'+pw+'@') : '';10 port = port || 27017;11 MongoClient.connect(`mongodb://${auth}${host}:${port}/${db}`, (err, db) => {12 assert.equal(null, err);13 this._connect = db;14 done(this);15 })16 });17 }18 convQuery(query){19 try{20 if(query.hasOwnProperty('_id')){21 if(query['_id']['$in']){22 query['_id']['$in'] = query['_id']['$in'].map((tId) => ObjectID(tId));23 }else{24 query['_id'] = ObjectID(query['_id']);25 }26 }27 }catch(e){28 logger.error(e.message);29 }30 return query;31 }32 insert(collect, doc, options){33 return new Promise((done, fail) => {34 if(this._connect && doc){35 var coll = this._connect.collection(collect);36 coll[(Array.isArray(doc) ? 'insertMany' : 'insert')](doc, options, (err, info) => {37 err && logger.error(err)38 assert.equal(null, err);39 //logger.info(result);40 done(info);41 });42 }else{43 fail();44 }45 });46 }47 remove(collect, query, options){48 return new Promise((done, fail) => {49 if(this._connect && query){50 var coll = this._connect.collection(collect);51 var ret = coll.removeMany(query, options);52 // conver object id53 this.convQuery(query);54 55 done();56 }else{57 fail();58 }59 });60 }61 findAndModify(collect, query, doc, options){62 return new Promise((done, fail) => {63 if(this._connect && query && doc){64 var coll = this._connect.collection(collect);65 //this.convQuery(query);66 options = options || {};67 coll.findOneAndUpdate(query, doc, options).then((data) => {68 done(data);69 }).catch((e) => {70 fail(e);71 });72 }else{73 fail();74 }75 });76 }77 upSert(collect, query, doc, options){78 return new Promise((done, fail) => {79 if(this._connect && doc){80 var coll = this._connect.collection(collect);81 // conver object id82 this.convQuery(query);83 84 options = options || {};85 options.w = 1;86 options.upsert = true;87 88 coll[(Array.isArray(doc) ? 'updateMany' : 'update')](query, doc,options, (err, info) => {89 err && logger.error(err)90 assert.equal(null, err);91 done(info);92 });93 }else{94 fail();95 }96 })97 }98 query(collect, query, options){99 //logger.info('test')100 return new Promise((done, fail) => {101 if(this._connect){102 var coll = this._connect.collection(collect);103 // conver object id104 this.convQuery(query);105 106 //logger.info(coll);107 coll.find(query, options).toArray((err, info) => {108 assert.equal(null, err);109 done(info);110 });111 }else{112 fail();113 }114 });115 }116 buildIndex(collect, keys, reserve, extras){117 return new Promise((done, fail) => {118 if(this._connect){119 var coll = this._connect.collection(collect);120 var index = {};121 Array.isArray(keys) ? keys.map((key) => {index[key]= (reserve ? -1 : 1)}) : (index[keys]=(reserve ? -1 : 1));122 return callback ? coll.ensureIndex(index, extras, (err, indexName) => {123 assert.equal(null, err);124 console.log('buildIndex:'+indexName)125 done(indexName);126 }) : coll.ensureIndex(index, extras);127 }else{128 fail();129 }130 });131 }132 update(collect, query, doc){133 return new Promise((done, fail) => {134 if(this._connect){135 // conver object id136 this.convQuery(query);137 var coll = this._connect.collection(collect);138 return coll.updateOne(query, doc, {w:1}).then((info) => {139 done(info);140 }).catch((e) => {141 fail(e)142 });143 }else{144 fail();145 }146 });147 }148 checkIndex(collect, option){149 return new Promise((done, fail) => {150 if(this._connect){151 var coll = this._connect.collection(collect);152 return coll.indexInformation(option || {full:true}, (err, info) => {153 assert.equal(null, err);154 done(info);155 });156 }else{157 fail();158 }159 });160 }161}...

Full Screen

Full Screen

cardinfo.js

Source:cardinfo.js Github

copy

Full Screen

1 /******************************************************************************************************************* 2 Ä«µåÇҺΠ¾È³»3 *******************************************************************************************************************/4 $( document ).ready(function() {5 $('[cardinfo]').click(function(e) {6 $('#sp-cardinfo, #sp-cardinfo-loading').remove();7 var _url = $(this).data('url');8 var _offset = $(this).offset();9 var _load = '<div id="sp-cardinfo-loading" style="top:'+ (_offset.top-24) +'px;left:'+ (_offset.left-7) +'px;">ºÒ·¯¿À´ÂÁß</div>';10 var _now = (document.documentElement && document.documentElement.scrollTop) || document.body.scrollTop;11 $('body').prepend( _load );12 $('#sp-cardinfo-loading').fadeIn('fast');13 $.ajax({14 type: 'get',15 dataType: 'html',16 url: _url,17 success: function(data){18 var $result = $(data).filter('#sp-result').html();19 $('body').append( $result );20 $('#sp-cardinfo').css('height',$(document).height()).fadeIn('fast');21 //$('#sp-cardinfo > ul').css({'top':_offset.top,'left':_offset.left - 600});22 $('#sp-cardinfo > ul').css('top',_now + 100);23 $('#sp-cardinfo-loading').fadeOut();24 /* ¿¬µ¿ */25 var _connect;26 var _connectdata;27 if( $('#sp-cardinfo [connect="¹«ÀÌÀÚÇÒºÎ"]').size() ){28 $('#sp-cardinfo [connect="¹«ÀÌÀÚÇÒºÎ"]').each(function( a ){29 if( $(this).data('connect') ){30 _connectdata = $(this).data('connect').split('^');31 if( _connectdata.length == 1 ){32 _connect = '';33 _connect += '<ul>';34 _connect += ' <p>'+ _connectdata[0] +'</p>';35 _connect += '</ul>';36 $('#sp-cardinfo [connectbox="¹«ÀÌÀÚÇÒºÎ"]').append( _connect );37 }else if( _connectdata.length == 2 ){38 _connect = '';39 _connect += '<ul>';40 _connect += ' <li class="sp-title">'+ _connectdata[0] +'</li>';41 _connect += ' <li class="sp-content">'+ _connectdata[1] +'</li>';42 _connect += '</ul>';43 $('#sp-cardinfo [connectbox="¹«ÀÌÀÚÇÒºÎ"]').append( _connect );44 }45 }46 });47 }48 if( $('#sp-cardinfo [connect="ºÎºÐ¹«ÀÌÀÚÇÒºÎ"]').size() ){49 $('#sp-cardinfo [connect="ºÎºÐ¹«ÀÌÀÚÇÒºÎ"]').each(function( a ){50 if( $(this).data('connect') ){51 _connectdata = $(this).data('connect').split('^');52 if( _connectdata.length == 1 ){53 _connect = '';54 _connect += '<ul>';55 _connect += ' <p>'+ _connectdata[0] +'</p>';56 _connect += '</ul>';57 $('#sp-cardinfo [connectbox="ºÎºÐ¹«ÀÌÀÚÇÒºÎ"]').append( _connect );58 }else if( _connectdata.length == 2 ){59 _connect = '';60 _connect += '<ul>';61 _connect += ' <li class="sp-title">'+ _connectdata[0] +'</li>';62 _connect += ' <li class="sp-content">'+ _connectdata[1] +'</li>';63 _connect += '</ul>';64 $('#sp-cardinfo [connectbox="ºÎºÐ¹«ÀÌÀÚÇÒºÎ"]').append( _connect );65 }66 }67 });68 }69 },70 error: function(xhr,status,error){71 $('#sp-cardinfo-loading').html('Àá½Ã ÈÄ ´Ù½Ã ½ÃµµÇØÁÖ¼¼¿ä');72 setTimeout(function(){73 $('#sp-cardinfo-loading').fadeOut('fast');74 }, 2000);75 },76 timeout: 300077 });78 });79 //KEY EVENT80 $(document).keydown(function(e) {81 if (e.keyCode == 27) {82 $('#sp-cardinfo').fadeOut('fast');83 }84 });85 //$(document).on('click', '#sp-cardinfo, #sp-cardinfo > ul > button', function(e) {86 $('#sp-cardinfo, #sp-cardinfo > ul > button').live('click', function(){87 $('#sp-cardinfo').fadeOut('fast');88 });89 //$(document).on('click', ''#sp-cardinfo > ul', function(e) {90 $('#sp-cardinfo > ul').live('click', function(e){91 e.stopPropagation();92 });93 //$(document).on('click', '#sp-cardinfo > ul > p > button', function(e) {94 $('#sp-cardinfo > ul > p > button').live('click',function(){95 var _index = $('#sp-cardinfo > ul > p > button').index( $(this) );96 $('#sp-cardinfo > ul > p > button').removeClass('-on');97 $('#sp-cardinfo > ul > p > button').eq(_index).addClass('-on');98 $('#sp-cardinfo > ul > li').removeClass('-on');99 $('#sp-cardinfo > ul > li').eq(_index).addClass('-on');100 });...

Full Screen

Full Screen

service.test.js

Source:service.test.js Github

copy

Full Screen

1/*global bridge,assert,suite,setup,teardown,test*/2/*jshint esnext:true, maxlen:false*/3suite('Service /', function() {4 var service = bridge.service;5 setup(function() {6 this.sinon = sinon.sandbox.create();7 });8 teardown(function() {9 this.sinon.restore();10 });11 suite('Service#method()', function() {12 var fakeMessage;13 var myService;14 setup(function() {15 myService = service('service-name');16 fakeMessage = {17 type: '_method',18 foo: 'foo',19 data: {20 name: 'my-method',21 args: ['a', 'b', 'c']22 },23 event: { ports: [] },24 respond: sinon.spy()25 };26 });27 teardown(function() {28 myService.destroy();29 });30 test('it responds to the message with the return value', function() {31 myService.method('my-method', () => 'value');32 myService.emit('_method', fakeMessage);33 sinon.assert.calledWith(fakeMessage.respond, 'value');34 });35 test('it applys arguments to the callback', function() {36 var spy = sinon.spy();37 myService.method('my-method', spy);38 myService.emit('_method', fakeMessage);39 sinon.assert.calledWith(spy, 'a', 'b', 'c');40 });41 test('it throws if no method is found', function(done) {42 myService.method('my-method', () => {});43 fakeMessage.data.name = 'unknown';44 try { myService.emit('_method', fakeMessage); }45 catch (e) { done(); }46 });47 });48 suite('on connect', function() {49 var fakeMessage;50 setup(function() {51 fakeMessage = {52 type: '_connect',53 data: {54 clientId: 123,55 service: 'service1'56 },57 event: { ports: [] },58 setSourcePort: sinon.spy(),59 respond: sinon.spy()60 };61 });62 teardown(function() {});63 test('it does not respond if the service name does not match', function() {64 fakeMessage.data.service = 'service3';65 var myService = service('service1');66 myService.emit('_connect', fakeMessage);67 sinon.assert.notCalled(fakeMessage.respond);68 myService = service('service2');69 myService.emit('_connect', fakeMessage);70 sinon.assert.notCalled(fakeMessage.respond);71 myService = service('service3');72 myService.emit('_connect', fakeMessage);73 sinon.assert.called(fakeMessage.respond);74 });75 test('it does not respond if no clientId was provided', function() {76 delete fakeMessage.data.clientId;77 var myService = service('service1');78 myService.emit('_connect', fakeMessage);79 sinon.assert.notCalled(fakeMessage.respond);80 fakeMessage.data.clientId = 123;81 myService.emit('_connect', fakeMessage);82 sinon.assert.called(fakeMessage.respond);83 });84 test('it does not respond if the client is already connected', function() {85 var myService = service('service1');86 myService.emit('_connect', fakeMessage);87 sinon.assert.called(fakeMessage.respond);88 fakeMessage.respond.reset();89 myService.emit('_connect', fakeMessage);90 sinon.assert.notCalled(fakeMessage.respond);91 });92 test('it responds on MessageChannel the Client and Service are not within Windows', function() {93 var service = bridge.service('service1');94 var port = new MessageChannel().port1;95 fakeMessage.event.ports = [port];96 // Client 197 fakeMessage.data.originEnv = 'Window';98 service.emit('_connect', fakeMessage);99 sinon.assert.notCalled(fakeMessage.setSourcePort);100 // Client 2101 fakeMessage.data.clientId = 1234;102 fakeMessage.data.originEnv = 'Worker';103 service.emit('_connect', fakeMessage);104 sinon.assert.calledWith(fakeMessage.setSourcePort, port);105 });106 });...

Full Screen

Full Screen

db.js

Source:db.js Github

copy

Full Screen

1const mongodb = require("mongodb");2const mongoClient = mongodb.MongoClient;3// 以下划线开头的，一般都是做为私有的来定义的。4function _connect(cb) {5 mongoClient.connect("mongodb://127.0.0.1:27017",{useUnifiedTopology:true},function (err,client) {6 if(err)7 console.log("网络连接错误");8 else{9 // console.log("成功");10 const db = client.db("lwy");11 cb(db)12 }13 })14}15// 插入一条记录16// coll:集合17// insertObj:插入的内容18// cb 插入成功以后的回调函数，用于返回结果19module.exports.insertOne = function (coll,insertObj,cb) {20 _connect(function (db) {21 db.collection(coll).insertOne(insertObj,cb)22 // db.collection(coll).insertOne(insertObj,function (err,results) {23 // cb(err,results);24 // })25 })26}27/*28* 根据条件，获得总文档数29* coll:指定集合30* whereObj:条件*/31module.exports.count = function (coll,whereObj,cb) {32 _connect(function (db) {33 db.collection(coll).countDocuments(whereObj,cb)34 })35}36module.exports.connect = _connect;37/*根据ID进行删除*/38module.exports.deleteOneById = function (coll,id,cb) {39 _connect(function (db) {40 db.collection(coll).deleteOne({41 _id:mongodb.ObjectId(id)42 },cb)43 })44}45/*根据ID进行修改*/46module.exports.updateOneById = function (coll,id,upObj,cb) {47 _connect(function (db) {48 db.collection(coll).updateOne({49 _id:mongodb.ObjectId(id)50 },upObj,cb)51 })52}53// 根据条件更改多条记录54module.exports.updateMany = function (coll,whereObj,upObj,cb) {55 _connect(function (db) {56 db.collection(coll).updateMany(whereObj,upObj,cb)57 })58}59module.exports.updateOne = function (coll,whereObj,upObj,cb) {60 _connect(function (db) {61 db.collection(coll).updateOne(whereObj,upObj,cb)62 })63}64// 根据ID获得相对应的信息65module.exports.findOneById = function (coll,id,cb) {66 _connect(function (db) {67 db.collection(coll).findOne({68 _id:mongodb.ObjectId(id)69 },cb)70 })71}72module.exports.findOne = function (coll,obj,cb) {73 _connect(function (db) {74 db.collection(coll).findOne(obj.whereObj,{projection: obj.getObj},cb)75 })76}77// 根据条件进行查找78module.exports.find = function (coll,obj,cb) {79 obj.whereObj = obj.whereObj || {};80 obj.getObj = obj.getObj || {};81 obj.sortObj = obj.sortObj || {};82 obj.skip = obj.skip || 0;83 obj.limit = obj.limit || 0;84 // console.log(obj)85 _connect(function (db) {86 db.collection(coll)87 .find(obj.whereObj)88 .project(obj.getObj)//通过0/1返回指定字段 0与1不可混用89 .skip(obj.skip)90 .limit(obj.limit)91 .sort(obj.sortObj)92 .toArray(cb)93 })94}95//查找字段去重96module.exports.distinct = function (coll,obj,cb) {97 obj.getObj = obj.getObj || {};98 _connect(function (db) {99 db.collection(coll)100 .distinct(obj.getObj)101 .then(cb)102 })103}104module.exports.connect = _connect;105// _connect(function (db) {106// console.log(db)...

Full Screen

Full Screen

bankmiss.js

Source:bankmiss.js Github

copy

Full Screen

1 /******************************************************************************************************************* 2 미확인 입금자3 *******************************************************************************************************************/4 $( document ).ready(function() {5 $('[bankmiss]').click(function(e) {6 $('#sp-bankmiss, #sp-bankmiss-loading').remove();7 var _url = $(this).data('url');8 var _offset = $(this).offset();9 var _load = '<div id="sp-bankmiss-loading" style="top:'+ (_offset.top-24) +'px;left:'+ (_offset.left-7) +'px;">불러오는중</div>';10 var _now = (document.documentElement && document.documentElement.scrollTop) || document.body.scrollTop;11 $('body').prepend( _load );12 $('#sp-bankmiss-loading').fadeIn('fast');13 $.ajax({14 type: 'get',15 dataType: 'html',16 url: _url,17 success: function(data){18 var $result = $(data).filter('#sp-result').html();19 $('body').append( $result );20 $('#sp-bankmiss').css('height',$(document).height()).fadeIn('fast');21 //$('#sp-bankmiss .sp-bankmiss-inside').css('marginTop',_offset.top);22 $('#sp-bankmiss .sp-bankmiss-inside').css('top',_now + 100);23 $('#sp-bankmiss-loading').fadeOut();24 /* 연동 */25 var _connect;26 var _connectdata;27 if( $('#sp-bankmiss [connect="미확인입금자"]').size() ){28 $('#sp-bankmiss [connect="미확인입금자"]').each(function( a ){29 if( $(this).data('connect') ){30 _connectdata = $(this).data('connect').split('^');31 if( _connectdata.length == 4 ){32 _connect = '';33 _connect += '<tr>';34 _connect += ' <td>'+ _connectdata[0] +'</td>';35 _connect += ' <td>'+ _connectdata[1] +'</td>';36 _connect += ' <td>'+ _connectdata[2] +'</td>';37 _connect += ' <td>'+ _connectdata[3] +'</td>';38 _connect += '</tr>';39 $('#sp-bankmiss [connectbox]').append( _connect );40 }41 }42 });43 }44 },45 error: function(xhr,status,error){46 $('#sp-bankmiss-loading').html('잠시 후 다시 시도해주세요');47 setTimeout(function(){48 $('#sp-bankmiss-loading').fadeOut('fast');49 }, 2000);50 },51 timeout: 300052 });53 });54 //KEY EVENT55 $(document).keydown(function(e) {56 if (e.keyCode == 27) {57 $('#sp-bankmiss').fadeOut('fast');58 }59 });60 //$(document).on('click', '#sp-bankmiss, #sp-bankmiss button', function(e) {61 $('#sp-bankmiss, #sp-bankmiss button').live('click', function(){62 $('#sp-bankmiss').fadeOut('fast');63 });64 //$(document).on('click', '#sp-bankmiss .sp-bankmiss-inside', function(e) {65 $('#sp-bankmiss .sp-bankmiss-inside').live('click', function(e){66 e.stopPropagation();67 });...

Full Screen

Full Screen

server.js

Source:server.js Github

copy

Full Screen

1var connect = require('express')2 //, gzip = require('connect-gzip')3 , bodyParser = require('body-parser')4 , cookieParser = require('cookie-parser')5 , serveStatic = require('serve-static')6 , compose = require('./util/compose')7 , parse = require('url').parse8var Application = module.exports = function Application(options) {9 if (!(this instanceof Application)) 10 return new Application()11 this._connect = connect(options)12 //this._connect.use(gzip.gzip())13 this._stack = []14}15var app = Application.prototype16app.serve = function serve(directory, options) {17 var mountPath18 19 if(options && options.mount) {20 mountPath = options.mount21 delete options.mount22 this._connect.use(mountPath, serveStatic(directory, options))23 } else {24 this._connect.use(serveStatic(directory, options))25 }26 return this27}28app.connect = function connect(fn) {29 if(!this._defaults) {30 this._defaults = true31 this._connect.use(cookieParser())32 this._connect.use(bodyParser.urlencoded({ extended:true }))33 }34 if(this._stack.length) {35 throw new Error('All connect middleware (.connect) must be added before any kent middleware (.use)')36 }37 38 this._connect.use(fn)39 return this40}41app.set = function set() {42 this._connect.set.apply(this._connect, arguments)43 return this44}45app.use = function use(fn) {46 if(fn._stack) this._stack.push.apply(this._stack, fn._stack)47 else this._stack.push(fn)48 return this49}50app.listen = function listen() {51 var fn = compose(this._stack)52 this._connect.use(function(req, res, next) {53 fn.call(createContext(req, res), next)()54 })55 return this._connect.listen.apply(this._connect, arguments)56}57function createContext(req, res) {58 var ctx = {59 req,60 res,61 body:req.body,62 cookies:{63 get:function(name) { return req.cookies[name] },64 set:function(name, value, options) { res.cookie(name, value, options) }65 },66 redirect:function(url) {67 res.writeHead(302, { Location:url })68 res.end()69 },70 params:{}71 }72 var parsedUrl = parse(req.url, true)73 ctx.url = parsedUrl.path74 ctx.path = parsedUrl.pathname75 ctx.query = parsedUrl.query76 ctx.host = req.headers.host77 ctx.site = req.protocol+'://'+ctx.host78 ctx.href = ctx.site+parsedUrl.path79 return ctx...

Full Screen

Full Screen

grid.js

Source:grid.js Github

copy

Full Screen

...27 addEdges() {28 for (let col = 0; col < this.size; col++) {29 for (let row = 0; row < this.size; row++) {30 const current = this._cellId(col, row)31 this._connect(current, col + 1, row) // right32 this._connect(current, col - 1, row) // left33 this._connect(current, col, row + 1) // bottom34 this._connect(current, col, row - 1) // top35 this._connect(current, col + 1, row + 1) // bottom-right36 this._connect(current, col + 1, row - 1) // top-right 37 this._connect(current, col - 1, row + 1) // bottom-left38 this._connect(current, col - 1, row - 1) // top-left39 }40 }41 }42 _cellId(y, x) {43 const startingIndex = 6544 const letter = String.fromCharCode(y + startingIndex)45 return `${letter}${x}`46 }47 _connect(node, y, x) {48 this.graph.connect(node, this._cellId(y, x))49 }...

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const { _connect } = require("qawolf");2const { _launch } = require("qawolf");3const { _create } = require("qawolf");4const { _test } = require("qawolf");5const { _run } = require("qawolf");6const { _close } = require("qawolf");7const { _teardown } = require("qawolf");8const { _setup } = require("qawolf");9const { _createBrowser } = require("qawolf");10const { _createPage } = require("qawolf");11const { _createContext } = require("qawolf");12const { _createBrowser } = require("qawolf");13const { _createPage } = require("qawolf");14const { _createContext } = require("qawolf");15const { _launchBrowser } = require("qawolf");16const { _launchPage } = require("qawolf");17const { _launchContext } = require("qawolf");18const { _runBrowser } = require("qawolf");19const { _runPage } = require("qawolf");20const { _runContext } = require("qawolf");

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const qawolf = require("qawolf");2const browser = await qawolf.launch();3const context = browser.contexts()[0];4const page = await context.newPage();5await page.type("input[name=\"q\"]", "qawolf");6await page.click("input[type=\"submit\"]");7await qawolf._connect(page, "test");8await browser.close();

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const { _connect } = require('qawolf');2const { chromium } = require('playwright');3(async () => {4 const browser = await chromium.launch();5 const context = await _connect(browser.wsEndpoint(), 'chromium');6 const page = await context.newPage();7})();8{9 "scripts": {10 },11 "dependencies": {12 }13}14 at CDPSession.send (D:\qawolf-test15 at async BrowserContext._createPageInContext (D:\qawolf-test16 at async BrowserContext.newPage (D:\qawolf-test17 at async Object._connect (D:\qawolf-test18 at async Object.<anonymous> (D:\qawolf-test\test.js:4:22)

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const { _connect } = require("qawolf");2const { _type } = require("qawolf");3_type("input[name='q']", "qawolf");4const { _click } = require("qawolf");5_click("input[value='Google Search']");6const { _close } = require("qawolf");7_close();8const { _select } = require("qawolf");9_select("select[name='q']", "qawolf");10const { _check } = require("qawolf");11_check("input[name='q']", "qawolf");12const { _uncheck } = require("qawolf");13_uncheck("input[name='q']", "qawolf");14const { _selectOption } = require("qawolf");15_selectOption("select[name='q']", "qawolf");16const { _selectOptions } = require("qawolf");17_selectOptions("select[name='q']", "qawolf");18const { _fill } = require("qawolf");19_fill("input[name='q']", "qawolf");20const { _press } = require("qawolf");21_press("input[name='q']", "qawolf");22const { _drag } = require("qawolf");23_drag("input[name='q']", "qawolf");24const { _hover } = require("qawolf");25_hover("input[name='q']", "qawolf");26const { _clear } = require("qawolf");27_clear("input[name='q']", "qawolf");28const {

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const qawolf = require("qawolf");2const browser = await qawolf.launch();3const context = await browser.newContext();4const page = await context.newPage();5await qawolf.stopVideos();6await browser.close();7}8}9}

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const qawolf = require("qawolf");2const browser = await qawolf.launch();3const element = await page.$("css selector");4const text = await page.evaluate(element => element.textContent, element);5await qawolf.stopVideos();6await browser.close();7console.log(text);8await qawolf.stopVideos();9await browser.close();10console.log(text);11await qawolf.launch()12await page.$(“css selector”)13await page.evaluate(element => element.textContent, element)14await qawolf.stopVideos();15await browser.close();16console.log(text);

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const { _connect } = require("qawolf");2_connect({3 launchOptions: { headless: false },4 contextOptions: {},5});6const { _launch } = require("qawolf");7const browser = await _launch({8 launchOptions: { headless: false },9 contextOptions: {},10});11const page = await browser.newPage();12await page.close();13await browser.close();14const { _context } = require("qawolf");15const context = await _context({16 launchOptions: { headless: false },17 contextOptions: {},18});19const page = await context.newPage();20await page.close();21await context.close();22const { _page } = require("qawolf");23const page = await _page({24 launchOptions: { headless: false },25 contextOptions: {},26});27await page.close();28const { _browser } = require("qawolf");29const browser = await _browser({30 launchOptions: { headless: false },31 contextOptions: {},32});33const page = await browser.newPage();34await page.close();35await browser.close();36const { chromium } = require("playwright");37const browser = await chromium.launch({38});39const context = await browser.newContext({40 "Mozilla/5.0 (Linux;

Full Screen

Full Screen

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run qawolf automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful