- unit test MarketRemoteDataSource and AssetRemoteDataSource

app/src/main/java/dev/pinkroom/marketsight/data/mapper/RemoteMapper.kt

@@ -134,13 +134,14 @@ fun QuoteAssetDto.toQuoteAsset() = QuoteAsset(
     id = tradeId,
     bidPrice = bidPrice,
     askPrice = askPrice,
-    timeStamp = timeStamp.toLocalDateTimeWithNanoSecond(),
+    timeStamp = requestDate.toLocalDateTimeWithNanoSecond(),
     symbol = symbol,
 )
 
 fun QuotesCryptoResponseDto.toQuotesResponseDto() = QuotesResponseDto(
     quotes = quotes.entries.first().value,
     pageToken = pageToken,
+    symbol = quotes.entries.first().key,
 )
 
 fun TradesResponseDto.toTradesResponse() = TradesResponse(
@@ -151,11 +152,12 @@ fun TradesResponseDto.toTradesResponse() = TradesResponse(
 fun TradeAssetDto.toTradeAsset() = TradeAsset(
     id = tradeId,
     tradePrice = tradePrice,
-    timeStamp = timeStamp.toLocalDateTimeWithNanoSecond(),
+    timeStamp = dateTransaction.toLocalDateTimeWithNanoSecond(),
     symbol = symbol,
 )
 
 fun TradesCryptoResponseDto.toTradesResponseDto() = TradesResponseDto(
     trades = trades.entries.first().value,
     pageToken = pageToken,
+    symbol = trades.entries.first().key,
 )

app/src/main/java/dev/pinkroom/marketsight/data/remote/model/dto/alpaca_api/BarAssetDto.kt

@@ -3,6 +3,7 @@ package dev.pinkroom.marketsight.data.remote.model.dto.alpaca_api
 import com.google.gson.annotations.SerializedName
 
 data class BarAssetDto(
+    @SerializedName("T") val type: String? = null,
     @SerializedName("c") val closingPrice: Double,
     @SerializedName("h") val highPrice: Double,
     @SerializedName("l") val lowPrice: Double,

app/src/main/java/dev/pinkroom/marketsight/data/remote/model/dto/alpaca_api/QuoteAssetDto.kt

@@ -3,9 +3,10 @@ package dev.pinkroom.marketsight.data.remote.model.dto.alpaca_api
 import com.google.gson.annotations.SerializedName
 
 data class QuoteAssetDto(
+    @SerializedName("T") val type: String? = null,
     @SerializedName("i") val tradeId: Long,
     @SerializedName("bp") val bidPrice: Double,
     @SerializedName("ap") val askPrice: Double,
-    @SerializedName("t") val timeStamp: String,
+    @SerializedName("t") val requestDate: String,
     @SerializedName("S") val symbol: String? = null,
 )

app/src/main/java/dev/pinkroom/marketsight/data/remote/model/dto/alpaca_api/QuotesResponseDto.kt

@@ -5,4 +5,5 @@ import com.google.gson.annotations.SerializedName
 data class QuotesResponseDto(
     val quotes: List<QuoteAssetDto>,
     @SerializedName("next_page_token") val pageToken: String? = null,
+    val symbol: String,
 )

app/src/main/java/dev/pinkroom/marketsight/data/remote/model/dto/alpaca_api/TradeAssetDto.kt

@@ -3,8 +3,9 @@ package dev.pinkroom.marketsight.data.remote.model.dto.alpaca_api
 import com.google.gson.annotations.SerializedName
 
 data class TradeAssetDto(
+    @SerializedName("T") val type: String? = null,
     @SerializedName("i") val tradeId: Long,
     @SerializedName("p") val tradePrice: Double,
-    @SerializedName("t") val timeStamp: String,
+    @SerializedName("t") val dateTransaction: String,
     @SerializedName("S") val symbol: String? = null,
 )

app/src/main/java/dev/pinkroom/marketsight/data/remote/model/dto/alpaca_api/TradesResponseDto.kt

@@ -5,4 +5,5 @@ import com.google.gson.annotations.SerializedName
 data class TradesResponseDto(
     val trades: List<TradeAssetDto>,
     @SerializedName("next_page_token") val pageToken: String? = null,
+    val symbol: String,
 )

app/src/test/java/dev/pinkroom/marketsight/data/data_source/AssetsRemoteDataSourceTest.kt

@@ -0,0 +1,55 @@
+package dev.pinkroom.marketsight.data.data_source
+
+import assertk.assertThat
+import assertk.assertions.isEqualTo
+import assertk.assertions.isNotEmpty
+import dev.pinkroom.marketsight.data.remote.AlpacaPaperApi
+import dev.pinkroom.marketsight.domain.model.assets.TypeAsset
+import dev.pinkroom.marketsight.factories.AssetDtoFactory
+import dev.pinkroom.marketsight.util.MainCoroutineRule
+import io.mockk.coEvery
+import io.mockk.coVerify
+import io.mockk.mockk
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+import kotlinx.coroutines.test.runTest
+import org.junit.Rule
+import org.junit.Test
+
+@OptIn(ExperimentalCoroutinesApi::class)
+class AssetsRemoteDataSourceTest{
+    @get:Rule
+    val coroutineRule = MainCoroutineRule()
+
+    private val assetDtoFactory = AssetDtoFactory()
+    private val alpacaPaperApi = mockk<AlpacaPaperApi>()
+    private val assetsRemoteDataSource = AssetsRemoteDataSource(
+        alpacaPaperApi = alpacaPaperApi
+    )
+
+    @Test
+    fun `When call getAllAssets, Then return list of assets`() = runTest {
+        // GIVEN
+        val type = TypeAsset.Stock
+        mockResponseGetAssetsPaperApi(typeAsset = type)
+
+        // WHEN
+        val response = assetsRemoteDataSource.getAllAssets(typeAsset = type)
+
+        // THEN
+        coVerify { alpacaPaperApi.getAssets(typeAsset = type.value, status = any()) }
+        assertThat(response).isNotEmpty()
+        response.forEach {
+            assertThat(it.type).isEqualTo(type.value)
+        }
+    }
+
+    private fun mockResponseGetAssetsPaperApi(
+        typeAsset: TypeAsset,
+    ){
+        coEvery {
+            alpacaPaperApi.getAssets(typeAsset = any(), status = any())
+        }.returns(
+            assetDtoFactory.listAssets(number = 250, type = typeAsset)
+        )
+    }
+}

app/src/test/java/dev/pinkroom/marketsight/factories/AssetDtoFactory.kt

@@ -0,0 +1,28 @@
+package dev.pinkroom.marketsight.factories
+
+import com.github.javafaker.Faker
+import dev.pinkroom.marketsight.data.remote.model.dto.alpaca_paper_api.AssetDto
+import dev.pinkroom.marketsight.domain.model.assets.TypeAsset
+import kotlin.random.Random
+
+class AssetDtoFactory: BaseFactory<AssetDto> {
+
+    private val faker = Faker()
+    override fun build() = AssetDto(
+        id = faker.number().randomNumber().toString(),
+        type = if (Random.nextInt() % 2 == 0) "us_equity" else "crypto",
+        symbol = faker.stock().nsdqSymbol(),
+        name = faker.stock().nsdqSymbol(),
+        exchange = "NASDAQ",
+    )
+
+    fun listAssets(number: Int, type: TypeAsset) = List(number) { build(type = type) }
+
+    private fun build(type: TypeAsset) = AssetDto(
+        id = faker.number().randomNumber().toString(),
+        type = type.value,
+        symbol = faker.stock().nsdqSymbol(),
+        name = faker.stock().nsdqSymbol(),
+        exchange = "NASDAQ",
+    )
+}

app/src/test/java/dev/pinkroom/marketsight/factories/BarAssetDtoFactory.kt

@@ -0,0 +1,23 @@
+package dev.pinkroom.marketsight.factories
+
+import com.github.javafaker.Faker
+import dev.pinkroom.marketsight.data.remote.model.dto.alpaca_api.BarAssetDto
+
+class BarAssetDtoFactory: BaseFactory<BarAssetDto> {
+
+    private val faker = Faker()
+    override fun build() = BarAssetDto(
+        tradeCountInBar = faker.number().randomDigit(),
+        barVolume = faker.number().randomDouble(10,1,1000),
+        timestamp = "2024-04-11T13:45:17.0231232021Z",
+        lowPrice = faker.number().randomDouble(10,1,1000),
+        highPrice = faker.number().randomDouble(10,1,1000),
+        closingPrice = faker.number().randomDouble(10,1,1000),
+        openingPrice = faker.number().randomDouble(10,1,1000),
+        volumeWeightedAvgPrice = faker.number().randomDouble(10,1,1000),
+    )
+
+    fun buildList(number: Int, symbol: String, type: String? = null) = List(number){
+        build().copy(symbol = symbol, type = type)
+    }
+}

app/src/test/java/dev/pinkroom/marketsight/factories/QuoteAssetDtoFactory.kt

@@ -0,0 +1,21 @@
+package dev.pinkroom.marketsight.factories
+
+import com.github.javafaker.Faker
+import dev.pinkroom.marketsight.data.remote.model.dto.alpaca_api.QuoteAssetDto
+import kotlin.random.Random
+
+class QuoteAssetDtoFactory: BaseFactory<QuoteAssetDto> {
+
+    private val faker = Faker()
+    override fun build() = QuoteAssetDto(
+        type = if (Random.nextInt() % 2 == 0) "us_equity" else "crypto",
+        tradeId = faker.number().randomNumber(),
+        bidPrice = faker.number().randomDouble(100,1,1000000),
+        askPrice = faker.number().randomDouble(100,1,1000000),
+        requestDate = "2024-05-03T16:58:38.422833437Z",
+    )
+
+    fun buildList(number: Int, type: String? = null, symbol: String? = null) = List(number) {
+        build().copy(type = type, symbol = symbol)
+    }
+}

app/src/test/java/dev/pinkroom/marketsight/factories/TradeAssetDtoFactory.kt

@@ -0,0 +1,20 @@
+package dev.pinkroom.marketsight.factories
+
+import com.github.javafaker.Faker
+import dev.pinkroom.marketsight.data.remote.model.dto.alpaca_api.TradeAssetDto
+import kotlin.random.Random
+
+class TradeAssetDtoFactory: BaseFactory<TradeAssetDto> {
+
+    private val faker = Faker()
+    override fun build() = TradeAssetDto(
+        type = if (Random.nextInt() % 2 == 0) "us_equity" else "crypto",
+        tradePrice = faker.number().randomDouble(1000,1,10000000),
+        tradeId = faker.number().randomNumber(),
+        dateTransaction = "2024-05-03T16:58:38.422833437Z",
+    )
+
+    fun buildList(number: Int, type: String? = null, symbol: String? = null) = List(number) {
+        build().copy(type = type, symbol = symbol)
+    }
+}