Recipes for Accessing Heroku Data from Salesforce Functions

1/**
2 * Connects to the PostgreSQL instance.
3 * @param {ClientOptions} input The options to create a PostgreSQL client
4 * @returns {Client} A connected PostgreSQL client
5 */
6export async function pgConnect({ url }) {
7  if (!url) {
8    throw new Error(
9      "database url is not set, please set up the DATABASE_URL environment variable"
10    );
11  }
12
13  // Connect to PostgreSQL
14  const client = new Client({
15    connectionString: url,
16    ssl: {
17      rejectUnauthorized: false
18    }
19  });
20
21  await client.connect();
22
23  return client;
24}

1/**
2   * Get a connection to the database.
3   *
4   * @return Connection
5   * @throws SQLException
6   */
7  protected Connection getConnection() throws SQLException {
8    // If there is already a connection reuse it
9    if (connection != null && !connection.isClosed()) {
10      return connection;
11    }
12
13    try {
14      Class.forName("org.postgresql.Driver");
15      URI dbUri = new URI(this.url);
16
17      // Extract username and password from DATABASE_URL
18      String username = dbUri.getUserInfo().split(":")[0];
19      String password = dbUri.getUserInfo().split(":")[1];
20
21      // Construct a valid JDBC URL
22      String dbUrl =
23          "jdbc:postgresql://" + dbUri.getHost() + ':' + dbUri.getPort() + dbUri.getPath();
24
25      // Connect to PostgreSQL instance
26      connection = DriverManager.getConnection(dbUrl, username, password);
27
28      return connection;
29    } catch (URISyntaxException | ClassNotFoundException e) {
30      throw new RuntimeException(e);
31    }
32  }

1/**
2 * Connects to a Redis instance.
3 * @param {ClientOptions} input The options to create a Redis client
4 * @returns {RedisClientType} A connected Redis client
5 */
6export async function redisConnect({ url }) {
7  if (!url) {
8    throw new Error(
9      `database url is not set, please set up the REDIS_URL environment variable`
10    );
11  }
12
13  // Connect to Redis
14  const redisClient = createClient({
15    url,
16    socket: {
17      tls: true,
18      rejectUnauthorized: false
19    }
20  });
21  await redisClient.connect();
22  return redisClient;
23}

1/**
2   * Get a connection to the Redis database.
3   *
4   * @return Jedis
5   */
6  protected Jedis getConnection() {
7    if (connection != null && connection.isConnected()) {
8      return connection;
9    }
10
11    try {
12      TrustManager bogusTrustManager = new X509TrustManager() {
13        public X509Certificate[] getAcceptedIssuers() {
14          return null;
15        }
16
17        public void checkClientTrusted(X509Certificate[] certs, String authType) {}
18
19        public void checkServerTrusted(X509Certificate[] certs, String authType) {}
20      };
21
22      SSLContext sslContext = SSLContext.getInstance("SSL");
23      sslContext.init(null, new TrustManager[] {bogusTrustManager},
24          new java.security.SecureRandom());
25
26      HostnameVerifier bogusHostnameVerifier = (hostname, session) -> true;
27
28      connection = new Jedis(URI.create(this.url), sslContext.getSocketFactory(),
29          sslContext.getDefaultSSLParameters(), bogusHostnameVerifier);
30      return connection;
31    } catch (NoSuchAlgorithmException | KeyManagementException e) {
32      throw new RuntimeException(e);
33    }
34  }