in openai-java-core/src/main/kotlin/com/openai/services/blocking/vectorstores/FileServiceImpl.kt [64:285]
override fun delete(
params: FileDeleteParams,
requestOptions: RequestOptions,
): VectorStoreFileDeleted =
// delete /vector_stores/{vector_store_id}/files/{file_id}
withRawResponse().delete(params, requestOptions).parse()
override fun content(
params: FileContentParams,
requestOptions: RequestOptions,
): FileContentPage =
// get /vector_stores/{vector_store_id}/files/{file_id}/content
withRawResponse().content(params, requestOptions).parse()
class WithRawResponseImpl internal constructor(private val clientOptions: ClientOptions) :
FileService.WithRawResponse {
private val errorHandler: Handler<ErrorObject?> = errorHandler(clientOptions.jsonMapper)
private val createHandler: Handler<VectorStoreFile> =
jsonHandler<VectorStoreFile>(clientOptions.jsonMapper).withErrorHandler(errorHandler)
override fun create(
params: FileCreateParams,
requestOptions: RequestOptions,
): HttpResponseFor<VectorStoreFile> {
val request =
HttpRequest.builder()
.method(HttpMethod.POST)
.addPathSegments("vector_stores", params._pathParam(0), "files")
.putAllHeaders(DEFAULT_HEADERS)
.body(json(clientOptions.jsonMapper, params._body()))
.build()
.prepare(clientOptions, params, deploymentModel = null)
val requestOptions = requestOptions.applyDefaults(RequestOptions.from(clientOptions))
val response = clientOptions.httpClient.execute(request, requestOptions)
return response.parseable {
response
.use { createHandler.handle(it) }
.also {
if (requestOptions.responseValidation!!) {
it.validate()
}
}
}
}
private val retrieveHandler: Handler<VectorStoreFile> =
jsonHandler<VectorStoreFile>(clientOptions.jsonMapper).withErrorHandler(errorHandler)
override fun retrieve(
params: FileRetrieveParams,
requestOptions: RequestOptions,
): HttpResponseFor<VectorStoreFile> {
val request =
HttpRequest.builder()
.method(HttpMethod.GET)
.addPathSegments(
"vector_stores",
params._pathParam(0),
"files",
params._pathParam(1),
)
.putAllHeaders(DEFAULT_HEADERS)
.build()
.prepare(clientOptions, params, deploymentModel = null)
val requestOptions = requestOptions.applyDefaults(RequestOptions.from(clientOptions))
val response = clientOptions.httpClient.execute(request, requestOptions)
return response.parseable {
response
.use { retrieveHandler.handle(it) }
.also {
if (requestOptions.responseValidation!!) {
it.validate()
}
}
}
}
private val updateHandler: Handler<VectorStoreFile> =
jsonHandler<VectorStoreFile>(clientOptions.jsonMapper).withErrorHandler(errorHandler)
override fun update(
params: FileUpdateParams,
requestOptions: RequestOptions,
): HttpResponseFor<VectorStoreFile> {
val request =
HttpRequest.builder()
.method(HttpMethod.POST)
.addPathSegments(
"vector_stores",
params._pathParam(0),
"files",
params._pathParam(1),
)
.putAllHeaders(DEFAULT_HEADERS)
.body(json(clientOptions.jsonMapper, params._body()))
.build()
.prepare(clientOptions, params, deploymentModel = null)
val requestOptions = requestOptions.applyDefaults(RequestOptions.from(clientOptions))
val response = clientOptions.httpClient.execute(request, requestOptions)
return response.parseable {
response
.use { updateHandler.handle(it) }
.also {
if (requestOptions.responseValidation!!) {
it.validate()
}
}
}
}
private val listHandler: Handler<FileListPageResponse> =
jsonHandler<FileListPageResponse>(clientOptions.jsonMapper)
.withErrorHandler(errorHandler)
override fun list(
params: FileListParams,
requestOptions: RequestOptions,
): HttpResponseFor<FileListPage> {
val request =
HttpRequest.builder()
.method(HttpMethod.GET)
.addPathSegments("vector_stores", params._pathParam(0), "files")
.putAllHeaders(DEFAULT_HEADERS)
.build()
.prepare(clientOptions, params, deploymentModel = null)
val requestOptions = requestOptions.applyDefaults(RequestOptions.from(clientOptions))
val response = clientOptions.httpClient.execute(request, requestOptions)
return response.parseable {
response
.use { listHandler.handle(it) }
.also {
if (requestOptions.responseValidation!!) {
it.validate()
}
}
.let {
FileListPage.builder()
.service(FileServiceImpl(clientOptions))
.params(params)
.response(it)
.build()
}
}
}
private val deleteHandler: Handler<VectorStoreFileDeleted> =
jsonHandler<VectorStoreFileDeleted>(clientOptions.jsonMapper)
.withErrorHandler(errorHandler)
override fun delete(
params: FileDeleteParams,
requestOptions: RequestOptions,
): HttpResponseFor<VectorStoreFileDeleted> {
val request =
HttpRequest.builder()
.method(HttpMethod.DELETE)
.addPathSegments(
"vector_stores",
params._pathParam(0),
"files",
params._pathParam(1),
)
.putAllHeaders(DEFAULT_HEADERS)
.apply { params._body().ifPresent { body(json(clientOptions.jsonMapper, it)) } }
.build()
.prepare(clientOptions, params, deploymentModel = null)
val requestOptions = requestOptions.applyDefaults(RequestOptions.from(clientOptions))
val response = clientOptions.httpClient.execute(request, requestOptions)
return response.parseable {
response
.use { deleteHandler.handle(it) }
.also {
if (requestOptions.responseValidation!!) {
it.validate()
}
}
}
}
private val contentHandler: Handler<FileContentPageResponse> =
jsonHandler<FileContentPageResponse>(clientOptions.jsonMapper)
.withErrorHandler(errorHandler)
override fun content(
params: FileContentParams,
requestOptions: RequestOptions,
): HttpResponseFor<FileContentPage> {
val request =
HttpRequest.builder()
.method(HttpMethod.GET)
.addPathSegments(
"vector_stores",
params._pathParam(0),
"files",
params._pathParam(1),
"content",
)
.putAllHeaders(DEFAULT_HEADERS)
.build()
.prepare(clientOptions, params, deploymentModel = null)
val requestOptions = requestOptions.applyDefaults(RequestOptions.from(clientOptions))
val response = clientOptions.httpClient.execute(request, requestOptions)
return response.parseable {
response
.use { contentHandler.handle(it) }
.also {
if (requestOptions.responseValidation!!) {
it.validate()
}
}
.let {
FileContentPage.builder()
.service(FileServiceImpl(clientOptions))
.params(params)
.response(it)
.build()
}
}
}
}