Consulta de todas las imágenes de nuestra base de datos

Clase 15 de 61 • Curso Profesional de Node.js y JavaScript 2016

Wilfredo Bardales

student•

Codigo añadido

jonathan diaz Diaz Diaz

student•

Deberia hacerce un refactor de codigo, creo que es mejor tener un archivo db solo para la conexion y ejecutar querys, y otros archivos que se pueden nombrar como las tablas y en esos si hacer las operaciones sobre la base de datos para no tener todo en el archivos ya que si fueran muchas tablas seria muy largo.

Nicolas Alejandro Herrera

student•

Estoy de acuerdo podria aplicarse GRASP

Wilfredo Bardales

student•

Min 6:22 no se nota el codigo

Luis Antonio Rodriguez Garcia

student•

el codigo es este:
let images = yield r.db(db).table(‘images’).orderby({
index: r.desc(‘createdAt’)
}).run(conn)

Armando Alamilla Cuellar

student•

Tengo un problema:

cuando pongo un 3 en el fixtures.getImages()
solo pasan 4 test y me aparece esto:

db-test » list all images

C:\Users\Armando\Desktop\Carpetas\Armando Alamilla Cuéllar\javascript 2016\AyA-gram-db\node_modules\rethinkdb\errors.js:23

Rejected promise returned by test. Reason:

ReqlQueryLogicError {
frames: [
1,
],
message: Expected type SEQUENCE but found FUNCTION:␊ VALUE FUNCTION in:␊ r.db("ayagram_5ZaFUT0pYcRY2Wcagh24ay").table("images").insert(function() { return {"description": "an #awesome picture with #tags #platzi", "url": "http://ayagram.test/undefined", "likes": 0, "liked": false, "user_id": "9eb48124-e927-4af8-9c06-3d6e4d44d8f1"}; })␊ ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^,
msg: Expected type SEQUENCE but found FUNCTION:␊ VALUE FUNCTION,
name: ‘ReqlQueryLogicError’,
}

ReqlQueryLogicError.ReqlError [as constructor] (node_modules/rethinkdb/errors.js:23:13)
ReqlQueryLogicError.ReqlRuntimeError [as constructor] (node_modules/rethinkdb/errors.js:90:51)
new ReqlQueryLogicError (node_modules/rethinkdb/errors.js:101:54)
mkErr (node_modules/rethinkdb/util.js:177:10)
TcpConnection.Connection._processResponse (node_modules/rethinkdb/net.js:152:16)
TcpConnection.Connection._data (node_modules/rethinkdb/net.js:122:12)
Socket.<anonymous> (node_modules/rethinkdb/net.js:689:32)
npm ERR! Test failed. See above for more details.

cuando no pongo nada y lo dejo vacío: fixtures.getImages()
los 5 test pasan

aquí está mi código
db.js:

'use strict'

const co = require('co')
const r = require('rethinkdb')
const Promise = require('bluebird')
const uuid = require('uuid-base62')
const utils = require('./utils')

const defaults = {
  host: 'localhost',
  port: 28015,
  db: 'ayagram'
}

class Db {
  constructor (options) {
    options = options || {}
    this.host = options.host || defaults.host
    this.port = options.port || defaults.port
    this.db = options.db || defaults.db
  }

  connect (callback) {
    this.connection = r.connect({
      host: this.host,
      port: this.port
    })

    this.connected = true

    let db = this.db
    let connection = this.connection

    let setup = co.wrap(function * () {
      let conn = yield connection

      let dbList = yield r.dbList().run(conn)
      if (dbList.indexOf(db) === -1) {
        yield r.dbCreate(db).run(conn)
      }

      let dbTables = yield r.db(db).tableList().run(conn)
      if (dbTables.indexOf('images') === -1) {
        yield r.db(db).tableCreate('images').run(conn)
        yield r.db(db).table('images').indexCreate('createdAt').run(conn)
      }

      if (dbTables.indexOf('users') === -1) {
        yield r.db(db).tableCreate('users').run(conn)
      }

      return conn
    })

    return Promise.resolve(setup()).asCallback(callback)
  }

