Simplify event capture

Author: idan

action.yml

@@ -1,10 +1,6 @@
 name: 'GitHub Archive Action'
 description: 'It exports your GitHub data to a SQLite database in a branch of your repository'
 author: 'GitHub OCTO'
-inputs:
-  branch:
-    description: 'The branch into which to commit events containing GitHub-specific activity data.'
-    default: 'github-meta'
 runs:
   using: 'node12'
   main: 'dist/index.js'

package-lock.json

@@ -22,6 +22,7 @@
     "@actions/core": "^1.2.6",
     "@actions/exec": "^1.0.4",
     "@actions/github": "^4.0.0",
+    "nanoid": "^3.1.22",
     "sqlite": "^4.0.21",
     "sqlite3": "^5.0.2"
   },

package.json

@@ -1,11 +1,11 @@
 import * as core from '@actions/core'
 import * as github from '@actions/github'
 import { exec } from '@actions/exec'
-import { execSync } from 'child_process'
 import sqlite3 from 'sqlite3'
 import { open } from 'sqlite'
+import { nanoid } from 'nanoid'
 
-const dbfile = 'github-archive.db'
+const dbfile = 'github-archive.sqlite'
 const events = [
   'issues',
   'issue_comment',
@@ -14,6 +14,9 @@ const events = [
   'pull_request_review_comment',
 ]
 async function run(): Promise<void> {
+  const now = new Date().toISOString()
+  const id = nanoid()
+
   core.info(
     '[INFO] Usage https://github.com/githubocto/github-archive-action#readme'
   )
@@ -27,69 +30,63 @@ async function run(): Promise<void> {
     `${username}@users.noreply.github.com`,
   ])
   core.debug('Configured git user.name/user.email')
+  core.endGroup()
 
-  // Create the oprhan github-meta branch if it doesn't exist
-  const branch = core.getInput('branch')
-  const branchExists = await exec('git', [
-    'fetch',
-    'origin',
-    branch,
-    '--depth',
-    '1',
-  ])
-
-  if (branchExists !== 0) {
-    core.info(`No ${branch} branch exists, creating...`)
-    await exec('git', ['checkout', '--orphan', branch])
-    await exec('git', ['rm', '-rf', '.'])
-    await exec('git', [
-      'commit',
-      '--allow-empty',
-      '-m',
-      `Creating ${branch} branch`,
-    ])
-  } else {
-    core.info(`Checking out ${branch}`)
-    await exec('git', ['checkout', '-t', `origin/${branch}`])
+  const eventName = github.context.eventName
+  if (!events.includes(eventName)) {
+    throw new Error(`Unsupported event type: ${eventName}`)
   }
 
-  // open the database
-  const db = await open({
-    filename: dbfile,
-    driver: sqlite3.Database,
-  })
+  // Actions can be triggered in parallel
+  // As a result, several invocations of this code might be
+  // executing right now.
+  // We could figure out how to merge sqlite databases; there
+  // is even some prior art in https://github.com/cannadayr/git-sqlite
+  // The simple approach of "if our push is refused, pull and try again"
+  // is probably going to be sufficient.
+  while (true) {
+    // open the database
+    const db = await open({
+      filename: dbfile,
+      driver: sqlite3.Database,
+    })
 
-  // create tables if they don't exist
-  await db.run(`
+    // create tables if they don't exist
+    await db.run(`
   CREATE TABLE IF NOT EXISTS events (
-    id INTEGER PRIMARY KEY,
-    timestamp TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    id TEXT PRIMARY KEY,
+    timestamp TEXT NOT NULL,
     kind TEXT NOT NULL,
     event TEXT NOT NULL
   );`)
-  core.endGroup()
 
-  core.startGroup('Capture event')
-  for await (const e of events) {
-    core.debug(`Checking for "${e}" event...`)
-    if (github.context.eventName !== e) {
-      // not this event
-      continue
+    await db.run(
+      'INSERT INTO events (id, timestamp, kind, event) values (:id, :timestamp, :e, :payload)',
+      {
+        ':id': id,
+        ':timestamp': now,
+        ':e': eventName,
+        ':payload': JSON.stringify(github.context.payload),
+      }
+    )
+    await db.close()
+    await exec('git', ['add', dbfile])
+    await exec('git', [
+      'commit',
+      '-m',
+      `Capturing event ${eventName} (id: ${id})`,
+    ])
+    const code = await exec('git', ['push'])
+    if (code === 0) {
+      // success! We're finished.
+      core.info('Success!')
+      break
+    } else {
+      core.info('Retrying because of conflicts...')
+      await exec('git', ['reset', '--hard', 'HEAD'])
+      await exec('git', ['pull'])
     }
-    await db.run('INSERT INTO events (kind, event) values (:e, :payload)', {
-      ':e': e,
-      ':payload': JSON.stringify(github.context.payload),
-    })
-    core.info(`Captured ${e} event`)
   }
-  core.endGroup()
-
-  core.startGroup('Commit and close db')
-  await db.close()
-  await exec('git', ['add', dbfile])
-  await exec('git', ['commit', '-m', 'Adding data to repo'])
-  await exec('git', ['push', 'origin', branch])
-  core.endGroup()
 }
 
 run().catch(error => {