How to use knex method in argos

Best JavaScript code snippet using argos

index.js

Source:index.js Github

copy

Full Screen

...18 return migration.reset();19}20function insertPosts() {21 // ToDo: Get rid of pyramid of doom22 return when(knex('posts').insert(DataGenerator.forKnex.posts).then(function () {23 return knex('tags').insert(DataGenerator.forKnex.tags).then(function () {24 return knex('posts_tags').insert(DataGenerator.forKnex.posts_tags);25 });26 }));27}28function insertMorePosts(max) {29 var lang,30 status,31 posts = [],32 promises = [],33 i, j, k = 0;34 max = max || 50;35 for (i = 0; i < 2; i += 1) {36 lang = i % 2 ? 'en' : 'fr';37 posts.push(DataGenerator.forKnex.createGenericPost(k++, null, lang));38 for (j = 0; j < max; j += 1) {39 status = j % 2 ? 'draft' : 'published';40 posts.push(DataGenerator.forKnex.createGenericPost(k++, status, lang));41 }42 }43 return sequence(_.times(posts.length, function(index) {44 return function() {45 return knex('posts').insert(posts[index]);46 }47 }));48}49function insertMorePostsTags(max) {50 max = max || 50;51 return when.all([52 // PostgreSQL can return results in any order53 knex('posts').orderBy('id', 'asc').select('id'),54 knex('tags').select('id', 'name')55 ]).then(function (results) {56 var posts = _.pluck(results[0], 'id'),57 injectionTagId = _.chain(results[1])58 .where({name: 'injection'})59 .pluck('id')60 .value()[0],61 promises = [],62 i;63 if (max > posts.length) {64 throw new Error('Trying to add more posts_tags than the number of posts.');65 }66 for (i = 0; i < max; i += 1) {67 promises.push(DataGenerator.forKnex.createPostsTags(posts[i], injectionTagId));68 }69 return sequence(_.times(promises.length, function(index) {70 return function() {71 return knex('posts_tags').insert(promises[index]);72 };73 }));74 });75}76function insertDefaultUser() {77 var users = [],78 userRoles = [];79 users.push(DataGenerator.forKnex.createUser(DataGenerator.Content.users[0]));80 userRoles.push(DataGenerator.forKnex.createUserRole(1, 1));81 return knex('users')82 .insert(users)83 .then(function () {84 return knex('roles_users').insert(userRoles);85 });86}87function insertEditorUser() {88 var users = [],89 userRoles = [];90 users.push(DataGenerator.forKnex.createUser(DataGenerator.Content.users[1]));91 userRoles.push(DataGenerator.forKnex.createUserRole(2, 2));92 return knex('users')93 .insert(users)94 .then(function () {95 return knex('roles_users').insert(userRoles);96 });97}98function insertAuthorUser() {99 var users = [],100 userRoles = [];101 users.push(DataGenerator.forKnex.createUser(DataGenerator.Content.users[2]));102 userRoles.push(DataGenerator.forKnex.createUserRole(3, 3));103 return knex('users')104 .insert(users)105 .then(function () {106 return knex('roles_users').insert(userRoles);107 });108}109function insertDefaultApp() {110 var apps = [];111 apps.push(DataGenerator.forKnex.createApp(DataGenerator.Content.apps[0]));112 return knex('apps')113 .insert(apps)114 .then(function () {115 return knex('permissions_apps')116 .insert({117 app_id: 1,118 permission_id: 1119 });120 });121}122function insertApps() {123 return knex('apps').insert(DataGenerator.forKnex.apps).then(function () {124 return knex('app_fields').insert(DataGenerator.forKnex.app_fields);125 });126}127function insertAppWithSettings() {128 var apps = [], app_settings = [];129 apps.push(DataGenerator.forKnex.createApp(DataGenerator.Content.apps[0]));130 app_settings.push(DataGenerator.forKnex.createAppSetting(DataGenerator.Content.app_settings[0]));131 app_settings.push(DataGenerator.forKnex.createAppSetting(DataGenerator.Content.app_settings[1]));132 return knex('apps').insert(apps, 'id')133 .then(function (results) {134 var appId = results[0];135 for (var i = 0; i < app_settings.length; i++) {136 app_settings[i].app_id = appId;137 }138 return knex('app_settings').insert(app_settings);139 });140}141function insertAppWithFields() {142 var apps = [], app_fields = [];143 apps.push(DataGenerator.forKnex.createApp(DataGenerator.Content.apps[0]));144 app_fields.push(DataGenerator.forKnex.createAppField(DataGenerator.Content.app_fields[0]));145 app_fields.push(DataGenerator.forKnex.createAppField(DataGenerator.Content.app_fields[1]));146 return knex('apps').insert(apps, 'id')147 .then(function (results) {148 var appId = results[0];149 for (var i = 0; i < app_fields.length; i++) {150 app_fields[i].app_id = appId;151 }152 return knex('app_fields').insert(app_fields);153 });154}155function insertDefaultFixtures() {156 return insertDefaultUser().then(function () {157 return insertPosts()158 }).then(function () {159 return insertApps();160 });161}162function loadExportFixture(filename) {163 var filepath = path.resolve(__dirname + '/fixtures/' + filename + '.json');164 return nodefn.call(fs.readFile, filepath).then(function (fileContents) {165 var data;166 // Parse the json data...

Full Screen

Full Screen

knex.js

Source:knex.js Github

copy

Full Screen

1const bcryptjs = require('bcryptjs');2const {3 User,4 Category,5 Company,6 Image,7 Address,8 Role,9 ClientsCompanies,10 Product,11 ProductImages,12 Payment,13 Order,14 OrderDetail,15 UserAuth,16 AuthClaims,17} = require('../models');18const {19 getClaimsByClientCompanyID,20 selectProductsByIds,21} = require('../../api/helpers/sql');22const permissions = async (db, trx, role, claims, user_id, company_id) => {23 const [roleData] = await Role.findBy({ role });24 const [client_company_id] = await trx('clients_companies').insert(25 ClientsCompanies.serialize(26 new ClientsCompanies(roleData.id, user_id, company_id)27 ),28 'id'29 );30 return Promise.all(31 claims.map(({ _id }) =>32 trx('user_auth').insert(33 UserAuth.serialize(new UserAuth(client_company_id, _id))34 )35 )36 );37};38function KnexPersist(db, class_, table) {39 return {40 async save(obj) {41 const is_update = obj.id && (await this.get(obj.id));42 if (is_update) {43 await this._update(obj.id, obj);44 return 'update';45 }46 await this._create(obj);47 return 'create';48 },49 async delete(obj_id) {50 return db(table).where('id', obj_id).del();51 },52 async deleteAll() {53 return db(table).del();54 },55 async get(obj_id) {56 return db(table).where('id', obj_id).first();57 },58 async findBy(where) {59 return db(table).where(where);60 },61 async getAll(order_by = 'desc') {62 return db.select('*').from(table).orderBy('created_at', order_by);63 },64 async first() {65 return db(table).first();66 },67 async _create(obj) {68 return db(table).insert(obj);69 },70 async _update(obj_id, obj) {71 return db(table)72 .where('id', obj_id)73 .update({74 ...obj,75 updated_at: new Date(),76 });77 },78 async raw(query) {79 return db.raw(query);80 },81 };82}83function UserKnexPersist(db) {84 return {85 ...KnexPersist(db, User, 'users'),86 async _create(obj) {87 const password = await bcryptjs.hash(obj.salt + obj.password, 10);88 return db('users').insert({ ...obj, password });89 },90 };91}92function CompanyKnexPersist(db) {93 const table = 'companies';94 return {95 ...KnexPersist(db, Company, table),96 async _create(obj) {97 // eslint-disable-next-line no-unused-vars98 const { token, ...company } = obj;99 return db.transaction(async (trx) => {100 const claims = await AuthClaims.getAll();101 const [company_id] = await db('companies').insert(company, 'id');102 return permissions(db, trx, 'admin', claims, obj.user_id, company_id);103 });104 },105 async trx_client(obj) {106 return db.transaction(async (trx) => {107 const client_claims = [108 'may_manager_profile',109 'may_manager_order',110 'authenticated',111 ];112 const claim = (await AuthClaims.getAll()).filter(({ _claim }) =>113 client_claims.includes(_claim)114 );115 return permissions(116 db,117 trx,118 'client',119 claim,120 obj.user_id,121 obj.company_id122 );123 });124 },125 };126}127function ImageKnexPersist(db) {128 return {129 ...KnexPersist(db, Image, 'images'),130 };131}132function AddressKnexPersist(db) {133 return {134 ...KnexPersist(db, Address, 'addresses'),135 };136}137function RoleKnexPersist(db) {138 return {139 ...KnexPersist(db, Role, 'roles'),140 };141}142function ClientsCompaniesKnexPersist(db) {143 return {144 ...KnexPersist(db, ClientsCompanies, 'clients_companies'),145 };146}147function ProductKnexPersist(db) {148 return {149 ...KnexPersist(db, Product, 'products'),150 };151}152function ProductImagesKnexPersist(db) {153 return {154 ...KnexPersist(db, ProductImages, 'product_images'),155 };156}157function PaymentKnexPersist(db) {158 return {159 ...KnexPersist(db, Payment, 'payments'),160 };161}162function OrderDetailKnexPersist(db) {163 return {164 ...KnexPersist(db, OrderDetail, 'order_detail'),165 };166}167function OrderKnexPersist(db) {168 return {169 ...KnexPersist(db, Order, 'orders'),170 async _create(obj) {171 return db.transaction(async (trx) => {172 const { items, ...order } = obj;173 if (items.length) {174 const ids = items.map(({ id }) => id);175 const { rows: products } = await Product.raw(176 selectProductsByIds(ids)177 );178 if (!products.length) {179 return {180 statusCode: 404,181 data: { message: 'Invalid products id!' },182 };183 }184 const validated_product = products.map((product) => {185 const { quantity } = items.find((item) => item.id === product.id);186 return {187 ...product,188 quantity,189 total: product.price * quantity,190 };191 });192 const total = validated_product.reduce((a, n) => a + n.total, 0);193 const [order_data] = await trx('orders').insert(194 { ...order, total },195 '*'196 );197 const detail = await Promise.all(198 validated_product.map(async ({ name, price, type, quantity }) =>199 trx('order_detail').insert(200 OrderDetail.serialize(201 new OrderDetail(order_data.id, name, price, type, quantity)202 ),203 '*'204 )205 )206 );207 return 'Order successfully created!';208 }209 throw Error('Missing order items!');210 });211 },212 };213}214function CategoryKnexPersist(db) {215 return {216 ...KnexPersist(db, Category, 'categories'),217 };218}219function AuthClaimsKnexPersist(db) {220 return {221 ...KnexPersist(db, AuthClaims, 'auth_claims'),222 };223}224function UserAuthKnexPersist(db) {225 return {226 ...KnexPersist(db, UserAuth, 'user_auth'),227 async getAuth(user_id) {228 const client_company = await ClientsCompanies.findBy({ user_id });229 return Promise.all(230 client_company.map(async ({ _id, _role_id, _company_id }) => {231 const userClaim = await User.raw(getClaimsByClientCompanyID(_id));232 const claims = userClaim.rows.map(({ claim }) => claim);233 return {234 company: Company.serialize(await Company.fetch(_company_id)),235 role: (await Role.fetch(_role_id))._role,236 claims,237 };238 })239 );240 },241 };242}243module.exports = {244 UserKnexPersist,245 CategoryKnexPersist,246 CompanyKnexPersist,247 ImageKnexPersist,248 AddressKnexPersist,249 RoleKnexPersist,250 ClientsCompaniesKnexPersist,251 ProductKnexPersist,252 ProductImagesKnexPersist,253 PaymentKnexPersist,254 OrderKnexPersist,255 OrderDetailKnexPersist,256 AuthClaimsKnexPersist,257 UserAuthKnexPersist,...

Full Screen

Full Screen

jwtAuth-Service.js

Source:jwtAuth-Service.js Github

copy

Full Screen

1const bcrypt = require("bcryptjs");23const jwtAuthService = {4 updateObs(knex, updateID, updateUser, updateData) {5 return knex(updateUser)6 .where(updateID)7 .update(updateData)8 },9 delObs(knex, delObs, user) {10 return knex(user)11 .where(delObs)12 .delete();13 },14 addObsData(knex, newObs, user) {15 16 return knex(user)17 .insert(newObs)18 .returning('*')19 .then(rows => rows[0])20 },21 getJwtUsers(knex) {22 return knex.select('*').from('users')23 },24 addJwtUsers(knex, newUser) {25 return knex26 .insert(newUser)27 .into('users')28 },29 addJwtUserData(knex, user_name, user_email) {30 return Promise.all([31 knex32 .schema33 .createTable(user_name, userData => {34 userData.increments('id', { primaryKey: true })35 userData.string('icao')36 userData.string('obs_date_time')37 userData.string('wind')38 userData.string('vis')39 userData.string('clouds')40 userData.string('wx')41 userData.string('tmp')42 userData.string('dp')43 userData.string('remarks')44 userData.string('user_email')45 46 })47 .then(function(){48 return knex(user_name)49 .insert({50 'user_email': user_email,51 'icao': 'KATL',52 'obs_date_time': '161855Z',53 'wind': '10015G25KT',54 'vis': '2SM',55 'clouds': 'SKC FEW001 SCT050 BKN100 OVC200',56 'wx': '+TSRA FG',57 'tmp': '10',58 'dp': '09',59 'remarks': 'This is ONLY an example!'60 })61 .catch(err => {62 console.log(err) ...

Full Screen

Full Screen

fixtures.js

Source:fixtures.js Github

copy

Full Screen

1'use strict'2module.exports = {3 setupTables (knex) {4 const tables = [5 knex.schema.createTable('videos', function (table) {6 table.increments()7 table.timestamps()8 table.integer('vid')9 table.string('title')10 table.string('uri')11 table.integer('category_id')12 table.timestamp('deleted_at').nullable()13 }),14 knex.schema.createTable('posts', function (table) {15 table.increments()16 table.timestamps()17 table.string('title')18 table.string('uri')19 table.integer('category_id')20 table.timestamp('deleted_at').nullable()21 }),22 knex.schema.createTable('images', function (table) {23 table.increments()24 table.timestamps()25 table.string('uri')26 table.integer('imageable_id')27 table.string('imageable_type')28 table.string('storage_path')29 table.timestamp('deleted_at').nullable()30 }),31 knex.schema.createTable('categories', function (table) {32 table.increments()33 table.timestamps()34 table.string('title')35 table.integer('all_views')36 table.integer('categorizable_id')37 table.string('categorizable_type')38 table.timestamp('deleted_at').nullable()39 }),40 knex.schema.createTable('comments', function (table) {41 table.increments()42 table.timestamps()43 table.string('text')44 table.integer('commentable_id')45 table.string('commentable_type')46 table.integer('responsible_id')47 table.string('responsible_type')48 table.timestamp('deleted_at').nullable()49 }),50 knex.schema.createTable('tags', function (table) {51 table.increments()52 table.string('title')53 table.string('color').nullable()54 table.integer('taggable_id')55 table.string('taggable_type')56 table.timestamps()57 table.timestamp('deleted_at').nullable()58 }),59 knex.schema.createTable('reactions', function (table) {60 table.increments()61 table.string('reaction')62 table.integer('reactionable_id')63 table.string('reactionable_type')64 table.timestamps()65 table.timestamp('deleted_at').nullable()66 }),67 knex.schema.createTable('issues', function (table) {68 table.increments()69 table.string('title')70 table.string('description')71 table.timestamps()72 table.timestamp('deleted_at').nullable()73 })74 ]75 return Promise.all(tables)76 },77 dropTables (knex) {78 const tables = [79 knex.schema.dropTable('videos'),80 knex.schema.dropTable('posts'),81 knex.schema.dropTable('comments'),82 knex.schema.dropTable('tags'),83 knex.schema.dropTable('images'),84 knex.schema.dropTable('reactions'),85 knex.schema.dropTable('issues'),86 knex.schema.dropTable('categories')87 ]88 return Promise.all(tables)89 },90 createRecords (knex, table, values) {91 return knex.table(table).insert(values).returning('id')92 },93 truncate (knex, table) {94 return knex.table(table).truncate()95 },96 up (knex) {97 return this.setupTables(knex)98 },99 down (knex) {100 return this.dropTables(knex)101 }...

Full Screen

Full Screen

provider.js

Source:provider.js Github

copy

Full Screen

1const {2 UserKnexPersist,3 CategoryKnexPersist,4 CompanyKnexPersist,5 ImageKnexPersist,6 AddressKnexPersist,7 RoleKnexPersist,8 ClientsCompaniesKnexPersist,9 ProductKnexPersist,10 ProductImagesKnexPersist,11 PaymentKnexPersist,12 OrderKnexPersist,13 OrderDetailKnexPersist,14 AuthClaimsKnexPersist,15 UserAuthKnexPersist,16} = require('./knex');17const { db } = require('../../db');18const { PersistorSingleton } = require('./persist');19class PersistorProvider {20 static getPersistor() {21 if (PersistorProvider.instance) {22 return PersistorProvider.instance;23 }24 return new PersistorSingleton({25 User: [UserKnexPersist, db],26 Category: [CategoryKnexPersist, db],27 Company: [CompanyKnexPersist, db],28 Image: [ImageKnexPersist, db],29 Address: [AddressKnexPersist, db],30 Role: [RoleKnexPersist, db],31 ClientsCompanies: [ClientsCompaniesKnexPersist, db],32 Product: [ProductKnexPersist, db],33 ProductImages: [ProductImagesKnexPersist, db],34 Payment: [PaymentKnexPersist, db],35 Order: [OrderKnexPersist, db],36 OrderDetail: [OrderDetailKnexPersist, db],37 AuthClaims: [AuthClaimsKnexPersist, db],38 UserAuth: [UserAuthKnexPersist, db],39 });40 }41}...

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const knex = require('knex');2const config = require('./knexfile');3const db = knex(config.development);4db('users')5 .then(users => {6 console.log(users);7 })8 .catch(err => {9 console.log(err);10 });

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1module.exports = function (argosy) {2 .accept({role: 'math', cmd: 'sum'})3 .map(function (msg, respond) {4 respond(null, {answer: msg.left + msg.right})5 })6}7### argosy.accept(pattern)8### argosy.accept(pattern).map(fn)9### argosy.accept(pattern).map(fn).map(fn)

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1var argos = require('knex')({2 connection: {3 }4});5var knex = require('./knexfile.js');6var argos = require('knex')(knex['development']);7var knex = require('./knexfile.js');8var argos = require('knex')(knex['development']);9var knex = require('./knexfile.js');10var argos = require('knex')(knex['development']);11var knex = require('./knexfile.js');12var argos = require('knex')(knex['development']);13var knex = require('./knexfile.js');14var argos = require('knex')(knex['development']);15var knex = require('./knexfile.js');16var argos = require('knex')(knex['development']);17var knex = require('./knexfile.js');18var argos = require('knex')(knex['development']);19var knex = require('./knexfile.js');20var argos = require('knex')(knex['development']);21var knex = require('./knexfile.js');22var argos = require('knex')(knex['development']);23var knex = require('./knexfile.js');24var argos = require('knex')(knex['development']);

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 argos 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