  disconnect (callback) {
    if (!this.connected) {
      return Promise.reject(new Error('not connected')).asCallback(callback)
    }

    this.connected = false
    return Promise.resolve(this.connection)
      .then((conn) => conn.close())
  }

  saveImage (image, callback) {
    if (!this.connected) {
      return Promise.reject(new Error('not connected')).asCallback(callback)
    }

    let connection = this.connection
    let db = this.db

    let tasks = co.wrap(function * () {
      let conn = yield connection
      image.createdAt = new Date()
      image.tags = utils.extractTags(image.description)

      let result = yield r.db(db).table('images').insert(image).run(conn)

      if (result.errors > 0) {
        return Promise.reject(new Error(result.first_error))
      }

      image.id = result.generated_keys[0]

      yield r.db(db).table('images').get(image.id).update({
        public_id: uuid.encode(image.id)
      }).run(conn)

      let created = yield r.db(db).table('images').get(image.id).run(conn)

      return Promise.resolve(created)
    })

    return Promise.resolve(tasks()).asCallback(callback)
  }

  likeImage (id, callback) {
    if (!this.connected) {
      return Promise.reject(new Error('not connected')).asCallback(callback)
    }

    let connection = this.connection
    let db = this.db
    let imageId = uuid.decode(id)

    let tasks = co.wrap(function * () {
      let conn = yield connection

      let image = yield r.db(db).table('images').get(imageId).run(conn)
      yield r.db(db).table('images').get(imageId).update({
        liked: true,
        likes: image.likes + 1
      }).run(conn)

      let created = yield r.db(db).table('images').get(imageId).run(conn)
      return Promise.resolve(created)
    })

    return Promise.resolve(tasks()).asCallback(callback)
  }

  getImage (id, callback) {
    if (!this.connected) {
      return Promise.reject(new Error('not connected')).asCallback(callback)
    }

    let connection = this.connection
    let db = this.db
    let imageId = uuid.decode(id)

    let tasks = co.wrap(function * () {
      let conn = yield connection
      let image = yield r.db(db).table('images').get(imageId).run(conn)
      return Promise.resolve(image)
    })

    return Promise.resolve(tasks()).asCallback(callback)
  }

  getImages (callback) {
    if (!this.connected) {
      return Promise.reject(new Error('not connected')).asCallback(callback)
    }

    let connection = this.connection
    let db = this.db

    let tasks = co.wrap(function * () {
      let conn = yield connection

      let images = yield r.db(db).table('images').orderBy({
        index: r.desc('createdAt')
      }).run(conn)

      let result = yield images.toArray()

      return Promise.resolve(result)
    })

    return Promise.resolve(tasks()).asCallback(callback)
  }
}

module.exports = Db

db-test.js:

'use strict'

const test = require('ava')
const uuid = require('uuid-base62')
const r = require('rethinkdb')
const Db = require('../')
const fixtures = require('./fixtures')

test.beforeEach('setup database', async t => {
  const dbName = `ayagram_${uuid.v4()}`
  const db = new Db({db: dbName})
  await db.connect()
  t.context.db = db
  t.context.dbName = dbName
  t.true(db.connected, 'should be connected')
})

test.afterEach.always('cleanup database', async t => {
  let db = t.context.db
  let dbName = t.context.dbName

  await db.disconnect()
  t.false(db.connected, 'should be disconnected')

  let conn = await r.connect({})
  await r.dbDrop(dbName).run(conn)
})

test('save image', async t => {
  let db = t.context.db

  t.is(typeof db.saveImage, 'function', 'saveImage is function')

  let image = fixtures.getImage()

  let created = await db.saveImage(image)
  t.is(created.description, image.description)
  t.is(created.url, image.url)
  t.is(created.likes, image.likes)
  t.is(created.liked, image.liked)
  t.deepEqual(created.tags, ['awesome', 'tags', 'platzi'])
  t.is(created.user_id, image.user_id)
  t.is(created.public_id, uuid.encode(created.id))
  t.is(typeof created.id, 'string')
  t.truthy(created.createdAt)
})

