feat: Implement a publish method

Allows for controlling where new events go from the automatic
deployments.

src/app.ts

@@ -3,13 +3,18 @@ import { prDeploy } from "./pr-deploy";
 import { auto } from "./auto";
 import { Application } from "probot";
 import { LockStore, WatchStore } from "./store";
+import Webhooks from "@octokit/webhooks";
 
+/**
+ * Instantiates all the components of the app with it's dependencies.
+ */
 export function app(
   application: Application,
   lockStore: LockStore,
-  watchStore: WatchStore
+  watchStore: WatchStore,
+  publish: (event: Webhooks.WebhookEvent<any>) => Promise<any>
 ) {
   prClose(application);
   prDeploy(application, lockStore);
-  auto(application, lockStore, watchStore);
+  auto(application, lockStore, watchStore, publish);
 }

src/auto.ts

@@ -5,6 +5,7 @@ import { config, deploy } from "./deploy";
 import { hash } from "./util";
 import { v4 as uuid } from "uuid";
 import { PayloadRepository } from "@octokit/webhooks";
+import Webhooks from "@octokit/webhooks";
 
 export function match(auto: string | undefined, ref: string) {
   if (!auto) return false;
@@ -22,7 +23,8 @@ export function match(auto: string | undefined, ref: string) {
 export function auto(
   app: Application,
   lockStore: LockStore,
-  watchStore: WatchStore
+  watchStore: WatchStore,
+  publish: (event: Webhooks.WebhookEvent<any>) => Promise<any>
 ) {
   /**
    * Add watch adds a watch on a specific ref, sha and repository.
@@ -214,6 +216,7 @@ export function auto(
         repoId,
         sha,
         watches: watches.map(w => ({
+          target: w.target,
           id: w.id,
           ref: w.ref,
           sha: w.sha,
@@ -224,8 +227,8 @@ export function auto(
     );
     await Promise.all(
       watches.map(watch =>
-        app.receive({
-          id: context.id,
+        publish({
+          id: uuid(),
           name: "push_watch",
           payload: {
             ...watch,

src/index.ts

@@ -4,5 +4,5 @@ import { app } from "./app";
 
 export = (application: Application) => {
   const store = new InMemStore();
-  app(application, store, store);
+  app(application, store, store, application.receive.bind(application));
 };

test/factory.ts

@@ -18,7 +18,7 @@ export const deliverybot = (application: Application) => {
   // Assign plain octokit to remove the plugins (like retries) the GitHub adds
   // by default.
   application['Octokit'] = Octokit;
-  app(application, store, store);
+  app(application, store, store, application.receive.bind(application));
 };