Software: Apache/2.4.41 (Ubuntu). PHP/8.0.30 

uname -a: Linux apirnd 5.4.0-204-generic #224-Ubuntu SMP Thu Dec 5 13:38:28 UTC 2024 x86_64 

uid=33(www-data) gid=33(www-data) groups=33(www-data) 

Safe-mode: OFF (not secure)

/usr/local/lib/node_modules/strapi/node_modules/strapi-database/lib/   drwxr-xr-x
Free 13.07 GB of 57.97 GB (22.54%)
                            Encoder    Tools    Proc.    FTP brute    Sec.    SQL    PHP-code    Update    Self remove    Logout    

Viewing file:     connector-registry.js (1.33 KB)      -rw-r--r--

'use strict';
/**
 * Database connector registry
 */

const _ = require('lodash');
const requireConnector = require('./require-connector');

const createConnectorRegistry = ({ defaultConnection, connections }) => {
  const _connectors = new Map();

  return {
    /**
     * Load connector modules
     */
    load() {
      for (const connection of Object.values(connections)) {
        const { connector } = connection;
        if (!_connectors.has(connector)) {
          _connectors.set(connector, requireConnector(connector)(strapi));
        }
      }
    },

    /**
     * Initialize connectors
     */
    async initialize() {
      for (const connector of _connectors.values()) {
        await connector.initialize();
      }
    },

    get(key) {
      return _connectors.get(key);
    },

    set(key, val) {
      _connectors.set(key, val);
      return this;
    },

    get default() {
      const defaultConnector = connections[defaultConnection].connector;
      return _connectors.get(defaultConnector);
    },

    getByConnection(connection) {
      if (!_.has(connections, connection)) {
        throw new Error('Trying to access a connector for an unknow connection');
      }

      const connectorKey = connections[connection].connector;
      return _connectors.get(connectorKey);
    },
  };
};

module.exports = createConnectorRegistry;