rush Posts - Answer Overflow

rush

•Created by rush on 5/14/2024 in #❓︱help

need help with creating message-queue tasks.

Hello, it is an awesome product and I want to start by thanking you guys for making it opensource. I am trying to add a feature and I've built it raw, without integrating message-queue functionality into it. A little description- my feature uses langchain; it takes the required data and enriches it with more information (through an LLM). Now since I am sendiing many records, and aim to use it for more than 1 users at a time, I want to integrate it with message queues. The documentation doesn't seem to be helping me. I am a bit new to the development space also. I'll be grateful if you point me in the right direction. I have tried to look through and understand how the gmail and calendar sync is happening but doesn't seem to help by developing-with-reference technique for my use-case. So, this is the controller that is taking the arguments and working to enrich the data:

@Controller('gpt-api')
export class GPTAPIController {
  constructor(
    private gptAPIService: GPTAPIService,
  ) {}

    @Get()
    findAll(): string {
      return 'This action returns all cats';
    }
  
    @Post('enrichment')
    get(@Req() req): object {
      return this.gptAPIService.enrichData(req.body.options, req.body.rawData);
    }
  
    @Post('process-cv')
    async getCVProcess(): Promise<object> {
      const cvProcessingService = new CVProcessing(
        '/path/to/file.pdf',
      );
  
      return await cvProcessingService.getScoresFromCustomPrompt(
        questions,
        // req.body.field_names,
      );
    }
  
    @Post('putting')
    put() {}
}

@Controller('gpt-api')
export class GPTAPIController {
  constructor(
    private gptAPIService: GPTAPIService,
  ) {}

    @Get()
    findAll(): string {
      return 'This action returns all cats';
    }
  
    @Post('enrichment')
    get(@Req() req): object {
      return this.gptAPIService.enrichData(req.body.options, req.body.rawData);
    }
  
    @Post('process-cv')
    async getCVProcess(): Promise<object> {
      const cvProcessingService = new CVProcessing(
        '/path/to/file.pdf',
      );
  
      return await cvProcessingService.getScoresFromCustomPrompt(
        questions,
        // req.body.field_names,
      );
    }
  
    @Post('putting')
    put() {}
}

I want to integrate message queues such that when I send multiple CVs (or through multiple users at once) it adds to the message queue and then executes them one at a time. I am using Bull-MQ and Redis. I can provide more context if you want. I would appreciate any help.

18 replies

TTwenty

•Created by rush on 4/22/2024 in #❓︱help

Need Help with Email Sync (v0.4.0)

I am mainly into front-end side of things so not too much idea about back-end side of things. I have provided the following environment variables: FRONT_AUTH_CALLBACK_URL=http://localhost:3001/verify AUTH_GOOGLE_ENABLED=true MESSAGING_PROVIDER_GMAIL_ENABLED=true CALENDAR_PROVIDER_GOOGLE_ENABLED=true AUTH_GOOGLE_CLIENT_ID=my_google_auth_client_id AUTH_GOOGLE_CLIENT_SECRET=client_secret AUTH_GOOGLE_CALLBACK_URL=http://localhost:3000/auth/google/redirect MESSAGING_PROVIDER_GMAIL_CALLBACK_URL=http://localhost:3000/auth/google-gmail/get-access-token AUTH_GOOGLE_APIS_CALLBACK_URL=http://localhost:3000/auth/google-apis/get-access-token MESSAGE_QUEUE_TYPE=pg-boss [email protected] [email protected] EMAIL_FROM_NAME='Name from Domain' EMAIL_DRIVER=logger EMAIL_SMTP_HOST=smtp.gmail.com EMAIL_SMTP_PORT=465 [email protected] EMAIL_SMTP_PASSWORD='my app password with spaces as provided by google' am I missing something or doing something wrong? My email displays in PG Admin and says: query sync status is "PENDING". Please help me figure it out.

16 replies

Gaming

Programming