lone-cloud/prism
0
0
Fork 0
mirror of https://github.com/lone-cloud/prism synced 2026-06-03 19:54:44 -07:00
Code Issues Projects Releases Packages Wiki Activity

better socket connect

Browse source
This commit is contained in:
Egor 2026-01-18 19:00:37 -08:00
parent 00b8e35570
commit 9af3c2afcf
3 changed files with 26 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
server/Dockerfile
View file

@ -22,6 +22,7 @@ RUN curl -L https://github.com/AsamK/signal-cli/releases/download/v${SIGNAL_CLI_
COPY --from=builder /app/sup-server /usr/local/bin/sup-server
ENV PATH="/usr/local/signal-cli/bin:${PATH}"
ENV LD_LIBRARY_PATH="/usr/local/signal-cli/lib:${LD_LIBRARY_PATH}"
EXPOSE 8080

1
server/constants/config.ts
View file

@ -3,7 +3,6 @@ export const API_KEY = Bun.env.API_KEY;
export const VERBOSE = Bun.env.VERBOSE === 'true';
export const DEVICE_NAME = 'SUP';
export const DAEMON_START_MAX_ATTEMPTS = 10;
export const SUP_ENDPOINT_PREFIX = `[${DEVICE_NAME}:`;
export const LAUNCH_ENDPOINT_PREFIX = '[LAUNCH:';

51
server/modules/signal.ts
View file

@ -1,5 +1,5 @@
import { rm } from 'node:fs/promises';
import { DAEMON_START_MAX_ATTEMPTS, DEVICE_NAME, VERBOSE } from '../constants/config';
import { DEVICE_NAME, VERBOSE } from '../constants/config';
import { SIGNAL_CLI, SIGNAL_CLI_DATA, SIGNAL_CLI_SOCKET } from '../constants/paths';
import type { ListAccountsResult, StartLinkResult, UpdateGroupResult } from '../types';
import { logError, logInfo, logSuccess, logVerbose, logWarn } from '../utils/log';
@ -157,32 +157,31 @@ export async function startDaemon() {
}
})();
let attempts = 0;
while (attempts < DAEMON_START_MAX_ATTEMPTS) {
try {
const socket = await Bun.connect({
unix: SIGNAL_CLI_SOCKET,
socket: {
data() {},
error() {},
},
});
socket.end();
logSuccess('✓ signal-cli daemon started');
return proc;
} catch (_error) {
if (authError && attempts > 5 && !cleaned) {
logWarn('⚠ Detected stale account data, cleaning up and retrying...');
proc.kill();
await unlinkDevice();
cleaned = true;
return startDaemon();
}
await Bun.sleep(3000);
await new Promise((resolve) => setTimeout(resolve, 100));
attempts++;
try {
const socket = await Bun.connect({
unix: SIGNAL_CLI_SOCKET,
socket: {
data() {},
},
});
socket.end();
logSuccess('✓ signal-cli daemon started');
return proc;
} catch (error) {
if (authError && !cleaned) {
logWarn('⚠ Detected stale account data, cleaning up and retrying...');
proc.kill();
await unlinkDevice();
cleaned = true;
return startDaemon();
}
}
throw new Error('Failed to start signal-cli daemon');
logError('Failed to connect to signal-cli socket:', error);
if (proc.exitCode !== null) {
logError('signal-cli process exited with code:', proc.exitCode);
}
throw new Error('Failed to start signal-cli daemon');
}
}