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

GO-3753 App | Tech | Refact app params and metrics API interaction (#1605)

This commit is contained in:
Mikhail 2024-11-19 12:06:33 +01:00 committed by GitHub
parent d0edde4726
commit 7d616cfff3
Signed by: github
GPG key ID: B5690EEEBB952194
27 changed files with 139 additions and 122 deletions

View file

@ -72,10 +72,7 @@ class AuthMiddleware(
return middleware.versionGet().version
}
override suspend fun setMetrics(platform: String, version: String) {
middleware.metricsSetParameters(
platform = platform,
version = version
)
override suspend fun setInitialParams(command: Command.SetInitialParams) {
middleware.metricsSetParameters(command)
}
}

View file

@ -1581,15 +1581,16 @@ class Middleware @Inject constructor(
@Throws(Exception::class)
fun metricsSetParameters(
platform: String,
version: String
command: Command.SetInitialParams
) {
val request = Rpc.Initial.SetParameters.Request(
platform = platform,
version = version
platform = command.platform,
version = command.version,
logLevel = command.defaultLogLevel,
workdir = command.workDir
)
logRequestIfDebug(request)
val (response, time) = measureTimedValue { service.metricsSetParameters(request) }
val (response, time) = measureTimedValue { service.setInitialParams(request) }
logResponseIfDebug(response, time)
}

View file

@ -10,7 +10,7 @@ interface MiddlewareService {
//region APP commands
@Throws(Exception::class)
fun metricsSetParameters(request: Rpc.Initial.SetParameters.Request): Rpc.Initial.SetParameters.Response
fun setInitialParams(request: Rpc.Initial.SetParameters.Request): Rpc.Initial.SetParameters.Response
@Throws(Exception::class)
fun versionGet(request: Rpc.App.GetVersion.Request): Rpc.App.GetVersion.Response

View file

@ -18,12 +18,6 @@ class MiddlewareServiceImplementation @Inject constructor(
featureToggles: FeatureToggles
) : MiddlewareService {
init {
if (!featureToggles.isLogFromGoProcess) {
Service.setEnv("ANYTYPE_LOG_LEVEL", "*=fatal;anytype*=error")
}
}
override fun accountCreate(request: Rpc.Account.Create.Request): Rpc.Account.Create.Response {
val encoded = Service.accountCreate(Rpc.Account.Create.Request.ADAPTER.encode(request))
val response = Rpc.Account.Create.Response.ADAPTER.decode(encoded)
@ -1156,8 +1150,9 @@ class MiddlewareServiceImplementation @Inject constructor(
}
}
override fun metricsSetParameters(request: Rpc.Initial.SetParameters.Request): Rpc.Initial.SetParameters.Response {
val encoded = Service.initialSetParameters(Rpc.Initial.SetParameters.Request.ADAPTER.encode(request))
override fun setInitialParams(request: Rpc.Initial.SetParameters.Request): Rpc.Initial.SetParameters.Response {
val encoded =
Service.initialSetParameters(Rpc.Initial.SetParameters.Request.ADAPTER.encode(request))
val response = Rpc.Initial.SetParameters.Response.ADAPTER.decode(encoded)
val error = response.error
if (error != null && error.code != Rpc.Initial.SetParameters.Response.Error.Code.NULL) {