a
This commit is contained in:
parent
3db849301d
commit
facf03d836
@ -157,6 +157,9 @@ module.exports = function (sequelize, DataTypes) {
|
|||||||
type: DataTypes.UUID,
|
type: DataTypes.UUID,
|
||||||
foreignKey: true,
|
foreignKey: true,
|
||||||
},
|
},
|
||||||
|
city: {
|
||||||
|
type: DataTypes.STRING,
|
||||||
|
},
|
||||||
url_streaming: {
|
url_streaming: {
|
||||||
type: DataTypes.STRING,
|
type: DataTypes.STRING,
|
||||||
},
|
},
|
||||||
@ -337,5 +340,14 @@ module.exports = function (sequelize, DataTypes) {
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
||||||
|
Event.addScope('CitiesOfEvents', () => {
|
||||||
|
return {
|
||||||
|
attributes: [[sequelize.fn('DISTINCT', sequelize.col('city')), 'city']]
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
return Event;
|
return Event;
|
||||||
};
|
};
|
||||||
@ -44,6 +44,15 @@ routes.get('/events',
|
|||||||
}),
|
}),
|
||||||
);
|
);
|
||||||
|
|
||||||
|
routes.get('/events/cities',
|
||||||
|
isLoggedUser,
|
||||||
|
SortMiddleware.middleware({ default: "city" }),
|
||||||
|
eventController.find({
|
||||||
|
scopes: ['CitiesOfEvents']
|
||||||
|
})
|
||||||
|
);
|
||||||
|
|
||||||
|
|
||||||
routes.get('/events/next',
|
routes.get('/events/next',
|
||||||
isLoggedUser,
|
isLoggedUser,
|
||||||
FieldMiddleware.middleware({
|
FieldMiddleware.middleware({
|
||||||
|
|||||||
@ -6,7 +6,7 @@ const moment = require('moment');
|
|||||||
const { generateService, parseParamsToFindOptions } = require('../../helpers/service.helper');
|
const { generateService, parseParamsToFindOptions } = require('../../helpers/service.helper');
|
||||||
const Sequelize = require('sequelize');
|
const Sequelize = require('sequelize');
|
||||||
const models = require('../../core/models');
|
const models = require('../../core/models');
|
||||||
const { eventComposer } = require('../../helpers/composes.helper');
|
const { citiesComposer, eventComposer } = require('../../helpers/composes.helper');
|
||||||
|
|
||||||
const extraMethods = {
|
const extraMethods = {
|
||||||
|
|
||||||
@ -17,12 +17,17 @@ const extraMethods = {
|
|||||||
}
|
}
|
||||||
|
|
||||||
let rows = result.rows.map(row => row.toJSON());
|
let rows = result.rows.map(row => row.toJSON());
|
||||||
rows = rows.map(event => eventComposer(event, context));
|
|
||||||
|
if (context.scopes.includes('CitiesOfEvents'))
|
||||||
|
rows = rows.map(city => citiesComposer(city, context))
|
||||||
|
else
|
||||||
|
rows = rows.map(event => eventComposer(event, context));
|
||||||
|
|
||||||
return {
|
return {
|
||||||
count: rows.length,
|
count: rows.length,
|
||||||
rows: rows
|
rows: rows
|
||||||
}
|
}
|
||||||
|
|
||||||
},
|
},
|
||||||
|
|
||||||
afterFetchOne: (result, params, context) => {
|
afterFetchOne: (result, params, context) => {
|
||||||
|
|||||||
@ -60,13 +60,6 @@ module.exports = function (sequelize, DataTypes) {
|
|||||||
timestamps: true,
|
timestamps: true,
|
||||||
});
|
});
|
||||||
|
|
||||||
Venue.addScope('includeOnlyCities', () => {
|
|
||||||
return {
|
|
||||||
attributes: [[sequelize.fn('DISTINCT', sequelize.col('city')), 'city']]
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
|
|
||||||
Venue.associate = function (models) {
|
Venue.associate = function (models) {
|
||||||
Venue.Events = Venue.hasMany(models.Event, { foreignKey: 'venueId', as: 'events' });
|
Venue.Events = Venue.hasMany(models.Event, { foreignKey: 'venueId', as: 'events' });
|
||||||
};
|
};
|
||||||
|
|||||||
@ -16,15 +16,6 @@ routes.get('/venues',
|
|||||||
venueController.find()
|
venueController.find()
|
||||||
);
|
);
|
||||||
|
|
||||||
routes.get('/venues/cities',
|
|
||||||
isLoggedUser,
|
|
||||||
SortMiddleware.middleware({ default: "city" }),
|
|
||||||
venueController.find({
|
|
||||||
scopes: ['includeOnlyCities']
|
|
||||||
|
|
||||||
})
|
|
||||||
);
|
|
||||||
|
|
||||||
//routes.get('/venues/:id',
|
//routes.get('/venues/:id',
|
||||||
//isLoggedUser,
|
//isLoggedUser,
|
||||||
//venueController.findOne();
|
//venueController.findOne();
|
||||||
|
|||||||
@ -4,25 +4,9 @@
|
|||||||
const _ = require('lodash');
|
const _ = require('lodash');
|
||||||
const { generateService, parseParamsToFindOptions } = require('../../helpers/service.helper');
|
const { generateService, parseParamsToFindOptions } = require('../../helpers/service.helper');
|
||||||
const models = require('../../core/models');
|
const models = require('../../core/models');
|
||||||
const { citiesComposer } = require('../../helpers/composes.helper');
|
|
||||||
|
|
||||||
const extraMethods = {
|
const extraMethods = {
|
||||||
|
|
||||||
afterFetchAll: (result, params, context) => {
|
|
||||||
|
|
||||||
if (!result.count) {
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
let rows = result.rows.map(row => row.toJSON());
|
|
||||||
rows = rows.map(city => citiesComposer(city, context));
|
|
||||||
|
|
||||||
return {
|
|
||||||
count: rows.length,
|
|
||||||
rows: rows
|
|
||||||
}
|
|
||||||
},
|
|
||||||
|
|
||||||
};
|
};
|
||||||
|
|
||||||
module.exports = generateService(models.Venue, extraMethods);
|
module.exports = generateService(models.Venue, extraMethods);
|
||||||
Loading…
Reference in New Issue
Block a user