feat: update

src/server/routes/github-webhook.ts

@@ -1,12 +1,22 @@
 import { IncomingMessage, ServerResponse } from 'http';
 import { getStreamContent } from 'src/utils/stream';
+import { getCurrentBranchName, unsafeUpdateBot } from 'src/utils/update';
 
 export const ROUTE = '/github-webhook';
 
 const githubWebhookHandler = async (req: IncomingMessage, res: ServerResponse) => {
+  if (req.headers['X-GitHub-Event'] !== 'push') {
+    return;
+  }
+  // do not trust the content until we begin to check secret here
   const body = JSON.parse((await getStreamContent(req)).toString('utf-8'));
   console.log('/github-webhook', JSON.stringify(body, null, 2));
-  // TODO
+
+  const { ref, head_commit: headCommit } = body;
+  const currentBranch = await getCurrentBranchName();
+  if (ref === `refs/heads/${currentBranch}` && !headCommit?.message?.includes('skip ci')) {
+    unsafeUpdateBot();
+  }
   res.writeHead(200);
   res.end();
 };

src/utils/update.ts

@@ -10,6 +10,11 @@ const exec = async (command: string, options: cp.ExecOptions) => {
   });
 };
 
+export const getCurrentBranchName = async () => {
+  const cwd = path.resolve(__dirname, '..');
+  return (await exec('git branch --show-current', { cwd })).trim();
+};
+
 export const unsafeUpdateBot = async (
   branch?: string,
   onPullFinished?: (pullResult: string) => Promise<void>,