midjourney-api
midjourney-api copied to clipboard
erictik
missing response from server
the code that reproduces this issue or a replay of the bug
let completion;
let ReconnectCounter = 2;
while (--ReconnectCounter) {
try {
await logInfo("Midjourney Imagine: ${prompt}");
completion = await Promise.race([
client.Imagine(prompt, async (uri, progress) => {
await bot.sendChatAction(userCurrent.username, "typing");
await sendPhotoData(bot, uri, "request in processing...", {
chat_id: userCurrent.username,
message_id: waitMessage
}).then(async message => {
if (!waitMessage) {
waitMessage = message.message_id;
}
}).catch((error) => logInfo(error));
}),
new Promise((_, reject) =>
setTimeout(() => reject(new Error("Imagine timeout")), 2 * 60000)
)
]);
break;
} catch (e) {
if (e.message !== "Imagine timeout") {
throw e;
break;
} else {
await logInfo("close client Midjourney");
await client.Close();
await logInfo("sleep client Midjourney 150 ms");
await new Promise((resolve) => setTimeout(resolve, 150));
await logInfo("connect client Midjourney");
await client.init();
}
}
}
Describe the bug
Hello, the connection with midjourney is lost after 20-30 minutes of connection. Closing and reopening it doesn't provide a connection and reconnecting doesn't yield any result. What should I do?
error log
Error: ImagineApi failed with status 429 at Midjourney.Imagine (/opt/node_modules/midjourney/libs/midjourney.js:52:19) at process.processTicksAndRejections (node:internal/process/task_queues:95:5) at async MidjourneyGeneration (file:///opt/index.dev.js:463:22) at async MidjourneyGeneration (file:///opt/index.dev.js:548:7) at async MidjourneyGeneration (file:///opt/index.dev.js:548:7) at async MidjourneyGeneration (file:///opt/index.dev.js:548:7) at async file:///opt/index.dev.js:324:13 at async Object.callback (file:///opt/index.dev.js:1157:7)
Error: Invalid aspect ratio: 9/16 (Should be W:H, for example 16:9)
at WsMessage.messageCreate (/opt/node_modules/midjourney/libs/ws.message.js:91:39)
at WsMessage.parseMessage (/opt/node_modules/midjourney/libs/ws.message.js:193:18)
at WebSocket.
Error: Could not validate this link. Please try again later.
at WsMessage.messageCreate (/opt/node_modules/midjourney/libs/ws.message.js:91:39)
at WsMessage.parseMessage (/opt/node_modules/midjourney/libs/ws.message.js:193:18)
at WebSocket.
Error: You've already requested an upscale for this image!
at WsMessage.messageCreate (/opt/node_modules/midjourney/libs/ws.message.js:91:39)
at WsMessage.parseMessage (/opt/node_modules/midjourney/libs/ws.message.js:193:18)
at WebSocket.
Everything works well for the first 20-30 minutes, but afterwards, when the connection is lost (the server stops responding), I attempt to reconnect. At that point, I encounter various types of errors. I am unable to establish a new connection with Midjourney. It complains that it couldn't find a callback for the result.
string New user id [xxxxx] string [event text:user: xxxxx = Go] - init string Midjourney Imagine: Go Imagine Go nonce 1137308208306585600 2023-08-05T08:56:47.025Z string [event text:user: xxxxx = Mister] - init string Midjourney Imagine: Mister Imagine Mister nonce 1137308633239912448 2023-08-05T08:58:28.337Z string close client Midjourney string sleep client Midjourney 150 ms string connect client Midjourney open.time 0 2023-08-05T08:58:47.449Z ws ready 2023-08-05T08:58:48.386Z
FilterMessages not found {
id: '*',
flags: 0,
content: '**Mister** - <@1093132196581216257> (fast)',
hash: '*-*-*-*-*',
progress: 'done',
uri: 'https://cdn.discordapp.com/attachments//.png',
options: [
{
type: 2,
style: 2,
label: 'U1',
custom: 'MJ::JOB::upsample::1::*-*-4aec-*-*'
},
...
]
} Map(0) {} 2023-08-05T08:59:11.060Z
In general, nothing is clear, it would be nice if the library itself monitored that the connection was not processed for a long time. And tried to reconnect without losing the handlers.
Any resolution to this issue? Mine works well for far longer -- maybe 5 hours. I have also made a timeout system like yours. But after many hours it starts timing out over and over. My app is running on an AWS sever, so I am fairly certain the internet connection is not the problem.
Any resolution to this issue? Mine works well for far longer -- maybe 5 hours. I have also made a timeout system like yours. But after many hours it starts timing out over and over. My app is running on an AWS sever, so I am fairly certain the internet connection is not the problem.
I uninstalled the updates and reinstalled. And I controlled nodemon to track only 1 target. There were no problems after that.
"dev": "nodemon --watch index.dev.js index.dev.js",
So if you have logs. Then the tracking extensions can restart the script
The latest version of midjourney-api behaves unconditionally well
const client = new Midjourney({
ServerId: process.env.MIDJOURNEY_SERVERID,
ChannelId: process.env.MIDJOURNEY_CHANNELID,
SalaiToken: process.env.MIDJOURNEY_SALAITOKEN,
Debug: debugConsole,
Ws: true,
});
async function MidjourneyGeneration(text, prompt, userCurrent, waitMessage = false, count = 5) {
try {
if (moderation(prompt)) {
await bot.sendMessage(userCurrent.username, `Запрос "${text}" не прошёл модерацию.`, {
parse_mode: 'Markdown'
}).catch((error) => logInfo(error));
return;
}
await bot.sendChatAction(userCurrent.username, 'typing');
userCurrent.subscribe = (userCurrent.subscribe / 1) - 1;
await DB.saveData(userCurrent, userCurrent.username);
//await userCurrent.save();
let completion;
let ReconnectCounter = 2;
while (--ReconnectCounter) {
try {
await logInfo(`Midjourney Imagine: ${prompt}`);
completion = await Promise.race([
client.Imagine(prompt, async (uri, progress) => {
await logInfo(`Imagine URL: ${uri}`);
await bot.sendChatAction(userCurrent.username, 'typing');
await sendPhotoData(bot, uri, '👀 Пожалуйста, подождите... ', {
chat_id: userCurrent.username,
message_id: waitMessage
}).then(async message => {
if (!waitMessage) {
waitMessage = message.message_id;
}
}).catch((error) => logInfo(error));
}),
new Promise((_, reject) =>
setTimeout(() => reject(new Error('Imagine timeout')), 3 * 60000)
)
]);
break;
} catch (e) {
if (e.message !== 'Imagine timeout') {
await logInfo(e);
await cancelOperation(e, text, prompt, userCurrent, waitMessage, -1, false, false, false);
return;
} else {
await logInfo('close client Midjourney');
await client.Close();
await logInfo('sleep client Midjourney 150 ms');
await new Promise((resolve) => setTimeout(resolve, 150));
await logInfo('connect client Midjourney');
await client.init();
}
}
}
let isError;
if (ReconnectCounter <= 0) {
isError = true;
} else {
let inline_keyboard = inline_keyboard_button(completion);
let max = 10;
isError = true;
for (let i = 0; isError && (i < 10); i++) {
await sendPhotoData(bot, completion.uri, `[Ссылка на изображение](${completion.uri})`, {
chat_id: userCurrent.username,
message_id: waitMessage,
reply_markup: {
inline_keyboard: inline_keyboard
}
}).then(async message => {
isError = false;
waitMessage = message.message_id;
}).catch((error) => {
if (i >= max) {
logInfo(error)
}
});
}
}
if (isError) {
await cancelOperation(true, text, prompt, userCurrent, waitMessage, -1, false, false, false);
} else if (waitMessage) {
await contentMessageSet(userCurrent, waitMessage, completion, text);
userCurrent.last = prompt;
await DB.saveData(userCurrent, userCurrent.username);
//await userCurrent.save();
}
} catch (error) {
await logInfo(error);
await cancelOperation(error, text, prompt, userCurrent, waitMessage, --count, false, false, false);
};
}
async function MidjourneyGenerationCustom(BDButtonFile, BDButton, id, userCurrent, waitMessage = false, count = 5) {
try {
BDButton[id][1] = id;
await writeJsonFile(BDButtonFile, BDButton);
await bot.sendChatAction(userCurrent.username, 'typing');
userCurrent.subscribe = (userCurrent.subscribe / 1) - 1;
await DB.saveData(userCurrent, userCurrent.username);
//await userCurrent.save();
let completion;
let ReconnectCounter = 2;
while (--ReconnectCounter) {
try {
await logInfo(`Midjourney Custom: ${BDButton[id][0]}`);
completion = await Promise.race([
client.Custom({
msgId: BDButton.id,
flags: BDButton.flags,
content: BDButton.content,
customId: BDButton[id][0],
loading: async (uri, progress) => {
await bot.sendChatAction(userCurrent.username, 'typing');
await sendPhotoData(bot, uri, '👀 Пожалуйста, подождите... ', {
chat_id: userCurrent.username,
message_id: waitMessage
}).then(async message => {
if (!waitMessage)
waitMessage = message.message_id;
}).catch((error) => logInfo(error));
}
}),
new Promise((_, reject) =>
setTimeout(() => reject(new Error('Custom timeout')), 3 * 60000)
)
]);
break; // Выход из цикла, если Promise завершился успешно
} catch (e) {
if (e.message !== 'Custom timeout') {
await logInfo(e);
await cancelOperation(e, `${BDButton.promptSave} -- ${id}`, false, userCurrent, waitMessage, -1, BDButton, id, BDButtonFile);
return;
} else {
await logInfo('close client Midjourney');
await client.Close();
await logInfo('sleep client Midjourney 150 ms');
await new Promise((resolve) => setTimeout(resolve, 150));
await logInfo('connect client Midjourney');
await client.init();
}
}
}
let isError;
if (ReconnectCounter <= 0) {
isError = true;
} else {
let inline_keyboard = inline_keyboard_button(completion);
let max = 10;
isError = true;
for (let i = 0; isError && (i < 10); i++) {
await sendPhotoData(bot, completion.uri, `[Ссылка на изображение](${completion.uri})`, {
chat_id: userCurrent.username,
message_id: waitMessage,
reply_markup: {
inline_keyboard: inline_keyboard
}
}).then(async message => {
isError = false;
waitMessage = message.message_id;
}).catch((error) => {
if (i >= max) {
logInfo(error)
}
});
}
}
if (isError) {
await cancelOperation(true, `${BDButton.promptSave} -- ${id}`, false, userCurrent, waitMessage, -1, BDButton, id, BDButtonFile);
} else if (waitMessage) {
BDButton[id][1] = completion.uri;
await writeJsonFile(BDButtonFile, BDButton);
await contentMessageSet(userCurrent, waitMessage, completion, id);
}
} catch (error) {
await logInfo(error);
await cancelOperation(error, `${BDButton.promptSave} -- ${id}`, false, userCurrent, waitMessage, --count, BDButton, id, BDButtonFile);
};
}
function inline_keyboard_button(completion) {
if (completion.options === undefined) return [];
let inline_keyboard = [];
for (const row of completion.options) {
let labeltext = row.label.trim();
if (sortButton[labeltext] === false) {
continue;
}
if ((typeof sortButton[labeltext] === 'object') && sortButton[labeltext]['text']) {
labeltext = sortButton[labeltext]['text'].trim();
}
inline_keyboard.push({
text: labeltext,
callback_data: labeltext
});
}
inline_keyboard.sort((a, b) => {
let indexA = Infinity;
if ((typeof sortButton[a.text] === 'object') && sortButton[a.text]['index']) {
indexA = sortButton[a.text]['index'];
} else if (sortButton[a.text] != undefined) {
indexA = sortButton[a.text];
}
let indexB = Infinity;
if ((typeof sortButton[b.text] === 'object') && sortButton[b.text]['index']) {
indexB = sortButton[b.text]['index'];
} else if (sortButton[b.text] != undefined) {
indexB = sortButton[b.text];
}
return indexA - indexB;
});
return inline_keyboard.reduce((acc, curr, index) => {
const groupIndex = Math.floor(index / 3);
if (!acc[groupIndex]) {
acc[groupIndex] = [];
}
acc[groupIndex].push(curr);
return acc;
}, []);
}
async function contentMessageSet(userCurrent, waitMessage, completion, prompt) {
let content = {
id: completion.id,
flags: completion.flags,
content: completion.content,
data: +(new Date()),
promptSave: prompt
};
for (const comOpt of completion.options) {
let labeltext = comOpt.label.trim();
if (sortButton[labeltext] === false) {
continue;
}
if ((typeof sortButton[labeltext] === 'object') && sortButton[labeltext]['text']) {
labeltext = sortButton[labeltext]['text'].trim();
}
content[labeltext] = [comOpt.custom, false];
}
await writeJsonFile('tmp/' + userCurrent.username + '/' + waitMessage, content);
}
I'm having the same issue, after several hours, no more responses from the server com back
