OffX Twitter Ingestion

The OffX Twitter ingestion service has:

Fetched ${rawTweets.length} tweets
Processed ${processedTweets.length} after filtering
Stored ${newTweetsCount} new tweets

`,\n });\n });\n }\n\n return {\n success: true,\n fetchedCount: rawTweets.length,\n processedCount: processedTweets.length,\n newCount: newTweetsCount,\n timestamp: new Date().toISOString(),\n };\n } catch (error: unknown) {\n console.error(\"Error in Twitter fetch cron job:\", error);\n\n // Extract useful error information\n const errorInstance = error instanceof Error ? error : new Error(String(error));\n const errorType = error instanceof TwitterError ? error.type : \"unknown\";\n const errorMessage = errorInstance.message || \"Unknown error\";\n const statusCode = error instanceof TwitterError\n ? error.statusCode\n : undefined;\n\n // Construct detailed error message\n const detailedError = `\n Type: ${errorType}\n Message: ${errorMessage}\n ${statusCode ? `Status Code: ${statusCode}` : \"\"}\n Time: ${new Date().toISOString()}\n `;\n\n // Send error notification with retry mechanism\n try {\n await withRetry(async () => {\n await email({\n subject: \"OffX: Twitter Fetch Error\",\n text: `Error in Twitter fetch cron job: ${detailedError}`,\n html: `

OffX Twitter Fetch Error

The following error occurred during the Twitter fetch cron job:

${detailedError}

Please check the logs for more details.

`,\n });\n });\n } catch (emailError) {\n console.error(\"Failed to send error notification email:\", emailError);\n }\n\n return {\n success: false,\n error: errorMessage,\n errorType,\n statusCode,\n timestamp: new Date().toISOString(),\n };\n }\n}\n","deleted","label",[168,150],"backend","permalink","https://www.val.town/x/jpd3v/offx/code/backend/twitter-fetch.cron.ts","extension","actionData","errors"]