suroh
1 year ago
18 changed files with 0 additions and 6838 deletions
@ -1,19 +0,0 @@ |
|||
/* eslint-env node */ |
|||
module.exports = { |
|||
root: true, |
|||
'extends': [ |
|||
'eslint:recommended' |
|||
], |
|||
env: { |
|||
browser: false, |
|||
node: true, |
|||
}, |
|||
parserOptions: { |
|||
ecmaVersion: 'latest', |
|||
sourceType: 'module' |
|||
}, |
|||
rules: { |
|||
quotes: ['error', 'single'], |
|||
semi: ['error', 'never'] |
|||
} |
|||
} |
@ -1,25 +0,0 @@ |
|||
import MapModel from '../db/models/map.js' |
|||
|
|||
const getAllMaps = async (req, res) => { |
|||
const maps = await MapModel.query() |
|||
|
|||
res.json({ maps }) |
|||
} |
|||
|
|||
const getMapByName = async (req, res) => { |
|||
const name = req.params.mapName |
|||
try { |
|||
let map = await MapModel.query().where({ name }).withGraphFetched('map_points').first() |
|||
|
|||
if (!map) { |
|||
const created = await MapModel.query().insert({ name }) |
|||
map = await MapModel.query().findById(created.id).withGraphFetched('map_points') |
|||
} |
|||
|
|||
res.json(map) |
|||
} catch (error) { |
|||
console.error(error) |
|||
} |
|||
} |
|||
|
|||
export { getMapByName, getAllMaps } |
@ -1,16 +0,0 @@ |
|||
import MapModel from '../db/models/map.js' |
|||
|
|||
const setPoint = async (req, res, next) => { |
|||
try { |
|||
const { mapId, point } = req.body |
|||
|
|||
const map = await MapModel.query().findById(mapId) |
|||
const p = await map.$relatedQuery('map_points').insert(point) |
|||
|
|||
res.json(p) |
|||
} catch (err) { |
|||
next(err) |
|||
} |
|||
} |
|||
|
|||
export { setPoint } |
@ -1,23 +0,0 @@ |
|||
import knexConfig from '../knexfile.js' |
|||
import Knex from 'knex' |
|||
import { Model } from 'objection' |
|||
import { newDb } from 'pg-mem' |
|||
|
|||
const environment = process.env.NODE_ENV || 'development' |
|||
|
|||
// variable for exporting the db
|
|||
let DB |
|||
|
|||
if (environment == 'test') { |
|||
const mem = newDb() |
|||
DB = mem.adapters.createKnex(0, { |
|||
migrations: { |
|||
directory: './db/migrations' |
|||
}, |
|||
}) |
|||
Model.knex(DB) |
|||
} else { |
|||
DB = Knex(knexConfig[environment]) |
|||
} |
|||
|
|||
export default DB |
@ -1,34 +0,0 @@ |
|||
/** |
|||
* @param { import("knex").Knex } knex |
|||
* @returns { Promise<void> } |
|||
*/ |
|||
const up = (knex) => { |
|||
return knex.schema |
|||
.createTable('maps', (table) => { |
|||
table.increments().primary() |
|||
table.string('name').notNullable().unique() |
|||
table.timestamp('created_at').defaultTo(knex.fn.now()) |
|||
table.timestamp('updated_at').defaultTo(knex.fn.now()) |
|||
}) |
|||
.createTable('map_points', (table) => { |
|||
table.increments().primary() |
|||
table.string('name') |
|||
table.string('notes') |
|||
table.point('location') |
|||
table.timestamp('created_at').defaultTo(knex.fn.now()) |
|||
table.timestamp('updated_at').defaultTo(knex.fn.now()) |
|||
table.integer('map_id').references('id').inTable('maps') |
|||
}) |
|||
} |
|||
|
|||
/** |
|||
* @param { import("knex").Knex } knex |
|||
* @returns { Promise<void> } |
|||
*/ |
|||
const down = (knex) => { |
|||
return knex.schema |
|||
.raw('DROP TABLE maps CASCADE') |
|||
.dropTable('map_points') |
|||
} |
|||
|
|||
export { up, down } |
@ -1,21 +0,0 @@ |
|||
import { Model } from 'objection' |
|||
import Point from './point.js' |
|||
|
|||
class MapModel extends Model { |
|||
static tableName = 'maps' |
|||
|
|||
static get relationMappings() { |
|||
return { |
|||
map_points: { |
|||
relation: Model.HasManyRelation, |
|||
modelClass: Point, |
|||
join: { |
|||
from: 'maps.id', |
|||
to: 'map_points.map_id', |
|||
} |
|||
} |
|||
} |
|||
} |
|||
} |
|||
|
|||
export default MapModel |
@ -1,7 +0,0 @@ |
|||
import { Model } from 'objection' |
|||
|
|||
class PointModel extends Model { |
|||
static tableName = 'map_points' |
|||
} |
|||
|
|||
export default PointModel |
@ -1,6 +0,0 @@ |
|||
import App from './server.js' |
|||
import 'dotenv/config' |
|||
|
|||
App.listen(process.env.PORT, () => { |
|||
console.log(`Ethermap listening for connections on port ${process.env.PORT}`) |
|||
}) |
@ -1,64 +0,0 @@ |
|||
// Update with your config settings.
|
|||
import 'dotenv/config' |
|||
import { dirname } from 'path' |
|||
import { fileURLToPath } from 'url' |
|||
|
|||
const __dirname = dirname(fileURLToPath(import.meta.url)) |
|||
|
|||
/** |
|||
* @type { Object.<string, import("knex").Knex.Config> } |
|||
*/ |
|||
export default { |
|||
development: { |
|||
client: 'pg', |
|||
connection: { |
|||
database: process.env.DB_NAME, |
|||
user: process.env.DB_USER, |
|||
password: process.env.DB_PASS, |
|||
host: process.env.DB_HOST, |
|||
port: process.env.DB_PORT |
|||
}, |
|||
migrations: { |
|||
directory: __dirname + '/db/migrations' |
|||
}, |
|||
seeds: { |
|||
directory: __dirname + '/db/seeds' |
|||
} |
|||
}, |
|||
|
|||
staging: { |
|||
client: 'pg', |
|||
connection: { |
|||
database: process.env.DB_NAME, |
|||
user: process.env.DB_USER, |
|||
password: process.env.DB_PASS, |
|||
host: process.env.DB_HOST, |
|||
port: process.env.DB_PORT |
|||
}, |
|||
pool: { |
|||
min: 2, |
|||
max: 10 |
|||
}, |
|||
migrations: { |
|||
tableName: 'knex_migrations' |
|||
} |
|||
}, |
|||
|
|||
production: { |
|||
client: 'pg', |
|||
connection: { |
|||
database: process.env.DB_NAME, |
|||
user: process.env.DB_USER, |
|||
password: process.env.DB_PASS, |
|||
host: process.env.DB_HOST, |
|||
port: process.env.DB_PORT |
|||
}, |
|||
pool: { |
|||
min: 2, |
|||
max: 10 |
|||
}, |
|||
migrations: { |
|||
tableName: 'knex_migrations' |
|||
} |
|||
} |
|||
} |
@ -1,6 +0,0 @@ |
|||
// TODO@me update error handler
|
|||
export default (err, _, res) => { |
|||
res.status(500).json({ message: err.message }) |
|||
} |
|||
|
|||
|
File diff suppressed because it is too large
@ -1,36 +0,0 @@ |
|||
{ |
|||
"name": "ethermap", |
|||
"version": "0.0.1", |
|||
"description": "collaborative map tool inspired by etherpad", |
|||
"main": "index.js", |
|||
"type": "module", |
|||
"scripts": { |
|||
"dev": "nodemon index.js", |
|||
"test": "ava", |
|||
"test:routes": "ava ./tests/routes.js", |
|||
"test:db": "ava ./tests/db.js", |
|||
"migrate:latest": "knex migrate:latest", |
|||
"migrate:drop": "knex migrate:down" |
|||
}, |
|||
"keywords": [ |
|||
"ethermap", |
|||
"map", |
|||
"collaborative" |
|||
], |
|||
"author": "", |
|||
"license": "GPL-3.0-or-later", |
|||
"dependencies": { |
|||
"dotenv": "^16.3.1", |
|||
"express": "^4.18.2", |
|||
"knex": "^2.5.1", |
|||
"objection": "^3.1.1", |
|||
"pg": "^8.11.3" |
|||
}, |
|||
"devDependencies": { |
|||
"ava": "^5.3.1", |
|||
"eslint": "^8.48.0", |
|||
"nodemon": "^3.0.1", |
|||
"pg-mem": "^2.6.13", |
|||
"supertest": "^6.3.3" |
|||
} |
|||
} |
@ -1,8 +0,0 @@ |
|||
import { Router } from 'express' |
|||
import { getMapByName } from '../controllers/maps.js' |
|||
|
|||
const router = Router() |
|||
|
|||
router.get('/:mapName', getMapByName) |
|||
|
|||
export default router |
@ -1,8 +0,0 @@ |
|||
import { Router } from 'express' |
|||
import { setPoint } from '../controllers/points.js' |
|||
|
|||
const router = Router() |
|||
|
|||
router.post('/addpoint', setPoint) |
|||
|
|||
export default router |
@ -1,15 +0,0 @@ |
|||
import { Router } from 'express' |
|||
|
|||
import { getAllMaps } from '../controllers/maps.js' |
|||
|
|||
const router = Router() |
|||
|
|||
router.get('/', (_, res) => { |
|||
res.send('ethermap') |
|||
}) |
|||
|
|||
router.get('/maps', getAllMaps) |
|||
|
|||
|
|||
export default router |
|||
|
@ -1,30 +0,0 @@ |
|||
// web server
|
|||
import express from 'express' |
|||
|
|||
// database
|
|||
import DB from './db/DB.js' |
|||
import { Model } from 'objection' |
|||
|
|||
// middleware
|
|||
import ErrorMiddleware from './middleware/errors.js' |
|||
|
|||
// database setup
|
|||
Model.knex(DB) |
|||
|
|||
// webserver setup
|
|||
const app = express() |
|||
app.use(express.json()) |
|||
|
|||
// routes
|
|||
import rootRouter from './routes/root.js' |
|||
import mapsRouter from './routes/maps.js' |
|||
import pointsRouter from './routes/points.js' |
|||
|
|||
app.use(rootRouter) |
|||
app.use('/m', mapsRouter) |
|||
app.use('/p', pointsRouter) |
|||
|
|||
// error middleware
|
|||
app.use(ErrorMiddleware) |
|||
|
|||
export default app |
@ -1,37 +0,0 @@ |
|||
// testing tools
|
|||
import test from 'ava' |
|||
import db from '../db/DB.js' |
|||
|
|||
// db model
|
|||
import MapModel from '../db/models/map.js' |
|||
|
|||
test.before(async () => { |
|||
await db.migrate.latest() |
|||
}) |
|||
|
|||
test('Selecting maps should return array', async t => { |
|||
const maps = await MapModel.query() |
|||
|
|||
t.truthy(maps) |
|||
}) |
|||
|
|||
test.serial('Inserting map returns map object', async t => { |
|||
const map = await MapModel.query().insert({ name: 'milo' }) |
|||
|
|||
t.is(map.name, 'milo') |
|||
}) |
|||
|
|||
test.serial('Insert point for existing map returns point', async t => { |
|||
const map = await MapModel.query().where({ name: 'milo' }).first() |
|||
const point = await map.$relatedQuery('map_points').insert({ |
|||
name: 'pointy', |
|||
location: '(50.8552,4.3454)', |
|||
}) |
|||
|
|||
t.is(point.name, 'pointy') |
|||
t.is(point.location, '(50.8552,4.3454)') |
|||
}) |
|||
|
|||
test.after(async () => { |
|||
await db.migrate.down() |
|||
}) |
@ -1,93 +0,0 @@ |
|||
// testing tools
|
|||
import test from 'ava' |
|||
import request from 'supertest' |
|||
|
|||
// express app
|
|||
import App from '../server.js' |
|||
import db from '../db/DB.js' |
|||
|
|||
test.before(async t => { |
|||
await db.migrate.latest() |
|||
}) |
|||
|
|||
test.serial('get "/" route should return body of "ethermap"', async t => { |
|||
const res = await request(App).get('/') |
|||
|
|||
t.is(res.status, 200) |
|||
t.is(res.text, 'ethermap') |
|||
}) |
|||
|
|||
test.serial('get "/maps" route should return an object containing an array called "maps"', async t => { |
|||
const res = await request(App).get('/maps') |
|||
|
|||
t.is(res.status, 200) |
|||
t.truthy(res.body.maps?.constructor === Array) |
|||
}) |
|||
|
|||
test.serial('get "/m/:mapName" route should return map with matching name', async t => { |
|||
const res = await request(App).get('/m/bingo') |
|||
|
|||
t.is(res.status, 200) |
|||
t.is(res.body.name, 'bingo') |
|||
}) |
|||
|
|||
test.serial('get "/m/:mapName" route with different mapName should create new map with different id', async t => { |
|||
const res = await request(App).get('/m/cheese') |
|||
|
|||
t.is(res.status, 200) |
|||
t.truthy(res.body.id) |
|||
t.not(res.body.id, 1) |
|||
}) |
|||
|
|||
test.serial('get "/m/:mapName" route with existing mapName should return same id', async t => { |
|||
const res = await request(App).get('/m/bingo') |
|||
|
|||
t.is(res.status, 200) |
|||
t.is(res.body.id, 1) |
|||
}) |
|||
|
|||
test.serial('post "/p/addpoint" body containing a name, location and map_id should return a point', async t => { |
|||
const { body: { id: mapId } } = await request(App).get('/m/bingo') |
|||
const res = await request(App) |
|||
.post('/p/addpoint') |
|||
.send({ |
|||
mapId, |
|||
point: { |
|||
name: 'pointy', |
|||
location: '(50.8552,4.3454)', |
|||
} |
|||
}) |
|||
|
|||
t.is(res.status, 200) |
|||
t.is(res.body.id, 1) |
|||
t.is(res.body.map_id, mapId) |
|||
t.is(res.body.name, 'pointy') |
|||
}) |
|||
|
|||
test.serial('get "/m/:mapName" with associated points should return a map with an array of points', async t => { |
|||
const res = await request(App).get('/m/bingo') |
|||
|
|||
t.is(res.status, 200) |
|||
t.truthy(res.body.map_points) |
|||
t.is(res.body.map_points.length, 1) |
|||
}) |
|||
|
|||
test.serial('post "/p/addpoint" with incorrect data keys throws 500 error', async t => { |
|||
const { body: { id: mapId } } = await request(App).get('/m/bingo') |
|||
const error = await request(App) |
|||
.post('/p/addpoint') |
|||
.send({ |
|||
mapId, |
|||
point: { |
|||
title: 'pointy', |
|||
coords: '(50.8552,4.3454)', |
|||
} |
|||
}) |
|||
|
|||
t.is(error.status, 500) |
|||
}) |
|||
|
|||
test.after(async () => { |
|||
await db.migrate.down() |
|||
}) |
|||
|
Loading…
Reference in new issue