mirror of
https://github.com/danny-avila/LibreChat.git
synced 2025-12-17 00:40:14 +01:00
fix: Remove script for migrateDataToFirstUser (#590)
This commit is contained in:
parent
3c1aeab340
commit
4e317c85fd
3 changed files with 11 additions and 45 deletions
|
|
@ -3,16 +3,16 @@ const Token = require('../../models/schema/tokenSchema');
|
||||||
const crypto = require('crypto');
|
const crypto = require('crypto');
|
||||||
const bcrypt = require('bcryptjs');
|
const bcrypt = require('bcryptjs');
|
||||||
const { registerSchema } = require('../../strategies/validators');
|
const { registerSchema } = require('../../strategies/validators');
|
||||||
const { migrateDataToFirstUser, sendEmail } = require('../../utils');
|
const { sendEmail } = require('../../utils');
|
||||||
const config = require('../../../config/loader');
|
const config = require('../../../config/loader');
|
||||||
const domains = config.domains;
|
const domains = config.domains;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Logout user
|
* Logout user
|
||||||
*
|
*
|
||||||
* @param {Object} user
|
* @param {Object} user
|
||||||
* @param {*} refreshToken
|
* @param {*} refreshToken
|
||||||
* @returns
|
* @returns
|
||||||
*/
|
*/
|
||||||
const logoutUser = async (user, refreshToken) => {
|
const logoutUser = async (user, refreshToken) => {
|
||||||
try {
|
try {
|
||||||
|
|
@ -37,7 +37,7 @@ const logoutUser = async (user, refreshToken) => {
|
||||||
* Register a new user
|
* Register a new user
|
||||||
*
|
*
|
||||||
* @param {Object} user <email, password, name, username>
|
* @param {Object} user <email, password, name, username>
|
||||||
* @returns
|
* @returns
|
||||||
*/
|
*/
|
||||||
const registerUser = async (user) => {
|
const registerUser = async (user) => {
|
||||||
const { error } = registerSchema.validate(user);
|
const { error } = registerSchema.validate(user);
|
||||||
|
|
@ -91,9 +91,6 @@ const registerUser = async (user) => {
|
||||||
newUser.password = hash;
|
newUser.password = hash;
|
||||||
newUser.save();
|
newUser.save();
|
||||||
|
|
||||||
if (isFirstRegisteredUser) {
|
|
||||||
migrateDataToFirstUser(newUser);
|
|
||||||
}
|
|
||||||
return { status: 200, user: newUser };
|
return { status: 200, user: newUser };
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
return { status: 500, message: err?.message || 'Something went wrong' };
|
return { status: 500, message: err?.message || 'Something went wrong' };
|
||||||
|
|
@ -103,8 +100,8 @@ const registerUser = async (user) => {
|
||||||
/**
|
/**
|
||||||
* Request password reset
|
* Request password reset
|
||||||
*
|
*
|
||||||
* @param {String} email
|
* @param {String} email
|
||||||
* @returns
|
* @returns
|
||||||
*/
|
*/
|
||||||
const requestPasswordReset = async (email) => {
|
const requestPasswordReset = async (email) => {
|
||||||
const user = await User.findOne({ email });
|
const user = await User.findOne({ email });
|
||||||
|
|
@ -141,10 +138,10 @@ const requestPasswordReset = async (email) => {
|
||||||
/**
|
/**
|
||||||
* Reset Password
|
* Reset Password
|
||||||
*
|
*
|
||||||
* @param {*} userId
|
* @param {*} userId
|
||||||
* @param {String} token
|
* @param {String} token
|
||||||
* @param {String} password
|
* @param {String} password
|
||||||
* @returns
|
* @returns
|
||||||
*/
|
*/
|
||||||
const resetPassword = async (userId, token, password) => {
|
const resetPassword = async (userId, token, password) => {
|
||||||
let passwordResetToken = await Token.findOne({ userId });
|
let passwordResetToken = await Token.findOne({ userId });
|
||||||
|
|
|
||||||
|
|
@ -1,7 +1,6 @@
|
||||||
const azureUtils = require('./azureUtils');
|
const azureUtils = require('./azureUtils');
|
||||||
const cryptoUtils = require('./crypto');
|
const cryptoUtils = require('./crypto');
|
||||||
const { tiktokenModels, maxTokensMap } = require('./tokens');
|
const { tiktokenModels, maxTokensMap } = require('./tokens');
|
||||||
const migrateConversations = require('./migrateDataToFirstUser');
|
|
||||||
const sendEmail = require('./sendEmail');
|
const sendEmail = require('./sendEmail');
|
||||||
const abortMessage = require('./abortMessage');
|
const abortMessage = require('./abortMessage');
|
||||||
|
|
||||||
|
|
@ -10,7 +9,6 @@ module.exports = {
|
||||||
...azureUtils,
|
...azureUtils,
|
||||||
maxTokensMap,
|
maxTokensMap,
|
||||||
tiktokenModels,
|
tiktokenModels,
|
||||||
migrateConversations,
|
|
||||||
sendEmail,
|
sendEmail,
|
||||||
abortMessage
|
abortMessage
|
||||||
}
|
}
|
||||||
|
|
@ -1,29 +0,0 @@
|
||||||
const Conversation = require('../models/schema/convoSchema');
|
|
||||||
const Preset = require('../models/schema/presetSchema');
|
|
||||||
|
|
||||||
const migrateConversations = async (userId) => {
|
|
||||||
try {
|
|
||||||
return await Conversation.updateMany({ user: null }, { $set: { user: userId } }).exec();
|
|
||||||
} catch (error) {
|
|
||||||
console.log(error);
|
|
||||||
return { message: 'Error saving conversation' };
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
const migratePresets = async (userId) => {
|
|
||||||
try {
|
|
||||||
return await Preset.updateMany({ user: null }, { $set: { user: userId } }).exec();
|
|
||||||
} catch (error) {
|
|
||||||
console.log(error);
|
|
||||||
return { message: 'Error saving conversation' };
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
const migrateDataToFirstUser = async (user) => {
|
|
||||||
const conversations = await migrateConversations(user.id);
|
|
||||||
console.log(conversations);
|
|
||||||
const presets = await migratePresets(user.id);
|
|
||||||
console.log(presets);
|
|
||||||
};
|
|
||||||
|
|
||||||
module.exports = migrateDataToFirstUser;
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue