// AWS에 완전히 종속된 서비스
import { DynamoDBClient, PutItemCommand } from "@aws-sdk/client-dynamodb";
import { SQSClient, SendMessageCommand } from "@aws-sdk/client-sqs";
import { SNSClient, PublishCommand } from "@aws-sdk/client-sns";
import { S3Client, PutObjectCommand } from "@aws-sdk/client-s3";
import { LambdaClient, InvokeCommand } from "@aws-sdk/client-lambda";

// 비즈니스 로직이 AWS SDK와 직접 결합
async function createOrder(order: Order): Promise<void> {
  // DynamoDB에 직접 저장
  await dynamodb.send(new PutItemCommand({
    TableName: "orders",
    Item: { /* DynamoDB 형식 */ }
  }));

  // SQS로 이벤트 발행
  await sqs.send(new SendMessageCommand({
    QueueUrl: process.env.ORDER_QUEUE_URL,
    MessageBody: JSON.stringify(order)
  }));

  // SNS로 알림
  await sns.send(new PublishCommand({
    TopicArn: process.env.ORDER_TOPIC_ARN,
    Message: `새 주문: ${order.id}`
  }));
}

// 나쁜 예: 비즈니스 로직에 AWS 직접 결합
async function saveUser(user: User) {
  await dynamodb.send(new PutItemCommand({
    TableName: "users",
    Item: marshallUser(user) // DynamoDB 형식 변환
  }));
}

// 좋은 예: 추상화 레이어로 격리
interface UserRepository {
  save(user: User): Promise<void>;
  findById(id: string): Promise<User | null>;
}

class DynamoDBUserRepository implements UserRepository {
  async save(user: User): Promise<void> {
    await this.client.send(new PutItemCommand({
      TableName: "users",
      Item: marshallUser(user)
    }));
  }
  // ...
}

// 이전할 때 이것만 교체하면 됨
class PostgresUserRepository implements UserRepository {
  async save(user: User): Promise<void> {
    await this.pool.query(
      "INSERT INTO users (id, name, email) VALUES ($1, $2, $3)",
      [user.id, user.name, user.email]
    );
  }
  // ...
}

// 은탄환 사고방식
const decision = {
  problem: "API가 느림",
  solution: "GraphQL로 전환",
  expected: "모든 성능 문제 해결",
  tradeoffs: "없음. GraphQL이 최고니까.",  // 🚨 위험
};

// 건강한 사고방식
const decision = {
  problem: "API가 느림 — over-fetching이 주 원인",
  solution: "GraphQL 부분 도입",
  expected: "over-fetching 해결로 평균 응답 시간 30% 개선",
  tradeoffs: [
    "N+1 쿼리 문제를 DataLoader로 관리해야 함",
    "캐싱 전략 재수립 필요",
    "팀 학습 비용 2-3주",
    "기존 REST와 공존 기간 필요"
  ],
  alternativesConsidered: [
    "REST에 sparse fieldset 적용",
    "BFF(Backend for Frontend) 패턴"
  ]
};

// 실제 필요한 것: 유저 목록을 보여주는 API

// 아키텍처 우주인의 설계
interface IQueryHandler<TQuery extends IQuery, TResult> {
  handle(query: TQuery): Promise<TResult>;
}

interface ICommandHandler<TCommand extends ICommand> {
  handle(command: TCommand): Promise<void>;
}

interface IEventHandler<TEvent extends IDomainEvent> {
  handle(event: TEvent): Promise<void>;
}

class GetUsersQuery implements IQuery {
  constructor(
    public readonly page: number,
    public readonly limit: number,
    public readonly correlationId: string = crypto.randomUUID()
  ) {}
}

class GetUsersQueryHandler
  implements IQueryHandler<GetUsersQuery, PaginatedResult<UserDto>>
{
  constructor(
    private readonly userReadRepository: IUserReadRepository,
    private readonly mapper: IMapper<UserEntity, UserDto>,
    private readonly logger: ILogger,
    private readonly cache: ICacheService,
    private readonly metrics: IMetricsService
  ) {}

  async handle(
    query: GetUsersQuery
  ): Promise<PaginatedResult<UserDto>> {
    this.logger.info("Handling GetUsersQuery", { correlationId: query.correlationId });
    this.metrics.increment("queries.getUsers");
    // ... 실제 DB 조회는 50줄 뒤에
  }
}

// 실제로 필요한 코드
async function getUsers(page: number, limit: number) {
  return db.query("SELECT * FROM users LIMIT $1 OFFSET $2", [limit, page * limit]);
}