channel_repository_impl

channel_repository_impl.kt

internal class ChannelRepositoryImpl @Inject constructor(
  private val chatClient: ChatClient,
  private val service: ChannelService,
  private val geminiDao: GeminiDao,
) : ChannelRepository {

  override suspend fun joinDefaultChannels(user: User): ApiResponse<List<GeminiChannel>> {
    val response = service.geminiChannels()
      .suspendOnSuccess {
        data.forEach { geminiChannel ->
          val channelClient = chatClient.channel(geminiChannel.id)
          channelClient.create(
            memberIds = listOf(geminiUser.id, user.id),
            extraData = mapOf(
              "name" to geminiChannel.name,
              "image" to "https://avatars.githubusercontent.com/u/8597527?s=200&v=4.png",
            )
          ).await().onSuccessSuspend {
            geminiDao.insertGeminiChannel(geminiChannel.toEntity())
          }
        }
      }
    return response
  }