boki/stock-bot
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity Actions

removed more stuff

Browse source
This commit is contained in:
Boki 2025-06-23 22:51:55 -04:00
parent 2d14bb87f9
commit 566f5dac92
2 changed files with 29 additions and 52 deletions
Download patch file Download diff file Expand all files Collapse all files

32
apps/stock/data-ingestion/src/handlers/ceo/actions/process-individual-symbol.action.ts
View file

@ -1,10 +1,16 @@
import { getRandomUserAgent } from '@stock-bot/utils';
import type { CeoHandler } from '../ceo.handler';
interface ProcessIndividualSymbolPayload {
ceoId: string;
symbol: string;
timestamp?: string;
}
export async function processIndividualSymbol(
this: CeoHandler,
payload: any,
_context: any
payload: ProcessIndividualSymbolPayload,
_context: unknown
): Promise<unknown> {
const { ceoId, symbol, timestamp } = payload;
const proxy = this.proxy?.getProxy();
@ -42,7 +48,27 @@ export async function processIndividualSymbol(
return null; // No data to process
}
const latestSpielTime = data.spiels[0]?.timestamp;
const posts = data.spiels.map((spiel: any) => ({
interface Spiel {
spiel: string;
spiel_reply_to_id: string;
spiel_reply_to: string;
spiel_reply_to_name: string;
spiel_reply_to_edited: boolean;
user_id: string;
name: string;
timestamp: string;
spiel_id: string;
color: string;
parent_id: string;
public_id: string;
parent_channel: string;
parent_timestamp: string;
votes: number;
editable: boolean;
edited: boolean;
}
const posts = data.spiels.map((spiel: Spiel) => ({
ceoId,
spiel: spiel.spiel,
spielReplyToId: spiel.spiel_reply_to_id,