test('like image', async t => {
  let db = t.context.db

  t.is(typeof db.likeImage, 'function', 'likeImage is a function')

  let image = fixtures.getImage()
  let created = await db.saveImage(image)
  let result = await db.likeImage(created.public_id)

  t.true(result.liked)
  t.is(result.likes, image.likes + 1)
})

test('get image', async t => {
  let db = t.context.db

  t.is(typeof db.getImage, 'function', 'getImage is a function')

  let image = fixtures.getImage()
  let created = await db.saveImage(image)
  let result = await db.getImage(created.public_id)

  t.deepEqual(created, result)
})

test('list all images', async t => {
  let db = t.context.db

  let images = fixtures.getImages(3)
  let saveImage = images.map(img => db.saveImage(img))
  let created = await Promise.all(saveImage)
  let result = await db.getImages()

  t.is(created.length, result.length)
})

Diego Forero

Team Platzi•

Porque estas pasando a getImages un numero en lugar de una función callback, la función que recibe el id es getImage, no getImages.

Armando Alamilla Cuellar

student•

¿En dónde puedo encontrar el código del proyecto?

Diego Forero

Team Platzi•

Este es el repo de un compañero que tomo el curso

Miguel Angel Espeso Alvarez

student•

Hola, me esta dando un error un test y no soy capaz de corregirlo.
Me da un error en un archivo de node_modules .
Alguien podria decirme a que se debe solo con el error de consola?
Gracias.

  4 passed
  1 failed

  db-test » get image

  C:\Users\victor\CURSOS\JAVASCRIPT-NODE\PROYECTO MICHAELGRAM\michaelgram-db\node_modules\base-x\index.js:47

  Rejected promise returned by test. Reason:

  TypeError {
    message: 'Cannot read property \'length\' of undefined',
  }

  decodeUnsafe (node_modules/base-x/index.js:47:16)
  Object.decode (node_modules/base-x/index.js:75:17)
  Object.decode (node_modules/uuid-base62/uuid-base62.js:67:53)
  Db.getImage (lib/db.js:141:24)
  Test.test [as fn] (test/db-test.js:68:25)
