realflashkaze/x-poster-client
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

udate

Browse Source
This commit is contained in:
NAME
2026-05-12 03:43:19 +00:00
parent 34a678b3c3
commit d9766dc7f0
3 changed files with 39 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/sqs-module/sqs.poster.worker.ts
+26 -5
View File
@@ -117,8 +117,14 @@ export class SqsPosterWorker {
console.log(`==> doPostTweet publish to X`);
// @ts-ignore
await this.xRouterService.postTweet({text, strategy});
// await this.notifyService.sendMessageToTele(`Post to X success!`);
const r = await this.xRouterService.postTweet({text, strategy});
if (r.success) {
await this.notifyService.sendMessageToTele(`Post to X success!`);
} else {
const mergerError = r.attempts.map(m => m.error).join(", ");
this.logger.error(mergerError);
await this.notifyService.sendMessageToTele(`==>.doPostTweet X got error ${mergerError}`)
}
sendSuccess = true;
}
@@ -141,7 +147,13 @@ export class SqsPosterWorker {
console.log('doReplyTweet');
// @ts-ignore
const r = await this.xRouterService.postReply({text, tweetUrl, tweetId, strategy});
await this.notifyService.sendMessageToTele(`Worker->reply message success`)
if (r.success) {
await this.notifyService.sendMessageToTele(`Worker->reply message success`)
} else {
const mergerError = r.attempts.map(m => m.error).join(", ");
this.logger.error(mergerError);
await this.notifyService.sendMessageToTele(`==> doReplyTweet error ${mergerError}`)
}
return r
} catch (e) {
this.logger.error(e);
@@ -163,11 +175,20 @@ export class SqsPosterWorker {
console.log('doQuoteTweet');
// @ts-ignore
const r = await this.xRouterService.postQuote({text, tweetUrl, tweetId, strategy});
await this.notifyService.sendMessageToTele(`✅ Quote message success`)
if (r.success) {
await this.notifyService.sendMessageToTele(`✅ Quote message success`)
} else {
const mergerError = r.attempts.map(m => m.error).join(", ");
this.logger.error(mergerError);
await this.notifyService.sendMessageToTele(`==> doQuoteTweet error ${mergerError}`)
}
return r
} catch (e) {
this.logger.error(e);
await this.notifyService.sendMessageToTele(`==> doQuoteTweet error:${e.message}`)
await this.notifyService.sendMessageToTele(`==> doQuoteTweet catch error:${e.message}`)
}
}