anyproto/anytype-kotlin
1
0
Fork 0
mirror of https://github.com/anyproto/anytype-kotlin.git synced 2025-06-08 05:47:05 +09:00
Code Activity

Protocol | Basic API for search with subscriptions (#2049)

Browse source
This commit is contained in:
Evgenii Kozlov 2022-01-18 17:58:09 +03:00 • committed by GitHub
parent 6255993aec
commit ae3ab1c776
Signed by: github
GPG key ID: 4AEE18F83AFDEB23
11 changed files with 246 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

24
middleware/src/main/java/com/anytypeio/anytype/middleware/block/BlockMiddleware.kt
View file

@ -360,6 +360,30 @@ class BlockMiddleware(
limit = limit
)
override suspend fun searchObjectsWithSubscription(
subscription: Id,
sorts: List<DVSort>,
filters: List<DVFilter>,
fulltext: String,
offset: Int,
limit: Int,
beforeId: Id?,
afterId: Id?
): List<Map<String, Any?>> = middleware.searchObjectsWithSubscription(
subscription = subscription,
sorts = sorts,
filters = filters,
fulltext = fulltext,
offset = offset,
limit = limit,
afterId = afterId,
beforeId = beforeId
)
override suspend fun cancelObjectSearchSubscription(
subscriptions: List<Id>
) = middleware.cancelObjectSearchSubscription(subscriptions = subscriptions)
override suspend fun relationListAvailable(
ctx: Id
): List<Relation> = middleware.relationListAvailable(ctx).map { it.toCoreModels() }

51
middleware/src/main/java/com/anytypeio/anytype/middleware/interactor/Middleware.kt
View file

@ -187,7 +187,7 @@ class Middleware(
fun createPage(ctx: Id?, emoji: String?, isDraft: Boolean?, type: String?): Id {
val details: MutableMap<String, Any> = mutableMapOf()
emoji?.let { details[iconEmojiKey] = it}
emoji?.let { details[iconEmojiKey] = it }
isDraft?.let { details[isDraftKey] = it }
type?.let { details[typeKey] = it }
@ -1200,6 +1200,47 @@ class Middleware(
return response.records.map { it?.toMap() ?: emptyMap() }
}
//region SEARCHING WITH SUBSCRIPTIONS
@Throws(Exception::class)
fun searchObjectsWithSubscription(
subscription: Id,
sorts: List<DVSort>,
filters: List<DVFilter>,
fulltext: String,
offset: Int,
limit: Int,
beforeId: Id?,
afterId: Id?,
): List<Map<String, Any?>> {
val request = Rpc.Object.SearchSubscribe.Request(
subId = subscription,
sorts = sorts.map { it.toMiddlewareModel() },
filters = filters.map { it.toMiddlewareModel() },
fullText = fulltext,
offset = offset,
limit = limit,
beforeId = beforeId.orEmpty(),
afterId = afterId.orEmpty()
)
if (BuildConfig.DEBUG) logRequest(request)
val response = service.objectSearchSubscribe(request)
if (BuildConfig.DEBUG) logResponse(response)
return response.records.map { it?.toMap() ?: emptyMap() }
}
@Throws(Exception::class)
fun cancelObjectSearchSubscription(subscriptions: List<String>) {
val request = Rpc.Object.SearchUnsubscribe.Request(
subIds = subscriptions
)
if (BuildConfig.DEBUG) logRequest(request)
val response = service.objectSearchUnsubscribe(request)
if (BuildConfig.DEBUG) logResponse(response)
}
//endregion
@Throws(Exception::class)
fun relationListAvailable(ctx: Id): List<MRelation> {
val request = Rpc.Object.RelationListAvailable.Request(
@ -1393,7 +1434,7 @@ class Middleware(
)
}
fun deleteRelationFromObject(ctx: Id, relation: Id) : Payload {
fun deleteRelationFromObject(ctx: Id, relation: Id): Payload {
val request = Rpc.Object.RelationDelete.Request(
contextId = ctx,
relationKey = relation
@ -1435,7 +1476,7 @@ class Middleware(
fun setObjectIsFavorite(
ctx: Id,
isFavorite: Boolean
) : Payload {
): Payload {
val request = Rpc.Object.SetIsFavorite.Request(
contextId = ctx,
isFavorite = isFavorite
@ -1449,7 +1490,7 @@ class Middleware(
fun setObjectIsArchived(
ctx: Id,
isArchived: Boolean
) : Payload {
): Payload {
val request = Rpc.Object.SetIsArchived.Request(
contextId = ctx,
isArchived = isArchived
@ -1480,7 +1521,7 @@ class Middleware(
if (BuildConfig.DEBUG) logResponse(response)
}
fun setObjectLayout(ctx: Id, layout: ObjectType.Layout) : Payload {
fun setObjectLayout(ctx: Id, layout: ObjectType.Layout): Payload {
val request = Rpc.Object.SetLayout.Request(
contextId = ctx,
layout = layout.toMiddlewareModel()

6
middleware/src/main/java/com/anytypeio/anytype/middleware/service/MiddlewareService.kt
View file

@ -162,6 +162,12 @@ interface MiddlewareService {
@Throws(Exception::class)
fun objectSearch(request: Object.Search.Request): Object.Search.Response
@Throws(Exception::class)
fun objectSearchSubscribe(request: Object.SearchSubscribe.Request): Object.SearchSubscribe.Response
@Throws(Exception::class)
fun objectSearchUnsubscribe(request: Object.SearchUnsubscribe.Request): Object.SearchUnsubscribe.Response
@Throws(Exception::class)
fun relationListAvailable(request: Object.RelationListAvailable.Request): Object.RelationListAvailable.Response

22
middleware/src/main/java/com/anytypeio/anytype/middleware/service/MiddlewareServiceImplementation.kt
View file

@ -633,6 +633,28 @@ class MiddlewareServiceImplementation : MiddlewareService {
}
}
override fun objectSearchSubscribe(request: Object.SearchSubscribe.Request): Object.SearchSubscribe.Response {
val encoded = Service.objectSearch(Object.SearchSubscribe.Request.ADAPTER.encode(request))
val response = Object.SearchSubscribe.Response.ADAPTER.decode(encoded)
val error = response.error
if (error != null && error.code != Object.SearchSubscribe.Response.Error.Code.NULL) {
throw Exception(error.description)
} else {
return response
}
}
override fun objectSearchUnsubscribe(request: Object.SearchUnsubscribe.Request): Object.SearchUnsubscribe.Response {
val encoded = Service.objectSearch(Object.SearchUnsubscribe.Request.ADAPTER.encode(request))
val response = Object.SearchUnsubscribe.Response.ADAPTER.decode(encoded)
val error = response.error
if (error != null && error.code != Object.SearchUnsubscribe.Response.Error.Code.NULL) {
throw Exception(error.description)
} else {
return response
}
}
override fun relationListAvailable(request: Object.RelationListAvailable.Request): Object.RelationListAvailable.Response {
val encoded = Service.objectRelationListAvailable(
Object.RelationListAvailable.Request.ADAPTER.encode(request)