npm ERR! Test failed.  See above for more details.```

Miguel Angel Espeso Alvarez

student•

Ya resolvi este problema, al cambiar “user_id” por “publicId” ,
me deje una sin cambiar en el archivo db.js

Álvaro René Sánchez Serrano

student•

¿Qué es un hook exactamente ?

Ricardo Azpeitia P.

student•

Literalmente gancho.

Mas específicamente en este contexto es un punto donde puedes enganchar uno o varios eventos.

Álvaro René Sánchez Serrano

student•

¿Como un middleware?

Esteban Ponce de León

student•

¿Por qué arroja este error con el index?

Error: Index 'createdAt' on table 'platzigram_2hjdsjd...' was accessed before its construction was finished in: r.db('platzigram_2hjdsjd...').table('images').orderBy({'index': r.desc('createdAt')})

¿Omití algo?

Este fue el código:

// db.js setup

let dbTables = yield r.db(db).tableList().run(conn)
if (dbTables.indexOf('images') === -1) {
    yield r.db(db).tableCreate('images').run(conn)
    yield r.db(db).table('images').indexCreate('createdAt').run(conn)
}

// getImages

let images = yield r.db(db).table('images').orderBy({
    index: r.desc('createdAt')
}).run(conn)

Camilo Posada Angel

student•

Me pasa igual ¿Lo pudiste solucionar?

Amelia Yesenia Vergaray Dávila

student•

¿Alguien sabe a que se debe este error?

Error: Index createdAt on table twinsdev_1wDtpeI7V9JKlpZn9gIHBI.desarrollador was accessed before its construction was finished in:
r.db(“twinsdev_1wDtpeI7V9JKlpZn9gIHBI”).table(“desarrollador”).orderBy({“index”: r.desc(“createdAt”)})

Angel Ponce

student•

A mi no me error y todos mis test pasaron… y no se por que? Debería preocuparme? hice todo igual al profe @julian_duque

Camilo Posada Angel

student•

Arroja error el index

ReqlOpFailedError: IndexcreatedAton tableplatzigram_7gJwD2B7QMI0uNuhHr2N
OT.imageswas accessed before its construction was finished in:

Ignacio Emmanuel Mancilla Olivares

student•

¿Qué diferencia hay en y t.deepEqual?

Ignacio Emmanuel Mancilla Olivares

student•

Siempre escucho que se refiere a resolver una promesa, por el momento resolver una promesa entiendo que es un pedazo de código que tiene que esperar para seguir la ejecución y resolverla se refiere a ejecutarla. ¿Alguien podría decirme si estoy en lo correcto, es algo distito o bien hay algo más que agregar?

Diego Forero

Team Platzi•

Lo que mencionas es correcto, una promesa es una forma de hacer código asincrono, para no bloquear toda la ejecución de tu aplicación, cuando la promesa se resuelve (recibe los datos de la petición o hace la tarea que debía hacer) retorna esta respuesta al hilo principal de ejecución para mostrar por ejemplo los datos si es un request solicitando datos a un API

'use strict'

const co = require('co')
const r = require('rethinkdb')
const Promise = require('bluebird')
const uuid = require('uuid-base62')
const utils = require('./utils')

const defaults = {
  host: 'localhost',
  port: 28015,
  db: 'ayagram'
}

class Db {
  constructor (options) {
    options = options || {}
    this.host = options.host || defaults.host
    this.port = options.port || defaults.port
    this.db = options.db || defaults.db
  }

  connect (callback) {
    this.connection = r.connect({
      host: this.host,
      port: this.port
    })

    this.connected = true

    let db = this.db
    let connection = this.connection

    let setup = co.wrap(function * () {
      let conn = yield connection

      let dbList = yield r.dbList().run(conn)
      if (dbList.indexOf(db) === -1) {
        yield r.dbCreate(db).run(conn)
      }

      let dbTables = yield r.db(db).tableList().run(conn)
      if (dbTables.indexOf('images') === -1) {
        yield r.db(db).tableCreate('images').run(conn)
        yield r.db(db).table('images').indexCreate('createdAt').run(conn)
      }

      if (dbTables.indexOf('users') === -1) {
        yield r.db(db).tableCreate('users').run(conn)
      }

      return conn
    })

    return Promise.resolve(setup()).asCallback(callback)
  }

  disconnect (callback) {
    if (!this.connected) {
      return Promise.reject(new Error('not connected')).asCallback(callback)
    }

    this.connected = false
    return Promise.resolve(this.connection)
      .then((conn) => conn.close())
  }

  saveImage (image, callback) {
    if (!this.connected) {
      return Promise.reject(new Error('not connected')).asCallback(callback)
    }

    let connection = this.connection
    let db = this.db

    let tasks = co.wrap(function * () {
      let conn = yield connection
      image.createdAt = new Date()
      image.tags = utils.extractTags(image.description)

      let result = yield r.db(db).table('images').insert(image).run(conn)

      if (result.errors > 0) {
        return Promise.reject(new Error(result.first_error))
      }

      image.id = result.generated_keys[0]

      yield r.db(db).table('images').get(image.id).update({
        public_id: uuid.encode(image.id)
      }).run(conn)

      let created = yield r.db(db).table('images').get(image.id).run(conn)

      return Promise.resolve(created)
    })

    return Promise.resolve(tasks()).asCallback(callback)
  }

  likeImage (id, callback) {
    if (!this.connected) {
      return Promise.reject(new Error('not connected')).asCallback(callback)
    }

    let connection = this.connection
    let db = this.db
    let imageId = uuid.decode(id)

    let tasks = co.wrap(function * () {
      let conn = yield connection

      let image = yield r.db(db).table('images').get(imageId).run(conn)
      yield r.db(db).table('images').get(imageId).update({
        liked: true,
        likes: image.likes + 1
      }).run(conn)

      let created = yield r.db(db).table('images').get(imageId).run(conn)
      return Promise.resolve(created)
    })

    return Promise.resolve(tasks()).asCallback(callback)
  }

  getImage (id, callback) {
    if (!this.connected) {
      return Promise.reject(new Error('not connected')).asCallback(callback)
    }

    let connection = this.connection
    let db = this.db
    let imageId = uuid.decode(id)

    let tasks = co.wrap(function * () {
      let conn = yield connection
      let image = yield r.db(db).table('images').get(imageId).run(conn)
      return Promise.resolve(image)
    })

    return Promise.resolve(tasks()).asCallback(callback)
  }

  getImages (callback) {
    if (!this.connected) {
      return Promise.reject(new Error('not connected')).asCallback(callback)
    }

    let connection = this.connection
    let db = this.db

    let tasks = co.wrap(function * () {
      let conn = yield connection

      let images = yield r.db(db).table('images').orderBy({
        index: r.desc('createdAt')
      }).run(conn)

      let result = yield images.toArray()

      return Promise.resolve(result)
    })

    return Promise.resolve(tasks()).asCallback(callback)
  }
}

module.exports = Db

'use strict'

const test = require('ava')
const uuid = require('uuid-base62')
const r = require('rethinkdb')
const Db = require('../')
const fixtures = require('./fixtures')

test.beforeEach('setup database', async t => {
  const dbName = `ayagram_${uuid.v4()}`
  const db = new Db({db: dbName})
  await db.connect()
  t.context.db = db
  t.context.dbName = dbName
  t.true(db.connected, 'should be connected')
})

test.afterEach.always('cleanup database', async t => {
  let db = t.context.db
  let dbName = t.context.dbName

  await db.disconnect()
  t.false(db.connected, 'should be disconnected')

  let conn = await r.connect({})
  await r.dbDrop(dbName).run(conn)
})

test('save image', async t => {
  let db = t.context.db

  t.is(typeof db.saveImage, 'function', 'saveImage is function')

  let image = fixtures.getImage()

  let created = await db.saveImage(image)
  t.is(created.description, image.description)
  t.is(created.url, image.url)
  t.is(created.likes, image.likes)
  t.is(created.liked, image.liked)
  t.deepEqual(created.tags, ['awesome', 'tags', 'platzi'])
  t.is(created.user_id, image.user_id)
  t.is(created.public_id, uuid.encode(created.id))
  t.is(typeof created.id, 'string')
  t.truthy(created.createdAt)
})

test('like image', async t => {
  let db = t.context.db

  t.is(typeof db.likeImage, 'function', 'likeImage is a function')

  let image = fixtures.getImage()
  let created = await db.saveImage(image)
  let result = await db.likeImage(created.public_id)

  t.true(result.liked)
  t.is(result.likes, image.likes + 1)
})

test('get image', async t => {
  let db = t.context.db

  t.is(typeof db.getImage, 'function', 'getImage is a function')

  let image = fixtures.getImage()
  let created = await db.saveImage(image)
  let result = await db.getImage(created.public_id)

  t.deepEqual(created, result)
})

test('list all images', async t => {
  let db = t.context.db

  let images = fixtures.getImages(3)
  let saveImage = images.map(img => db.saveImage(img))
  let created = await Promise.all(saveImage)
  let result = await db.getImages()

  t.is(created.length, result.length)
})

  4 passed
  1 failed

  db-test » get image

  C:\Users\victor\CURSOS\JAVASCRIPT-NODE\PROYECTO MICHAELGRAM\michaelgram-db\node_modules\base-x\index.js:47

  Rejected promise returned by test. Reason:

  TypeError {
    message: 'Cannot read property \'length\' of undefined',
  }

  decodeUnsafe (node_modules/base-x/index.js:47:16)
  Object.decode (node_modules/base-x/index.js:75:17)
  Object.decode (node_modules/uuid-base62/uuid-base62.js:67:53)
  Db.getImage (lib/db.js:141:24)
  Test.test [as fn] (test/db-test.js:68:25)
npm ERR! Test failed.  See above for more details.```

