Skip to content

Commit

Permalink
Fix checks
Browse files Browse the repository at this point in the history
  • Loading branch information
WRadoslaw committed Apr 8, 2024
1 parent c1ec1d5 commit e285b34
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 16 deletions.
6 changes: 3 additions & 3 deletions src/interactions-server/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -14,11 +14,11 @@ import fs from 'fs'
import { recommendationServiceManager } from '../utils/RecommendationServiceManager'
import { initInteractionsDb } from './interactionsEm'

export const logger = createLogger('interactions-api')

recommendationServiceManager.enableSync()
recommendationServiceManager.initBatchLoop()
initInteractionsDb().then(() => undefined)

export const logger = createLogger('interactions-api')
initInteractionsDb()

export const app = express()

Expand Down
26 changes: 13 additions & 13 deletions src/interactions-server/interactionsEm.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,24 +3,24 @@ import { createLogger } from '@subsquid/logger'

const interactionsEmLogger = createLogger('interactionsEm')

export async function initInteractionsDb() {
let instance: typeof mongoose | null = null
try {
interactionsEmLogger.info(`Initializing interactions database connection...`)
instance = await mongoose.connect(
export function initInteractionsDb() {
interactionsEmLogger.info(`Initializing interactions database connection...`)
mongoose
.connect(
`mongodb://${process.env.DB_NAME}:${process.env.DB_PASS}@interactions_db:${process.env.INTERACTIONS_DB_PORT}/interactions?authSource=admin`,
{
family: 4,
}
)
interactionsEmLogger.info(`Connected to interactions database`)
} catch (e) {
interactionsEmLogger.error(
`Error during interactions database connection initialization: ${String(e)}`
)
process.exit(-1) // Exit to trigger docker service restart an re-attempt to connect
}
return instance
.then(() => {
interactionsEmLogger.info(`Connected to interactions database`)
})
.catch((e) => {
interactionsEmLogger.error(
`Error during interactions database connection initialization: ${String(e)}`
)
process.exit(-1) // Exit to trigger docker service restart an re-attempt to connect
})
}

const PurchaseModel = mongoose.model(
Expand Down

0 comments on commit e285b34

Please sign in to comment.