Sam Willis
@samwillis.uk
1.1K followers 283 following 146 posts
Building sync and streams Databricks & Neon. Prev co-founder @electric.ax - acquired. Started PGlite.dev, co-creator of Tanstack DB @tanstack.com.
Building sync and streams Databricks & Neon. Prev co-founder @electric.ax - acquired. Started PGlite.dev, co-creator of Tanstack DB @tanstack.com.
![const graph = new D2({ initialFrontier: 0 });
const issuesInput = graph.newInput<[string, Issue]>();
const usersInput = graph.newInput<[string, User]>();
const commentsInput = graph.newInput<[string, Comment]>();
const commentCounts = commentsInput.pipe(
map(([_key, comment]) => [comment.issue_id, 1]),
concat(issuesInput.pipe(map(([_key, issue]) => [issue.id, 0]))),
reduce((values) => {
let count = 0;
for (const [num, diff] of values) {
count += num * diff;
}
return [[count, 1]];
})
);
issuesInput.pipe(
map(([_key, issue]) => [issue.user_id, issue]),
join(usersInput.pipe(map(([_key, user]) => [user.id, user]))),
join(commentCounts),
map(([_key, [[issue, user], commentCount]]) => [
issue.id,
{
...issue,
user_id: user.id,
username: user.username,
user_email: user.email,
user_full_name: user.full_name,
comment_count: commentCount || 0,
},
]),
consolidate(),
output((msgs) => {
console.log(msgs);
})
);](https://cdn.bsky.app/img/feed_thumbnail/plain/did:plc:7zsebsiw55hprbjz6prpsbem/bafkreidmctemtym2lbzvsrx47fkyaaz7gqlwwaduxobwdphffri6dbz7a4)
![const graph = new D2({ initialFrontier: 0 });
const issuesInput = graph.newInput<[string, Issue]>();
const usersInput = graph.newInput<[string, User]>();
const commentsInput = graph.newInput<[string, Comment]>();
const commentCounts = commentsInput.pipe(
map(([_key, comment]) => [comment.issue_id, 1]),
concat(issuesInput.pipe(map(([_key, issue]) => [issue.id, 0]))),
reduce((values) => {
let count = 0;
for (const [num, diff] of values) {
count += num * diff;
}
return [[count, 1]];
})
);
issuesInput.pipe(
map(([_key, issue]) => [issue.user_id, issue]),
join(usersInput.pipe(map(([_key, user]) => [user.id, user]))),
join(commentCounts),
map(([_key, [[issue, user], commentCount]]) => [
issue.id,
{
...issue,
user_id: user.id,
username: user.username,
user_email: user.email,
user_full_name: user.full_name,
comment_count: commentCount || 0,
},
]),
consolidate(),
output((msgs) => {
console.log(msgs);
})
);](https://cdn.bsky.app/img/feed_thumbnail/plain/did:plc:7zsebsiw55hprbjz6prpsbem/bafkreif3eumrvvl3tsnrgrqhqlbke6co66lc3rg7ri4epz62yektej73qm)
![<script>
// In your <head>
(t=>{var r,i,a,d,l="",s={},u=document,b=1,n=e=>{(i=e.getAttribute?.(t))&&(d=s[i
]??=b,a=t+d,e.removeAttribute(e[t]),e.setAttribute(a,""),e[t]=a,d==b)&&(
l+=`[${a}]{${i}}`,b++)};new MutationObserver(e=>{e.map(e=>{
"childList"==e.type?e.addedNodes.forEach(e=>{n(e),[...e.querySelectorAll?.(
`[${t}]`)||[]].map(n)}):n(e.target)}),l&&((r=u.createElement("style")
).innerHTML=l,u.head.appendChild(r),l="")}).observe(u,{attributeFilter:[t],
childList:!0,subtree:!0})})("x-style");
</script>
<a
href="/something-awsome"
x-style="
color: red;
font-size: 30px;
&:hover {
background-color: yellow;
}
& > span {
color: green;
&::after {
display: inline;
content: '!';
}
}
"
>
Click here for <span>Something Awsome</span>
</a>](https://cdn.bsky.app/img/feed_thumbnail/plain/did:plc:7zsebsiw55hprbjz6prpsbem/bafkreihzw4wk2kmofpqzb67txqsgbandxlaal2hzbzapopifvfqwsisi6y)
