-
Notifications
You must be signed in to change notification settings - Fork 30
/
builder.ts
125 lines (112 loc) · 3.37 KB
/
builder.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
import { prismaClient } from '../prisma/client';
import { readFileSync } from 'fs';
import { daysAgo, getMediaType } from '$lib/utils';
import { getRecentCoreCommits } from './getRecentCoreCommits';
export class IssueAlreadyPublished extends Error {
constructor() {
const message = 'This issue has already been published';
super(message);
}
}
interface ContentFetcher {
section: string;
getContent(days: number): Promise<string>;
}
class CoreCommitContentFetcher implements ContentFetcher {
section = '{neovim-core-commits-section}';
template = './twin/core-commit-template.md';
async getContent(days: number) {
const newCoreCommitTemplate = readFileSync(this.template, 'utf8');
const commits = await getRecentCoreCommits();
const content = [];
for (const commit of commits) {
if (daysAgo(days) < commit.date) {
let commitContent = newCoreCommitTemplate;
commitContent = commitContent.replaceAll('{title}', commit.title);
commitContent = commitContent.replaceAll('{body}', commit.body);
commitContent = commitContent.replaceAll('{url}', commit.url);
content.push(commitContent);
}
}
return content.join('');
}
}
class PluginContentFetcher implements ContentFetcher {
section = '{new-plugins-section}';
template = './twin/new-plugin-template.md';
async getContent(days: number): Promise<string> {
const newPluginTemplate = readFileSync(this.template, 'utf8');
const plugins = await this.getNewPlugins(days);
const content = [];
for (const plugin of plugins) {
let post = newPluginTemplate.replaceAll('{fullname}', `${plugin.owner}/${plugin.name}`);
post = post.replaceAll(
'{image}',
plugin.media.filter((m) => getMediaType(m) === 'image')[0]?.url ?? ''
);
post = post.replaceAll('{starcount}', plugin.stars.toString())
post = post.replaceAll('{category}', plugin.category);
post = post.replaceAll('{description}', plugin.shortDescription);
post = post.replaceAll('{summary}', plugin.description);
post = post.replaceAll('{githubUrl}', `https://github.com/${plugin.owner}/${plugin.name}`);
post = post.replaceAll(
'{dotfyleUrl}',
`/plugins/${plugin.owner}/${plugin.name}?utm_source=twin-web`
);
content.push(post);
}
return content.join('\n\n');
}
async getNewPlugins(days: number) {
const plugins = await prismaClient.neovimPlugin.findMany({
include: {
media: true
},
where: {
createdAt: {
gte: daysAgo(days)
},
},
orderBy: {
neovimConfigPlugins: {
_count: 'desc'
}
}
});
return plugins;
}
}
export class TwinPostBuilder {
template = './twin/template.md';
contentFetchers: ContentFetcher[] = [new CoreCommitContentFetcher(), new PluginContentFetcher()];
async validate(issue: number) {
const twinIssue = await prismaClient.twinPost.findUnique({
where: {
issue
}
});
if (!twinIssue) return;
if (!twinIssue.publishedAt) return;
throw new IssueAlreadyPublished();
}
async run(issue: number, days: number) {
let content = readFileSync(this.template, 'utf8');
for (const contentFetcher of this.contentFetchers) {
content = content.replace(contentFetcher.section, await contentFetcher.getContent(days));
}
const title = `Issue #${issue}`;
const post = {
title,
content,
issue,
publishedAt: null
};
return await prismaClient.twinPost.upsert({
where: {
issue
},
create: post,
update: post
});
}
}