Skip to content

Commit

Permalink
Feat(tenant): Update socket function
Browse files Browse the repository at this point in the history
  • Loading branch information
arimet committed Sep 15, 2023
1 parent f7824f6 commit cebe1ed
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 13 deletions.
2 changes: 1 addition & 1 deletion cypress/support/authentication.js
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ export const teardown = (withoutLogin = false) => {
logout();
return;
}
// set sessionStorage as tenant: 'lodex_test'

cy.window().then(win => {
win.sessionStorage.setItem('tenant', 'lodex_test');
});
Expand Down
18 changes: 7 additions & 11 deletions src/api/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -135,18 +135,14 @@ if (!module.parent) {
const io = new Server(httpServer);

io.on('connection', socket => {
progress.addProgressListener(payload => {
const emitPayload = payload => {
socket.emit(payload.room, payload.data);
});
addPublisherListener(payload => {
socket.emit(payload.room, payload.data);
});
addEnrichmentJobListener(payload => {
socket.emit(payload.room, payload.data);
});
addImportListener(payload => {
socket.emit(payload.room, payload.data);
});
};

progress.addProgressListener(emitPayload);
addPublisherListener(emitPayload);
addEnrichmentJobListener(emitPayload);
addImportListener(emitPayload);
});
}

Expand Down
2 changes: 1 addition & 1 deletion src/api/services/mongoClient.js
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ export const mongoConnectionString = tenant =>
export const mongoClientFactory = MongoClientImpl => async tenant => {
if (!tenant) {
throw new Error(
`Le tenant n'est pas renseigné, impossible de se connecter à la base de données.`,
`L'instance n'est pas renseigné, impossible de se connecter à la base de données.`,
);
}

Expand Down

0 comments on commit cebe1ed

Please sign in to comment.