Allow duplication options

deployment/after-install.sh

@@ -86,6 +86,7 @@ services:
       SENTRY_SAMPLE_RATE: ${SENTRY_SAMPLE_RATE:-1}
       CLOUDFRONT_KEY_ID: ${CLOUDFRONT_KEY_ID}
       JOTFORM_APIKEY: ${JOTFORM_APIKEY}
+      WORDPRESS_API_URL: ${WORDPRESS_API_URL}
     volumes:
       - /var/docker/keys:/app/keys
     logging:

src/features/wp/WordpressJsonApiTrigger/index.spec.ts

@@ -0,0 +1,96 @@
+import axios from "axios";
+import WordpressJsonApiTrigger from ".";
+
+// mock axios
+
+jest.mock("axios");
+
+describe("WordpressJsonApiTrigger", () => {
+  beforeAll(() => {
+    process.env = Object.assign(process.env, {
+      WORDPRESS_API_URL: "https://example.com",
+    });
+  });
+
+  afterAll(() => {
+    jest.resetAllMocks();
+    process.env = Object.assign(process.env, {
+      WORDPRESS_API_URL: "",
+    });
+  });
+
+  afterEach(() => {
+    jest.clearAllMocks();
+  });
+  it("Should create a new instance of WordpressJsonApiTrigger", () => {
+    const instance = new WordpressJsonApiTrigger(1);
+    expect(instance).toBeInstanceOf(WordpressJsonApiTrigger);
+  });
+
+  it("Should call axios on generateUseCase", async () => {
+    const instance = new WordpressJsonApiTrigger(1);
+
+    await instance.generateUseCase();
+
+    expect(axios).toHaveBeenCalledTimes(1);
+
+    expect(axios).toHaveBeenCalledWith({
+      headers: {
+        "Content-Type": "application/json",
+        "User-Agent": "Tryber API",
+      },
+      method: "GET",
+      url: "https://example.com/regenerate-campaign-use-cases/1",
+    });
+  });
+
+  it("Should call axios on generateMailmerges", async () => {
+    const instance = new WordpressJsonApiTrigger(1);
+
+    await instance.generateMailMerges();
+
+    expect(axios).toHaveBeenCalledTimes(1);
+
+    expect(axios).toHaveBeenCalledWith({
+      headers: {
+        "Content-Type": "application/json",
+        "User-Agent": "Tryber API",
+      },
+      method: "GET",
+      url: "https://example.com/regenerate-campaign-crons/1",
+    });
+  });
+  it("Should call axios on generatePages", async () => {
+    const instance = new WordpressJsonApiTrigger(1);
+
+    await instance.generatePages();
+
+    expect(axios).toHaveBeenCalledTimes(1);
+
+    expect(axios).toHaveBeenCalledWith({
+      headers: {
+        "Content-Type": "application/json",
+        "User-Agent": "Tryber API",
+      },
+      method: "GET",
+      url: "https://example.com/regenerate-campaign-pages/1",
+    });
+  });
+
+  it("Should call axios on generateTasks", async () => {
+    const instance = new WordpressJsonApiTrigger(1);
+
+    await instance.generateTasks();
+
+    expect(axios).toHaveBeenCalledTimes(1);
+
+    expect(axios).toHaveBeenCalledWith({
+      headers: {
+        "Content-Type": "application/json",
+        "User-Agent": "Tryber API",
+      },
+      method: "GET",
+      url: "https://example.com/regenerate-campaign-tasks/1",
+    });
+  });
+});

src/features/wp/WordpressJsonApiTrigger/index.ts

@@ -0,0 +1,36 @@
+import axios from "axios";
+
+class WordpressJsonApiTrigger {
+  constructor(private campaign: number) {}
+
+  public async generateUseCase() {
+    await this.postToWordpress(
+      `regenerate-campaign-use-cases/${this.campaign}`
+    );
+  }
+
+  public async generateMailMerges() {
+    await this.postToWordpress(`regenerate-campaign-crons/${this.campaign}`);
+  }
+
+  public async generatePages() {
+    await this.postToWordpress(`regenerate-campaign-pages/${this.campaign}`);
+  }
+
+  public async generateTasks() {
+    await this.postToWordpress(`regenerate-campaign-tasks/${this.campaign}`);
+  }
+
+  private async postToWordpress(url: string) {
+    await axios({
+      method: "GET",
+      url: `${process.env.WORDPRESS_API_URL}/${url}`,
+      headers: {
+        "User-Agent": "Tryber API",
+        "Content-Type": "application/json",
+      },
+    });
+  }
+}
+
+export default WordpressJsonApiTrigger;