api: flesh initial version of the backend api (just a test)

Pedro Lucas Porcellis porcellis@eletrotupi.com 6 months ago 634e68b8ab478e7ccb51cd03e1af8382cc520611

Parents: 36300f0

12 file(s) changed

api/migrations/001_initial_schema.sql +23 -0
api/orbit.db +0 -0
api/package.json +3 -3
api/src/app.js +4 -10
api/src/create-app.js +21 -0
api/src/db.js +4 -3
api/src/routes/mood.js +6 -6
api/src/routes/users.js +5 -5
api/src/setup-db.js +37 -0
api/tests/mood.test.js +90 -0
api/tests/test-helper.js +24 -0
api/tests/users.test.js +68 -0

api/migrations/001_initial_schema.sql

@@ -0,0 +1,24 @@
  + -- Users table
  + CREATE TABLE IF NOT EXISTS users (
  +   id INTEGER PRIMARY KEY AUTOINCREMENT,
  +   email TEXT UNIQUE NOT NULL,
  +   password TEXT NOT NULL,
  +   first_name TEXT NOT NULL,
  +   last_name TEXT NOT NULL,
  +   created_at DATETIME DEFAULT CURRENT_TIMESTAMP
  + );
  + 
  + -- Mood tracking table
  + CREATE TABLE IF NOT EXISTS mood (
  +   id INTEGER PRIMARY KEY AUTOINCREMENT,
  +   user_id INTEGER NOT NULL,
  +   stress_level INTEGER NOT NULL CHECK (stress_level BETWEEN 1 AND 5),
  +   anxiety_level INTEGER NOT NULL CHECK (anxiety_level BETWEEN 1 AND 5),
  +   title TEXT,
  +   description TEXT,
  +   created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
  +   FOREIGN KEY (user_id) REFERENCES users(id)
  + );
  + 
  + -- Index for faster mood queries by user
  + CREATE INDEX IF NOT EXISTS idx_mood_user_id ON mood(user_id);

api/orbit.db

Binary file brotha

api/package.json

