Skip to content

fix: stability improvements batch 4 (Tier 2 cleanup) #2861

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
simonredfern merged 4 commits into from
Jul 13, 2026
Merged

fix: stability improvements batch 4 (Tier 2 cleanup) #2861

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
1abb0d2
fix(dates): make shared SimpleDateFormat instances thread-safe
hongwei1 Jul 7, 2026
54c271c
fix(db): run blocking JDBC/gRPC on a dedicated bounded pool
hongwei1 Jul 7, 2026
0c89dda
fix(email): surface password-reset SMTP failures instead of reporting…
hongwei1 Jul 7, 2026
aad23d0
fix(ukob): wrap v3.1 ResourceDoc example bodies in JvalueCaseClass
hongwei1 Jul 7, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 1 addition & 2 deletions obp-api/src/main/scala/bootstrap/liftweb/Boot.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -162,7 +162,6 @@ import org.apache.commons.io.FileUtils
import java.io.{File, FileInputStream}
import java.util.stream.Collectors
import java.util.{Locale, TimeZone}
import scala.concurrent.ExecutionContext
import scala.util.control.NonFatal


Expand Down Expand Up @@ -1071,7 +1070,7 @@ object ToSchemify extends MdcLoggable {
// start grpc server (optional)
val grpcServerOpt: Option[ObpGrpcServer] =
if (APIUtil.getPropsAsBoolValue("grpc.server.enabled", false)) {
val server = new ObpGrpcServer(ExecutionContext.global)
val server = new ObpGrpcServer(code.api.util.BlockingIoExecutionContext.ec)
server.start()
Some(server)
} else None
Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310AccountAccess.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ object Http4sUKOBv310AccountAccess extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion

lazy val createAccountAccessConsents: HttpRoutes[IO] = HttpRoutes.of[IO] {
Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310Accounts.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ object Http4sUKOBv310Accounts extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion

lazy val getAccounts: HttpRoutes[IO] = HttpRoutes.of[IO] {
Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310Balances.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ object Http4sUKOBv310Balances extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("Balances") :: Nil

Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310Beneficiaries.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ object Http4sUKOBv310Beneficiaries extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("Beneficiaries") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310DirectDebits.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ object Http4sUKOBv310DirectDebits extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("Direct Debits") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310DomesticPayments.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ object Http4sUKOBv310DomesticPayments extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("Domestic Payments") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion ...rc/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310DomesticScheduledPayments.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ object Http4sUKOBv310DomesticScheduledPayments extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("Domestic Scheduled Payments") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion ...i/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310DomesticStandingOrders.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ object Http4sUKOBv310DomesticStandingOrders extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("Domestic Standing Orders") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310FilePayments.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ object Http4sUKOBv310FilePayments extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("File Payments") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310FundsConfirmations.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ object Http4sUKOBv310FundsConfirmations extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("Funds Confirmations") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion ...pi/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310InternationalPayments.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ object Http4sUKOBv310InternationalPayments extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("International Payments") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion ...in/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310InternationalScheduledPayments.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ object Http4sUKOBv310InternationalScheduledPayments extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("International Scheduled Payments") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion .../main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310InternationalStandingOrders.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ object Http4sUKOBv310InternationalStandingOrders extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("International Standing Orders") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310Offers.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ object Http4sUKOBv310Offers extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("Offers") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310Partys.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ object Http4sUKOBv310Partys extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("Partys") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310Products.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ object Http4sUKOBv310Products extends MdcLoggable {

val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])

val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion

Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310ScheduledPayments.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ object Http4sUKOBv310ScheduledPayments extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("Scheduled Payments") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310StandingOrders.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ object Http4sUKOBv310StandingOrders extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("Standing Orders") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310Statements.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ object Http4sUKOBv310Statements extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion
private val tag = ApiTag("Statements") :: apiTagMockedData :: Nil

Expand Down
2 changes: 1 addition & 1 deletion obp-api/src/main/scala/code/api/UKOpenBanking/v3_1_0/Http4sUKOBv310Transactions.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ object Http4sUKOBv310Transactions extends MdcLoggable {
implicit val formats: Formats = CustomJsonFormats.formats
val implementedInApiVersion: ScannedApiVersion = ApiVersion.ukOpenBankingV31
val resourceDocs = ArrayBuffer[ResourceDoc]()
private def parseBody(s: String): org.json4s.JObject = com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject]
private def parseBody(s: String): code.api.berlin.group.v1_3.JvalueCaseClass = code.api.berlin.group.v1_3.JvalueCaseClass(com.openbankproject.commons.util.JsonAliases.parse(s).asInstanceOf[org.json4s.JObject])
val ukV31Prefix = Root / ApiVersion.ukOpenBankingV31.urlPrefix / ApiVersion.ukOpenBankingV31.apiShortVersion

// -----------------------------------------------------------------------
Expand Down
6 changes: 2 additions & 4 deletions obp-api/src/main/scala/code/api/dynamic/entity/projection/ProjectionDb.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,12 +1,10 @@
package code.api.dynamic.entity.projection

import cats.effect.IO
import code.api.util.APIUtil
import code.api.util.{APIUtil, BlockingIoExecutionContext}
import doobie._
import doobie.implicits._

import scala.concurrent.ExecutionContext

/**
* A **committing** Doobie transactor over the shared HikariCP pool, for projection operations that
* run independently of any Lift request transaction — provisioner DDL/backfill and the read-path
Expand All @@ -19,7 +17,7 @@ import scala.concurrent.ExecutionContext
*/
object ProjectionDb {
private lazy val xa: Transactor[IO] =
Transactor.fromDataSource[IO].apply(APIUtil.vendor.HikariDatasource.ds, ExecutionContext.global)
Transactor.fromDataSource[IO].apply(APIUtil.vendor.HikariDatasource.ds, BlockingIoExecutionContext.ec)

def run[A](program: ConnectionIO[A]): IO[A] = program.transact(xa)
}
27 changes: 19 additions & 8 deletions obp-api/src/main/scala/code/api/util/APIUtil.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -151,16 +151,27 @@
val DateWithMs = "yyyy-MM-dd'T'HH:mm:ss.SSS'Z'"
val DateWithMsAndTimeZoneOffset = "yyyy-MM-dd'T'HH:mm:ss.SSSZ"

val DateWithYearFormat = new SimpleDateFormat(DateWithYear)
val DateWithMonthFormat = new SimpleDateFormat(DateWithMonth)
val DateWithDayFormat = new SimpleDateFormat(DateWithDay)
val DateWithSecondsFormat = new SimpleDateFormat(DateWithSeconds)
// SimpleDateFormat is not thread-safe (parse and format both mutate the internal Calendar).
// Give every thread its own instance so shared use across concurrent requests is safe,
// while avoiding a fresh allocation on the hot from_date/to_date parse path.
private val DateWithYearFormatTL = ThreadLocal.withInitial(() => new SimpleDateFormat(DateWithYear))
private val DateWithMonthFormatTL = ThreadLocal.withInitial(() => new SimpleDateFormat(DateWithMonth))
private val DateWithDayFormatTL = ThreadLocal.withInitial(() => new SimpleDateFormat(DateWithDay))
private val DateWithSecondsFormatTL = ThreadLocal.withInitial(() => new SimpleDateFormat(DateWithSeconds))
private val DateWithMsFormatTL = ThreadLocal.withInitial(() => new SimpleDateFormat(DateWithMs))
private val DateWithMsRollbackFormatTL = ThreadLocal.withInitial(() => new SimpleDateFormat(DateWithMsAndTimeZoneOffset))
private val rfc7231DateTL = ThreadLocal.withInitial(() => new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss z", Locale.ENGLISH))

def DateWithYearFormat: SimpleDateFormat = DateWithYearFormatTL.get()

Check warning on line 165 in obp-api/src/main/scala/code/api/util/APIUtil.scala

View check run for this annotation

SonarQubeCloud / SonarCloud Code Analysis

Rename function "DateWithYearFormat" to match the regular expression ^([a-z][a-zA-Z0-9]*+(_[^a-zA-Z0-9]++)?+|[^a-zA-Z0-9]++)$ 


See more on https://sonarcloud.io/project/issues?id=OpenBankProject_OBP-API&issues=AZ9begX2NKmjP9Iyu5-f&open=AZ9begX2NKmjP9Iyu5-f&pullRequest=2861
def DateWithMonthFormat: SimpleDateFormat = DateWithMonthFormatTL.get()

Check warning on line 166 in obp-api/src/main/scala/code/api/util/APIUtil.scala

View check run for this annotation

SonarQubeCloud / SonarCloud Code Analysis

Rename function "DateWithMonthFormat" to match the regular expression ^([a-z][a-zA-Z0-9]*+(_[^a-zA-Z0-9]++)?+|[^a-zA-Z0-9]++)$ 


See more on https://sonarcloud.io/project/issues?id=OpenBankProject_OBP-API&issues=AZ9begX2NKmjP9Iyu5-g&open=AZ9begX2NKmjP9Iyu5-g&pullRequest=2861
def DateWithDayFormat: SimpleDateFormat = DateWithDayFormatTL.get()

Check warning on line 167 in obp-api/src/main/scala/code/api/util/APIUtil.scala

View check run for this annotation

SonarQubeCloud / SonarCloud Code Analysis

Rename function "DateWithDayFormat" to match the regular expression ^([a-z][a-zA-Z0-9]*+(_[^a-zA-Z0-9]++)?+|[^a-zA-Z0-9]++)$ 


See more on https://sonarcloud.io/project/issues?id=OpenBankProject_OBP-API&issues=AZ9begX2NKmjP9Iyu5-h&open=AZ9begX2NKmjP9Iyu5-h&pullRequest=2861
def DateWithSecondsFormat: SimpleDateFormat = DateWithSecondsFormatTL.get()

Check warning on line 168 in obp-api/src/main/scala/code/api/util/APIUtil.scala

View check run for this annotation

SonarQubeCloud / SonarCloud Code Analysis

Rename function "DateWithSecondsFormat" to match the regular expression ^([a-z][a-zA-Z0-9]*+(_[^a-zA-Z0-9]++)?+|[^a-zA-Z0-9]++)$ 


See more on https://sonarcloud.io/project/issues?id=OpenBankProject_OBP-API&issues=AZ9begX2NKmjP9Iyu5-i&open=AZ9begX2NKmjP9Iyu5-i&pullRequest=2861
// If you need UTC Z format, please continue to use DateWithMsFormat. eg: 2025-01-01T01:01:01.000Z
val DateWithMsFormat = new SimpleDateFormat(DateWithMs)
def DateWithMsFormat: SimpleDateFormat = DateWithMsFormatTL.get()

Check warning on line 170 in obp-api/src/main/scala/code/api/util/APIUtil.scala

View check run for this annotation

SonarQubeCloud / SonarCloud Code Analysis

Rename function "DateWithMsFormat" to match the regular expression ^([a-z][a-zA-Z0-9]*+(_[^a-zA-Z0-9]++)?+|[^a-zA-Z0-9]++)$ 


See more on https://sonarcloud.io/project/issues?id=OpenBankProject_OBP-API&issues=AZ9begX2NKmjP9Iyu5-j&open=AZ9begX2NKmjP9Iyu5-j&pullRequest=2861
// If you need a format with timezone offset (+0000), please use DateWithMsRollbackFormat, eg: 2025-01-01T01:01:01.000+0000
val DateWithMsRollbackFormat = new SimpleDateFormat(DateWithMsAndTimeZoneOffset)
val rfc7231Date = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss z", Locale.ENGLISH)
def DateWithMsRollbackFormat: SimpleDateFormat = DateWithMsRollbackFormatTL.get()

Check warning on line 172 in obp-api/src/main/scala/code/api/util/APIUtil.scala

View check run for this annotation

SonarQubeCloud / SonarCloud Code Analysis

Rename function "DateWithMsRollbackFormat" to match the regular expression ^([a-z][a-zA-Z0-9]*+(_[^a-zA-Z0-9]++)?+|[^a-zA-Z0-9]++)$ 


See more on https://sonarcloud.io/project/issues?id=OpenBankProject_OBP-API&issues=AZ9begX2NKmjP9Iyu5-k&open=AZ9begX2NKmjP9Iyu5-k&pullRequest=2861

def rfc7231Date: SimpleDateFormat = rfc7231DateTL.get()

val DateWithYearExampleString: String = "1100"
val DateWithMonthExampleString: String = "1100-01"
Expand Down
Loading
Loading