sergio11

@Component
@Slf4j
@RequiredArgsConstructor
public class TweetsIngestHandler {

    /**
     * Text Analyzer Service
     */
    private final ITextAnalyzerService textAnalyzerService;

sergio11

@Slf4j
@RequiredArgsConstructor
public class TwitterMessageProducer extends MessageProducerSupport {

    private final TwitterStream twitterStream;
    private final MessageChannel outputChannel;
    private final TweetEntityMapper tweetEntityMapper;

    @Getter
    @Setter

sergio11

@Slf4j
@RequiredArgsConstructor
@Component
public class TweetsProcessedHandler {

    private final ITweetsService tweetService;

    /**
     *
     * @param newProcessedTweet

sergio11

@Data
@EqualsAndHashCode(callSuper = false)
@AllArgsConstructor
@NoArgsConstructor
@Document(indexName = "tweets_processed")
public class TweetEntity {

    @Id
    @Field(type = FieldType.Long)
    private Long id;

sergio11

import com.dreamsoftware.model.OTPGenerated
import com.dreamsoftware.model.RedisStorageConfig
import com.dreamsoftware.model.exception.OTPDestinationIsBlockedException
import com.dreamsoftware.model.exception.OTPNotFoundException
import com.dreamsoftware.model.exception.OTPSaveDataException
import com.dreamsoftware.repository.OTPRepository
import com.dreamsoftware.utils.hashSha256andEncode
import redis.clients.jedis.JedisCluster

class OTPRepositoryImpl(

sergio11

import com.dreamsoftware.model.OtpSenderConfig
import com.dreamsoftware.model.SmsSenderConfig
import com.dreamsoftware.model.exception.OTPSenderFailedException
import com.twilio.Twilio
import com.twilio.rest.api.v2010.account.Message
import com.twilio.type.PhoneNumber

class OTPSmsSenderServiceImpl: SupportOTPSender<SmsSenderConfig>() {

    override suspend fun sendOTP(

sergio11

import com.dreamsoftware.model.MailSenderConfig
import com.dreamsoftware.model.exception.OTPSenderFailedException
import com.sendgrid.Method
import com.sendgrid.Request
import com.sendgrid.SendGrid
import com.sendgrid.helpers.mail.Mail
import com.sendgrid.helpers.mail.objects.Content
import com.sendgrid.helpers.mail.objects.Email

class OTPMailSenderServiceImpl: SupportOTPSender<MailSenderConfig>() {

sergio11

from datetime import datetime
from airflow import DAG
import importlib
import os

# Define default arguments for the DAG
default_args = {
    'owner': 'airflow',
    'start_date': datetime(2023, 1, 1),
    'retries': 1,

sergio11

from airflow.utils.decorators import apply_defaults
from operators.base_custom_operator import BaseCustomOperator
from bson import ObjectId
import importlib
import scipy
import tempfile
from datetime import datetime


class GenerateMelodyOperator(BaseCustomOperator):

sergio11

from airflow.utils.decorators import apply_defaults
from operators.base_custom_operator import BaseCustomOperator
from bson import ObjectId
import importlib
import scipy
import tempfile
from datetime import datetime

class GenerateVoiceOperator(BaseCustomOperator):