Avoid running interactions-api container if env vars are not present

.env

@@ -19,10 +19,14 @@ GQL_PORT=4350
 AUTH_API_PORT=4074
 # Recommendation service config
 INTERACTIONS_API_PORT=4075
-RECOMMENDATION_SERVICE_PRIVATE_KEY=
+# Set private key and database name for recommendation service
+# If you set only private key, Orion will support only local interactions service (for now at least)
+RECOMMENDATION_SERVICE_PRIVATE_KEY=save-interactions-locally
+# jsgenesis-dev
+RECOMMENDATION_SERVICE_DATABASE=
 # this will disable export block check for recommendation system - sync all data from the beginning
 FORCE_RECOMMENDATION_DATA_SYNC=false
-RECOMMENDATION_SERVICE_DATABASE=jsgenesis-dev
+
 
 # Archive gateway url
 ARCHIVE_GATEWAY_URL=${CUSTOM_ARCHIVE_GATEWAY_URL:-http://localhost:8888/graphql}

Makefile

@@ -39,17 +39,24 @@ typegen:
 prepare: install codegen build setup-recommendations
 
 up-squid:
- @docker network create joystream_default || true
- @docker-compose up -d
+ @set -a; \
+ source .env; \
+ set +a; \
+ docker network create joystream_default || true; \
+ if [ -z "$$RECOMMENDATION_SERVICE_PRIVATE_KEY" ] && [ -z "$$RECOMMENDATION_SERVICE_DATABASE"]; then \
+ docker-compose up -d; \
+ else \
+ docker-compose --profile interactions up -d; \
+ fi \
 
 up-archive:
- @docker network create joystream_default || true
+ @docker network create joystream_default || truee
  @docker-compose -f archive/docker-compose.yml up -d
 
 up: up-archive up-squid
 
 down-squid:
- @docker-compose down -v
+ @docker-compose down -v --remove-orphans
 
 down-archive:
  @docker-compose -f archive/docker-compose.yml down -v

docker-compose.yml

@@ -21,6 +21,7 @@ services:
  image: mongo:latest
  container_name: interactions_db
  hostname: interactions_db
+ profiles: ['interactions']
  restart: unless-stopped
  shm_size: 1g
  command: ['mongod', '--port', '${INTERACTIONS_DB_PORT}']
@@ -94,9 +95,10 @@ services:
  ports:
  - '${AUTH_API_PORT}:${AUTH_API_PORT}'
 
- orion_interations-api:
- container_name: orion_interations-api
- hostname: orion_interations-api
+ orion_interactions-api:
+ container_name: orion_interactions-api
+ hostname: orion_interactions-api
+ profiles: ['interactions']
  image: node:18
  restart: unless-stopped
  env_file:

src/interactions-server/index.ts

@@ -12,9 +12,11 @@ import swaggerUi, { JsonObject } from 'swagger-ui-express'
 import YAML from 'js-yaml'
 import fs from 'fs'
 import { recommendationServiceManager } from '../utils/RecommendationServiceManager'
+import { initInteractionsDb } from './interactionsEm'
 
 recommendationServiceManager.enableSync()
 recommendationServiceManager.initBatchLoop()
+initInteractionsDb().then(() => undefined)
 
 export const logger = createLogger('interactions-api')
 

src/interactions-server/interactionsEm.ts

@@ -3,7 +3,7 @@ import { createLogger } from '@subsquid/logger'
 
 const interactionsEmLogger = createLogger('interactionsEm')
 
-async function initInteractionsDb() {
+export async function initInteractionsDb() {
  let instance: typeof mongoose | null = null
  try {
  interactionsEmLogger.info(`Initializing interactions database connection...`)
@@ -23,9 +23,6 @@ async function initInteractionsDb() {
  return instance
 }
 
-// eslint-disable-next-line no-void
-void initInteractionsDb()
-
 const PurchaseModel = mongoose.model(
  'Purchase',
  new mongoose.Schema({

src/utils/RecommendationServiceManager.ts

@@ -46,7 +46,7 @@ export class RecommendationServiceManager {
  !process.env.RECOMMENDATION_SERVICE_DATABASE
  ) {
  recommendationServiceLogger.error(
- 'RecommendationServiceManager initalized without required variables'
+ 'RecommendationServiceManager initialized without required variables'
  )
  return
  }
@@ -212,7 +212,7 @@ export class RecommendationServiceManager {
  }
 
  enableSync() {
- this._enabled = true
+ this._enabled = !!this.client
  }
 
  private async sendBatchRequest(requests: ClientRequests.Request[]) {
@@ -348,11 +348,16 @@ export class RecommendationServiceManager {
  }
 
  initBatchLoop() {
+ if (!this.client) {
+ // Avoid initialization if client is not available
+ return
+ }
  if (this._loopInitialized) {
  throw new Error('update loop was initialized more than once')
  }
+ recommendationServiceLogger.info('Initializing interactions update loop...')
  this._loopInitialized = true
- this._batchUpdateLoop(30 * 1_000) // 5mins
+ this._batchUpdateLoop(30 * 1_000) // 5 mins
  .then(() => {
  /* Do nothing */
  })