Skip to content

Commit

Permalink
resolving further conflicts
Browse files Browse the repository at this point in the history
  • Loading branch information
Xm0onh committed Dec 24, 2024
1 parent 7bb391c commit ae9731e
Show file tree
Hide file tree
Showing 5 changed files with 0 additions and 28 deletions.
8 changes: 0 additions & 8 deletions auto-kol/agent/src/services/agents/nodes/autoApprovalNode.ts
Original file line number Diff line number Diff line change
Expand Up @@ -7,11 +7,7 @@ import { uploadToDsn } from '../../../utils/dsn.js';
import { config as globalConfig } from '../../../config/index.js';
import { ResponseStatus } from '../../../types/queue.js';

<<<<<<< HEAD
export const createAutoApprovalNode = (config: WorkflowConfig) => {
=======
export const createAutoApprovalNode = (config: WorkflowConfig, scraper: ExtendedScraper) => {
>>>>>>> main
return async (state: typeof State.State) => {
logger.info('Auto Approval Node - Evaluating pending responses');
try {
Expand Down Expand Up @@ -62,14 +58,10 @@ export const createAutoApprovalNode = (config: WorkflowConfig, scraper: Extended
tweetId: response.tweet.id,
});

<<<<<<< HEAD
const sendTweetResponse = await config.client.sendTweet(
response.response,
response.tweet.id,
);
=======
const sendTweetResponse = await scraper.sendTweet(response.response, response.tweet.id);
>>>>>>> main
logger.info('Tweet sent', {
sendTweetResponse,
});
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,13 +51,9 @@ export const createRecheckSkippedNode = (config: WorkflowConfig) => {
} else {
const flagged = await flagBackSkippedTweet(tweet.id, decision.reason);
if (!flagged) {
<<<<<<< HEAD
logger.info('Failed to flag back skipped tweet:', {
tweetId: tweet.id,
});
=======
logger.info('Failed to flag back skipped tweet:', { tweetId: tweet.id });
>>>>>>> main
}
}
}
Expand Down
4 changes: 0 additions & 4 deletions auto-kol/agent/src/tools/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -10,11 +10,7 @@ import { ExtendedScraper } from '../services/twitter/api.js';
export const createTools = (scraper: ExtendedScraper) => {
const mentionTool = createMentionTool(scraper);

<<<<<<< HEAD
const fetchTimelineTool = createFetchTimelineTool(scraper);
=======
const fetchTimelineTool = createFetchTimelineTool();
>>>>>>> main

const tweetSearchTool = createTweetSearchTool(scraper);

Expand Down
8 changes: 0 additions & 8 deletions auto-kol/agent/src/tools/tools/fetchTimelineTool.ts
Original file line number Diff line number Diff line change
Expand Up @@ -6,22 +6,14 @@ import { ExtendedScraper } from '../../services/twitter/api.js';

const logger = createLogger('fetch-timeline-tool');

<<<<<<< HEAD
export const createFetchTimelineTool = (twitterScraper: ExtendedScraper) =>
=======
export const createFetchTimelineTool = () =>
>>>>>>> main
new DynamicStructuredTool({
name: 'fetch_timeline',
description: 'Fetch the timeline regularly to get new tweets',
schema: z.object({}),
func: async () => {
try {
<<<<<<< HEAD
const tweets = await getTimeLine(twitterScraper);
=======
const tweets = await getTimeLine();
>>>>>>> main
tweets.sort((a, b) => new Date(b.created_at).getTime() - new Date(a.created_at).getTime());
return {
tweets: tweets,
Expand Down
4 changes: 0 additions & 4 deletions auto-kol/agent/src/tools/tools/tweetSearchTool.ts
Original file line number Diff line number Diff line change
Expand Up @@ -22,11 +22,7 @@ export const createTweetSearchTool = (scraper: ExtendedScraper) =>
func: async ({ lastProcessedId }) => {
try {
logger.info('Called search_recent_tweets');
<<<<<<< HEAD
await updateKOLs(scraper);
=======
await updateKOLs();
>>>>>>> main
const kols = await getKOLsAccounts();

if (kols.length === 0) {
Expand Down

0 comments on commit ae9731e

Please sign in to comment.