refactor(ts): refactor remaining actions into TS

Author: jescalada

src/proxy/actions/Action.ts

@@ -19,6 +19,14 @@ export interface Commit {
  * Class representing a Push.
  */
 class Action {
+  id: string;
+  type: string;
+  method: string;
+  timestamp: number;
+  project: string;
+  repoName: string;
+  url: string;
+  repo: string;
   steps: Step[] = [];
   error: boolean = false;
   errorMessage?: string | null;
@@ -37,14 +45,7 @@ class Action {
   user?: string;
   attestation?: string;
   lastStep?: Step;
-  id: string;
-  type: string;
-  method: string;
-  timestamp: number;
-  project: string;
-  repoName: string;
-  url: string;
-  repo: string;
+  proxyGitPath?: string;
 
   /**
    * Create an action.

src/proxy/chain.js

@@ -1,4 +1,4 @@
-const proc = require('./processors');
+import * as proc from './processors';
 
 const pushActionChain = [
   proc.push.parsePush,

src/proxy/processors/index.js

@@ -0,0 +1,4 @@
+import * as pre from './pre-processor';
+import * as push from './push-action';
+
+export { pre, push };

src/proxy/processors/index.ts

@@ -0,0 +1,14 @@
+import { writeAudit } from '../../../db';
+import { Action } from '../../actions';
+
+const exec = async (req: any, action: Action) => {
+  if (action.type !== 'pull') {
+    await writeAudit(action);
+  }
+
+  return action;
+};
+
+exec.displayName = 'audit.exec';
+
+export { exec };

src/proxy/processors/push-action/audit.js

@@ -1,8 +1,7 @@
-const { getServiceUIURL } = require('../../../service/urls');
+import { Action, Step } from '../../actions';
+import { getServiceUIURL } from '../../../service/urls';
 
-const Step = require('../../actions').Step;
-
-const exec = async (req, action) => {
+const exec = async (req: any, action: Action) => {
   const step = new Step('authBlock');
   const url = getServiceUIURL(req);
 
@@ -19,4 +18,5 @@ const exec = async (req, action) => {
 };
 
 exec.displayName = 'blockForAuth.exec';
-exports.exec = exec;
+
+export { exec };

src/proxy/processors/push-action/audit.ts

@@ -12,7 +12,7 @@ const exec = async (req: any, action: Action): Promise<Action> => {
   // Find the user associated with this Git Account
   const list = await getUsers({ gitAccount: action.user });
 
-  console.log(JSON.stringify(list));
+  console.log(`Users for this git account: ${JSON.stringify(list)}`);
 
   if (list.length == 1) {
     user = list[0].username;

src/proxy/processors/push-action/blockForAuth.js renamed to src/proxy/processors/push-action/blockForAuth.ts

@@ -1,7 +1,7 @@
-const Step = require('../../actions').Step;
-const fs = require('node:fs');
+import { Action, Step } from '../../actions';
+import fs from 'node:fs';
 
-const exec = async (req, action) => {
+const exec = async (req: any, action: Action): Promise<Action> => {
   const step = new Step('clearBareClone');
 
   // Recursively remove the contents of ./.remote and ignore exceptions
@@ -17,4 +17,5 @@ const exec = async (req, action) => {
 };
 
 exec.displayName = 'clearBareClone.exec';
-exports.exec = exec;
+
+export { exec };

src/proxy/processors/push-action/checkUserPushPermission.ts

@@ -1,8 +1,7 @@
-const Step = require('../../actions').Step;
-const simpleGit = require('simple-git')
+import { Action, Step } from '../../actions';
+import simpleGit from 'simple-git';
 
-
-const exec = async (req, action) => {
+const exec = async (req: any, action: Action): Promise<Action> => {
   const step = new Step('diff');
 
   try {
@@ -11,6 +10,10 @@ const exec = async (req, action) => {
     // https://stackoverflow.com/questions/40883798/how-to-get-git-diff-of-the-first-commit
     let commitFrom = `4b825dc642cb6eb9a060e54bf8d69288fbee4904`;
 
+    if (!action.commitData) {
+      throw new Error('No commit data found');
+    }
+
     if (action.commitFrom === '0000000000000000000000000000000000000000') {
       if (action.commitData[0].parent !== '0000000000000000000000000000000000000000') {
         commitFrom = `${action.commitData[action.commitData.length - 1].parent}`;
@@ -24,7 +27,7 @@ const exec = async (req, action) => {
     const diff = await git.diff([revisionRange]);
     step.log(diff);
     step.setContent(diff);
-  } catch (e) {
+  } catch (e: any) {
     step.setError(e.toString('utf-8'));
   } finally {
     action.addStep(step);
@@ -33,4 +36,5 @@ const exec = async (req, action) => {
 };
 
 exec.displayName = 'getDiff.exec';
-exports.exec = exec;
+
+export { exec };