Formatting

cequence-io · Nov 26, 2024 · 7e5d455 · 7e5d455
1 parent a8dfef8
commit 7e5d455
Show file tree

Hide file tree

Showing 3 changed files with 22 additions and 9 deletions.
diff --git a/anthropic-client/src/main/scala/io/cequence/openaiscala/anthropic/service/impl/package.scala b/anthropic-client/src/main/scala/io/cequence/openaiscala/anthropic/service/impl/package.scala
@@ -103,11 +103,12 @@ package object impl extends AnthropicServiceConsts {
 
             case Message.UserMessageContent(contentBlocks) =>
               val (newContentBlocks, remainingCache) =
-                contentBlocks.foldLeft((Seq.empty[ContentBlockBase], userMessagesToCacheCount)) {
-                  case ((acc, cacheLeft), content) =>
-                    val (block, newCacheLeft) =
-                      toAnthropic(cacheLeft)(content.asInstanceOf[OpenAIContent])
-                    (acc :+ block, newCacheLeft)
+                contentBlocks.foldLeft(
+                  (Seq.empty[ContentBlockBase], userMessagesToCacheCount)
+                ) { case ((acc, cacheLeft), content) =>
+                  val (block, newCacheLeft) =
+                    toAnthropic(cacheLeft)(content.asInstanceOf[OpenAIContent])
+                  (acc :+ block, newCacheLeft)
                 }
               (acc :+ Message.UserMessageContent(newContentBlocks), remainingCache)
 

diff --git a/...tream/src/main/scala/io/cequence/openaiscala/service/OpenAIStreamedServiceImplicits.scala b/...tream/src/main/scala/io/cequence/openaiscala/service/OpenAIStreamedServiceImplicits.scala
@@ -4,10 +4,20 @@ import akka.NotUsed
 import akka.stream.Materializer
 import akka.stream.scaladsl.Source
 import io.cequence.openaiscala.domain.BaseMessage
-import io.cequence.openaiscala.domain.response.{ChatCompletionChunkResponse, TextCompletionResponse}
-import io.cequence.openaiscala.domain.settings.{CreateChatCompletionSettings, CreateCompletionSettings}
+import io.cequence.openaiscala.domain.response.{
+  ChatCompletionChunkResponse,
+  TextCompletionResponse
+}
+import io.cequence.openaiscala.domain.settings.{
+  CreateChatCompletionSettings,
+  CreateCompletionSettings
+}
 import io.cequence.openaiscala.service.StreamedServiceTypes.OpenAIStreamedService
-import io.cequence.openaiscala.service.adapter.{OpenAIChatCompletionServiceWrapper, OpenAICoreServiceWrapper, OpenAIServiceWrapper}
+import io.cequence.openaiscala.service.adapter.{
+  OpenAIChatCompletionServiceWrapper,
+  OpenAICoreServiceWrapper,
+  OpenAIServiceWrapper
+}
 import io.cequence.wsclient.domain.WsRequestContext
 import io.cequence.wsclient.service.CloseableService
 import io.cequence.wsclient.service.adapter.ServiceWrapperTypes.CloseableServiceWrapper

diff --git a/...openaiscala/examples/nonopenai/AnthropicCreateChatCompletionCachedWithOpenAIAdapter.scala b/...openaiscala/examples/nonopenai/AnthropicCreateChatCompletionCachedWithOpenAIAdapter.scala
@@ -26,7 +26,9 @@ object AnthropicCreateChatCompletionCachedWithOpenAIAdapter
         messages = messages,
         settings = CreateChatCompletionSettings(
           NonOpenAIModelId.claude_3_5_sonnet_20241022
-        ).setUseAnthropicSystemMessagesCache(true), // this is how we pass it through the adapter
+        ).setUseAnthropicSystemMessagesCache(
+          true
+        ) // this is how we pass it through the adapter
       )
       .map { content =>
         println(content.choices.headOption.map(_.message.content).getOrElse("N/A"))