como puedo extraer una data de mi bd en mysql y luego enviar ese objeto mediante web sockets estoy tratando de enviar notificaciones estoy haciendo una api restfull pero necesito enviar notificaciones en tiempo real cuando activen las notificaciones mediante mi api estoy llamando a un servicio en mi backend que deberia retornar el objeto con los datos de la bd pero cuando lo envio con el sockent.emit no llena nada una ayuda porfavor
estoy usando sequelize como orm para la bd
var express = require('express');
const app = express();
const server = require('http').Server(app);
const io = require('socket.io')(server, {
cors: {
origin: "http://localhost:4200",
methods: ["GET", "POST"],
transports: ['websocket', 'polling'],
credentials: true
},
allowEIO3: true
});
var notifications = require('./services/getNotifications').getNotifys();
io.on('connection',function(socket){
const socketId = socket.id;
console.log('se ha conectado el id: ' + '-----------' + socketId);
//notification
socket.emit('Notifications',notifications);
});
//rutas
module.exports = {server,io};
aqui es donde tengo mi conection y este es el servicio que llamo
var { Product_Notification,Product } = require('../models/index');
exports.getNotifys = async function(){
const activeNotifications = await Product_Notification.findAll({
where: { status:true },
attributes:["id","value_to_report"],
include:{
association: "item",
attributes:["id","name","product_quantity","product_code"],
where:{active_notification: true}
}
}).catch(err =>{ return err});
if(activeNotifications && activeNotifications.length > 0) return activeNotifications;
else return message = "any notification active yet";
}
esto es lo que recibo en mi fron de angular
y de esta manera es que conecto el socket con el front en angular
import { EventEmitter, Injectable } from '@angular/core';
import { Socket } from 'ngx-socket-io';
@Injectable({
providedIn: 'root'
})
export class NotifiSocketService extends Socket{
outEven: EventEmitter<any> = new EventEmitter();
callBack: EventEmitter<any> = new EventEmitter();
constructor(
) {
super({ url: 'http://localhost:5000', options: {}});
this.listen();
}
listen = () =>{
this.ioSocket.on('Notifications',(res: any) => this.callBack.emit(res));
}
}
@Component({
selector: 'app-navbar',
templateUrl: './navbar.component.html',
styleUrls: ['./navbar.component.css']
})
export class NavbarComponent implements OnInit, DoCheck,OnDestroy, AfterViewInit {
subscriptions:Subscription []=[];
public notifications:Notification[] = [];
public _notifications!:number
public user:any;
public msg:string = 'hola';
public pinga:any;
constructor(
private socket: NotifiSocketService,
private _userService:UserService,
private _notificationService:NotificationService,
) {
this.user = _userService.getIdentity();
socket.callBack.subscribe( res =>{
console.log(res);
})
}
agradeceria la ayuda soy bastante nuevo con sockets apenas lo estoy usando
si me pueden guiar de como hcaer el codigo mas escalable lo agradeceria