// db.js setup

let dbTables = yield r.db(db).tableList().run(conn)
if (dbTables.indexOf('images') === -1) {
    yield r.db(db).tableCreate('images').run(conn)
    yield r.db(db).table('images').indexCreate('createdAt').run(conn)
}

// getImages

let images = yield r.db(db).table('images').orderBy({
    index: r.desc('createdAt')
}).run(conn)

Consulta de todas las imágenes de nuestra base de datos

Crea el backend de tu aplicación

Introducción y arquitectura de nuestro proyecto

Cómo crear una cuenta de Amazon Web Services y configurar S3 ( Almacenamiento de Archivos )

Usando el SDK de Amazon Web Services

Cómo agregar Standard ( Linter ) a nuestro código en JavaScript

Testing en JavaScript usando AVA

Prueba unitaria para validar un array

Uso de expresiones regulares para nuestras pruebas unitarias

Módulo de base de datos con RethinkDB

Introduccion a RethinkDB

Accediendo a nuestra base de datos Rethinkdb desde Node.js

Creación de test para RethinkDB y almacenamiento de ruta de imágenes

Almacenamiento de rutas de imágenes en RethinkDB

Completando el test para nuestro objeto imagen

Creación de un fixture para test de petición de imágenes

Petición de de imagen desde base de datos

