Almacenamiento de rutas de imágenes en RethinkDB

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

Resumen

Primero una acotación, no vamos a guardar directamente nuestras imágenes en RethinkDB, sería algo contraproducente almacenar un binario (imagen) debió a su capacidad realtime.

Lo que si vamos a almacenar, es precisamente la URL de donde estará almacenada esa imagen, que de hecho, será por medio de Amazon S3, aquí nos enfocamos en entender cómo será esa inserción a nuestra base de datos con node, mediante los métodos .table() y .insert() respectivamente.

JAIME URQUIZU

student•

Muy mal… a ver, ¿de dónde sale la base de datos ‘platzigram’ que tiene en RethinkDB?, y lo que es peor… cuando hace en data explorer r.db(‘platzigram’).table(‘images’).insert(’(…)’)… ¿cómo se ha creado y cuándo la tabla images? En el test no sale… muy mal…

Sebastian Diaz

student•

Cada vez que se ejecutan los test se crea una db , esta db se elimina siempre que ejecuten o no los test, si lo que quieres es que puedas ver los datos creados en ls db, solo debe comentar o eliminar la siguiente parte del codigo:

test.after.always('cleanup database', async t => {
  let conn = await r.connect({})
  await r.dbDrop(dbName).run(conn)
})

eso si ten en cuenta que de acuerdo a la logica creada por el profe cada que ejecutes un test se va a crear una db nueva, por lo que si corres 10 veces el comando npm test ps vas a tener 10 db en rethinkdb.

Armando Alamilla Cuellar

student•

Necesito ayuda, un test no pasa
En la consola me aparece lo siguiente:
1 passed
1 failed

db-test » save image

C:\Users\Armando\Desktop\Carpetas\Armando Alamilla Cuéllar\javascript 2016\AyA-gram-db\test\db-test.js:42

41: (typeof , ‘string’)
42: t.truthy(created.createdAt)
43: })

Value is not truthy:

undefined

created.createdAt
=> undefined

created
=> {
createAd: Date 2018-02-10 02:29:08 900ms UTC {},
id: ‘8a2959f2-f86d-49c9-b9c8-ca10bf55cc64’,
liked: false,
likes: 0,
url: ‘’,
user_id: ‘26a46d9e-e94a-4da0-b8e4-af0f38ada420’,
}
npm ERR! Test failed. See above for more details.

Este es mi código

db.js:

'use strict'

const co = require('co')
const r = require('rethinkdb')
const Promise = require('bluebird')

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)
      }

      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.createAd = new Date()

      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]

      return Promise.resolve(image)
    })

    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 dbName = `ayagram_${uuid.v4()}`
const db = new Db({db: dbName})

test.before('setup database', async t => {
  await db.connect()
  t.true(db.connected, 'should be connected')
})

test.after('disconnect database', async t => {
  await db.disconnect()
  t.false(db.connected, 'should be disconnected')
})

test.after.always('cleanup database', async t => {
  let conn = await r.connect({})
  await r.dbDrop(dbName).run(conn)
})

test('save image', async t => {
  t.is(typeof db.saveImage, 'function', 'saveImage is function')

  let image = {
    url: `https://ayagram.test/${uuid.v4()}.jpg`,
    likes: 0,
    liked: false,
    user_id: uuid.uuid()
  }

  let created = await db.saveImage(image)
  t.is(created.url, image.url)
  t.is(created.likes, image.likes)
  t.is(created.liked, image.liked)
  t.is(created.user_id, image.user_id)
  t.is(typeof created.id, 'string')
  t.truthy(created.createdAt)
})

Diego Forero

Team Platzi•

En el código tienes createAt y en el test createdAt, revisa cual esta mal escrito respecto a tu modelo y con eso debe funciona.

Armando Alamilla Cuellar

student•

Cómo no lo noté antes.
¡Muchas gracias! 😃

Wilfredo Bardales

student•

codigo añadido
-Creacion de test para RethinkDB y almacenamiento
-Completando el test para nuestro objeto imagen

Esteban Ponce de León

student•

El atributo .errors viene dado a partir de la conexión con rethinkdb?

CARLOS GUZMAN

student•

Hola, el atributo errors, hace parte del objeto que devuelve la promesa que inserta el registro, si haces la prueba en el data explorer, insertando un registro, notarás que devuelve un objeto y una de las propiedades del objeto es

{ "deleted": 0 , **"errors": 0 ,** "generated_keys": [ "40535566-a14d-4358-a515-732273cfb68f" ] , "inserted": 1 , "replaced": 0 , "skipped": 0 , "unchanged": 0 }

Walter Camaly

student•

es posible hacer una asignación de la tabla a una variable para reutilizar en el código

<code> let  tableImages = r.db(db).table('images')
            tableImages.insert(images).run(conn)

Daniel Hernandez

student•

¿Entonces siempre que utilicemos nuestra base de datos lo vamos a hacer a través de tests?

Diego Forero

Team Platzi•

No, lo que estamos haciendo es crear una prueba con el resultado que esperamos al guardar una imagen, en este caso es que la ruta de la imagen quede guardada en la base de datos, por esto primero se hace el test, luego se desarrolla toda la funcionalidad para que el test pase.

Daniel Hernandez

student•

Muchas gracias por la aclaración

'use strict'

const co = require('co')
const r = require('rethinkdb')
const Promise = require('bluebird')

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)
      }

      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.createAd = new Date()

      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]

      return Promise.resolve(image)
    })

    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 dbName = `ayagram_${uuid.v4()}`
const db = new Db({db: dbName})

test.before('setup database', async t => {
  await db.connect()
  t.true(db.connected, 'should be connected')
})

test.after('disconnect database', async t => {
  await db.disconnect()
  t.false(db.connected, 'should be disconnected')
})

test.after.always('cleanup database', async t => {
  let conn = await r.connect({})
  await r.dbDrop(dbName).run(conn)
})

test('save image', async t => {
  t.is(typeof db.saveImage, 'function', 'saveImage is function')

  let image = {
    url: `https://ayagram.test/${uuid.v4()}.jpg`,
    likes: 0,
    liked: false,
    user_id: uuid.uuid()
  }

  let created = await db.saveImage(image)
  t.is(created.url, image.url)
  t.is(created.likes, image.likes)
  t.is(created.liked, image.liked)
  t.is(created.user_id, image.user_id)
  t.is(typeof created.id, 'string')
  t.truthy(created.createdAt)
})

Almacenamiento de rutas de imágenes en RethinkDB

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.