Skip to content

Commit

Permalink
removed tr-catch block as errors are caught and logged by GHAct
Browse files Browse the repository at this point in the history
  • Loading branch information
@nleanba
nleanba committed Jun 9, 2024
1 parent d8805d9 commit 2e45edd
Showing 1 changed file with 94 additions and 101 deletions.
195 changes: 94 additions & 101 deletions src/action_worker.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -11,129 +11,122 @@ import { gg2rdf } from "./gg2rdf.ts";
const GHTOKEN = Deno.env.get("GHTOKEN");

const worker = new GHActWorker(self, config, async (job: Job, log) => {
try {
log("Starting transformation\n" + JSON.stringify(job, undefined, 2));
log("Starting transformation\n" + JSON.stringify(job, undefined, 2));

let modified: string[] = [];
let removed: string[] = [];
let message = "";
let modified: string[] = [];
let removed: string[] = [];
let message = "";

const targetRepo = new GitRepository(
config.targetRepositoryUri,
config.targetBranch,
GHTOKEN,
config.workDir + "/target-repo",
);
const targetRepo = new GitRepository(
config.targetRepositoryUri,
config.targetBranch,
GHTOKEN,
config.workDir + "/target-repo",
);

if ("files" in job) {
modified = job.files.modified;
if ("added" in job.files) {
modified = [...modified, ...job.files.added];
removed = job.files.removed;
}
if ("files" in job) {
modified = job.files.modified;
if ("added" in job.files) {
modified = [...modified, ...job.files.added];
removed = job.files.removed;
}
message = `GG2RDF ${job.id} (${config.sourceRepository})`;
//ghact should take care of this
//updateLocalData("source", log); // also done by getModifiedAfter
} else if (job.from) {
const files = await worker.gitRepository.getModifiedAfter(
job.from,
job.till,
log,
);
modified = [...files.added, ...files.modified];
removed = files.removed;
if (files.till && files.till !== "HEAD") {
message = `GG2RDF ${config.sourceRepository}@${files.till}`;
job.till = files.till;
} else {
message = `GG2RDF ${job.id} (${config.sourceRepository})`;
//ghact should take care of this
//updateLocalData("source", log); // also done by getModifiedAfter
} else if (job.from) {
const files = await worker.gitRepository.getModifiedAfter(
job.from,
job.till,
log,
}
} else {
throw new Error(
"Could not start job, neither explicit file list nor from-commit specified",
);
}

log(`\nTotal files: ${modified.length + removed.length}\n`);

// run saxon on modified files
for (const file of modified) {
if (
file.endsWith(".xml") &&
existsSync(`${worker.gitRepository.directory}/${file}`)
) {
Deno.mkdirSync(
config.workDir + "/tmpttl/" + file.slice(0, file.lastIndexOf("/")),
{
recursive: true,
},
);
modified = [...files.added, ...files.modified];
removed = files.removed;
if (files.till && files.till !== "HEAD") {
message = `GG2RDF ${config.sourceRepository}@${files.till}`;
job.till = files.till;
} else {
message = `GG2RDF ${job.id} (${config.sourceRepository})`;
try {
gg2rdf(
`${worker.gitRepository.directory}/${file}`,
`${config.workDir}/tmpttl/${file.slice(0, -4)}.ttl`,
log,
);
log("gg2rdf successful");
} catch (error) {
log("gg2rdf failed:");
log(error);
throw new Error("gg2rdf failed");
}
} else {
throw new Error(
"Could not start job, neither explicit file list nor from-commit specified",
log(
`Skipping ${file} (not *.xml or does not exist in treatments-xml)`,
);
}
}

log(`\nTotal files: ${modified.length + removed.length}\n`);
targetRepo.updateLocalData(log);

// run saxon on modified files
for (const file of modified) {
if (
file.endsWith(".xml") &&
existsSync(`${worker.gitRepository.directory}/${file}`)
) {
for (const file of modified) {
if (file.endsWith(".xml")) {
try {
Deno.mkdirSync(
config.workDir + "/tmpttl/" + file.slice(0, file.lastIndexOf("/")),
`${targetRepo.directory}/${file.slice(0, file.lastIndexOf("/"))}`,
{
recursive: true,
},
);
try {
gg2rdf(
`${worker.gitRepository.directory}/${file}`,
`${config.workDir}/tmpttl/${file.slice(0, -4)}.ttl`,
log,
);
log("gg2rdf successful");
} catch (error) {
log("gg2rdf failed:");
log(error);
throw new Error("gg2rdf failed");
}
} else {
Deno.renameSync(
`${config.workDir}/tmpttl/${file.slice(0, -4)}.ttl`,
`${targetRepo.directory}/${file.slice(0, -4)}.ttl`,
);
// TODO check if newer?
} catch (e) {
log(
`Skipping ${file} (not *.xml or does not exist in treatments-xml)`,
`Failed to move ${config.workDir}/tmpttl/${
file.slice(0, -4)
}.ttl to ${targetRepo.directory}/${file.slice(0, -4)}.ttl: \n${e}`,
);
}
}
}

targetRepo.updateLocalData(log);

for (const file of modified) {
if (file.endsWith(".xml")) {
try {
Deno.mkdirSync(
`${targetRepo.directory}/${file.slice(0, file.lastIndexOf("/"))}`,
{
recursive: true,
},
);
Deno.renameSync(
`${config.workDir}/tmpttl/${file.slice(0, -4)}.ttl`,
`${targetRepo.directory}/${file.slice(0, -4)}.ttl`,
);
// TODO check if newer?
} catch (e) {
log(
`Failed to move ${config.workDir}/tmpttl/${
file.slice(0, -4)
}.ttl to ${targetRepo.directory}/${file.slice(0, -4)}.ttl: \n${e}`,
);
}
}
}

for (const file of removed) {
if (file.endsWith(".xml")) {
const ttlFile = `${targetRepo.directory}/${file.slice(0, -4)}.ttl`;
try {
Deno.removeSync(ttlFile);
} catch (e) {
log(
`Failed to remove file ${ttlFile}. Possbly the xml file was removed before it was transformed. \n${e}`,
);
}
for (const file of removed) {
if (file.endsWith(".xml")) {
const ttlFile = `${targetRepo.directory}/${file.slice(0, -4)}.ttl`;
try {
Deno.removeSync(ttlFile);
} catch (e) {
log(
`Failed to remove file ${ttlFile}. Possbly the xml file was removed before it was transformed. \n${e}`,
);
}
}

await targetRepo.commit(job, message, log);
await targetRepo.push(log);
log("git push successful");
log("Completed transformation successfully");
} catch (error) {
log("FAILED TRANSFORMATION");
log(error);
if (error.stack) log(error.stack);
throw error;
}

await targetRepo.commit(job, message, log);
await targetRepo.push(log);
log("git push successful");
log("Completed transformation successfully");
});

0 comments on commit 2e45edd

Please sign in to comment.