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
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
|
import { CoolFastifyRequest, Route } from "../../../../types/fastify";
import { FastifyInstance, FastifyPluginOptions } from "fastify";
import { Repository } from "../../../../git/repository";
import { Tag } from "../../../../git/tag";
import { BaseTreeEntry, BlobTreeEntry, TreeEntry } from "../../../../git/tree_entry";
import { basename } from "path";
import branches from "./branches";
import log from "./log";
import { verifyRepoName } from "../../util";
import { Tree as APITree, Tag as APITag, TreeEntry as APITreeEntry } from "api";
import { ServerError } from "../../../../git/error";
import { commitMap } from "./map";
declare module "fastify" {
interface FastifyRequest {
repository: Repository,
}
}
function addHooks(fastify: FastifyInstance, opts: FastifyPluginOptions): void {
fastify.addHook("preHandler", async(req: CoolFastifyRequest, reply) => {
const repository = await Repository.open(opts.config.settings.git_dir, req.params.repo, req.query.branch).catch((err: ServerError) => err);
if(repository instanceof ServerError) {
reply.code(repository.code).send({ error: repository.message });
return;
}
req.repository = repository;
});
fastify.addHook("onRequest", async(req: CoolFastifyRequest, reply) => {
if(!verifyRepoName(req.params.repo)) {
reply.code(400).send({ error: "Bad request" });
}
});
}
async function treeEntryMap(entry: BaseTreeEntry) {
const latest_commit = await entry.latestCommit();
return <APITreeEntry>{
name: basename(entry.path),
type: entry instanceof TreeEntry ? "tree" : "blob",
latest_commit: {
id: latest_commit.id,
message: latest_commit.message,
date: latest_commit.date
}
};
}
async function tagMap(tag: Tag) {
const author = await tag.author();
return <APITag>{
name: tag.name,
author: { name: author.name, email: author.email },
date: await tag.date()
};
}
export default function(fastify: FastifyInstance, opts: FastifyPluginOptions, done: (err?: Error) => void): void {
addHooks(fastify, opts);
fastify.register(log);
fastify.register(branches);
fastify.route<Route>({
method: "GET",
url: "/tree",
handler: async(req, reply) => {
const tree = await req.repository.tree().catch((err: ServerError) => err);
if(tree instanceof ServerError) {
reply.code(tree.code).send({ error: tree.message });
return;
}
const tree_path = (Object.keys(req.query).length !== 0 && req.query.path)
? req.query.path
: null;
let data: APITree;
if(tree_path) {
const tree_path_entry = await tree.find(tree_path).catch((err: ServerError) => err);
if(tree_path_entry instanceof ServerError) {
reply.code(tree_path_entry.code).send({ error: tree_path_entry.message });
return;
}
data = tree_path_entry instanceof BlobTreeEntry
? { type: "blob", content: await (await tree_path_entry.blob()).content() }
: { type: "tree", content: await Promise.all((await (tree_path_entry as TreeEntry).tree()).entries().map(treeEntryMap)) };
}
else {
data = { type: "tree", content: await Promise.all(tree.entries().map(treeEntryMap)) };
}
reply.send({ data: data });
}
});
fastify.route<Route>({
method: "GET",
url: "/tree/history",
handler: async(req, reply) => {
const tree = await req.repository.tree().catch((err: ServerError) => err);
if(tree instanceof ServerError) {
reply.code(tree.code).send({ error: tree.message });
return;
}
if(Object.keys(req.query).length === 0) {
reply.code(400).send({ error: "Missing query parameter 'path'!" });
return;
}
const tree_path = req.query.path;
const tree_entry = await tree.find(tree_path).catch((err: ServerError) => err);
if(tree_entry instanceof ServerError) {
reply.code(tree_entry.code).send({ error: tree_entry.message });
return;
}
const history = await tree_entry.history(Number(req.query.count));
reply.send({ data: await Promise.all(history.map(commitMap)) });
}
});
fastify.route<Route>({
method: "GET",
url: "/tags",
handler: async(req, reply) => {
const tags = await req.repository.tags();
reply.send({
data: await Promise.all(tags.map(tagMap))
});
}
});
done();
}
|
