{
  "_id": "67e4f4f0d56e3a0ddbfab123",
  "chatId": "67e4f3ffd56e3a0ddbfab111",
  "senderId": "67e4f2aed56e3a0ddbfab001",
  "type": "media",
  "content": "aksamdan bir kare",
  "media": {
    "url": "https://cdn.example.com/messages/photos/8c7f.webp",
    "type": "image",
    "name": "IMG_1123.jpg",
    "size": 148220,
    "width": 1440,
    "height": 1080
  },
  "creditTransfer": null,
  "readBy": ["67e4f2aed56e3a0ddbfab001"],
  "createdAt": "2026-03-09T10:10:10.000Z",
  "updatedAt": "2026-03-09T10:10:10.000Z"
}

export type MessageType = 'text' | 'media' | 'credit_transfer';

export type MessageMedia = {
  url: string;
  type: 'image' | 'video' | 'audio' | 'file';
  name?: string;
  size?: number;
  duration?: number;
  width?: number;
  height?: number;
  thumbnail_url?: string;
};

export type Message = {
  _id: string;
  chatId: string;
  senderId: string;
  type: MessageType;
  content?: string | null;
  media?: MessageMedia | null;
  creditTransfer?: {
    amount: number;
    recipientId: string;
    senderId: string;
  } | null;
  readBy: string[];
  createdAt: string;
  updatedAt: string;
};

export type MessageListResponse = {
  messages: Message[];
  participants: Array<{
    _id: string;
    username?: string;
  }>;
  page: number;
  limit: number;
  total: number;
  totalPages: number;
  hasNextPage: boolean;
  hasPreviousPage: boolean;
};

export type BaseResponseDto<T> = {
  isSuccess: boolean;
  statusCode: number;
  data: T;
  errors?: string[];
  timestamp: string;
};

import { createApi, fetchBaseQuery } from '@reduxjs/toolkit/query/react';
import type { RootState } from '../store';

export const baseApi = createApi({
  reducerPath: 'api',
  baseQuery: fetchBaseQuery({
    baseUrl: `${process.env.EXPO_PUBLIC_API_URL}/api`,
    prepareHeaders: (headers, { getState }) => {
      const token = (getState() as RootState).auth.accessToken;
      if (token) headers.set('Authorization', `Bearer ${token}`);
      return headers;
    },
  }),
  tagTypes: ['Messages'],
  endpoints: () => ({}),
});

import { baseApi } from './baseApi';
import type { BaseResponseDto, Message, MessageListResponse } from '@/types/messages';

type GetChatMessagesArgs = {
  chatId: string;
  page?: number;
  limit?: number;
};

type SendTextMessageV2Args = {
  chatId?: string;
  targetUserId?: string;
  content: string;
};

type SendPhotoMessageV2Args = {
  chatId?: string;
  targetUserId?: string;
  content?: string; // caption
  file: {
    uri: string;
    name: string;
    type: 'image/jpeg' | 'image/jpg' | 'image/png' | 'image/webp';
  };
};

const unwrap = <T>(response: BaseResponseDto<T> | T): T => {
  if (response && typeof response === 'object' && 'data' in (response as any)) {
    return (response as BaseResponseDto<T>).data;
  }
  return response as T;
};

export const messagesApi = baseApi.injectEndpoints({
  endpoints: (builder) => ({
    getChatMessages: builder.query<MessageListResponse, GetChatMessagesArgs>({
      query: ({ chatId, page = 1, limit = 20 }) => ({
        url: `v1/messages/chat/${chatId}`,
        params: { page, limit },
      }),
      transformResponse: (res: BaseResponseDto<MessageListResponse> | MessageListResponse) =>
        unwrap(res),
      providesTags: (_result, _error, arg) => [{ type: 'Messages', id: arg.chatId }],
    }),

    sendTextMessageV2: builder.mutation<Message, SendTextMessageV2Args>({
      query: (body) => ({
        url: 'v2/messages',
        method: 'POST',
        body: {
          type: 'text',
          chatId: body.chatId,
          targetUserId: body.targetUserId,
          content: body.content,
        },
      }),
      transformResponse: (res: BaseResponseDto<Message> | Message) => unwrap(res),
      invalidatesTags: (result) =>
        result?.chatId ? [{ type: 'Messages', id: result.chatId }] : [],
    }),

    sendPhotoMessageV2: builder.mutation<Message, SendPhotoMessageV2Args>({
      query: ({ chatId, targetUserId, content, file }) => {
        const form = new FormData();
        form.append('type', 'media');
        if (chatId) form.append('chatId', chatId);
        if (targetUserId) form.append('targetUserId', targetUserId);
        if (content) form.append('content', content);
        form.append('file', file as any);

        return {
          url: 'v2/messages',
          method: 'POST',
          body: form,
        };
      },
      transformResponse: (res: BaseResponseDto<Message> | Message) => unwrap(res),
      invalidatesTags: (result) =>
        result?.chatId ? [{ type: 'Messages', id: result.chatId }] : [],
    }),
  }),
});

export const {
  useGetChatMessagesQuery,
  useSendTextMessageV2Mutation,
  useSendPhotoMessageV2Mutation,
} = messagesApi;

const photoFile = {
  uri: asset.uri,
  name: asset.fileName ?? `photo-${Date.now()}.jpg`,
  type: (asset.type ?? 'image/jpeg') as 'image/jpeg' | 'image/jpg' | 'image/png' | 'image/webp',
};