mazz

Finch.start_link(name: MyFinch)

url = "https://horizon.stellar.org/accounts/GAFNBDOZBFUKHB4ZY5ANCQ25PM33YLTMWQKW25J7LXNZM3YSHRH3BELY/transactions?limit=200&cursor=119456526699307008&include_failed=true"
Finch.build(:get, url, [{"Accept", "text/event-stream"}]) 
|> Finch.stream(MyFinch, nil, fn
  {:status, status}, _acc ->
    IO.inspect(status)

  {:headers, headers}, _acc ->
    IO.inspect(headers)

mazz

defmodule LumensAppWebApi.WalletController do
  use LumensAppWeb, :controller
  alias StellarBase.StrKey
  alias Stellar.KeyPair
  require Logger

  def show_qr(conn, %{"network" => network}) when network in ["pubnet", "testnet"] do
    session_id = UUID.uuid6()
    Logger.debug("Generating QR code for network: #{network}, session_id: #{session_id}")

mazz

# ueberauth config
config :ueberauth, Ueberauth,
  providers: [
    google:
      {Ueberauth.Strategy.Google,
       [
         prompt: "consent",
         access_type: "offline",
         default_scope: "email"
       ]}

mazz

defmodule App.Simplified.Broadway do
  use Broadway

  require Logger

  alias Broadway.Message

  def start_link(_opts) do
    Broadway.start_link(App.Simplified.Broadway,
      name: BroadwayBlueskeySimplified,

mazz

defmodule Markably.UserNotifications.Broadway do
  @moduledoc false
  use Broadway

  alias Broadway.Message

  require Logger

  def start_link(_opts) do
    Broadway.start_link(Markably.UserNotifications.Broadway,

mazz

defmodule WordWeb.Components.ChannelRow do
  use Surface.LiveComponent

  alias Surface.Components.{
    LiveRedirect
  }

  alias WordWeb.Components.{
    Button,
    Card

mazz

Apr 11 19:59:19 pov-epc open5gs-mmed[846]: #033[32m04/11 19:59:19.417#033[0m: [#033[33mdiam#033[0m] #033[1;33mERROR#033[0m: pid:PSM/hss.localpyhss in fd_p_ce_msgrcv@p_ce.c:747: ERROR: in '(save_remote_CE_info(*msg, peer, &pei, &rc))' :#011Invalid argument
Apr 11 19:59:19 pov-epc open5gs-mmed[846]:  ((null):0)
Apr 11 19:59:19 pov-epc open5gs-mmed[846]: #033[32m04/11 19:59:19.417#033[0m: [#033[33mdiam#033[0m] #033[1;33mERROR#033[0m: pid:PSM/hss.localpyhss in md_hook_cb_tree@dbg_msg_dumps.c:116: DROPPED 'Internal error ('hss.localpyhss'): unhandled message.'
Apr 11 19:59:19 pov-epc open5gs-mmed[846]:  ((null):0)
Apr 11 19:59:19 pov-epc open5gs-mmed[846]: #033[32m04/11 19:59:19.417#033[0m: [#033[33mdiam#033[0m] #033[1;33mERROR#033[0m: pid:PSM/hss.localpyhss in md_hook_cb_tree@dbg_msg_dumps.c:117:      'Capabilities-Exchange-Answer'
Apr 11 19:59:19 pov-epc open5gs-mmed[846]:  ((null):0)
Apr 11 19:59:19 pov-epc open5gs-mmed[846]: #033[32m04/11 19:59:19.417#033[0m: [#033[33mdiam#033[0m] #033[1;33mERROR#033[0m: pid:P

mazz

Apr 11 19:11:49 pov-epc open5gs-mmed[845]: #033[32m04/11 19:11:49.129#033[0m: [#033[33mdiam#033[0m] #033[1;33mERROR#033[0m: pid:PSM/hss.localpyhss in md_hook_cb_tree@dbg_msg_dumps.c:116: DROPPED 'Internal error ('hss.localpyhss'): unhandled message.'
Apr 11 19:11:49 pov-epc open5gs-mmed[845]:  ((null):0)
Apr 11 19:11:49 pov-epc open5gs-mmed[845]: #033[32m04/11 19:11:49.129#033[0m: [#033[33mdiam#033[0m] #033[1;33mERROR#033[0m: pid:PSM/hss.localpyhss in md_hook_cb_tree@dbg_msg_dumps.c:117:      'Capabilities-Exchange-Answer'
Apr 11 19:11:49 pov-epc open5gs-mmed[845]:  ((null):0)
Apr 11 19:11:49 pov-epc open5gs-mmed[845]: #033[32m04/11 19:11:49.129#033[0m: [#033[33mdiam#033[0m] #033[1;33mERROR#033[0m: pid:PSM/hss.localpyhss in md_hook_cb_tree@dbg_msg_dumps.c:117:        Version: 0x01
Apr 11 19:11:49 pov-epc open5gs-mmed[845]:  ((null):0)
Apr 11 19:11:49 pov-epc open5gs-mmed[845]: #033[32m04/11 19:11:49.129#033[0m: [#033[33mdiam#033[0m] #033[1;33mERROR#033[0m: pid:PSM/hss.localpyhss in md_hook_cb_tree@dbg_msg_dum

mazz

  def presign_upload(entry, socket) do
    uploads = socket.assigns.uploads
    bucket = FaithfulWord.config([:s3, :bucket])

    dbg(socket.assigns.upload_path_prefix)

    ## HACK to generate dir path on s3 by uploading an empty .gitkeep file
    ## this must be done before the upload occurs

    # gitkeep_file = File.read!("gitkeep")

mazz

defmodule MarkablyWeb.UserChannel do
  use Phoenix.Channel, hibernate_after: :infinity

  alias Phoenix.Socket.Broadcast
  alias Markably.Pipeline.Timing

  @impl true
  def join("user:" <> user_id, _payload, socket) do
    dbg("join MarkablyWeb.UserChannel")
    dbg(user_id)