@@ -4,13 +4,13 @@ "version": "1.0.0",
      "description": "",
      "license": "ISC",
      "author": "",
  -   "type": "commonjs",
  -   "main": "index.js",
  +   "type": "module",
  +   "main": "src/index.js",
      "directories": {
        "test": "tests"
      },
      "scripts": {
  -     "test": "echo \"Error: no test specified\" && exit 1"
  +     "test": "npx ava"
      },
      "dependencies": {
        "bcryptjs": "^3.0.3",

api/src/app.js

@@ -1,12 +1,6 @@
  - const express = require("express");
  - const app = express();
  - 
  - const users = require("./routes/users");
  - const mood = require("./routes/mood");
  - 
  - app.use(express.json());
  - app.use("/users", users);
  - app.use("/mood", mood);
  + import { createApp } from "./create-app.js";
  + import db from "./db.js";
    
  - module.exports = app;
  + const app = createApp(db);
    
  + export default app;

api/src/create-app.js

@@ -0,0 +1,22 @@
  + import express from "express";
  + import users from "./routes/users.js";
  + import mood from "./routes/mood.js";
  + 
  + export function createApp(database) {
  +   const app = express();
  + 
  +   app.use(express.json());
  + 
  +   // Inject database into request
  +   app.use((req, res, next) => {
  +     req.db = database;
  +     next();
  +   });
  + 
  +   app.use("/users", users);
  +   app.use("/mood", mood);
  + 
  +   return app;
  + }
  + 
  + export default createApp;

api/src/db.js

@@ -1,4 +1,5 @@
  - const Database = require('better-sqlite3');
  - const db = new Database('orbit.db');
  + import { setupDatabase } from './setup-db.js';
  + 
  + const db = setupDatabase();
    
  - module.exports = db;
  + export default db;

api/src/routes/mood.js

@@ -1,14 +1,14 @@
  - const express = require("express");
  - const db = require("../db");
  + import express from "express";
  + 
    const router = express.Router();
    
    router.post("/", (req, res) => {
      const { user_id, stress_level, anxiety_level, title, description } = req.body;
    
      if (!user_id || !stress_level || !anxiety_level)
  -     return res.status(400).json({ error: "Campos fatlantes" });
  +     return res.status(400).json({ error: "Campos faltantes" });
    
  -   const stmt = db.prepare(
  +   const stmt = req.db.prepare(
        `
          INSERT INTO mood (user_id, stress_level, anxiety_level, title, description)
          VALUES (?, ?, ?, ?, ?)

@@ -23,11 +23,11 @@ res.status(201).json({ id: result.lastInsertRowid });
    });
    
    router.get("/:user_id", (req, res) => {
  -   const stmt = db.prepare("SELECT * FROM mood WHERE user_id = ?");
  +   const stmt = req.db.prepare("SELECT * FROM mood WHERE user_id = ?");
      const rows = stmt.all(req.params.user_id);
    
      res.json(rows);
    });
    
  - module.exports = router;
  + export default router;
    

api/src/routes/users.js

@@ -1,6 +1,6 @@
  - const express = require("express");
  - const bcrypt = require("bcryptjs");
  - const db = require("../db");
  + import express from "express";
  + import bcrypt from "bcryptjs";
  + 
    const router = express.Router();
    
    // XXX: Needs translations

@@ -12,7 +12,7 @@
      const hashed = bcrypt.hashSync(password, 10);
    
      try {
  -     const stmt = db.prepare(
  +     const stmt = req.db.prepare(
          `
            INSERT INTO users (email, password, first_name, last_name)
            VALUES (?, ?, ?, ?)

@@ -27,5 +27,5 @@ res.status(400).json({ error: "Email já cadastrado" });
      }
    });
    
  - module.exports = router;
  + export default router;
    

api/src/setup-db.js

@@ -0,0 +1,38 @@
  + import Database from 'better-sqlite3';
  + import fs from 'fs';
  + import path from 'path';
  + import { fileURLToPath } from 'url';
  + 
  + const __filename = fileURLToPath(import.meta.url);
  + const __dirname = path.dirname(__filename);
  + 
  + export function setupDatabase(dbPath = 'orbit.db') {
  +   const db = new Database(dbPath);
  + 
  +   // Read and execute migrations
  +   const migrationsDir = path.join(__dirname, '..', 'migrations');
  +   const migrationFile = path.join(migrationsDir, '001_initial_schema.sql');
  + 
  +   if (fs.existsSync(migrationFile)) {
  +     const migration = fs.readFileSync(migrationFile, 'utf8');
  +     db.exec(migration);
  +   }
  + 
  +   return db;
  + }
  + 
  + export function setupTestDatabase() {
  +   // Use in-memory database for tests
  +   const db = new Database(':memory:');
  + 
  +   // Read and execute migrations
  +   const migrationsDir = path.join(__dirname, '..', 'migrations');
  +   const migrationFile = path.join(migrationsDir, '001_initial_schema.sql');
  + 
  +   if (fs.existsSync(migrationFile)) {
  +     const migration = fs.readFileSync(migrationFile, 'utf8');
  +     db.exec(migration);
  +   }
  + 
  +   return db;
  + }

api/tests/mood.test.js

@@ -0,0 +1,90 @@
  + import test from "ava";
  + import request from "supertest";
  + import { createApp } from "../src/create-app.js";
  + import { setupTestDb, cleanupTestDb } from "./test-helper.js";
  + 
  + let app;
  + let db;
  + let userId;
  + 
  + test.before(() => {
  +   db = setupTestDb();
  +   app = createApp(db);
  + });
  + 
  + test.beforeEach(async () => {
  +   cleanupTestDb();
  + 
  +   // Create a user for the mood tests
  +   const res = await request(app)
  +     .post("/users")
  +     .send({
  +       email: "maria@example.com",
  +       password: "123456",
  +       first_name: "Maria",
  +       last_name: "Silva",
  +     });
  + 
  +   userId = res.body.id;
  + });
  + 
  + test.serial("Registrar humor", async (t) => {
  +   const res = await request(app).post("/mood").send({
  +     user_id: userId,
  +     stress_level: 3,
  +     anxiety_level: 4,
  +     title: "Bad day",
  +     description: "Stressado com a faculdade",
  +   });
  + 
  +   t.is(res.status, 201);
  +   t.truthy(res.body.id);
  + });
  + 
  + test.serial("Listar humores do usuário", async (t) => {
  +   const res = await request(app).get(`/mood/${userId}`);
  +   t.is(res.status, 200);
  +   t.true(Array.isArray(res.body));
  + });
  + 
  + test.serial("Falha ao registrar humor sem stress_level", async (t) => {
  +   const res = await request(app).post("/mood").send({
  +     user_id: userId,
  +     anxiety_level: 4,
  +     title: "Test",
  +   });
  + 
  +   t.is(res.status, 400);
  +   t.is(res.body.error, "Campos faltantes");
  + });
  + 
  + test.serial("Listar múltiplos humores do usuário", async (t) => {
  +   // Ensure we have a valid userId
  +   t.truthy(userId, "userId should be defined");
  + 
  +   // Create first mood entry
  +   const res1 = await request(app).post("/mood").send({
  +     user_id: userId,
  +     stress_level: 3,
  +     anxiety_level: 4,
  +     title: "Morning",
  +     description: "Morning mood",
  +   });
  +   t.is(res1.status, 201);
  + 
  +   // Create second mood entry
  +   const res2 = await request(app).post("/mood").send({
  +     user_id: userId,
  +     stress_level: 2,
  +     anxiety_level: 2,
  +     title: "Evening",
  +     description: "Evening mood",
  +   });
  +   t.is(res2.status, 201);
  + 
  +   const res = await request(app).get(`/mood/${userId}`);
  +   t.is(res.status, 200);
  +   t.true(Array.isArray(res.body));
  +   t.is(res.body.length, 2);
  + });
  + 

api/tests/test-helper.js

@@ -0,0 +1,25 @@
  + import { setupTestDatabase } from '../src/setup-db.js';
  + 
  + // Store the test database globally
  + let testDb;
  + 
  + // Replace the default db connection with test database
  + export function setupTestDb() {
  +   testDb = setupTestDatabase();
  +   return testDb;
  + }
  + 
  + // Get the test database
  + export function getTestDb() {
  +   return testDb;
  + }
  + 
  + export function cleanupTestDb() {
  +   // Clear all tables
  +   if (testDb) {
  +     testDb.exec(`
  +       DELETE FROM mood;
  +       DELETE FROM users;
  +     `);
  +   }
  + }

api/tests/users.test.js

@@ -0,0 +1,68 @@
  + import test from "ava";
  + import request from "supertest";
  + import { createApp } from "../src/create-app.js";
  + import { setupTestDb, cleanupTestDb } from "./test-helper.js";
  + 
  + let app;
  + let db;
  + 
  + test.before(() => {
  +   db = setupTestDb();
  +   app = createApp(db);
  + });
  + 
  + test.beforeEach(() => {
  +   cleanupTestDb();
  + });
  + 
  + test("Criar usuário", async (t) => {
  +   const res = await request(app)
  +     .post("/users")
  +     .send({
  +       email: "john@example.com",
  +       password: "123456",
  +       first_name: "John",
  +       last_name: "Doe",
  +     });
  + 
  +   t.is(res.status, 201);
  +   t.truthy(res.body.id);
  + });
  + 
  + test("Falha ao criar usuário sem email", async (t) => {
  +   const res = await request(app)
  +     .post("/users")
  +     .send({
  +       password: "123456",
  +       first_name: "John",
  +       last_name: "Doe",
  +     });
  + 
  +   t.is(res.status, 400);
  +   t.is(res.body.error, "Campos faltantes");
  + });
  + 
  + test("Falha ao criar usuário com email duplicado", async (t) => {
  +   // First user
  +   await request(app)
  +     .post("/users")
  +     .send({
  +       email: "duplicate@example.com",
  +       password: "123456",
  +       first_name: "John",
  +       last_name: "Doe",
  +     });
  + 
  +   // Duplicate email
  +   const res = await request(app)
  +     .post("/users")
  +     .send({
  +       email: "duplicate@example.com",
  +       password: "123456",
  +       first_name: "Jane",
  +       last_name: "Smith",
  +     });
  + 
  +   t.is(res.status, 400);
  +   t.is(res.body.error, "Email já cadastrado");
  + });