update to match with changes in api

apps/studio/components/interfaces/Replication/CreatePipelineModal.tsx

@@ -23,7 +23,7 @@ const CreatePipelineModal = ({ visible, onClose }: CreatePipelineModalProps) =>
     projectRef: ref,
   })
 
-  let thisProjectSource = data?.find((s) => s.name === ref)
+  let thisProjectSource = data?.sources?.find((s) => s.name === ref)
 
   if (!thisProjectSource) {
     toast.error("Failed to find this project's source")
@@ -32,7 +32,7 @@ const CreatePipelineModal = ({ visible, onClose }: CreatePipelineModalProps) =>
   const { data: sinks_data } = useReplicationSinksQuery({
     projectRef: ref,
   })
-  const sinks = sinks_data ?? []
+  const sinks = sinks_data ? sinks_data.sinks : []
 
   const { data: pub_data } = useReplicationPublicationsQuery({
     projectRef: ref,

apps/studio/components/interfaces/Replication/Pipelines.tsx

@@ -22,7 +22,7 @@ export const ReplicationPipelines = () => {
   const [showDeletePipelineModal, setShowDeletePipelineModal] = useState(false)
   const [pipelineIdToDelete, setPipelineIdToDelete] = useState(-1)
 
-  const pipelines = pipelines_data ?? []
+  const pipelines = pipelines_data ? pipelines_data.pipelines : []
 
   return (
     <>

apps/studio/components/interfaces/Replication/Publications.tsx

@@ -21,7 +21,7 @@ export const ReplicationPublications = () => {
   const [showDeletePublicationModal, setShowDeletePublicationModal] = useState(false)
   const [publicationToDelete, setPublicationToDelete] = useState('')
 
-  const sources = sources_data ?? []
+  const sources = sources_data ? sources_data.sources : []
   const thisProjectSource = sources.find((s) => s.name === ref)
 
   const { data: pub_data } = useReplicationPublicationsQuery({

apps/studio/components/interfaces/Replication/Sinks.tsx

@@ -21,7 +21,7 @@ export const ReplicationSinks = () => {
   const [sinkIdToDelete, setSinkIdToDelete] = useState(-1)
   const [sinkNameToDelete, setSinkNameToDelete] = useState('')
 
-  const sinks = sinks_data ?? []
+  const sinks = sinks_data ? sinks_data.sinks : []
 
   return (
     <>

apps/studio/data/replication/publications-query.ts

@@ -25,7 +25,7 @@ async function fetchReplicationPublications(
     handleError(error)
   }
 
-  return data.filter((pub) => pub.name !== 'supabase_realtime')
+  return data.publications.filter((pub) => pub.name !== 'supabase_realtime')
 }
 
 export type ReplicationPublicationsData = Awaited<ReturnType<typeof fetchReplicationPublications>>

apps/studio/pages/project/[ref]/replication/index.tsx

@@ -18,7 +18,7 @@ const PageLayout: NextPageWithLayout = () => {
     projectRef: ref,
   })
 
-  let replicationEnabled = data ? data?.length !== 0 && data[0].name === ref : false
+  let replicationEnabled = data ? data?.sources?.length !== 0 && data.sources[0].name === ref : false
 
   const { mutate: createSource, isLoading: isCreating } = useCreateSourceMutation({
     onSuccess: () => {