mirror of
https://github.com/Ocelot-Social-Community/Ocelot-Social.git
synced 2025-12-13 07:46:06 +00:00
Update to use PubSub in development
- for some reason RedisPubSub works locally, but with docker it tries to connect to Redis and therefore it doesn't pass the build. PubSub is imported from graphql-subscriptions which is a dependency of apollo-server-express, and suitable for dev purposes.
This commit is contained in:
parent
069c637c84
commit
409150813d
@ -2,7 +2,6 @@ import express from 'express'
|
|||||||
import http from 'http'
|
import http from 'http'
|
||||||
import helmet from 'helmet'
|
import helmet from 'helmet'
|
||||||
import { ApolloServer } from 'apollo-server-express'
|
import { ApolloServer } from 'apollo-server-express'
|
||||||
|
|
||||||
import CONFIG from './config'
|
import CONFIG from './config'
|
||||||
import middleware from './middleware'
|
import middleware from './middleware'
|
||||||
import { getNeode, getDriver } from './db/neo4j'
|
import { getNeode, getDriver } from './db/neo4j'
|
||||||
@ -10,6 +9,7 @@ import decode from './jwt/decode'
|
|||||||
import schema from './schema'
|
import schema from './schema'
|
||||||
import webfinger from './activitypub/routes/webfinger'
|
import webfinger from './activitypub/routes/webfinger'
|
||||||
import { RedisPubSub } from 'graphql-redis-subscriptions'
|
import { RedisPubSub } from 'graphql-redis-subscriptions'
|
||||||
|
import { PubSub } from 'graphql-subscriptions'
|
||||||
import Redis from 'ioredis'
|
import Redis from 'ioredis'
|
||||||
|
|
||||||
export const NOTIFICATION_ADDED = 'NOTIFICATION_ADDED'
|
export const NOTIFICATION_ADDED = 'NOTIFICATION_ADDED'
|
||||||
@ -23,14 +23,13 @@ const options = {
|
|||||||
return Math.min(times * 50, 2000)
|
return Math.min(times * 50, 2000)
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
if (options.host && options.port && options.password) {
|
if (options.host && options.port && options.password) {
|
||||||
prodPubsub = new RedisPubSub({
|
prodPubsub = new RedisPubSub({
|
||||||
publisher: new Redis(options),
|
publisher: new Redis(options),
|
||||||
subscriber: new Redis(options),
|
subscriber: new Redis(options),
|
||||||
})
|
})
|
||||||
} else {
|
} else {
|
||||||
devPubsub = new RedisPubSub()
|
devPubsub = new PubSub()
|
||||||
}
|
}
|
||||||
export const pubsub = prodPubsub || devPubsub
|
export const pubsub = prodPubsub || devPubsub
|
||||||
const driver = getDriver()
|
const driver = getDriver()
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user