Skip to content

Instantly share code, notes, and snippets.

➜ ~ curl "https://telecom-exchange.kaller.app/exchange/reservation?tariff=a4a5dd77-db5e-4143-a789-2e6e2ccfa269" \
-H 'Content-Type: application/json' \
-H 'Authorization: Bearer eyJhbGciOiJSUzI1NiIsInR5cCIgOiAiSldUIiwia2lkIiA6ICJNTnlKRmplMEhhMlFvWjZXN2E3a2dpTW5hbDlBZ3B3bFB0VzFlT2ZLSk1JIn0.eyJleHAiOjE3MDczODYyMjUsImlhdCI6MTcwNzM3NTQyNSwianRpIjoiOWMwMmZjM2ItN2NkOC00NjY5LThhMjAtNThmZDZmYjIxZmI5IiwiaXNzIjoiaHR0cDovL2xvY2FsaG9zdC9yZWFsbXMva2FsbGVyIiwiYXVkIjoiYWNjb3VudCIsInN1YiI6ImY6MTcxNDkyNzMtN2YyNi00NjE4LWIzNjctMWViOGRlYzNjZTJmOjRiZjVlYmRkLWJkYWQtNGEwZi05NjkyLTk5NzExMzk0ODdhYSIsInR5cCI6IkJlYXJlciIsImF6cCI6ImthbGxlciIsInNlc3Npb25fc3RhdGUiOiI5YTBlZjc2MS0zODJiLTQzMzItYTQ3NC00MDc0ZjE4MTM2ZDkiLCJhY3IiOiIxIiwiYWxsb3dlZC1vcmlnaW5zIjpbImh0dHA6Ly9sb2NhbGhvc3Q6ODA4MCJdLCJyZWFsbV9hY2Nlc3MiOnsicm9sZXMiOlsib2ZmbGluZV9hY2Nlc3MiLCJ1bWFfYXV0aG9yaXphdGlvbiJdfSwicmVzb3VyY2VfYWNjZXNzIjp7ImFjY291bnQiOnsicm9sZXMiOlsibWFuYWdlLWFjY291bnQiLCJtYW5hZ2UtYWNjb3VudC1saW5rcyIsInZpZXctcHJvZmlsZSJdfX0sInNjb3BlIjoib3BlbmlkIHByb2ZpbGU
2024-02-06 10:03:39,612 WARN [com.arjuna.ats.jta] (executor-thread-1) ARJUNA016041: prepare on < formatId=131077, gtrid_length=35, bqual_length=36, tx_uid=0:ffffac110002:8c71:65c203c5:32, node_name=quarkus, branch_uid=0:ffffac110002:8c71:65c203c5:35, subordinatenodename=null, eis_name=0 > (io.agroal.narayana.BaseXAResource@829873) failed with exception XAException.XAER_RMFAIL: org.postgresql.xa.PGXAException: Error preparing transaction. prepare xid=< formatId=131077, gtrid_length=35, bqual_length=36, tx_uid=0:ffffac110002:8c71:65c203c5:32, node_name=quarkus, branch_uid=0:ffffac110002:8c71:65c203c5:35, subordinatenodename=null, eis_name=0 >
at org.postgresql.xa.PGXAConnection.prepare(PGXAConnection.java:365)
at io.agroal.narayana.BaseXAResource.prepare(BaseXAResource.java:108)
at com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord.topLevelPrepare(XAResourceRecord.java:214)
at com.arjuna.ats.arjuna.coordinator.BasicAction.doPrepare(BasicAction.java:2678)
at com.arjuna.ats.arjuna.coordinato
#!/bin/sh
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
08:47:37 WARN traceId=5b61b55561b15629a76a2294d740bf17, parentId=, spanId=2c8f51f90fc163ff, sampled=true [co.ar.at.arjuna] (executor-thread-2212) ARJUNA012125: TwoPhaseCoordinator.beforeCompletion - failed for SynchronizationImple< 0:ffffac110021:9095:65a925a1:ca2e5, org.hibernate.resource.transaction.backend.jta.internal.synchronization.RegisteredSynchronization@653a98c4 >: org.hibernate.exception.SQLGrammarException: could not execute statement [ERROR: permission denied for sequence accounts_uid_seq
Where: SQL statement "INSERT INTO billing.accounts (uuid) VALUES (account) returning uid"
PL/pgSQL function billing.inbox_events_process() line 54 at SQL statement] [insert into billing.inbox (aggregateId,aggregateType,payload,timestamp,type,id) values (?,?,?,?,?,?)]
at org.hibernate.exception.internal.SQLStateConversionDelegate.convert(SQLStateConversionDelegate.java:89)
at org.hibernate.exception.internal.StandardSQLExceptionConverter.convert(StandardSQLExceptionConverter.java:56)
at org.hibernate.engi
2024-01-19 13:27:10,807 INFO [io.kal.App] (EventThread) $ onSuccess() called with: args = [[{"success":true}]]
2024-01-19 13:28:15,166 INFO [io.kal.App] (EventThread) $ on any incoming [OutgoingEvent, {"text":"{\"time\":\"2024-01-19T10:26:02.171Z\",\"aggregateType\":\"Contacts\",\"id\":\"e0ba09f6-3a1b-40b1-88e5-89b4133d5979\",\"payload\":\"{\\\"number\\\":\\\"+79773021878#10\\\",\\\"name\\\":\\\"user name\\\"}\",\"type\":\"CreateContact\"}"}]
2024-01-19 13:28:15,542 INFO [io.kal.App] (EventThread) $ on any incoming [OutgoingEvent, {"text":"{\"time\":\"2024-01-19T10:27:10.944Z\",\"aggregateType\":\"Contacts\",\"id\":\"338ebce7-a8ba-46d2-aa08-9b159e0e7c66\",\"payload\":\"{\\\"number\\\":\\\"+79773021878#10\\\",\\\"name\\\":\\\"user name\\\"}\",\"type\":\"CreateContact\"}"}]
2024-01-19 13:28:15,774 INFO [io.kal.App] (EventThread) $ on any incoming [OutgoingEvent, {"text":"{\"time\":\"2024-01-19T10:26:02.169Z\",\"aggregateType\":\"Contacts\",\"id\":\"689f1cf8-f297-4246-af32-f515e4af6816\",\"payload\":\"{\\\"n
package io.kaller;
import io.quarkus.runtime.StartupEvent;
import io.socket.client.AckWithTimeout;
import io.socket.client.IO;
import io.socket.client.Socket;
import io.socket.engineio.client.transports.Polling;
import io.socket.engineio.client.transports.WebSocket;
import io.vertx.core.json.JsonObject;
import jakarta.annotation.Priority;
package io.kaller;
import io.quarkus.runtime.StartupEvent;
import io.socket.client.AckWithTimeout;
import io.socket.client.IO;
import io.socket.client.Socket;
import io.socket.emitter.Emitter;
import io.socket.engineio.client.transports.Polling;
import io.socket.engineio.client.transports.WebSocket;
import io.vertx.core.json.JsonObject;
package io.kaller.flows;
import io.kaller.clients.RestClient;
import io.kaller.clients.TokenManager;
import io.kaller.model.RegistrationByNumberData;
import java.util.function.BiConsumer;
import java.util.function.Consumer;
public enum Flow {
curl 'https://telecom-registration.kaller.app/registration/provider/apple' \/apple' \
-vX PUT \
-H 'Host: telecom-registration.kaller.app' \
-H 'Accept: */*' \
-H 'Connection: keep-alive' \
-H 'Content-Length: 891' \
-H 'User-Agent: os=iOS&os_version=15.1&device=iPhone 11' \
-H 'Accept-Language: ru-IL;q=1.0, en-IL;q=0.9' \
-H 'Authorization: Bearer eyJhbGciOiJSUzI1NiIsInR5cCIgOiAiSldUIiwia2lkIiA6ICJNTnlKRmplMEhhMlFvWjZXN2E3a2dpTW5hbDlBZ3B3bFB0VzFlT2ZLSk1JIn0.eyJleHAiOjE3MDUzNDEyNzUsImlhdCI6MTcwNTMzMDQ3NSwianRpIjoiM2VhZDViN2UtOTgzYi00MDE2LWFiNjItYWYyYjlhN2I4MWI0IiwiaXNzIjoiaHR0cDovL2xvY2FsaG9zdC9yZWFsbXMva2FsbGVyIiwiYXVkIjoiYWNjb3VudCIsInN1YiI6ImY6MTcxNDkyNzMtN2YyNi00NjE4LWIzNjctMWViOGRlYzNjZTJmOjEzOGJlODA2LWNjZjctNDQxZS05MDc4LTA5ZTQzYTJmMWFmNyIsInR5cCI6IkJlYXJlciIsImF6cCI6ImthbGxlciIsInNlc3Npb25fc3RhdGUiOiI5ZDZlOWE2Zi03NjlkLTRkNWQtOGZkZi1hMTJjYTljZDI1ZDIiLCJhY3IiOiIxIiwiYWxsb3dlZC1vcmlnaW5zIjpbImh0dHA6Ly9sb2NhbGhvc3Q6ODA4MCJdLCJyZWFsbV9hY2Nlc3MiOnsicm9sZXMiOlsib2ZmbGluZV9hY2Nlc3MiLCJ1bWFfYXV0aG9yaXphdGlvbiJdf
curl 'https://telecom-registration.kaller.app/registration/provider/apple' \
-vX PUT \
-H 'Host: telecom-registration.kaller.app' \
-H 'Accept: */*' \
-H 'Connection: keep-alive' \
-H 'Content-Length: 891' \
-H 'User-Agent: os=iOS&os_version=15.1&device=iPhone 11' \
-H 'Accept-Language: ru-IL;q=1.0, en-IL;q=0.9' \
-H 'Authorization: Bearer eyJhbGciOiJSUzI1NiIsInR5cCIgOiAiSldUIiwia2lkIiA6ICJNTnlKRmplMEhhMlFvWjZXN2E3a2dpTW5hbDlBZ3B3bFB0VzFlT2ZLSk1JIn0.eyJleHAiOjE3MDUzNDEyNzUsImlhdCI6MTcwNTMzMDQ3NSwianRpIjoiM2VhZDViN2UtOTgzYi00MDE2LWFiNjItYWYyYjlhN2I4MWI0IiwiaXNzIjoiaHR0cDovL2xvY2FsaG9zdC9yZWFsbXMva2FsbGVyIiwiYXVkIjoiYWNjb3VudCIsInN1YiI6ImY6MTcxNDkyNzMtN2YyNi00NjE4LWIzNjctMWViOGRlYzNjZTJmOjEzOGJlODA2LWNjZjctNDQxZS05MDc4LTA5ZTQzYTJmMWFmNyIsInR5cCI6IkJlYXJlciIsImF6cCI6ImthbGxlciIsInNlc3Npb25fc3RhdGUiOiI5ZDZlOWE2Zi03NjlkLTRkNWQtOGZkZi1hMTJjYTljZDI1ZDIiLCJhY3IiOiIxIiwiYWxsb3dlZC1vcmlnaW5zIjpbImh0dHA6Ly9sb2NhbGhvc3Q6ODA4MCJdLCJyZWFsbV9hY2Nlc3MiOnsicm9sZXMiOlsib2ZmbGluZV9hY2Nlc3MiLCJ1bWFfYXV0aG9yaXphdGlvbiJdfSwicmVzb3