Consulta de todas las imágenes de nuestra base de datos

Buenas prácticas de creación de usuarios en Backend (Encriptación con Hash)

Petición de un usuario desde base de datos

Autenticación de usuario mediante password

Control de errores mediante excepciones (Try, Catch, Throws )

Consulta de imágenes en relación a nombre de usuario

Consulta de imágenes en relación a tag

Preparando nuestro módulo para microservicios

Módulo del API de nuestra aplicación

Introducción a los Microservicios

Creación de rutas para microservicios

Creación de nuestro endpoint GET /picture

Creción de nuestro endpoint POST /picture

Creción de nuestro endpoint POST /picture/:id/like

Creción de nuestro endpoint GET /picture/list

Creción de nuestro endpoint GET /picture/tag

Creación de nuestro endpoint POST /user

Creación de nuestro endpoint GET /user-name

Creación de Tokens para nuestro API usando JSON Web Tokens

Limitando nuestros request esperando recibir un Token

Test de autenticación de usuario

Módulo de Client de nuestra aplicación

Creación de nuestro cliente

Implementando el perfil de usuario

Carga de imágenes desde nuestro cliente

Cómo implementar autenticación de usuarios con Passport

Configurando un middleware en express

Estrategia de autenticación local (password / contraseña )

Consulta, altas de usuarios y manejos de errores en autenticación

Autenticación con Facebook

Creación de un token del API a partir de autenticación por Facebook

Manejo de sesiones de usuarios

Integración con nuestro Frontend

Consulta y alta de imagenes

Implementación de perfil de usuario

RealTime con Socket.io

Implementación de de Socket.io junto con RethinkDB

Escuchar un evento y mostrar los cambios en frontend

Lleva tu proyecto a producción

Introduccion a Vagrant

Creando nuestra primer maquina virtual con Vagrant

Introduccion a Ansible

Creando nuestro primer rol de ansible

Creando nuestro primer playbook para despliegue

Crear tareas para Platzigram dentro de Ansible

Crear tareas para el resto de los proyectos

Creación de servicios de upstart

Introducción a NGINX

Creación de rutas para nuestros microservicios

Llevando nuestro proyecto a Digital Ocean

Dominio y proyecto en producción

Terminaste este curso, tenemos buenas noticias, entra y entérate.