chore: RedwoodJS GraphQL subscription templates now use Dynamic Topic IDs

packages/cli/src/commands/experimental/templates/realtime.ts.template

@@ -6,8 +6,8 @@ export const liveQueryStore = new InMemoryLiveQueryStore()
 // Note: If you did not setup examples, please replace with your current subscriptions
 import type { NewMessageChannel } from 'src/subscriptions/newMessage/newMessage'
 
-// then use merge the types by intersecting each like: `NewMessageChannel<string> & OtherChannel`
-export type PubSubChannels = NewMessageChannel<string>
+// then use merge the types by intersecting each like: `NewMessageChannel & OtherChannel`
+export type PubSubChannels = NewMessageChannel
 
 export const pubSub = createPubSub<PubSubChannels>()
 

packages/cli/src/commands/experimental/templates/subscriptions/blank/blank.service.ts.template

@@ -13,7 +13,7 @@ export const ${subscriptionServiceResolver} = async (
 
   const { id, from, body } = input
 
-  context.pubSub.publish(`${typeName}:<%= '$' %>{id}`, { from, body })
+context.pubSub.publish('${typeName}', id, { from, body })
 
   return input
 }

packages/cli/src/commands/experimental/templates/subscriptions/blank/blank.ts.template

@@ -8,9 +8,9 @@ export const schema = gql`
   }
 `
 // Be sure to import this type and then in `api/src/lib/realtime.ts` extend PubSubChannels:
-// export type PubSubChannels = ExistingChannel<string> & Publish${typeName}Channel<string>
-export type Publish${typeName}Channel<T extends string> = {
-  [Key in `${typeName}:<%= '$' %>{T}`]: [payload: { from: string; body: string }]
+// export type PubSubChannels = ExistingChannel<string> & Publish${typeName}Channel
+export type Publish${typeName}Channel = {
+  ${typeName}: [id: string, payload: { from: string; body: string }]
 }
 
 /**
@@ -38,7 +38,7 @@ const ${subscriptionName}Subscription = {
     subscribe: (_, { id }, { pubSub }) => {
       logger.debug({ id }, '${name} subscription')
 
-      return pubSub.subscribe(`${typeName}:<%= '$' %>{id}`)
+      return pubSub.subscribe('${typeName}', id)
     },
     resolve: (payload) => {
       logger.debug({ payload }, '${name} subscription resolve')

packages/cli/src/commands/experimental/templates/subscriptions/newMessage/newMessage.ts.template

@@ -7,8 +7,8 @@ export const schema = gql`
     newMessage(roomId: ID!): Message!
   }
 `
-export type NewMessageChannel<T extends string> = {
-  [Key in `newMessage:${T}`]: [payload: { from: string; body: string }]
+export type NewMessageChannel = {
+  newMessage: [roomId: string, payload: { from: string; body: string }]
 }
 
 /**
@@ -36,7 +36,7 @@ const newMessage = {
     subscribe: (_, { roomId }, { pubSub }) => {
       logger.debug({ roomId }, 'newMessage subscription')
 
-      return pubSub.subscribe(`newMessage:${roomId}`)
+      return pubSub.subscribe('newMessage', roomId)
     },
     resolve: (payload) => {
       logger.debug({ payload }, 'newMessage subscription resolve')

packages/cli/src/commands/experimental/templates/subscriptions/newMessage/rooms.ts.template

@@ -13,7 +13,7 @@ export const sendMessage = async (
 
   const { roomId, from, body } = input
 
-  context.pubSub.publish(`newMessage:${roomId}`, { from, body })
+  context.pubSub.publish('newMessage', roomId, { from, body })
 
   return input
 }