projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'fix-streaming' into 'develop'
[akkoma]
/
lib
/
mix
/
tasks
/
pleroma
/
user.ex
diff --git
a/lib/mix/tasks/pleroma/user.ex
b/lib/mix/tasks/pleroma/user.ex
index 93ecb463196282396922381ccce5ed2c8ddf2135..3635c02bc4d21aaf0b29c5f25434e3d83e624ebf 100644
(file)
--- a/
lib/mix/tasks/pleroma/user.ex
+++ b/
lib/mix/tasks/pleroma/user.ex
@@
-144,7
+144,7
@@
defmodule Mix.Tasks.Pleroma.User do
end
end
end
end
- def run(["
unsubscrib
e", nickname]) do
+ def run(["
deactivat
e", nickname]) do
start_pleroma()
with %User{} = user <- User.get_cached_by_nickname(nickname) do
start_pleroma()
with %User{} = user <- User.get_cached_by_nickname(nickname) do
@@
-163,7
+163,7
@@
defmodule Mix.Tasks.Pleroma.User do
end
end
end
end
- def run(["
unsubscrib
e_all_from_instance", instance]) do
+ def run(["
deactivat
e_all_from_instance", instance]) do
start_pleroma()
Pleroma.User.Query.build(%{nickname: "@#{instance}"})
start_pleroma()
Pleroma.User.Query.build(%{nickname: "@#{instance}"})
@@
-171,7
+171,7
@@
defmodule Mix.Tasks.Pleroma.User do
|> Stream.each(fn users ->
users
|> Enum.each(fn user ->
|> Stream.each(fn users ->
users
|> Enum.each(fn user ->
- run(["
unsubscrib
e", user.nickname])
+ run(["
deactivat
e", user.nickname])
end)
end)
|> Stream.run()
end)
end)
|> Stream.run()