Skip to content

Commit

Permalink
Allow to configure audience
Browse files Browse the repository at this point in the history
  • Loading branch information
bpaquet committed Jul 20, 2024
1 parent 9fb54d3 commit 686fbfb
Show file tree
Hide file tree
Showing 4 changed files with 15 additions and 3 deletions.
6 changes: 6 additions & 0 deletions load_test/config/runtime.exs
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,9 @@ config :load_test,
sse_jwt_secret:
System.get_env("SSE_JWT_SECRET") || "966KljJz--KyzyBnMOrFXfAkq9XMqWwPgdBV3cKTxsc"

config :load_test,
sse_jwt_audience: System.get_env("SSE_JWT_AUDIENCE") || "public_api"

config :load_test,
publish_url: System.get_env("PUBLISH_URL") || "http://localhost:3000/v1/publish"

Expand All @@ -29,6 +32,9 @@ config :load_test,
publish_jwt_secret:
System.get_env("PUBLISH_JWT_SECRET") || "nLjJdNLlpdv3W4Xk7MyVCAZKD-hvza6FQ4yhUUFnjmg"

config :load_test,
publish_jwt_audience: System.get_env("PUBLISH_JWT_AUDIENCE") || "internal_api"

config :load_test,
delay_between_messages_min:
String.to_integer(System.get_env("DELAY_BETWEEN_MESSAGES_MIN") || "500")
Expand Down
8 changes: 7 additions & 1 deletion load_test/lib/load_test/main.ex
Original file line number Diff line number Diff line change
Expand Up @@ -6,12 +6,14 @@ defmodule LoadTest.Main do
defstruct [
:sse_timeout,
:sse_url,
:sse_jwt_secret,
:sse_jwt_issuer,
:sse_jwt_secret,
:sse_jwt_audience,
:publish_url,
:publish_timeout,
:publish_jwt_issuer,
:publish_jwt_secret,
:publish_jwt_audience,
:delay_between_messages_min,
:delay_between_messages_max,
:number_of_messages_min,
Expand All @@ -31,11 +33,13 @@ defmodule LoadTest.Main do
{:ok, sse_url} = Application.fetch_env(:load_test, :sse_url)
{:ok, sse_jwt_issuer} = Application.fetch_env(:load_test, :sse_jwt_issuer)
{:ok, sse_jwt_secret} = Application.fetch_env(:load_test, :sse_jwt_secret)
{:ok, sse_jwt_audience} = Application.fetch_env(:load_test, :sse_jwt_audience)

{:ok, publish_url} = Application.fetch_env(:load_test, :publish_url)
{:ok, publish_timeout} = Application.fetch_env(:load_test, :publish_timeout)
{:ok, publish_jwt_issuer} = Application.fetch_env(:load_test, :publish_jwt_issuer)
{:ok, publish_jwt_secret} = Application.fetch_env(:load_test, :publish_jwt_secret)
{:ok, publish_jwt_audience} = Application.fetch_env(:load_test, :publish_jwt_audience)

{:ok, delay_between_messages_min} =
Application.fetch_env(:load_test, :delay_between_messages_min)
Expand All @@ -53,10 +57,12 @@ defmodule LoadTest.Main do
sse_url: sse_url,
sse_jwt_issuer: sse_jwt_issuer,
sse_jwt_secret: JOSE.JWK.from_oct(sse_jwt_secret),
sse_jwt_audience: sse_jwt_audience,
publish_url: publish_url,
publish_timeout: publish_timeout,
publish_jwt_issuer: publish_jwt_issuer,
publish_jwt_secret: JOSE.JWK.from_oct(publish_jwt_secret),
publish_jwt_audience: publish_jwt_audience,
delay_between_messages_min: delay_between_messages_min,
delay_between_messages_max: delay_between_messages_max,
number_of_messages_min: number_of_messages_min,
Expand Down
2 changes: 1 addition & 1 deletion load_test/lib/load_test/user/publisher.ex
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ defmodule LoadTest.User.Publisher do
"iss" => context.publish_jwt_issuer,
"exp" => exp,
"iat" => iat,
"aud" => "internal_api"
"aud" => context.publish_jwt_audience
}

jws = %{
Expand Down
2 changes: 1 addition & 1 deletion load_test/lib/load_test/user/sse.ex
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ defmodule SseUser do
"iss" => context.sse_jwt_issuer,
"exp" => exp,
"iat" => iat,
"aud" => "public_api",
"aud" => context.sse_jwt_audience,
"sub" => topic
}

Expand Down

0 comments on commit 686fbfb

Please sign in to comment.