-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
15 changed files
with
334 additions
and
14 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
181 changes: 181 additions & 0 deletions
181
ok-marketplace-be/ok-marketplace-app-ktor/src/commonTest/kotlin/repo/V2AdRepoBaseTest.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,181 @@ | ||
| package ru.otus.otuskotlin.marketplace.app.ktor.repo | ||
|
|
||
| import io.ktor.client.call.* | ||
| import io.ktor.client.plugins.contentnegotiation.* | ||
| import io.ktor.client.request.* | ||
| import io.ktor.client.statement.* | ||
| import io.ktor.http.* | ||
| import io.ktor.serialization.kotlinx.json.* | ||
| import io.ktor.server.testing.* | ||
| import ru.otus.otuskotlin.marketplace.api.v2.apiV2Mapper | ||
| import ru.otus.otuskotlin.marketplace.api.v2.mappers.toTransportAd | ||
| import ru.otus.otuskotlin.marketplace.api.v2.models.* | ||
| import ru.otus.otuskotlin.marketplace.app.ktor.MkplAppSettings | ||
| import ru.otus.otuskotlin.marketplace.app.ktor.module | ||
| import ru.otus.otuskotlin.marketplace.common.models.MkplAdId | ||
| import ru.otus.otuskotlin.marketplace.common.models.MkplAdLock | ||
| import ru.otus.otuskotlin.marketplace.common.models.MkplDealSide | ||
| import ru.otus.otuskotlin.marketplace.stubs.MkplAdStub | ||
| import kotlin.test.Test | ||
| import kotlin.test.assertEquals | ||
| import kotlin.test.assertNotEquals | ||
|
|
||
| abstract class V2AdRepoBaseTest { | ||
| abstract val workMode: AdRequestDebugMode | ||
| abstract val appSettingsCreate: MkplAppSettings | ||
| abstract val appSettingsRead: MkplAppSettings | ||
| abstract val appSettingsUpdate: MkplAppSettings | ||
| abstract val appSettingsDelete: MkplAppSettings | ||
| abstract val appSettingsSearch: MkplAppSettings | ||
| abstract val appSettingsOffers: MkplAppSettings | ||
|
|
||
| protected val uuidOld = "10000000-0000-0000-0000-000000000001" | ||
| protected val uuidNew = "10000000-0000-0000-0000-000000000002" | ||
| protected val uuidSup = "10000000-0000-0000-0000-000000000003" | ||
| protected val initAd = MkplAdStub.prepareResult { | ||
| id = MkplAdId(uuidOld) | ||
| adType = MkplDealSide.DEMAND | ||
| lock = MkplAdLock(uuidOld) | ||
| } | ||
| protected val initAdSupply = MkplAdStub.prepareResult { | ||
| id = MkplAdId(uuidSup) | ||
| adType = MkplDealSide.SUPPLY | ||
| } | ||
|
|
||
|
|
||
| @Test | ||
| fun create() { | ||
| val createAd = AdCreateObject( | ||
| title = initAd.title, | ||
| description = initAd.description, | ||
| adType = initAd.adType.toTransportAd(), | ||
| visibility = initAd.visibility.toTransportAd(), | ||
| ) | ||
| v2TestApplication( | ||
| conf = appSettingsCreate, | ||
| func = "create", | ||
| request = AdCreateRequest( | ||
| ad = createAd, | ||
| debug = AdDebug(mode = workMode), | ||
| ), | ||
| ) { response -> | ||
| val responseObj = response.body<IResponse>() as AdCreateResponse | ||
| assertEquals(200, response.status.value) | ||
| assertEquals(uuidNew, responseObj.ad?.id) | ||
| assertEquals(createAd.title, responseObj.ad?.title) | ||
| assertEquals(createAd.description, responseObj.ad?.description) | ||
| assertEquals(createAd.adType, responseObj.ad?.adType) | ||
| assertEquals(createAd.visibility, responseObj.ad?.visibility) | ||
| } | ||
| } | ||
|
|
||
| @Test | ||
| fun read() = v2TestApplication( | ||
| conf = appSettingsRead, | ||
| func = "read", | ||
| request = AdReadRequest( | ||
| ad = AdReadObject(uuidOld), | ||
| debug = AdDebug(mode = workMode), | ||
| ), | ||
| ) { response -> | ||
| val responseObj = response.body<IResponse>() as AdReadResponse | ||
| assertEquals(200, response.status.value) | ||
| assertEquals(uuidOld, responseObj.ad?.id) | ||
| } | ||
|
|
||
| @Test | ||
| fun update() { | ||
| val adUpdate = AdUpdateObject( | ||
| id = uuidOld, | ||
| title = initAd.title, | ||
| description = initAd.description, | ||
| adType = initAd.adType.toTransportAd(), | ||
| visibility = initAd.visibility.toTransportAd(), | ||
| lock = initAd.lock.asString(), | ||
| ) | ||
| v2TestApplication( | ||
| conf = appSettingsUpdate, | ||
| func = "update", | ||
| request = AdUpdateRequest( | ||
| ad = adUpdate, | ||
| debug = AdDebug(mode = workMode), | ||
| ), | ||
| ) { response -> | ||
| val responseObj = response.body<IResponse>() as AdUpdateResponse | ||
| assertEquals(200, response.status.value) | ||
| assertEquals(adUpdate.id, responseObj.ad?.id) | ||
| assertEquals(adUpdate.title, responseObj.ad?.title) | ||
| assertEquals(adUpdate.description, responseObj.ad?.description) | ||
| assertEquals(adUpdate.adType, responseObj.ad?.adType) | ||
| assertEquals(adUpdate.visibility, responseObj.ad?.visibility) | ||
| } | ||
| } | ||
| @Test | ||
| fun delete() = v2TestApplication( | ||
| conf = appSettingsDelete, | ||
| func = "delete", | ||
| request = AdDeleteRequest( | ||
| ad = AdDeleteObject( | ||
| id = uuidOld, | ||
| lock = initAd.lock.asString(), | ||
| ), | ||
| debug = AdDebug(mode = workMode), | ||
| ), | ||
| ) { response -> | ||
| val responseObj = response.body<IResponse>() as AdDeleteResponse | ||
| assertEquals(200, response.status.value) | ||
| assertEquals(uuidOld, responseObj.ad?.id) | ||
| } | ||
|
|
||
| @Test | ||
| fun search() = v2TestApplication( | ||
| conf = appSettingsSearch, | ||
| func = "search", | ||
| request = AdSearchRequest( | ||
| adFilter = AdSearchFilter(), | ||
| debug = AdDebug(mode = workMode), | ||
| ), | ||
| ) { response -> | ||
| val responseObj = response.body<IResponse>() as AdSearchResponse | ||
| assertEquals(200, response.status.value) | ||
| assertNotEquals(0, responseObj.ads?.size) | ||
| assertEquals(uuidOld, responseObj.ads?.first()?.id) | ||
| } | ||
|
|
||
| @Test | ||
| fun offers() = v2TestApplication( | ||
| conf = appSettingsOffers, | ||
| func = "offers", | ||
| request = AdOffersRequest( | ||
| ad = AdReadObject( | ||
| id = uuidOld, | ||
| ), | ||
| debug = AdDebug(mode = workMode), | ||
| ), | ||
| ) { response -> | ||
| val responseObj = response.body<IResponse>() as AdOffersResponse | ||
| assertEquals(200, response.status.value) | ||
| assertNotEquals(0, responseObj.ads?.size) | ||
| assertEquals(uuidSup, responseObj.ads?.first()?.id) | ||
| } | ||
|
|
||
| private inline fun <reified T: IRequest> v2TestApplication( | ||
| conf: MkplAppSettings, | ||
| func: String, | ||
| request: T, | ||
| crossinline function: suspend (HttpResponse) -> Unit, | ||
| ): Unit = testApplication { | ||
| application { module(appSettings = conf) } | ||
| val client = createClient { | ||
| install(ContentNegotiation) { | ||
| json(apiV2Mapper) | ||
| } | ||
| } | ||
| val response = client.post("/v2/ad/$func") { | ||
| contentType(ContentType.Application.Json) | ||
| header("X-Trace-Id", "12345") | ||
| setBody(request) | ||
| } | ||
| function(response) | ||
| } | ||
| } |
51 changes: 51 additions & 0 deletions
51
ok-marketplace-be/ok-marketplace-app-ktor/src/commonTest/kotlin/repo/V2AdRepoInmemoryTest.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,51 @@ | ||
| package ru.otus.otuskotlin.marketplace.app.ktor.repo | ||
|
|
||
| import ru.otus.otuskotlin.marketplace.api.v2.models.AdRequestDebugMode | ||
| import ru.otus.otuskotlin.marketplace.app.ktor.MkplAppSettings | ||
| import ru.otus.otuskotlin.marketplace.common.MkplCorSettings | ||
| import ru.otus.otuskotlin.marketplace.common.repo.IRepoAd | ||
| import ru.otus.otuskotlin.marketplace.repo.common.AdRepoInitialized | ||
| import ru.otus.otuskotlin.marketplace.repo.inmemory.AdRepoInMemory | ||
|
|
||
| class V2AdRepoInmemoryTest : V2AdRepoBaseTest() { | ||
| override val workMode: AdRequestDebugMode = AdRequestDebugMode.TEST | ||
| private fun mkAppSettings(repo: IRepoAd) = MkplAppSettings( | ||
| corSettings = MkplCorSettings( | ||
| repoTest = repo | ||
| ) | ||
| ) | ||
|
|
||
| override val appSettingsCreate: MkplAppSettings = mkAppSettings( | ||
| repo = AdRepoInitialized(AdRepoInMemory(randomUuid = { uuidNew })) | ||
| ) | ||
| override val appSettingsRead: MkplAppSettings = mkAppSettings( | ||
| repo = AdRepoInitialized( | ||
| AdRepoInMemory(randomUuid = { uuidNew }), | ||
| initObjects = listOf(initAd), | ||
| ) | ||
| ) | ||
| override val appSettingsUpdate: MkplAppSettings = mkAppSettings( | ||
| repo = AdRepoInitialized( | ||
| AdRepoInMemory(randomUuid = { uuidNew }), | ||
| initObjects = listOf(initAd), | ||
| ) | ||
| ) | ||
| override val appSettingsDelete: MkplAppSettings = mkAppSettings( | ||
| repo = AdRepoInitialized( | ||
| AdRepoInMemory(randomUuid = { uuidNew }), | ||
| initObjects = listOf(initAd), | ||
| ) | ||
| ) | ||
| override val appSettingsSearch: MkplAppSettings = mkAppSettings( | ||
| repo = AdRepoInitialized( | ||
| AdRepoInMemory(randomUuid = { uuidNew }), | ||
| initObjects = listOf(initAd), | ||
| ) | ||
| ) | ||
| override val appSettingsOffers: MkplAppSettings = mkAppSettings( | ||
| repo = AdRepoInitialized( | ||
| AdRepoInMemory(randomUuid = { uuidNew }), | ||
| initObjects = listOf(initAd, initAdSupply), | ||
| ) | ||
| ) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
12 changes: 6 additions & 6 deletions
12
ok-marketplace-be/ok-marketplace-repo-inmemory/src/commonTest/kotlin/AdRepoInMemoryTest.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,4 @@ | ||
| # Модуль `ok-marketplace-repo-stubs` | ||
|
|
||
|
|
||
| Модуль реализует интерфейс репозитария в виде стабов. |
Oops, something went wrong.