Share songs with friends on atproto
atjams.pdewey.com
elixir
atproto
music
feat: edits
Patrick Dewey
(May 14, 2026, 10:52 PM EDT)
3d8616bd
2d5dad99
+262
-40
+48
lib/atjams/atproto.ex
+48
lib/atjams/atproto.ex
···
124
124
end
125
125
126
126
@doc """
127
+
Updates an existing `com.pdewey.atjams.share` record via `putRecord`,
128
+
preserving the original `createdAt`. Returns the new cid (record changed).
129
+
"""
130
+
def update_share(%{did: did, session_key: session_key}, rkey, %{} = form, %DateTime{} = original_created_at)
131
+
when is_binary(rkey) do
132
+
record =
133
+
%{
134
+
"$type" => @share_collection,
135
+
"songUrl" => form.song_url,
136
+
"createdAt" => DateTime.to_iso8601(original_created_at)
137
+
}
138
+
|> maybe_put("title", form.title)
139
+
|> maybe_put("artist", form.artist)
140
+
|> maybe_put("notes", form.notes)
141
+
142
+
with {:ok, client} <- OAuthClient.new(session_key),
143
+
{:ok, %{status: 200, body: body}, _client} <-
144
+
XRPC.post(client, "com.atproto.repo.putRecord",
145
+
json: %{
146
+
repo: did,
147
+
collection: @share_collection,
148
+
rkey: rkey,
149
+
record: record
150
+
}
151
+
) do
152
+
{:ok,
153
+
%{
154
+
uri: Map.get(body, "uri"),
155
+
cid: Map.get(body, "cid"),
156
+
did: did,
157
+
rkey: rkey,
158
+
song_url: form.song_url,
159
+
title: form.title,
160
+
artist: form.artist,
161
+
notes: form.notes,
162
+
created_at: original_created_at
163
+
}}
164
+
else
165
+
{:ok, %{status: status, body: body}, _client} ->
166
+
Logger.warning("putRecord failed: status=#{status} body=#{inspect(body)}")
167
+
{:error, {:pds_error, status, body}}
168
+
169
+
{:error, reason, _client} -> {:error, reason}
170
+
{:error, reason} -> {:error, reason}
171
+
end
172
+
end
173
+
174
+
@doc """
127
175
Creates a `com.pdewey.atjams.like` record on the user's PDS referencing
128
176
the given share (via strongRef: `{uri, cid}`).
129
177
"""
+16
lib/atjams/feed.ex
+16
lib/atjams/feed.ex
···
160
160
end
161
161
162
162
@doc """
163
+
Clears the enrichment columns on a share so the next `Enrichment.start/1`
164
+
refetches. Call this when a share's `song_url` changes via edit.
165
+
"""
166
+
def invalidate_enrichment(uri) when is_binary(uri) do
167
+
case Repo.get(Share, uri) do
168
+
nil ->
169
+
:not_found
170
+
171
+
%Share{} = share ->
172
+
share
173
+
|> Share.changeset(%{links: nil, link_source: nil, links_fetched_at: nil})
174
+
|> Repo.update()
175
+
end
176
+
end
177
+
178
+
@doc """
163
179
Lists shares that should be (re)enriched: never fetched, or fetched more
164
180
than `max_age_days` ago. Useful for a periodic catch-up sweep.
165
181
"""
+3
-5
lib/atjams_web/components/feed_components.ex
+3
-5
lib/atjams_web/components/feed_components.ex
···
113
113
</summary>
114
114
<ul class="menu menu-sm dropdown-content bg-base-100 rounded-xl z-10 w-36 p-1 shadow-lg border border-base-200 mt-1">
115
115
<li>
116
-
<button
117
-
type="button"
118
-
phx-click="edit_share"
119
-
phx-value-uri={@item.share.uri}
116
+
<.link
117
+
navigate={~p"/profile/#{@item.share.did}/#{@item.share.rkey}/edit"}
120
118
class="flex items-center gap-2 px-2 py-1.5 rounded-md hover:bg-base-200"
121
119
>
122
120
<.icon name="hero-pencil-square" class="size-4" /> Edit
123
-
</button>
121
+
</.link>
124
122
</li>
125
123
<li>
126
124
<button
-4
lib/atjams_web/live/feed_live.ex
-4
lib/atjams_web/live/feed_live.ex
···
80
80
{:noreply, AtjamsWeb.ShareActions.delete_share(socket, share_uri)}
81
81
end
82
82
83
-
def handle_event("edit_share", _params, socket) do
84
-
{:noreply, put_flash(socket, :info, "Editing shares isn't built yet — delete and re-share for now.")}
85
-
end
86
-
87
83
## Helpers
88
84
89
85
defp current_user_did(%{assigns: %{current_user: %{did: did}}}), do: did
-4
lib/atjams_web/live/profile_live.ex
-4
lib/atjams_web/live/profile_live.ex
···
102
102
{:noreply, AtjamsWeb.ShareActions.delete_share(socket, share_uri)}
103
103
end
104
104
105
-
def handle_event("edit_share", _params, socket) do
106
-
{:noreply, put_flash(socket, :info, "Editing shares isn't built yet — delete and re-share for now.")}
107
-
end
108
-
109
105
## Helpers
110
106
111
107
defp current_user_did(%{assigns: %{current_user: %{did: did}}}), do: did
+1
lib/atjams_web/router.ex
+1
lib/atjams_web/router.ex
+65
-2
nix/default.nix
+65
-2
nix/default.nix
···
1
1
{
2
2
lib,
3
3
beam,
4
-
elixir,
5
4
nodejs,
5
+
stdenv,
6
+
zstd,
6
7
appName ? "atjams",
7
8
}:
8
9
10
+
let
11
+
version = "0.1.0";
12
+
in
9
13
beam.mixRelease {
10
14
pname = appName;
11
-
version = "0.1.0";
15
+
inherit version;
12
16
src = ../.;
13
17
mixEnv = "prod";
14
18
···
16
20
nodejs
17
21
];
18
22
23
+
# ezstd is a NIF dependency that requires zstd. We provide the system
24
+
# zstd and patch build_deps.sh to be a no-op (it normally clones & builds
25
+
# zstd from source, which doesn't work in the Nix sandbox).
26
+
buildInputs = [
27
+
stdenv.cc
28
+
zstd
29
+
];
30
+
31
+
configurePhase = ''
32
+
runHook preConfigure
33
+
echo "=== CUSTOM configurePhase from atjams ==="
34
+
35
+
# Fix ezstd: provide system zstd headers+lib and make build_deps.sh a
36
+
# no-op (it normally clones & builds zstd from source, which doesn't
37
+
# work in the Nix sandbox).
38
+
if [ -d "$MIX_DEPS_PATH/ezstd" ]; then
39
+
echo "ezstd found at $MIX_DEPS_PATH/ezstd"
40
+
ZSTD_DIR="$MIX_DEPS_PATH/ezstd/_build/deps/zstd"
41
+
mkdir -p "$ZSTD_DIR/lib"
42
+
43
+
for h in zstd.h zstd_errors.h zdict.h; do
44
+
if [ -f "${zstd.dev}/include/$h" ]; then
45
+
ln -sf "${zstd.dev}/include/$h" "$ZSTD_DIR/lib/"
46
+
fi
47
+
done
48
+
49
+
ln -sf "${zstd.out}/lib/libzstd.so" "$ZSTD_DIR/lib/libzstd.so" 2>/dev/null || true
50
+
51
+
printf '#!/usr/bin/env bash\nexit 0\n' > "$MIX_DEPS_PATH/ezstd/build_deps.sh"
52
+
chmod +x "$MIX_DEPS_PATH/ezstd/build_deps.sh"
53
+
chmod +x "$MIX_DEPS_PATH/ezstd/c_src/"*.sh 2>/dev/null || true
54
+
else
55
+
echo "ezstd NOT FOUND at $MIX_DEPS_PATH/ezstd"
56
+
echo "MIX_DEPS_PATH=$MIX_DEPS_PATH"
57
+
ls "$MIX_DEPS_PATH/" 2>/dev/null || echo "deps dir empty or missing"
58
+
fi
59
+
60
+
mix deps.compile --no-deps-check --skip-umbrella-children
61
+
62
+
ln -sfn "$MIX_DEPS_PATH" deps
63
+
64
+
runHook postConfigure
65
+
'';
66
+
67
+
# Fetch hex dependencies as a fixed-output derivation.
68
+
# To update: delete the hash, rebuild, and copy the suggested hash.
69
+
mixFodDeps = beam.fetchMixDeps {
70
+
pname = appName;
71
+
inherit version;
72
+
src = ../.;
73
+
hash = "sha256-e2YhuIeAlKYVJBwae4ly5WAI+E8tihmjlhADgkRCwfU=";
74
+
};
75
+
19
76
preBuild = ''
20
77
mix assets.deploy
78
+
'';
79
+
80
+
postInstall = ''
81
+
chmod +x "$out/bin/atjams"
82
+
chmod +x "$out/bin/server" 2>/dev/null || true
83
+
chmod +x "$out/bin/migrate" 2>/dev/null || true
21
84
'';
22
85
23
86
meta = with lib; {