weseek__growi/src/server/service/search.js

// eslint-disable-next-line no-unused-vars
const logger = require('@alias/logger')('growi:service:search');

class SearchService {

  constructor(crowi) {
    this.crowi = crowi;
    this.configManager = crowi.configManager;

    try {
      this.delegator = this.initDelegator();
    }
    catch (err) {
      logger.error(err);
    }

    if (this.isAvailable) {
      this.delegator.init();
      this.registerUpdateEvent();
    }
  }

  get isAvailable() {
    return this.delegator != null;
  }

  get isSearchboxEnabled() {
    return this.configManager.getConfig('crowi', 'app:searchboxSslUrl') != null;
  }

  get isElasticsearchEnabled() {
    return this.configManager.getConfig('crowi', 'app:elasticsearchUri') != null;
  }

  initDelegator() {
    logger.info('Initializing search delegator');

    const searchEvent = this.crowi.event('search');

    if (this.isSearchboxEnabled) {
      logger.info('Searchbox is enabled');
      const SearchboxDelegator = require('./search-delegator/searchbox.js');
      return new SearchboxDelegator(this.configManager, searchEvent);
    }
    if (this.isElasticsearchEnabled) {
      logger.info('Elasticsearch (not Searchbox) is enabled');
      const ElasticsearchDelegator = require('./search-delegator/elasticsearch.js');
      return new ElasticsearchDelegator(this.configManager, searchEvent);
    }

  }

  registerUpdateEvent() {
    const pageEvent = this.crowi.event('page');
    pageEvent.on('create', this.delegator.syncPageUpdated.bind(this.delegator));
    pageEvent.on('update', this.delegator.syncPageUpdated.bind(this.delegator));
    pageEvent.on('delete', this.delegator.syncPageDeleted.bind(this.delegator));

    const bookmarkEvent = this.crowi.event('bookmark');
    bookmarkEvent.on('create', this.delegator.syncBookmarkChanged.bind(this.delegator));
    bookmarkEvent.on('delete', this.delegator.syncBookmarkChanged.bind(this.delegator));

    const tagEvent = this.crowi.event('tag');
    tagEvent.on('update', this.delegator.syncTagChanged.bind(this.delegator));
  }

  getInfo() {
    return this.delegator.getInfo();
  }

  async buildIndex() {
    return this.delegator.buildIndex();
  }

  async searchKeyword(keyword, user, userGroups, searchOpts) {
    return this.delegator.searchKeyword(keyword, user, userGroups, searchOpts);
  }

}

module.exports = SearchService;