11import { NextResponse } from 'next/server'
2+ import { getConfluenceCloudId } from '@/tools/confluence/utils'
23
34export async function POST ( request : Request ) {
45 try {
5- const { domain, accessToken, pageId } = await request . json ( )
6+ const { domain, accessToken, pageId, cloudId : providedCloudId } = await request . json ( )
67
78 if ( ! domain ) {
89 return NextResponse . json ( { error : 'Domain is required' } , { status : 400 } )
@@ -16,30 +17,22 @@ export async function POST(request: Request) {
1617 return NextResponse . json ( { error : 'Page ID is required' } , { status : 400 } )
1718 }
1819
19- // Log request details for debugging
20- console . log ( 'Request details:' , {
21- domain,
22- tokenLength : accessToken ? accessToken . length : 0 ,
23- pageId,
24- } )
20+ // Use provided cloudId or fetch it if not provided
21+ const cloudId = providedCloudId || await getConfluenceCloudId ( domain , accessToken )
2522
26- // Build the URL - using the same format as retrieve.ts
27- const url = `https://${ domain } ${ pageId }
23+ // Build the URL for the Confluence API
24+ const url = `https://api.atlassian.com/ex/confluence/ ${ cloudId } ${ pageId } storage,body. view,body.atlas_doc_format `
2825
29- console . log ( `Fetching Confluence page from: ${ url } )
3026
3127 // Make the request to Confluence API
3228 const response = await fetch ( url , {
3329 method : 'GET' ,
3430 headers : {
35- 'Content-Type' : 'application/json' ,
36- Accept : 'application/json' ,
37- Authorization : `Bearer ${ accessToken } ,
31+ 'Accept' : 'application/json' ,
32+ 'Authorization' : `Bearer ${ accessToken } ,
3833 } ,
3934 } )
4035
41- console . log ( 'Response status:' , response . status , response . statusText )
42-
4336 if ( ! response . ok ) {
4437 console . error ( `Confluence API error: ${ response . status } ${ response . statusText } )
4538 let errorMessage
@@ -50,35 +43,30 @@ export async function POST(request: Request) {
5043 errorMessage = errorData . message || `Failed to fetch Confluence page (${ response . status }
5144 } catch ( e ) {
5245 console . error ( 'Could not parse error response as JSON:' , e )
53-
54- // Try to get the response text for more context
55- try {
56- const text = await response . text ( )
57- console . error ( 'Response text:' , text )
58- errorMessage = `Failed to fetch Confluence page: ${ response . status } ${ response . statusText }
59- } catch ( textError ) {
60- errorMessage = `Failed to fetch Confluence page: ${ response . status } ${ response . statusText }
61- }
46+ errorMessage = `Failed to fetch Confluence page: ${ response . status } ${ response . statusText }
6247 }
6348
6449 return NextResponse . json ( { error : errorMessage } , { status : response . status } )
6550 }
6651
6752 const data = await response . json ( )
68- console . log ( `Successfully fetched page: ${ data . id } ${ data . title } )
6953
54+ // If body is empty, try to provide a minimal valid response
7055 return NextResponse . json ( {
71- file : {
72- id : data . id ,
73- name : data . title ,
74- mimeType : 'confluence/page' ,
75- url : data . _links ?. webui || '' ,
76- modifiedTime : data . version ?. createdAt || '' ,
77- spaceId : data . spaceId ,
78- webViewLink : data . _links ?. webui || '' ,
79- content : data . body ?. view ?. value || '' ,
80- } ,
56+ id : data . id ,
57+ title : data . title ,
58+ body : {
59+ view : {
60+ value : data . body ?. storage ?. value ||
61+ data . body ?. view ?. value ||
62+ data . body ?. atlas_doc_format ?. value ||
63+ data . content || // try alternative fields
64+ data . description ||
65+ `Content for page ${ data . title } // fallback content
66+ }
67+ }
8168 } )
69+
8270 } catch ( error ) {
8371 console . error ( 'Error fetching Confluence page:' , error )
8472 return NextResponse . json (
@@ -87,3 +75,97 @@ export async function POST(request: Request) {
8775 )
8876 }
8977}
78+
79+ export async function PUT ( request : Request ) {
80+ try {
81+ const body = await request . json ( )
82+
83+ const {
84+ domain,
85+ accessToken,
86+ pageId,
87+ cloudId : providedCloudId ,
88+ title,
89+ body : pageBody ,
90+ version
91+ } = body
92+
93+ if ( ! domain ) {
94+ return NextResponse . json ( { error : 'Domain is required' } , { status : 400 } )
95+ }
96+
97+ if ( ! accessToken ) {
98+ return NextResponse . json ( { error : 'Access token is required' } , { status : 400 } )
99+ }
100+
101+ if ( ! pageId ) {
102+ return NextResponse . json ( { error : 'Page ID is required' } , { status : 400 } )
103+ }
104+
105+ const cloudId = providedCloudId || await getConfluenceCloudId ( domain , accessToken )
106+
107+ // First, get the current page to check its version
108+ const currentPageUrl = `https://api.atlassian.com/ex/confluence/${ cloudId } ${ pageId }
109+ const currentPageResponse = await fetch ( currentPageUrl , {
110+ headers : {
111+ 'Accept' : 'application/json' ,
112+ 'Authorization' : `Bearer ${ accessToken } ,
113+ }
114+ } )
115+
116+ if ( ! currentPageResponse . ok ) {
117+ throw new Error ( `Failed to fetch current page: ${ currentPageResponse . status } )
118+ }
119+
120+ const currentPage = await currentPageResponse . json ( )
121+ const currentVersion = currentPage . version . number
122+
123+ // Build the update body with incremented version
124+ const updateBody : any = {
125+ id : pageId ,
126+ version : {
127+ number : currentVersion + 1 ,
128+ message : version ?. message || 'Updated via API'
129+ } ,
130+ title : title ,
131+ body : {
132+ representation : 'storage' ,
133+ value : pageBody ?. value || ''
134+ } ,
135+ status : 'current'
136+ }
137+
138+ const response = await fetch ( currentPageUrl , {
139+ method : 'PUT' ,
140+ headers : {
141+ 'Accept' : 'application/json' ,
142+ 'Content-Type' : 'application/json' ,
143+ 'Authorization' : `Bearer ${ accessToken } ,
144+ } ,
145+ body : JSON . stringify ( updateBody ) ,
146+ } )
147+
148+ if ( ! response . ok ) {
149+ const errorData = await response . json ( ) . catch ( ( ) => null )
150+ console . error ( 'Confluence API error response:' , {
151+ status : response . status ,
152+ statusText : response . statusText ,
153+ error : JSON . stringify ( errorData , null , 2 )
154+ } )
155+ const errorMessage = errorData ?. message ||
156+ ( errorData ?. errors && JSON . stringify ( errorData . errors ) ) ||
157+ `Failed to update Confluence page (${ response . status }
158+ return NextResponse . json ( { error : errorMessage } , { status : response . status } )
159+ }
160+
161+ const data = await response . json ( )
162+ return NextResponse . json ( data )
163+
164+ } catch ( error ) {
165+ console . error ( 'Error updating Confluence page:' , error )
166+ return NextResponse . json (
167+ { error : ( error as Error ) . message || 'Internal server error' } ,
168+ { status : 500 }
169+ )
170+ }
171+ }
0 commit comments