Skip to content
This repository has been archived by the owner on Apr 19, 2023. It is now read-only.

Commit

Permalink
🐛 Change imports to config
Browse files Browse the repository at this point in the history
  • Loading branch information
AnandChowdhary committed Sep 8, 2020
1 parent 704725e commit d3c8c25
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 6 deletions.
4 changes: 2 additions & 2 deletions src/_staart/helpers/elasticsearch.ts
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
import { elasticSearch, elasticSearchEnabled } from "@staart/elasticsearch";
import { logError } from "@staart/errors";
import { redisQueue } from "@staart/redis";
import { REDIS_QUEUE_PREFIX } from "../config";
import { config } from "@anandchowdhary/cosmic";

const ELASTIC_QUEUE = `${REDIS_QUEUE_PREFIX}es-records`;
const ELASTIC_QUEUE = `${config("redisQueuePrefix")}_es-records`;

let queueSetup = false;
const setupQueue = async () => {
Expand Down
5 changes: 3 additions & 2 deletions src/_staart/helpers/mail.ts
Original file line number Diff line number Diff line change
Expand Up @@ -4,10 +4,11 @@ import { render } from "@staart/mustache-markdown";
import { redisQueue } from "@staart/redis";
import { readFile } from "fs-extra";
import { join } from "path";
import { FRONTEND_URL, REDIS_QUEUE_PREFIX } from "../config";
import { FRONTEND_URL } from "../config";
import { PartialBy } from "../../_staart/helpers/utils";
import { config } from "@anandchowdhary/cosmic";

const MAIL_QUEUE = `${REDIS_QUEUE_PREFIX}outbound-emails`;
const MAIL_QUEUE = `${config("redisQueuePrefix")}outbound-emails`;

let queueSetup = false;
const setupQueue = async () => {
Expand Down
5 changes: 3 additions & 2 deletions src/_staart/helpers/webhooks.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,12 +2,13 @@ import { logError } from "@staart/errors";
import { redisQueue } from "@staart/redis";
import axios from "axios";
import { createHmac } from "crypto";
import { JWT_ISSUER, REDIS_QUEUE_PREFIX } from "../config";
import { JWT_ISSUER } from "../config";
import { Webhooks } from "../interfaces/enum";
import { webhooks } from "@prisma/client";
import { prisma } from "./prisma";
import { config } from "@anandchowdhary/cosmic";

const WEBHOOK_QUEUE = `${REDIS_QUEUE_PREFIX}webhooks`;
const WEBHOOK_QUEUE = `${config("redisQueuePrefix")}_webhooks`;

let queueSetup = false;
const setupQueue = async () => {
Expand Down

0 comments on commit d3c8c25

Please sign in to comment.