im implementing a graphql server, it must have e public subscription for public updates. My problem is how to get the count of the subscribers. Is there something im missing about graphql subscriptions? Are graphql endpoints even supposed to be freely available?
I am stuck on an issue where I need to create and download a zip of multiple files using NodeJs. Things I have tried and failed :
https://github.com/archiverjs/node-archiver/issues/364#issuecomment-573508251
https://github.com/kubernetes/kubernetes/issues/90483#issue-606722433
unexpected behavior using zip-stream NPM on Google k8s
In addition to this, now the files are encrypted as well so I have to decrypt them before adding them to zip on the fly.
Though I solved this also, my solution works perfectly while the server is running on a local machine but failed when on the Google Kubernetes Engine.
After some more research, I guess this might be because of a backpressure issue in the streams in NodeJs but as described in docs, backpressure is handled by the pipe method automatically. Is it possible that the receiving speed of the browser is not matching with the sending speed of my server/zipping if yes how to solve this problem?
All the samples related to the problem are in the links provided above.
In Addition to this readable stream is passed through decipher to decrypt it.
const decipher = crypto.createDecipheriv(algorithm, Buffer.from(key), Buffer.from(key.substring(0, 9)));
zipStreamer.entry(readableStream.pipe(decipher), {
name: fileName
}, (error, result) => {
if (!error) {
resolve("done");
} else {
reject("error");
}
});
I understand that you are meant to use https://www.npmjs.com/package/passport-saml but I am not sure about anything else. There doesn't seem to be guidance anyway on their docs. I'm assuming I need to set up a service provider account somewhere, but i'm not sure where or how. All their docs tell me to do is download and install - I want this to be a login button on my website that users can click to login with their university email and password. Where do I begin?
I am trying to run the webstorm debugger for a node.js express app on my laptop using babel7. When I run the application by clicking the debug symbol, the application starts and displays a message indicating it is listening on port 3000 as expected. However, when I try to access the endpoints it is just clocking and none of my endpoints are getting hit. On my local environment, I tried two approaches, how I have on the server where I have a server.js as the entry point which and another approach where I am using www.js as the entry point. Both approaches, start the application and appear to listen.
I am setting the following Run/Debug Configuration properties:
babel.config.json:
{
"presets": [
["@babel/preset-env"]
],
"plugins": [
"@babel/plugin-proposal-class-properties",
"@babel/plugin-proposal-object-rest-spread"
]
}
This is the server.js file:
require("core-js");
require("regenerator-runtime");
module.exports = require('./bin/www');
It appears as if the application is running and listening but unresponsive, I am not seeing any breakpoints hit and no console.log message are appearing in the console. I also pushed the code up to the test server and it works fine from there. The only x factor I can think of is that the test server uses the babel command to transpile the code to a different folder to run from there as opposed to transpiling on the fly using @babel/register. What could I missing here?
I use ava 3.13.0 with node 14.15.0 and Electron 10.1.5 and nodegit 0.27.0. and spectron.
I use ava with spectron to start my app, do some tests and stop it. All of this works - including functions which use nodegit in my app.
In addition to the tests described above I made also a pure non-Electron test file and import nodegit directly.
import * as nodegit from 'nodegit';
Executing this test now via ava returns this:
node_modules\.pnpm\nodegit@0.27.0\node_modules\nodegit\build\Release\nodegit.node'
was compiled against a different Node.js version using
NODE_MODULE_VERSION 82. This version of Node.js requires
NODE_MODULE_VERSION 83. Please try re-compiling or re-installing
the module (for instance, using `npm rebuild` or `npm install`).
at Module._extensions..node (internal/modules/cjs/loader.js:1122:18)
Where exactly does version 82 come from? I only have nodejs 14.15.0 installed, which uses version 83 as expected. Why does ava think the version is a mismatch where it works actually in my app? This is how my package.json looks like:
"devDependencies": {
"ava-ts": "0.25.2",
},
"scripts": {
"ava-ts": "node_modules/.bin/ava-ts",
...
},
"ava": {
"files": [
"*.ts"
],
"extensions": [
"ts"
],
"require": [
"ts-node/register"
],
"nodeArguments": [
"--napi-modules",
"--experimental-modules"
]
},
I built nodegit myself and in the config.gypi file it even refers to:
"node_module_version": 83,
I made a super simple reproducible example: https://github.com/Githubber2021/node_module_version-issue
% node --version
14.15.0
% npm install
% npm run ava
... error
Can anyone explain me if this a bug or where version 82 comes from?
I'm pretty new to express and socket.io and I'm trying to achieve a little website:
What is it supposed to do:
var column)
What it is not doing:
Actually the three points above are working quite well, my issue is with the last point :
My code is somehow not displaying every user in the correct column, in fact, it's displaying them in the same column as you are
Here is the code
$(document).ready(function () {
var socket = io();
var username = prompt("premier utilisateur : ", "nom");
var column = prompt("colonne ", "1,2,3 ou 4");
var gdhb = "";
socket.emit("new user entered his name");
socket.emit("nomUser", username);
if (column === "1") { column = ".one"; gdhb = ".dir1" }
if (column === "2") { column = ".two"; gdhb = ".dir2" }
if (column === "3") { column = ".three"; gdhb = ".dir3" }
if (column === "4") { column = ".four"; gdhb = ".dir4" }
socket.emit("user chose a column");
socket.emit("columnUser", column);
$(column).append($("<p class='username'>" + username + "</p>"))
$(document.body).click(function (b) {
var verbes = [
"appuie",
"bouscule",
"pousse"
];
var adverbes = [
"puis",
"ensuite",
"pour finir",
"alors"
];
var verbe = verbes[Math.floor(Math.random() * verbes.length)];
var adverbe = adverbes[Math.floor(Math.random() * adverbes.length)];
var verbadv = verbe + " " + adverbe;
console.log(verbadv);
socket.emit("verbadverbe");
socket.emit("verbadv", verbadv);
var div = $("<div />", {
"class": "document"
})
.css({
"left": b.pageX + 'px',
"top": b.pageY + 'px'
})
.append($("<p>" + verbadv + "</p>"))
.appendTo(column);
});
$(document.body).contextmenu(function (rc) {
var div = $("<div />", {
"class": "document"
})
.css({
"left": rc.pageX + 'px',
"top": rc.pageY + 'px'
})
.append($("<p>recule</p>"))
.appendTo(column);
});
var direction = "";
var oldx = 0;
var oldy = 0;
mousemovemethod = function (e) {
if (e.pageX > oldx && e.pageY == oldy) {
direction = "gauche";
}
else if (e.pageX == oldx && e.pageY > oldy) {
direction = "bas";
}
else if (e.pageX == oldx && e.pageY < oldy) {
direction = "haut";
}
else if (e.pageX < oldx && e.pageY == oldy) {
direction = "droite";
}
$(gdhb).append($("<p class='direction' id='direction'>" + direction + "</p>"))
$(".direction").prev().remove();
oldx = e.pageX;
oldy = e.pageY;
}
document.addEventListener('mousemove', mousemovemethod);
socket.on("columnUser", function (column) {
socket.on("nomUser", function (username) {
$(column).append($("<p class='username'>" + username + "</p>"));
socket.on("verbadv", function (verbadv) {
var div = $("<div />", {
"class": "document"
})
.append($("<p>" + verbadv + "</p>"))
.appendTo(column);
});
});
});
});
and the index.js :
const path = require('path');
const http = require('http');
const express = require('express');
const socketio = require('socket.io');
const app = express();
const server = http.createServer(app);
const io = socketio(server);
app.use(express.static(path.join(__dirname, 'public')));
io.on('connection', (socket) => {
console.log('Nouvel utilisateur')
socket.on("nomUser", (username) => {
console.log(username);
io.emit("nomUser", username);
});
socket.on("verbadv", (verbadv) => {
console.log(verbadv);
io.emit("verbadv", verbadv);
});
socket.on("columnUser", (column) => {
console.log(column);
io.emit("columnUser", column);
});
});
server.listen(3000, () => {
console.log('listen on 3000');
})
Also if it's needed to understand better, here is the css
body {
font-family: sans-serif;
font-size: 1.3rem;
margin: 0;
background-color: DarkSlateGray;
}
.wrapper {
display: grid;
grid-template-columns: repeat(4, 1fr);
grid-gap: 0px;
grid-auto-rows: minmax(100vh, auto);
height: 100vh;
}
.one,
.two,
.three,
.four {
-ms-overflow-style: none; /* Internet Explorer 10+ */
scrollbar-width: none; /* Firefox */
position: relative;
overflow: scroll;
height: 100%;
background-color: tan;
}
.one {
grid-column: 1 / 2;
}
.two {
grid-column: 2 / 3;
}
.three {
grid-column: 3 / 4;
}
.four {
grid-column: 4 / 4;
}
.one::-webkit-scrollbar,
.two::-webkit-scrollbar,
.three::-webkit-scrollbar,
.four::-webkit-scrollbar {
display: none; /* Safari and Chrome */
}
.note {
text-align: center;
width: 100px;
height: 30px;
}
.note p{
filter: drop-shadow(0 0 0.75rem black);
}
.document{
text-align: center;
}
.document p{
padding: 0;
margin: 0;
}
.username{
text-align: center;
padding: 0;
margin: 0;
}
.direction{
position: fixed;
bottom : 0;
width: 25vw;
text-align: center;
}
Thanks a lot for the precious help.
I have a multilevel nested document (its dynamic and some levels can be missing but maximum 3 levels). I want to update all the children and subchildren routes if any. The scenario is same as in any Windows explorer, where all subfolders' route need to change when a parent folder route is changed. For eg. In the below example, If I am at route=="l1/l2a" and it's name needs to be edited to "l2c", then I will update it's route as route=="l1/l2c and I will update all childrens' route to say "l1/l2c/l3a".
{
"name":"l1",
"route": "l1",
"children":
[
{
"name": "l2a",
"route": "l1/l2a",
"children":
[
{
"name": "l3a",
"route": "l1/l2a/l3a"
}]
},
{
"name": "l2b",
"route": "l1/l2b",
"children":
[
{
"name": "l3b",
"route": "l1/l2b/l3b"
}]
}
]
}
Currently I am able to go to a point and I am able to change its name and ONLY its route in the following manner:
router.put('/navlist',(req,res,next)=>{
newname=req.body.newName //suppose l2c
oldname=req.body.name //suppose l2a
route=req.body.route // existing route is l1/l2a
id=req.body._id
newroute=route.replace(oldname,newname); // l1/l2a has to be changed to l1/l2c
let segments = route.split('/');
let query = { route: segments[0]};
let update, options = {};
let updatePath = "";
options.arrayFilters = [];
for(let i = 0; i < segments.length -1; i++){
updatePath += `children.$[child${i}].`;
options.arrayFilters.push({ [`child${i}.route`]: segments.slice(0, i + 2).join('/') });
} //this is basically for the nested children
updateName=updatePath+'name'
updateRoute=updatePath+'route';
update = { $setOnInsert: { [updateName]:newDisplayName,[updateRoute]:newroute } };
NavItems.updateOne(query,update, options)
})
The problem is I am not able to edit the routes of it's children if any. Although I tried using the $[] operator. Suppose Path is the exact path to a point from where you need to update it's children.
updateChild = updatePath+'.children.$[].route'
updateChild2 = updatePath+'.children.$[].children.$[].route'
//update = { $set: { [updateChild]:'abc',[updateChild2]:'abc' } };
Its important that levels are customizable and thus I don't know whether there is "l3A" or not. Like there can be "l3A" but there may not be "l3B". But my code simply requires every correct path else it gives an error
code 500 MongoError: The path 'children.1.children' must exist in the document in order to apply array updates.
So the question is how can I apply changes using $set to a path that actually exists and how can I edit the existing route part. If the path exists, it's well and good and if the path does not exist, I am getting the ERROR.
I am racking my brain the whole week on this error now! My plan was to create a simple 'send email from nodejs' application. The problem that I ran into was, a mime-type error for my style.css. The error says it's is in a text/html format. I started as usual with 'npm init -y' and 'npm install express nodemailer nodemailer-mailgun-transport -S'. I also created a 'server.js', 'index.html' and 'style.css' (See code below). And that's it. The application works as expected and linking bootstrap cdn also works. It is only my custom css that gives me a hard time. So to simplify it I even took a copy/paste html template from w3schools
index.html
<!DOCTYPE html>
<html>
<head>
<link rel="stylesheet" type="text/css" href="style.css" />
</head>
<body>
<h1>This is a heading</h1>
<p>This is a paragraph.</p>
</body>
</html>
style.css
body {
background-color: powderblue;
}
h1 {
color: blue;
}
p {
color: red;
}
server.js
const express = require('express');
const app = express();
const PORT = 8080;
const path = require('path');
app.get('/', (req, res) => {
res.sendFile(path.join(__dirname, 'views', 'index.html'));
})
app.listen(PORT);
package.json
{
"name": "SendMail",
"version": "1.0.0",
"description": "",
"main": "index.js",
"scripts": {
"test": "echo \"Error: no test specified\" && exit 1"
},
"keywords": [],
"author": "",
"license": "ISC",
"dependencies": {
"express": "^4.17.1",
"nodemailer": "^6.4.15",
"nodemailer-mailgun-transport": "^2.0.1"
},
"style": "style.css"
}
The error in Chrome: 
What I've tried:
Is there anything else that I could try? Let me know if you need additional info. Thanks in advance!
I have a task to get key information about users in database. There are many left joins and the query works quite slow. I'm trying to optimize it somehow and I decided to select only specific fields (only id of a record for the moment).
Here is part of my query. I need to get only id of each event which belongs to a user and do the same for each user in database. Ideally I should get array of ids.
I tried to build a sub query but couldn't find some example with explanation. An example from official docs it's not enough to me.
When I run it I'm getting error
syntax error at or near "SELECT"
QueryFailedError: syntax error at or near "SELECT"
this.createQueryBuilder('profile')
.leftJoinAndSelect('profile.avatarPhoto', 'avatarPhoto')
.leftJoinAndSelect('profile.coverPhoto', 'coverPhoto')
.leftJoinAndSelect('profile.primaryCountry', 'country')
.leftJoinAndSelect('profile.primaryCity', 'city')
.leftJoinAndSelect('profile.images', 'image')
.leftJoinAndSelect('profile.practicedSports', 'practicedSport')
.leftJoinAndSelect(
(subQuery) =>
subQuery
.subQuery()
.createQueryBuilder()
.select(['id'])
.leftJoin('user', 'user')
.from(SportEvent, 'event'),
'event',
'event.user.id = profile.id',
)
// .leftJoinAndSelect('profile.sportServices', 'service')
// .leftJoinAndSelect('profile.lessons', 'lesson')
// .leftJoinAndSelect('profile.activityRequests', 'request')
.leftJoin('profile.userAuth', 'auth')
.where('auth.registered = true')
.andWhere('auth.blocked = false')
.take(params.pageSize)
.skip(itemsNumber)
.getMany()
This is generated SQL code
SELECT DISTINCT "distinctAlias"."profile_id" as "ids_profile_id"
FROM (SELECT "profile"."id" AS "profile_id", "profile"."email" AS "profile_email",
"profile"."first_name" AS "profile_first_name",
"profile"."middle_name" AS "profile_middle_name",
"profile"."last_name" AS "profile_last_name",
"profile"."about_user" AS "profile_about_user",
"profile"."interests" AS "profile_interests",
"profile"."birthday" AS "profile_birthday",
"profile"."gender" AS "profile_gender",
"profile"."sport_level" AS "profile_sport_level",
"profile"."phone_number" AS "profile_phone_number",
"profile"."contacts" AS "profile_contacts",
"profile"."payment_methods" AS "profile_payment_methods",
"profile"."settings" AS "profile_settings",
"profile"."options" AS "profile_options",
"profile"."updated_at" AS "profile_updated_at",
"profile"."created_at" AS "profile_created_at",
"profile"."avatar_photo_id" AS "profile_avatar_photo_id",
"profile"."cover_photo_id" AS "profile_cover_photo_id",
"profile"."cover_video_id" AS "profile_cover_video_id",
"profile"."default_album_id" AS "profile_default_album_id",
"profile"."primary_country_id" AS "profile_primary_country_id",
"profile"."primary_city_id" AS "profile_primary_city_id",
"profile"."primary_language_id" AS "profile_primary_language_id",
"avatarPhoto"."id" AS "avatarPhoto_id",
"avatarPhoto"."name" AS "avatarPhoto_name",
"avatarPhoto"."image_paths" AS "avatarPhoto_image_paths",
"avatarPhoto"."updated_at" AS "avatarPhoto_updated_at",
"avatarPhoto"."created_at" AS "avatarPhoto_created_at",
"avatarPhoto"."album_id" AS "avatarPhoto_album_id",
"avatarPhoto"."user_id" AS "avatarPhoto_user_id",
"coverPhoto"."id" AS "coverPhoto_id",
"coverPhoto"."name" AS "coverPhoto_name",
"coverPhoto"."image_paths" AS "coverPhoto_image_paths",
"coverPhoto"."updated_at" AS "coverPhoto_updated_at",
"coverPhoto"."created_at" AS "coverPhoto_created_at",
"coverPhoto"."album_id" AS "coverPhoto_album_id",
"coverPhoto"."user_id" AS "coverPhoto_user_id",
"country"."id" AS "country_id",
"country"."name" AS "country_name",
"country"."alpha_2" AS "country_alpha_2",
"country"."alpha_3" AS "country_alpha_3",
"country"."calling_code" AS "country_calling_code",
"country"."enabled" AS "country_enabled",
"country"."top" AS "country_top", "city"."id" AS "city_id",
"city"."name" AS "city_name",
"city"."coordinates" AS "city_coordinates",
"city"."top" AS "city_top",
"city"."country_id" AS "city_country_id",
"image"."id" AS "image_id",
"image"."name" AS "image_name",
"image"."image_paths" AS "image_image_paths",
"image"."updated_at" AS "image_updated_at",
"image"."created_at" AS "image_created_at",
"image"."album_id" AS "image_album_id",
"image"."user_id" AS "image_user_id",
"practicedSport"."id" AS "practicedSport_id",
"practicedSport"."start_date" AS "practicedSport_start_date",
"practicedSport"."sport_id" AS "practicedSport_sport_id",
"practicedSport"."user_id" AS "practicedSport_user_id",
"event".*
FROM "user_profiles" "profile" LEFT JOIN "media_images" "avatarPhoto"
ON "avatarPhoto"."id"="profile"."avatar_photo_id" LEFT JOIN "media_images" "coverPhoto"
ON "coverPhoto"."id"="profile"."cover_photo_id" LEFT JOIN "data_countries" "country"
ON "country"."id"="profile"."primary_country_id" LEFT JOIN "data_cities" "city"
ON "city"."id"="profile"."primary_city_id" LEFT JOIN "media_images" "image"
ON "image"."user_id"="profile"."id" LEFT JOIN "user_practiced_sports" "practicedSport"
ON "practicedSport"."user_id"="profile"."id"
LEFT JOIN SELECT id FROM "sport_events" "event"
LEFT JOIN "user" "user" "event"
ON event.user.id = "profile"."id"
LEFT JOIN "user_auth" "auth"
ON "auth"."profile_id"="profile"."id"
WHERE "auth"."registered" = true
AND auth.blocked = false) "distinctAlias"
ORDER BY "profile_id" ASC LIMIT 15
Could you explain what I'm doing wrong or send me an article with explanation? Thanks!
I've looked through multiple post about this but can't seem to pinpoint the problem. I'm doing a donation page for an organization and need this to check if paypal is even working. It's an error between my form and app.post. Error I get is: Cannot POST /path . Can't use / because its the path for my contact form
app.get("/donate", (req, res) => res.sendFile(__dirname + "views/donate.html"));
app.post("/done", (req, res) => {
const create_payment_json = {
intent: "sale",
payer: {
payment_method: "paypal",
},
redirect_urls: {
return_url: "https://asociacioncorazondiverso.org/donate.html",
cancel_url: "https://asociacioncorazondiverso.org/donate.html",
},
transactions: [
{
item_list: {
items: [
{
name: "Donación",
sku: "001",
price: "10.00",
currency: "USD",
quantity: 1,
},
],
},
amount: {
currency: "USD",
total: "10.00",
},
description: "Donación",
},
],
};
paypal.payment.create(create_payment_json, function (error, payment) {
if (error) {
throw error;
} else {
for (let i = 0; i < payment.links.length; i++) {
if (payment.links[i].rel === "approval_url") {
res.redirect(payment.links[i].href);
}
}
}
});
});
Form:
<div class="container-contact100-form-btn">
<h2>Donación de 10 USD</h2>
<form action="/done" method="post">
<button type="submit" class="btn btn-warning" value="Buy">Donación</button>
</form>
</div>
I have a node.js server that uses SSE to send updates to attached clients. Occasionally, I get a server error H27. At the same time, other client requests get lost probably while the client is re-registering to the SSE event service.
The time elapsed between the client GET /event request and the server H27 error is anywhere between 13sec to 19:35min (in 30 different occurrences encountered). But there is a full correlation between the timing of the GET /event request and a corresponding H27 error. I am sending a keep alive message from the server every 50sec to workaround the Heroku timeout limit of 55sec.
Here is an example for the full warning I get in Heroku logs: 2020-10-17T08:49:04.525770+00:00 heroku[router]: sock=client at=warning code=H27 desc="Client Request Interrupted" method=GET path="/event" host=appname.herokuapp.com request_id=c4c4e2fd-16ca-4292-a27b-2a70b12b16fa fwd="77.138.167.76" dyno=web.1 connect=1ms service=9499ms status=499 bytes= protocol=https
that resulted from the following GET request: 2020-10-17T08:48:55.027638+00:00 app[web.1]: Client 8 registered
Any idea how I can overcome this? My problem is that my application heavily relies on SSE, and if I now must switch to another mechanism (e.g., socket), it will take a considerable effort.
Edited for more clarity.
I am trying to make a splash screen applet - to start learning nodejs and electron.
I want to create an applet that launches, shows some messages every 10 seconds, and then quits.
I'm basing it off the Discord app and Teams where they have pop up loading screens that have a progress bar, and once completed load the full application.
I want to know how to do it before the "load full app" portion kicks in and how to close the splash screen completely.
Currently I have an index.js, index.html, and a main.js.
index.js is the electron browser window. index.html is the main rendered page, and the main.js is the timer to switch the innerHTML based on the time from:
// main.js
var startTime = 0,
totalTime = 10,
timeBuffer = 2,
totalPercent = 0,
timeCounter = setInterval( progress, 1000 );
function progress() {
if( (startTime += 1) >= (totalTime + timeBuffer + 1) ) {
// quit app (1)
} else {
// show messages here
}
}
At point (1) in the code, I've tried adding in app.close(); but that fails since I haven't added in app. I tried adding it in but that doesn't work either.
I tried adding in:
// main.js
const { ipcRenderer } = require('electron');
ipcRenderer.send('close-me');
//index.js
ipcMain.on( 'close-me', (evt, arg) => {
app.quit();
});
But this didn't work either. I'm still trying to understand the relationship between index.js and the other scripts you might write for the app - but thought quitting the app entirely would be easy.
I'm having trouble setting an attribute on a junction table.
I have a Many-to-Many association defined between two models UserModel and HangModel, through a custom table HangUsers.
const HangModel = rootRequire('/models/Hang');
const UserModel = rootRequire('/models/User');
const HangUsers = database.define('HangUsers', {
id: {
type: Sequelize.INTEGER(10).UNSIGNED,
primaryKey: true,
autoIncrement: true,
},
hangId: {
type: Sequelize.INTEGER(10).UNSIGNED,
references: {
model: HangModel,
key: 'id',
},
},
userId: {
type: Sequelize.INTEGER(10).UNSIGNED,
references: {
model: UserModel,
key: 'id',
},
},
rsvp: {
type: Sequelize.STRING,
allowNull: false,
validate: {
isIn: {
args: [ 'pending', 'joined' ],
msg: 'The rsvp provided is invalid',
},
},
},
});
UserModel.hasMany(HangUsers, { as: 'invitations' });
HangModel.hasMany(HangUsers, { as: 'invites' });
UserModel.belongsToMany(HangModel, { through: HangUsers });
HangModel.belongsToMany(UserModel, { through: HangUsers });
The through table has a column rsvp, that I'm trying to populate when I add users to a hang:
const hang = await HangModel.create();
await hang.addUser(user, { through: { rvsp: 'joined' } });
However, I'm getting an error:
AggregateError
at recursiveBulkCreate (/Users/sgarza62/ditto-app/api/node_modules/sequelize/lib/model.js:2600:17)
at processTicksAndRejections (internal/process/task_queues.js:97:5)
at async Function.bulkCreate (/Users/sgarza62/ditto-app/api/node_modules/sequelize/lib/model.js:2824:12)
at async Promise.all (index 0)
at async BelongsToMany.add (/Users/sgarza62/ditto-app/api/node_modules/sequelize/lib/associations/belongs-to-many.js:740:30)
at async /Users/sgarza62/ditto-app/api/routes/hangs.js:121:3 {
name: 'AggregateError',
errors: [
BulkRecordError [SequelizeBulkRecordError]: notNull Violation: HangUsers.rsvp cannot be null
at /Users/sgarza62/ditto-app/api/node_modules/sequelize/lib/model.js:2594:25
at processTicksAndRejections (internal/process/task_queues.js:97:5) {
name: 'SequelizeBulkRecordError',
errors: [ValidationError],
record: [HangUsers]
}
]
}
When I allow null on the rsvp column, the HangUsers row is created, but the rsvp value is NULL.
It seems the { through: { rsvp: 'joined' } } parameter is being ignored.
I've done this all according to the BelongsToMany docs and the Advanced M:N Associations docs, where it says:
However, defining the model by ourselves has several advantages. We can, for example, define more columns on our through table:
const User_Profile = sequelize.define('User_Profile', { selfGranted: DataTypes.BOOLEAN }, { timestamps: false }); User.belongsToMany(Profile, { through: User_Profile }); Profile.belongsToMany(User, { through: User_Profile });With this, we can now track an extra information at the through table, namely the selfGranted boolean. For example, when calling the user.addProfile() we can pass values for the extra columns using the through option.
Example:
const amidala = await User.create({ username: 'p4dm3', points: 1000 }); const queen = await Profile.create({ name: 'Queen' }); await amidala.addProfile(queen, { through: { selfGranted: false } }); const result = await User.findOne({ where: { username: 'p4dm3' }, include: Profile }); console.log(result);
This might be a dumb question, but I am trying to explain it as simply as I can.
So I have been using axios to retrieve data from my server to my react app (redux) Since I use socket.io in my app a lot, I thought I could make the authentication use that as well, so I don't have to use axios and socket.io concurrently. I have been using PassportJS for authentication, but I can't wrap my head around how the socket.io passport packages I found on npm work.
I am using this socket.io-redux middleware to fire reducers on socket.io events. With this, I can dispatch actions that then get sent to the server, and from the server I can fire the reducers I want, in order to change the state.
Here is my store.js
import { createStore, applyMiddleware, compose } from "redux";
import thunk from "redux-thunk";
import rootReducer from "./reducers";
import { composeWithDevTools } from 'redux-devtools-extension';
import createSocketIoMiddleware from 'redux-socket.io';
import io from 'socket.io-client';
const socket = io('http://localhost:5000');
const socketIoMiddleware = createSocketIoMiddleware(socket, "io/");
const initialState = {};
const middleware = [thunk, socketIoMiddleware];
const store = createStore(
rootReducer,
initialState,
composeWithDevTools(
applyMiddleware(...middleware)
)
);
// store.dispatch({type:'server/hello', data:'Hello!'});
export default store
Using this method a socket is created for every client upon connecting to the website. I created a Store class on the server side as well, with the the login/logout methods like so (these keep track of the clients and the users associated with them):
class Store
{
constructor(){
this.loggedInUsers = [];
}
loginUser(userID, socketID){
console.log('login', userID, socket.id);
const index = this.loggedInUsers.find(u => u.socketID !== socket.id && u.userID === userID);
if(index >= 0){
this.logoutUser(this.loggedInUsers[index].socketID);
}
this.loggedInUsers = [
...this.loggedInUsers,
{
userID: userID,
socketID: socket.id,
}
];
}
logoutUser(socketID){
console.log('logout', socketID);
const index = this.loggedInUsers.find(u => u.socketID === socketID);
if(index >= 0){
this.loggedInUsers = [...this.loggedInUsers.slice(0, index), ...this.loggedInUsers.slice(index+1)];
}
}
}
module.exports.store = new Store();
On login a socket.io event is emmitted to the server, then on a successful login the socket gets stored in a loggedInUsers object that holds the user IDs and the sockets associated with them, then fires a reducer to store the authenticated state in my store. On logout, the user with the socket given gets removed from the object.
Now I am wondering if this is even safe to do or not.
Client given below Ajax call to post the data to there server, but I am not able to understand how to convert this call into component.ts and servervice
<script src="https://ajax.googleapis.com/ajax/libs/jquery/3.4.1/jquery.min.js"></script>
<script type="text/javascript">
$.ajax
({
type: "POST",
url: 'https://xyz/client/schedule',
contentType: 'application/json',
data: JSON.stringify({
"apiKey": "myapikey"
}),
dataType : 'json',
headers: {
'authorization': '<?php echo $authorization; ?>'
},
success: function(retval)
{
// alert(retval);
console.log(retval);
// var success = retval.success;
}
});
</script>
I have updated Question and added after two replied answer
Below is component.ts on button click passing static values
import { Schedule } from '../Models/Schedule.model'
Schedule: Schedule = new Schedule();
addSchedule(scheduleForm: NgForm): void {
this.Schedule.ClassTitle='rrrr444v Class on 3rd April, 2020';
this.Schedule.ClassInfo= 'This is a demo class scheduled to understand API';
this.Schedule.ClassDateTime= '2020-11-12 11:30 AM';
this.Schedule.TimeZone= 'Asia/Kolkata';
this.Schedule.ClassDuration= '15';
this.Schedule.ClassRecording= 'yes';
this.Schedule.ClassAutoStart= 'false';
this.Schedule.RecordingAutoStart= 'false';
this.Schedule.ClassVideoRes= '720';
const data = {
apiKey: "7777",
data: this.Schedule
}
this.subscription =
this.userSvc.fetchData("xyz.com", data )
.subscribe(
data => {
// Data on Success
console.log("data", data);
},
error => {
console.log("error", error+'hihii');
}
);
}
Below is service.ts
fetchData(url: string, data: any): Observable<any> {
const headers = {
Authorization: "Bearer 123456",
"My-Custom-Header": "foobar",
contentType: "application/json"
};
return this.http.post(url, data, {
headers
});
}
in console getting this error.
I am not sure I am doing this quite right. My end goal is to send a post request from a lambda function to my electron app and create a system notification. Locally I have been able to do it from post man, but when I install the app (on linux) It doesn't work, now I am not sure where I am supposed to point my request to, in development I pointed it too. http://localhost:3000/notify what happens when you install the app. How would I send a post request to the app, eventually I want to build user accounts, so I will need to send requests to each separate user based on the lambda logic.
I am using express with electron, is there another way to handle post requests.
Here is my code so far in my main.js file
"use strict";
const { app, BrowserWindow } = require("electron");
const { Notification } = require("electron");
const express = require("express");
const bodyParser = require("body-parser");
function createWindow() {
const win = new BrowserWindow({
width: 800,
height: 600,
webPreferences: {
nodeIntegration: true,
},
});
win.loadFile("index.html");
win.webContents.openDevTools();
}
app.whenReady().then(createWindow);
app.on("window-all-closed", () => {
if (process.platform !== "darwin") {
app.quit();
}
});
app.on("activate", () => {
if (BrowserWindow.getAllWindows().length === 0) {
createWindow();
}
});
// Create a new instance of express
const appE = express();
// Tell express to use the body-parser middleware and to not parse extended bodies
appE.use(bodyParser.json());
// Route that receives a POST request to /sms
appE.post("/notify", function (req, res) {
const body = req.body;
console.log(body);
res.set("Content-Type", "text/plain");
function showNotification() {
const notification = {
title: "Basic Notification",
body: `You sent: ${body.message} to Express`,
};
new Notification(notification).show();
}
app.whenReady().then(createWindow).then(showNotification);
res.send(`You sent: ${body.message} to Express`);
});
// Tell our app to listen on port 3000
appE.listen(3000, function (err) {
if (err) {
throw err;
}
console.log("Server started on port 3000");
});
I'm taking a beginner docker course (https://www.youtube.com/watch?v=3c-iBn73dDE&t=4384s), which I think is very well done.
As part of the course an app is put together with a node server and js frontend, communicating with with docker containers for mongo db and mongo express for persistence.
The node app can be found at https://gitlab.com/nanuchi/techworld-js-docker-demo-app/-/blob/master/app/server.js . containing:
MongoClient.connect("mongodb://admin:password@mongodb:27017",
function (err, client) {
if (err) throw err;
var db = client.db('user-account');
userObj['userid'] = 1;
I have the 2 docker containers running on ubuntu 20.04 on a chromebook (screenshot). When I run:
11@penguin:~/techworld-js-docker-demo-app/app$ nodejs server.js
app listening on port 3000!
but when I open a browser to localhost:3000 , I get:
(node:2716) DeprecationWarning: current Server Discovery and Monitoring engine is deprecated, and will be removed in a future version. To use the new Server Discover and Monitoring pass option { useUnifiedTopology: true } to the MongoClient constructor.
/home/11/techworld-js-docker-demo-app/app/node_modules/mongodb/lib/topologies/server.js:240
throw err;
^
MongoNetworkError: failed to connect to server [mongodb:27017] on first connect [MongoNetworkError: getaddrinfo EAI_AGAIN mongodb mongodb:27017]
at Pool.<anonymous> (/home/11/techworld-js-docker-demo-app/app/node_modules/mongodb/lib/core/topologies/server.js:431:11)
at Pool.emit (events.js:198:13)
at createConnection (/home/11/techworld-js-docker-demo-app/app/node_modules/mongodb/lib/core/connection/pool.js:559:14)
at connect (/home/11/techworld-js-docker-demo-app/app/node_modules/mongodb/lib/core/connection/pool.js:973:11)
at makeConnection (/home/11/techworld-js-docker-demo-app/app/node_modules/mongodb/lib/core/connection/connect.js:39:11)
at callback (/home/11/techworld-js-docker-demo-app/app/node_modules/mongodb/lib/core/connection/connect.js:261:5)
at Socket.err (/home/11/techworld-js-docker-demo-app/app/node_modules/mongodb/lib/core/connection/connect.js:286:7)
at Object.onceWrapper (events.js:286:20)
at Socket.emit (events.js:198:13)
at emitErrorNT (internal/streams/destroy.js:91:8)
What am I doing wrong?
I'm using npm install socket.io-stream I implemented socket.io-stream on my angular component like this :
import * as io from 'socket.io-client';
import * as ss from 'socket.io-stream';
I just want to create a duplex stream like this :
stream=ss.createStream();
I have this error when I run ng build :
ERROR in ./node_modules/socket.io-stream/lib/iostream.js
Module not found: Error: Can't resolve 'stream' in '
'C:\Users\geoffroy\Documents\Mines Alès\2A\Stage\WebService based
GUI\WebApp\node_modules\socket.io-stream\lib'
ERROR in ./node_modules/socket.io-stream/lib/blob-read-stream.js
Module not found: Error: Can't resolve 'stream' in
'C:\Users\geoffroy\Documents\Mines Alès\2A\Stage\WebService based
GUI\WebApp\node_modules\socket.io-stream\lib'
I don't understand because on my server.js It seems to work..
I try to run the command npm install stream and I don't have error with ng build. But when I launch my application I have a new error in my browser console :
inherits_browser.js:5 Uncaught TypeError: Cannot read property 'prototype' of undefined
at Object.inherits (inherits_browser.js:5)
at Object../node_modules/socket.io-stream/lib/iostream.js (iostream.js:10)
at __webpack_require__ (bootstrap:76)
at Object../node_modules/socket.io-stream/lib/socket.js (socket.js:4)
at __webpack_require__ (bootstrap:76)
at Object../node_modules/socket.io-stream/lib/index.js (index.js:1)
at __webpack_require__ (bootstrap:76)
at Object../node_modules/socket.io-stream/index.js (index.js:2)
at __webpack_require__ (bootstrap:76)
Thanks for your help
I am aware of the other questions about this issue. The answers on them are of no help, however. I've been dealing with Node and npm for a few years and I've never come across something so confusing. This is my first time dealing with socket.io, however.
I've installed socket.io as a dependency on a git submodule of my project:
npm install --save socket.io
Then I require it:
const io = require("socket.io")(8099);
However, when I attempt to run the app, I get an error:
[error:app 10:31:32.339 C:\Users\<username>\dev\projects\js-ps-app\generator\generator-core\app.js:336:37] Unable to load plugin at 'C:\Users\<username>\dev\projects\js-ps-app\generator\plugins\generator-starter': Could not load plugin at path 'C:\Users\<username>\dev\projects\js-ps-app\generator\plugins\generator-starter': Cannot find module 'socket.io'
When attempting to reference the module relatively:
const io = require(".\\node_modules\\socket.io")(8099);
The error seems to shift to engine.io, which isn't even referenced in my project:
[error:app 10:38:40.630 C:\Users\<username>\dev\projects\js-ps-app\generator\generator-core\app.js:336:37] Unable to load plugin at 'C:\Users\<username>\dev\projects\js-ps-app\generator\plugins\generator-starter': Could not load plugin at path 'C:\Users\<username>\dev\projects\js-ps-app\generator\plugins\generator-starter': Cannot find module 'engine.io'
I am at a loss to know what to do.
For context: This is in the middle of working on Davide Barranca's Native Photoshop Apps video course—Lesson #15, specifically. Adobe Generator is working and connecting to Adobe Photoshop just fine. You can see where this project stands currently at its repo.
For example, here's the main repo's package.json:
{
"name": "js-ps-app",
"version": "0.1.0",
"private": true,
"scripts": {
"serve": "vue-cli-service serve",
"build": "vue-cli-service build",
"lint": "vue-cli-service lint",
"nwdev": "concurrently --kill-others --raw \"npm:serve\" \".\\node_modules\\.bin\\run .\\nwdev\" --success 'first'",
"generator": "node --inspect .\\generator\\generator-core\\app -f .\\generator\\plugins -v"
},
"dependencies": {
"@mdi/font": "^3.6.95",
"core-js": "^3.6.5",
"roboto-fontface": "*",
"vue": "^2.6.11",
"vue-router": "^3.2.0",
"vue-the-mask": "^0.11.1",
"vuetify": "^2.2.11",
"vuex": "^3.4.0"
},
"devDependencies": {
"7zip-bin-win": "^2.2.0",
"@vue/cli-plugin-babel": "~4.5.0",
"@vue/cli-plugin-eslint": "~4.5.0",
"@vue/cli-plugin-router": "~4.5.0",
"@vue/cli-plugin-vuex": "~4.5.0",
"@vue/cli-service": "~4.5.0",
"babel-eslint": "^10.1.0",
"concurrently": "^5.3.0",
"eslint": "^6.7.2",
"eslint-plugin-vue": "^7.1.0",
"node-sass": "^4.12.0",
"nw-vue-devtools-prebuilt": "0.0.10",
"nwjs-builder-phoenix": "^1.15.0",
"sass": "^1.19.0",
"sass-loader": "^8.0.2",
"vue-cli-plugin-vuetify": "~2.0.7",
"vue-template-compiler": "^2.6.11",
"vuetify-loader": "^1.3.0"
}
}
And here's generator-starter's package.json, which is what needs socket.io:
{
"name": "generator-starter",
"version": "1.0.0",
"description": "Blank Adobe Generator Plugin",
"main": "main.js",
"generator-core-version": "~3",
"menu": {
"id": "generator-starter",
"label": "Generator Plugin"
},
"scripts": {
"test": "echo \"Error: no test specified\" && exit 1"
},
"author": "Davide Barranca",
"license": "ISC",
"dependencies": {
"engine.io": "^4.0.1",
"socket.io": "^2.3.0"
}
}
"Running the app" means running npm run generator from the root of the project. It uses node to run app.js inside generator\generator-core, which takes the sibling directory generator\plugins as an argument.
I have a NodeJS app that seems to have an infinite loop due to persistent 100% CPU usage - https://github.com/3PG/Bot.
IDE: VSCode
I have changed many files and lines of code since June, but the problem still persists. I believe it is caused by an infinite loop.
How would I detect infinite loops in Node.js for TypeScript project?