M
post "/:bot_token"А в контроллере (или с помощью plug) проверяешь
conn.path_params["bot_token"]вот с этим сейчас попробую разобраться
А в контроллере (или с помощью plug) проверяешь
Size: a a a
2020 January 21
А в контроллере (или с помощью plug) проверяешь
SM
Ну у нас же на дворе 1.9.4, надо
Application.fetch_env!/2 использовать!Или
Application.compile_env!/2 с приходом 1.10M
Ну у нас же на дворе 1.9.4, надо
Application.fetch_env!/2 использовать!а я вот так делал
System.get_env("BOT_TOKEN")LL
Или
Application.compile_env!/2 с приходом 1.10А что это делает?
LL
Ааа, макрос
LL
Ну раньше можно было бы так
@attr Application.fetch_env!(...)LL
Ну да, теперь чуть-чуть удобнее будет
SM
а я вот так делал
System.get_env("BOT_TOKEN")У нас в прилаге так. Роутер:
pipeline :telegram doCheckBotToken:
plug :accepts, ["json"]
plug MyAppWeb.Plugs.Telegram.CheckBotToken
plug Plug.Parsers,
parsers: [MyApp.Parsers.TelegramJSON],
pass: ["*/*"]
end
scope "/webhook/:bot_token", MyAppWeb do
pipe_through :telegram
post "/", WebhookController, :update
end
defmodule MyAppWeb.Plugs.Telegram.CheckBotToken do
@behaviour Plug
import Plug.Conn
require Logger
@impl Plug
def init(opts), do: opts
@impl Plug
def call(conn, _opts) do
if Map.get(conn.path_params, "bot_token") == Nadia.Config.token() do
conn
else
Logger.warn("Incoming webhook request didn't provide a valid bot token, halting...")
conn
|> send_resp(:no_content, "")
|> halt()
end
end
end
LL
У нас в прилаге так. Роутер:
pipeline :telegram doCheckBotToken:
plug :accepts, ["json"]
plug MyAppWeb.Plugs.Telegram.CheckBotToken
plug Plug.Parsers,
parsers: [MyApp.Parsers.TelegramJSON],
pass: ["*/*"]
end
scope "/webhook/:bot_token", MyAppWeb do
pipe_through :telegram
post "/", WebhookController, :update
end
defmodule MyAppWeb.Plugs.Telegram.CheckBotToken do
@behaviour Plug
import Plug.Conn
require Logger
@impl Plug
def init(opts), do: opts
@impl Plug
def call(conn, _opts) do
if Map.get(conn.path_params, "bot_token") == Nadia.Config.token() do
conn
else
Logger.warn("Incoming webhook request didn't provide a valid bot token, halting...")
conn
|> send_resp(:no_content, "")
|> halt()
end
end
end
nice
M
У нас в прилаге так. Роутер:
pipeline :telegram doCheckBotToken:
plug :accepts, ["json"]
plug MyAppWeb.Plugs.Telegram.CheckBotToken
plug Plug.Parsers,
parsers: [MyApp.Parsers.TelegramJSON],
pass: ["*/*"]
end
scope "/webhook/:bot_token", MyAppWeb do
pipe_through :telegram
post "/", WebhookController, :update
end
defmodule MyAppWeb.Plugs.Telegram.CheckBotToken do
@behaviour Plug
import Plug.Conn
require Logger
@impl Plug
def init(opts), do: opts
@impl Plug
def call(conn, _opts) do
if Map.get(conn.path_params, "bot_token") == Nadia.Config.token() do
conn
else
Logger.warn("Incoming webhook request didn't provide a valid bot token, halting...")
conn
|> send_resp(:no_content, "")
|> halt()
end
end
end
Ух ты, спасибо)
МБ
я, конечно, чего-то мог не понять, но использовать токен бота в каждом запросе это как-то не очень безопасно... Почему-бы просто не заменить его на какой-то рандомный хэш, который скормить вместе с адресом хука в телегу, и сравнивать уже этот хук, а не токен бота
SM
я, конечно, чего-то мог не понять, но использовать токен бота в каждом запросе это как-то не очень безопасно... Почему-бы просто не заменить его на какой-то рандомный хэш, который скормить вместе с адресом хука в телегу, и сравнивать уже этот хук, а не токен бота
Да, так наверно будет лучше
D
https://elixirschool.com/ru/lessons/advanced/gen-stage/
Какой раз читаю пример из GenStage и никак не понимаю. Объясните по-тупому.
В Производителе A определяется функция
В Производителе-потребителе B определяется
Так кто и где вызывает функцию
Какой раз читаю пример из GenStage и никак не понимаю. Объясните по-тупому.
В Производителе A определяется функция
handle_demand(demand, state), которая принимает demand.В Производителе-потребителе B определяется
handle_events. Она ничего не вызывает. Так кто и где вызывает функцию
handle_demand и передаёт мифическое значение demand, которое нигде не обозначено?
PG
1) demand вычисляется автоматически на основе опций min_demand и max_demand подписки
2) demand это второй параметр ask
2) demand это второй параметр ask
PG
есть колбэк handle_subscribe, через него можно выбрать поведение консьюмера (automatic, 1, дефолт или manual, 2)
D
Я думал, в demand можно свои аргументы передать, чтобы производитель их обработал
PG
у него тип pos_integer: https://hexdocs.pm/gen_stage/GenStage.html#c:handle_demand/2
D
Как я писал: У меня есть много ссылок, которые надо распарсить.
В общем, идея была такой:
В
Я как-то должен из
Где я ошибся?
В общем, идея была такой:
[A] -> [B] -> [C]В
A загружается список ссылок, которые надо обработатьB - несколько производителей-потребителей, которые эти ссылки обрабатывают и передают их в единственный CЯ как-то должен из
C эти обработанный данные единственным вызовом забрать.Где я ошибся?
PG
может тебе не gen_stage нужен, а Task?