adamspiers.org
+161
CHAT_API_ATTEMPTS_LOG.md
+161
CHAT_API_ATTEMPTS_LOG.md
···
1
+
# Chat API Implementation Attempts Log
2
+
3
+
## Overview
4
+
We're trying to implement Bluesky chat DM functionality to notify project owners when someone creates a change request for their project. The OAuth scope `'atproto transition:generic transition:chat.bsky'` IS being granted correctly (confirmed via OAuth consent screen showing chat permissions).
5
+
6
+
## Confirmed Working Parts
7
+
- ✅ OAuth flow with chat scope (user sees chat permissions in consent screen)
8
+
- ✅ Change request record creation
9
+
- ✅ ATProto Agent authentication with OAuth session
10
+
- ✅ Session restoration and basic API calls work
11
+
12
+
## Failed Attempts (In Chronological Order)
13
+
14
+
### Attempt 1: Basic agent.chat.bsky approach
15
+
```typescript
16
+
const convoResponse = await agent.chat.bsky.convo.getConvoForMembers({
17
+
members: [targetDid]
18
+
})
19
+
```
20
+
**Result:** `Error: XRPCNotSupported, status: 404`
21
+
22
+
### Attempt 2: agent.api.chat.bsky with service routing
23
+
```typescript
24
+
const convoResponse = await agent.api.chat.bsky.convo.getConvoForMembers(
25
+
{ members: [targetDid] },
26
+
{
27
+
service: 'did:web:api.bsky.chat',
28
+
headers: {
29
+
'atproto-proxy': 'did:web:api.bsky.chat#atproto_labeler'
30
+
}
31
+
}
32
+
)
33
+
```
34
+
**Result:** `Error: could not resolve proxy did service url, status: 400`
35
+
36
+
### Attempt 3: Simplified service routing
37
+
```typescript
38
+
const convoResponse = await agent.api.chat.bsky.convo.getConvoForMembers(
39
+
{ members: [targetDid] },
40
+
{ service: 'did:web:api.bsky.chat' }
41
+
)
42
+
```
43
+
**Result:** `Error: could not resolve proxy did service url, status: 400`
44
+
45
+
### Attempt 4: No service parameter
46
+
```typescript
47
+
const convoResponse = await agent.api.chat.bsky.convo.getConvoForMembers({
48
+
members: [targetDid]
49
+
})
50
+
```
51
+
**Result:** `Error: XRPCNotSupported, status: 404`
52
+
53
+
### Attempt 5: BskyAgent approach with session transfer
54
+
```typescript
55
+
const bskyAgent = new BskyAgent({ service: 'https://bsky.social' })
56
+
if (agent.session) {
57
+
bskyAgent.session = agent.session // Copy session
58
+
}
59
+
const convoResponse = await bskyAgent.api.chat.bsky.convo.getConvoForMembers({
60
+
members: [targetDid]
61
+
})
62
+
```
63
+
**Result:** `Error: Authentication Required, status: 401` (agent.session was undefined)
64
+
65
+
### Attempt 6: BskyAgent with manual session construction
66
+
```typescript
67
+
const bskyAgent = new BskyAgent({ service: 'https://bsky.social' })
68
+
bskyAgent.session = {
69
+
did: oauthSession.sub,
70
+
handle: oauthSession.sub,
71
+
accessJwt: tokenSet?.access_token,
72
+
refreshJwt: tokenSet?.refresh_token,
73
+
active: true
74
+
}
75
+
```
76
+
**Result:** `TypeError: Cannot set property session of #<AtpAgent> which has only a getter`
77
+
78
+
### Attempt 7: BskyAgent with resumeSession
79
+
```typescript
80
+
await bskyAgent.resumeSession({
81
+
did: oauthSession.sub,
82
+
handle: oauthSession.sub,
83
+
accessJwt: tokenSet?.access_token,
84
+
refreshJwt: tokenSet?.refresh_token,
85
+
active: true
86
+
})
87
+
```
88
+
**Result:** `Error: Token could not be verified, error: 'InvalidToken', status: 400`
89
+
90
+
### Attempt 8: Back to agent.api.chat.bsky with different headers
91
+
```typescript
92
+
const convoResponse = await agent.api.chat.bsky.convo.getConvoForMembers(
93
+
{ members: [targetDid] },
94
+
{
95
+
service: 'did:web:api.bsky.chat',
96
+
headers: {
97
+
'atproto-accept-labelers': 'did:plc:ar7c4by46qjdydhdevvrndac;redact'
98
+
}
99
+
}
100
+
)
101
+
```
102
+
**Result:** [Testing now - likely same as previous service routing attempts]
103
+
104
+
### Attempt 9: Back to basic agent.chat.bsky (current)
105
+
```typescript
106
+
const convoResponse = await agent.chat.bsky.convo.getConvoForMembers({
107
+
members: [targetDid]
108
+
})
109
+
```
110
+
**Result:** `Error: XRPCNotSupported, status: 404`
111
+
112
+
### Attempt 10: SOLUTION FOUND - Using withProxy method ✅
113
+
```typescript
114
+
console.log('Creating chat proxy with withProxy method')
115
+
const chatAgent = agent.withProxy('bsky_chat', 'did:web:api.bsky.chat')
116
+
117
+
const convoResponse = await chatAgent.chat.bsky.convo.getConvoForMembers({
118
+
members: [targetDid]
119
+
})
120
+
121
+
await chatAgent.chat.bsky.convo.sendMessage({
122
+
convoId: convoResponse.data.convo.id,
123
+
message: {
124
+
text: message
125
+
}
126
+
})
127
+
```
128
+
**Result:** ✅ **SUCCESS!** Chat API implementation working correctly. Got business logic error: `"recipient requires incoming messages to come from someone they follow"` - this means the technical implementation is correct, the target user just has privacy settings that require them to follow the sender first. This is expected Bluesky behavior, not a technical bug.
129
+
130
+
## Key Debugging Info
131
+
- **OAuth Session Data:** `scope: undefined, aud: undefined, sub: 'did:plc:ucuwh64u4r5pycnlvrqvty3j'`
132
+
- **OAuth Consent Screen:** DOES show chat permissions (confirmed by user)
133
+
- **Request Scope:** `'atproto transition:generic transition:chat.bsky'`
134
+
- **Agent Type:** ATProto `Agent` created from OAuth session
135
+
136
+
## Theories for Why It's Not Working
137
+
138
+
### Theory 1: Scope Format Issue
139
+
- OAuth scope in token response is `undefined` even though consent screen shows chat permissions
140
+
- ATProto might handle scopes differently than standard OAuth2
141
+
142
+
### Theory 2: Service Routing Issue
143
+
- Chat APIs require specific service routing that we haven't figured out
144
+
- The `did:web:api.bsky.chat` service routing isn't working correctly
145
+
146
+
### Theory 3: Token Format Incompatibility
147
+
- OAuth tokens from ATProto client aren't compatible with BskyAgent
148
+
- Need different authentication method for chat APIs
149
+
150
+
### Theory 4: Chat API Availability
151
+
- Chat APIs might not be fully available via OAuth (only App Passwords?)
152
+
- Chat functionality might be restricted/beta
153
+
154
+
## Next Steps to Try
155
+
1. **Check ATProto SDK documentation** for official chat API examples
156
+
2. **Test with a different target DID** (maybe chat with yourself first)
157
+
3. **Look for working chat API examples** in ATProto community/GitHub
158
+
4. **Consider alternative notification methods** (mentions, follows, etc.)
159
+
160
+
## Current Status
161
+
Going in circles between the same 4-5 approaches. Need fresh perspective or to accept chat DMs might not be viable via OAuth.
+132
app/api/change-request/route.ts
+132
app/api/change-request/route.ts
···
1
+
import { NextRequest, NextResponse } from 'next/server'
2
+
import { Agent } from '@atproto/api'
3
+
import { getPdsEndpoint } from '@atproto/common-web'
4
+
import { IdResolver } from '@atproto/identity'
5
+
6
+
// GET - Fetch change request and related data
7
+
export async function GET(request: NextRequest) {
8
+
try {
9
+
const { searchParams } = new URL(request.url)
10
+
const did = searchParams.get('did')
11
+
const rkey = searchParams.get('rkey')
12
+
13
+
if (!did || !rkey) {
14
+
return NextResponse.json({ error: 'DID and rkey parameters required' }, { status: 400 })
15
+
}
16
+
17
+
// Resolve DID to get PDS endpoint
18
+
const resolver = new IdResolver()
19
+
const didDoc = await resolver.did.resolve(did)
20
+
21
+
if (!didDoc) {
22
+
return NextResponse.json({ error: 'Could not resolve DID' }, { status: 404 })
23
+
}
24
+
25
+
const pdsEndpoint = getPdsEndpoint(didDoc)
26
+
if (!pdsEndpoint) {
27
+
return NextResponse.json({ error: 'No PDS endpoint found for DID' }, { status: 404 })
28
+
}
29
+
30
+
// Create Agent pointing to the specific PDS for public access
31
+
const agent = new Agent({ service: pdsEndpoint })
32
+
33
+
try {
34
+
// Fetch the change request record
35
+
const changeRequestResponse = await agent.com.atproto.repo.getRecord({
36
+
repo: did,
37
+
collection: 'org.impactindexer.changeRequest',
38
+
rkey: rkey
39
+
})
40
+
41
+
if (!changeRequestResponse.success) {
42
+
return NextResponse.json({ error: 'Change request not found' }, { status: 404 })
43
+
}
44
+
45
+
const changeRequestData = changeRequestResponse.data.value as any
46
+
47
+
// Fetch requester's profile
48
+
let requesterProfile = null
49
+
try {
50
+
const profileResponse = await agent.getProfile({ actor: did })
51
+
if (profileResponse.success) {
52
+
requesterProfile = {
53
+
handle: profileResponse.data.handle,
54
+
displayName: profileResponse.data.displayName,
55
+
avatar: profileResponse.data.avatar
56
+
}
57
+
}
58
+
} catch (error) {
59
+
console.log('Could not fetch requester profile')
60
+
}
61
+
62
+
// Fetch original data if originalRecord URI exists
63
+
let originalData = null
64
+
if (changeRequestData.originalRecord) {
65
+
try {
66
+
// Parse the original record URI
67
+
const originalUri = changeRequestData.originalRecord
68
+
const originalUriParts = originalUri.replace('at://', '').split('/')
69
+
const originalDid = originalUriParts[0]
70
+
const originalRkey = originalUriParts[2]
71
+
72
+
// Resolve original DID and fetch the record
73
+
const originalDidDoc = await resolver.did.resolve(originalDid)
74
+
if (originalDidDoc) {
75
+
const originalPdsEndpoint = getPdsEndpoint(originalDidDoc)
76
+
if (originalPdsEndpoint) {
77
+
const originalAgent = new Agent({ service: originalPdsEndpoint })
78
+
const originalResponse = await originalAgent.com.atproto.repo.getRecord({
79
+
repo: originalDid,
80
+
collection: 'org.impactindexer.status',
81
+
rkey: originalRkey
82
+
})
83
+
84
+
if (originalResponse.success) {
85
+
originalData = originalResponse.data.value
86
+
}
87
+
}
88
+
}
89
+
} catch (error) {
90
+
console.log('Could not fetch original record:', error)
91
+
}
92
+
}
93
+
94
+
// Fetch proposed data
95
+
let proposedData = null
96
+
try {
97
+
// Parse the proposed record URI
98
+
const proposedUri = changeRequestData.proposedRecord
99
+
const proposedUriParts = proposedUri.replace('at://', '').split('/')
100
+
const proposedDid = proposedUriParts[0]
101
+
const proposedRkey = proposedUriParts[2]
102
+
103
+
// The proposed record should be in the same repository as the change request
104
+
const proposedResponse = await agent.com.atproto.repo.getRecord({
105
+
repo: proposedDid,
106
+
collection: 'org.impactindexer.status',
107
+
rkey: proposedRkey
108
+
})
109
+
110
+
if (proposedResponse.success) {
111
+
proposedData = proposedResponse.data.value
112
+
}
113
+
} catch (error) {
114
+
console.log('Could not fetch proposed record:', error)
115
+
}
116
+
117
+
return NextResponse.json({
118
+
...changeRequestData,
119
+
requesterProfile,
120
+
originalData,
121
+
proposedData
122
+
})
123
+
124
+
} catch (error: any) {
125
+
console.error('Failed to fetch change request:', error)
126
+
return NextResponse.json({ error: 'Change request not found' }, { status: 404 })
127
+
}
128
+
} catch (error) {
129
+
console.error('Change request fetch failed:', error)
130
+
return NextResponse.json({ error: 'Internal server error' }, { status: 500 })
131
+
}
132
+
}
+1
-1
app/api/login/route.ts
+1
-1
app/api/login/route.ts
+43
-3
app/api/oauth/callback/route.ts
+43
-3
app/api/oauth/callback/route.ts
···
10
10
// Create URLSearchParams object from the search string
11
11
const params = new URLSearchParams(url.search)
12
12
13
-
const { session } = await client.callback(params)
13
+
console.log('OAuth callback params:', Object.fromEntries(params))
14
+
15
+
// Retry OAuth callback up to 3 times for network errors
16
+
let session
17
+
let lastError
18
+
19
+
for (let attempt = 1; attempt <= 3; attempt++) {
20
+
try {
21
+
console.log(`OAuth callback attempt ${attempt}/3`)
22
+
const result = await client.callback(params)
23
+
session = result.session
24
+
break
25
+
} catch (error) {
26
+
lastError = error
27
+
console.error(`OAuth callback attempt ${attempt} failed:`, error.message)
28
+
29
+
// Check if it's a network/socket error worth retrying
30
+
const isNetworkError = error.message?.includes('UND_ERR_SOCKET') ||
31
+
error.message?.includes('fetch failed') ||
32
+
error.message?.includes('Failed to resolve OAuth server metadata')
33
+
34
+
if (isNetworkError && attempt < 3) {
35
+
console.log(`Network error detected, retrying in ${attempt * 1000}ms...`)
36
+
await new Promise(resolve => setTimeout(resolve, attempt * 1000))
37
+
continue
38
+
}
39
+
40
+
throw error
41
+
}
42
+
}
43
+
44
+
if (!session) {
45
+
throw lastError || new Error('Failed to create session after retries')
46
+
}
47
+
48
+
console.log('OAuth callback session created:', {
49
+
did: session.did,
50
+
sub: session.sub,
51
+
scope: session.tokenSet?.scope,
52
+
aud: session.tokenSet?.aud
53
+
})
14
54
15
55
await setSession({ did: session.did })
16
56
17
57
return NextResponse.redirect(new URL('/', request.url))
18
58
} catch (error) {
19
-
console.error('OAuth callback failed:', error)
59
+
console.error('OAuth callback failed after all retries:', error)
20
60
return NextResponse.redirect(
21
-
new URL('/?error=' + encodeURIComponent('Authentication failed'), request.url)
61
+
new URL('/?error=' + encodeURIComponent('Authentication failed - please try again'), request.url)
22
62
)
23
63
}
24
64
}
+1
-1
app/api/oauth/client-metadata.json/route.ts
+1
-1
app/api/oauth/client-metadata.json/route.ts
···
10
10
client_id: `${url}/api/oauth/client-metadata.json`,
11
11
client_uri: url,
12
12
redirect_uris: [`${url}/api/oauth/callback`],
13
-
scope: 'atproto transition:generic',
13
+
scope: 'atproto transition:generic transition:chat.bsky',
14
14
grant_types: ['authorization_code', 'refresh_token'],
15
15
response_types: ['code'],
16
16
application_type: 'web',
+121
-6
app/api/project-status/route.ts
+121
-6
app/api/project-status/route.ts
···
1
1
import { NextRequest, NextResponse } from 'next/server'
2
2
import { getSession, clearSession } from '@/lib/session'
3
3
import { getGlobalOAuthClient } from '@/lib/auth/client'
4
-
import { Agent } from '@atproto/api'
4
+
import { Agent, BskyAgent } from '@atproto/api'
5
5
import { TID } from '@atproto/common'
6
6
import { XrpcClient } from '@atproto/xrpc'
7
7
import { getPdsEndpoint } from '@atproto/common-web'
···
34
34
updatedAt?: string
35
35
}
36
36
37
-
async function getSessionAgent(): Promise<Agent | null> {
37
+
async function getSessionAgent(): Promise<{ agent: Agent; oauthSession: any } | null> {
38
38
try {
39
39
const session = await getSession()
40
40
···
46
46
const oauthSession = await client.restore(session.did)
47
47
48
48
if (!oauthSession) {
49
+
console.log('OAuth session restoration failed, clearing session')
49
50
await clearSession()
50
51
return null
51
52
}
52
53
53
-
return new Agent(oauthSession)
54
+
const agent = new Agent(oauthSession)
55
+
56
+
// Note: ATProto/Bluesky doesn't return scope in tokenSet, so we can't verify scopes
57
+
// Instead, we'll test chat permissions when actually trying to send messages
58
+
try {
59
+
const tokenInfo = oauthSession.tokenSet
60
+
console.log('OAuth session info:', {
61
+
scope: tokenInfo?.scope,
62
+
aud: tokenInfo?.aud,
63
+
sub: oauthSession.sub
64
+
})
65
+
console.log('Session created successfully - will test chat permissions when needed')
66
+
} catch (debugError) {
67
+
console.log('Could not debug session info:', debugError)
68
+
}
69
+
70
+
return { agent, oauthSession }
54
71
} catch (error) {
55
72
console.error('Session restore failed:', error)
73
+
// Clear potentially corrupted session
74
+
try {
75
+
await clearSession()
76
+
} catch (clearError) {
77
+
console.error('Failed to clear session:', clearError)
78
+
}
56
79
return null
57
80
}
58
81
}
59
82
83
+
async function sendChangeRequestNotification(
84
+
agent: Agent,
85
+
targetDid: string,
86
+
changeRequestUri: string,
87
+
requesterHandle: string,
88
+
reason: string,
89
+
oauthSession?: any
90
+
): Promise<{ success: boolean; error?: string }> {
91
+
try {
92
+
console.log('Attempting to send chat notification to:', targetDid)
93
+
94
+
// Create proxy for Bluesky chat service - this is the key missing piece!
95
+
console.log('Creating chat proxy with withProxy method')
96
+
const chatAgent = agent.withProxy('bsky_chat', 'did:web:api.bsky.chat')
97
+
98
+
// Create or get conversation with the project owner
99
+
console.log('Getting conversation for members')
100
+
const convoResponse = await chatAgent.chat.bsky.convo.getConvoForMembers({
101
+
members: [targetDid]
102
+
})
103
+
104
+
console.log('Conversation response:', convoResponse.data)
105
+
106
+
// Compose notification message
107
+
const message = `📝 Change Request for Your Project
108
+
109
+
From: @${requesterHandle}
110
+
Reason: ${reason}
111
+
112
+
Someone has suggested updates to your project information. The proposed changes have been saved for your review.
113
+
114
+
View details: https://impactindexer.org/change-request/${encodeURIComponent(changeRequestUri)}`
115
+
116
+
// Send the notification message via chat proxy
117
+
console.log('Sending message via chat proxy')
118
+
await chatAgent.chat.bsky.convo.sendMessage({
119
+
convoId: convoResponse.data.convo.id,
120
+
message: {
121
+
text: message
122
+
}
123
+
})
124
+
125
+
console.log('Change request notification sent successfully')
126
+
return { success: true }
127
+
} catch (error: any) {
128
+
console.error('Failed to send change request notification:', error)
129
+
130
+
// Check if it's a scope error
131
+
if (error.message?.includes('Missing required scope') || error.error === 'ScopeMissingError') {
132
+
console.log('User session lacks chat permissions - this is expected for existing users')
133
+
return {
134
+
success: false,
135
+
error: 'CHAT_SCOPE_MISSING'
136
+
}
137
+
}
138
+
139
+
return {
140
+
success: false,
141
+
error: error.message || 'Unknown error'
142
+
}
143
+
}
144
+
}
145
+
60
146
// GET - Fetch existing project status record using direct XRPC calls
61
147
export async function GET(request: NextRequest) {
62
148
try {
···
130
216
// POST - Create or update project status record
131
217
export async function POST(request: NextRequest) {
132
218
try {
133
-
const agent = await getSessionAgent()
219
+
console.log('POST /api/project-status - Starting request')
220
+
const sessionResult = await getSessionAgent()
134
221
135
-
if (!agent) {
222
+
if (!sessionResult) {
223
+
console.log('No agent available - authentication failed')
136
224
return NextResponse.json({ error: 'Authentication required' }, { status: 401 })
137
225
}
226
+
227
+
const { agent, oauthSession } = sessionResult
228
+
229
+
console.log('Agent created successfully')
138
230
139
231
const body = await request.json()
140
232
const { targetDid, isProposal, reason, ...recordData } = body
···
242
334
record: changeRequestRecord,
243
335
validate: false,
244
336
})
337
+
338
+
// Get requester's profile to get their handle
339
+
let requesterHandle = agent.assertDid // fallback to DID
340
+
try {
341
+
const profileResponse = await agent.getProfile({ actor: agent.assertDid })
342
+
if (profileResponse.success && profileResponse.data.handle) {
343
+
requesterHandle = profileResponse.data.handle
344
+
}
345
+
} catch (error) {
346
+
console.log('Could not fetch requester profile, using DID')
347
+
}
348
+
349
+
// Send notification to project owner
350
+
const notificationResult = await sendChangeRequestNotification(
351
+
agent,
352
+
targetDid,
353
+
changeRequestResponse.data.uri,
354
+
requesterHandle,
355
+
reason,
356
+
oauthSession
357
+
)
245
358
246
359
return NextResponse.json({
247
360
success: true,
···
249
362
proposedStatusUri: proposedStatusResponse.data.uri,
250
363
proposedStatusCid: proposedStatusResponse.data.cid,
251
364
changeRequestUri: changeRequestResponse.data.uri,
252
-
changeRequestCid: changeRequestResponse.data.cid
365
+
changeRequestCid: changeRequestResponse.data.cid,
366
+
chatNotificationSent: notificationResult.success,
367
+
chatNotificationError: notificationResult.error
253
368
})
254
369
} catch (error) {
255
370
console.error('Failed to write proposed status/change request records:', error)
+244
app/change-request/[uri]/page.tsx
+244
app/change-request/[uri]/page.tsx
···
1
+
'use client'
2
+
3
+
import { useParams } from 'next/navigation'
4
+
import { useEffect, useState } from 'react'
5
+
import Link from 'next/link'
6
+
import { ArrowLeft, User, Calendar, FileText, ExternalLink } from 'lucide-react'
7
+
8
+
interface ChangeRequestData {
9
+
targetDid: string
10
+
originalRecord?: string
11
+
proposedRecord: string
12
+
reason: string
13
+
createdAt: string
14
+
requesterProfile?: {
15
+
handle: string
16
+
displayName?: string
17
+
avatar?: string
18
+
}
19
+
originalData?: any
20
+
proposedData?: any
21
+
}
22
+
23
+
export default function ChangeRequestPage() {
24
+
const params = useParams()
25
+
const uri = decodeURIComponent(params.uri as string)
26
+
const [changeRequest, setChangeRequest] = useState<ChangeRequestData | null>(null)
27
+
const [loading, setLoading] = useState(true)
28
+
const [error, setError] = useState<string | null>(null)
29
+
30
+
useEffect(() => {
31
+
const fetchChangeRequest = async () => {
32
+
try {
33
+
// Parse the URI to extract the DID and record key
34
+
const uriParts = uri.split('/')
35
+
const did = uriParts[2] // at://did:plc:xyz/collection/rkey
36
+
const rkey = uriParts[4]
37
+
38
+
// Fetch the change request record
39
+
const response = await fetch(`/api/change-request?did=${encodeURIComponent(did)}&rkey=${encodeURIComponent(rkey)}`)
40
+
41
+
if (!response.ok) {
42
+
throw new Error('Failed to fetch change request')
43
+
}
44
+
45
+
const data = await response.json()
46
+
setChangeRequest(data)
47
+
} catch (error) {
48
+
console.error('Error fetching change request:', error)
49
+
setError('Failed to load change request')
50
+
} finally {
51
+
setLoading(false)
52
+
}
53
+
}
54
+
55
+
if (uri) {
56
+
fetchChangeRequest()
57
+
}
58
+
}, [uri])
59
+
60
+
if (loading) {
61
+
return (
62
+
<div className="space-y-6 animate-pulse">
63
+
<div className="h-6 bg-surface rounded w-32"></div>
64
+
<div className="bg-surface border-subtle shadow-card p-6">
65
+
<div className="h-8 bg-surface-hover rounded w-3/4 mb-4"></div>
66
+
<div className="h-4 bg-surface-hover rounded w-full mb-2"></div>
67
+
<div className="h-4 bg-surface-hover rounded w-2/3"></div>
68
+
</div>
69
+
</div>
70
+
)
71
+
}
72
+
73
+
if (error || !changeRequest) {
74
+
return (
75
+
<div className="space-y-6">
76
+
<Link
77
+
href="/"
78
+
className="inline-flex items-center text-sm text-gray-600 dark:text-gray-400 hover:text-gray-800 dark:hover:text-gray-200 transition-colors mb-6"
79
+
>
80
+
<ArrowLeft className="h-4 w-4 mr-2" />
81
+
Back to Dashboard
82
+
</Link>
83
+
84
+
<div className="bg-surface border-subtle shadow-card p-6 text-center">
85
+
<h1 className="text-xl font-serif font-medium text-primary mb-2">
86
+
Change Request Not Found
87
+
</h1>
88
+
<p className="text-secondary">
89
+
{error || 'The change request you\'re looking for could not be found.'}
90
+
</p>
91
+
</div>
92
+
</div>
93
+
)
94
+
}
95
+
96
+
const formatDate = (dateString: string) => {
97
+
return new Date(dateString).toLocaleDateString('en-US', {
98
+
year: 'numeric',
99
+
month: 'long',
100
+
day: 'numeric',
101
+
hour: '2-digit',
102
+
minute: '2-digit'
103
+
})
104
+
}
105
+
106
+
return (
107
+
<div className="space-y-6">
108
+
{/* Back Navigation */}
109
+
<Link
110
+
href="/"
111
+
className="inline-flex items-center text-sm text-gray-600 dark:text-gray-400 hover:text-gray-800 dark:hover:text-gray-200 transition-colors mb-6"
112
+
>
113
+
<ArrowLeft className="h-4 w-4 mr-2" />
114
+
Back to Dashboard
115
+
</Link>
116
+
117
+
{/* Header */}
118
+
<div className="bg-surface border-subtle shadow-card p-6">
119
+
<div className="flex items-start justify-between mb-4">
120
+
<div>
121
+
<h1 className="text-2xl font-serif font-medium text-primary mb-2">
122
+
📝 Change Request
123
+
</h1>
124
+
<div className="flex items-center text-sm text-secondary space-x-4">
125
+
<div className="flex items-center">
126
+
<Calendar className="h-4 w-4 mr-1" />
127
+
{formatDate(changeRequest.createdAt)}
128
+
</div>
129
+
{changeRequest.requesterProfile && (
130
+
<div className="flex items-center">
131
+
<User className="h-4 w-4 mr-1" />
132
+
@{changeRequest.requesterProfile.handle}
133
+
</div>
134
+
)}
135
+
</div>
136
+
</div>
137
+
</div>
138
+
139
+
{/* Reason */}
140
+
<div className="bg-amber-50 dark:bg-amber-900/20 border border-amber-200 dark:border-amber-800 rounded-lg p-4">
141
+
<div className="flex items-start">
142
+
<FileText className="h-5 w-5 text-amber-600 mt-0.5 mr-3 flex-shrink-0" />
143
+
<div>
144
+
<h3 className="font-medium text-amber-800 dark:text-amber-200 mb-1">
145
+
Reason for Change
146
+
</h3>
147
+
<p className="text-amber-700 dark:text-amber-300 text-sm">
148
+
{changeRequest.reason}
149
+
</p>
150
+
</div>
151
+
</div>
152
+
</div>
153
+
</div>
154
+
155
+
{/* Record Links */}
156
+
<div className="grid grid-cols-1 md:grid-cols-2 gap-4">
157
+
{changeRequest.originalRecord && (
158
+
<div className="bg-surface border-subtle shadow-card p-4">
159
+
<h3 className="font-medium text-primary mb-2">Original Record</h3>
160
+
<Link
161
+
href={`/project/${encodeURIComponent(changeRequest.targetDid)}`}
162
+
className="inline-flex items-center text-sm text-accent hover:text-accent-hover transition-colors"
163
+
>
164
+
View Current Project
165
+
<ExternalLink className="h-4 w-4 ml-1" />
166
+
</Link>
167
+
</div>
168
+
)}
169
+
170
+
<div className="bg-surface border-subtle shadow-card p-4">
171
+
<h3 className="font-medium text-primary mb-2">Proposed Changes</h3>
172
+
<Link
173
+
href={changeRequest.proposedRecord}
174
+
target="_blank"
175
+
rel="noopener noreferrer"
176
+
className="inline-flex items-center text-sm text-accent hover:text-accent-hover transition-colors"
177
+
>
178
+
View Proposed Record
179
+
<ExternalLink className="h-4 w-4 ml-1" />
180
+
</Link>
181
+
</div>
182
+
</div>
183
+
184
+
{/* Data Comparison (if available) */}
185
+
{changeRequest.originalData && changeRequest.proposedData && (
186
+
<div className="bg-surface border-subtle shadow-card p-6">
187
+
<h2 className="text-lg font-serif font-medium text-primary mb-4">
188
+
Proposed Changes
189
+
</h2>
190
+
<div className="space-y-4">
191
+
{Object.keys(changeRequest.proposedData).map((key) => {
192
+
if (key.startsWith('$') || key === 'createdAt' || key === 'updatedAt') return null
193
+
194
+
const originalValue = changeRequest.originalData?.[key]
195
+
const proposedValue = changeRequest.proposedData[key]
196
+
197
+
if (originalValue === proposedValue) return null
198
+
199
+
return (
200
+
<div key={key} className="border-l-2 border-accent pl-4">
201
+
<div className="text-sm font-medium text-primary mb-1 capitalize">
202
+
{key.replace(/([A-Z])/g, ' $1').trim()}
203
+
</div>
204
+
<div className="space-y-1 text-sm">
205
+
{originalValue !== undefined && (
206
+
<div className="text-red-600 dark:text-red-400">
207
+
- {typeof originalValue === 'object' ? JSON.stringify(originalValue) : String(originalValue)}
208
+
</div>
209
+
)}
210
+
<div className="text-green-600 dark:text-green-400">
211
+
+ {typeof proposedValue === 'object' ? JSON.stringify(proposedValue) : String(proposedValue)}
212
+
</div>
213
+
</div>
214
+
</div>
215
+
)
216
+
})}
217
+
</div>
218
+
</div>
219
+
)}
220
+
221
+
{/* Future: Action buttons for project owners */}
222
+
<div className="bg-surface border-subtle shadow-card p-6">
223
+
<h3 className="font-medium text-primary mb-2">Project Owner Actions</h3>
224
+
<p className="text-sm text-secondary mb-4">
225
+
As the project owner, you can review the proposed changes and decide whether to accept them.
226
+
</p>
227
+
<div className="flex space-x-3">
228
+
<button
229
+
disabled
230
+
className="px-4 py-2 bg-surface-hover text-muted rounded-lg cursor-not-allowed"
231
+
>
232
+
Accept Changes (Coming Soon)
233
+
</button>
234
+
<button
235
+
disabled
236
+
className="px-4 py-2 bg-surface-hover text-muted rounded-lg cursor-not-allowed"
237
+
>
238
+
Decline (Coming Soon)
239
+
</button>
240
+
</div>
241
+
</div>
242
+
</div>
243
+
)
244
+
}
+24
-1
app/project/[id]/page.tsx
+24
-1
app/project/[id]/page.tsx
···
168
168
const responseData = await response.json()
169
169
if (responseData.isProposal) {
170
170
// Handle proposal success
171
-
alert('Change request submitted successfully! The project owner will be able to review your suggested changes.')
171
+
const changeRequestUri = responseData.changeRequestUri
172
+
const chatNotificationSent = responseData.chatNotificationSent
173
+
174
+
let message = `Change request submitted successfully!
175
+
176
+
🔗 View your change request: ${window.location.origin}/change-request/${encodeURIComponent(changeRequestUri)}`
177
+
178
+
if (chatNotificationSent) {
179
+
message += `
180
+
181
+
✉️ The project owner has been notified via direct message on Bluesky.`
182
+
} else {
183
+
message += `
184
+
185
+
📝 Your change request has been saved. You may want to contact the project owner directly to let them know about your suggested changes.
186
+
187
+
💡 Tip: Share this link with them: ${window.location.origin}/change-request/${encodeURIComponent(changeRequestUri)}`
188
+
}
189
+
190
+
message += `
191
+
192
+
They will be able to review your suggested changes and decide whether to accept them.`
193
+
194
+
alert(message)
172
195
} else {
173
196
// Handle direct update success
174
197
setProjectStatus({...projectStatus, ...updatedData})
+45
lexicons/changeRequest.json
+45
lexicons/changeRequest.json
···
1
+
{
2
+
"lexicon": 1,
3
+
"id": "org.impactindexer.changeRequest",
4
+
"defs": {
5
+
"main": {
6
+
"type": "record",
7
+
"key": "tid",
8
+
"record": {
9
+
"type": "object",
10
+
"required": ["targetDid", "reason", "createdAt"],
11
+
"properties": {
12
+
"targetDid": {
13
+
"type": "string",
14
+
"format": "did",
15
+
"description": "DID of the project being modified"
16
+
},
17
+
"originalRecord": {
18
+
"type": "string",
19
+
"format": "at-uri",
20
+
"description": "URI reference to the original status record"
21
+
},
22
+
"proposedRecord": {
23
+
"type": "string",
24
+
"format": "at-uri",
25
+
"description": "URI reference to the proposed status record in the requester's repository"
26
+
},
27
+
"reason": {
28
+
"type": "string",
29
+
"maxLength": 1000,
30
+
"maxGraphemes": 200,
31
+
"description": "Explanation for the proposed changes"
32
+
},
33
+
"createdAt": {
34
+
"type": "string",
35
+
"format": "datetime"
36
+
},
37
+
"updatedAt": {
38
+
"type": "string",
39
+
"format": "datetime"
40
+
}
41
+
}
42
+
}
43
+
}
44
+
}
45
+
}
+2
-2
lib/auth/client.ts
+2
-2
lib/auth/client.ts
···
22
22
client_name: 'Interplanetary Impact Index',
23
23
client_id: publicUrl && publicUrl.trim()
24
24
? `${publicUrl}/api/oauth/client-metadata.json`
25
-
: `http://localhost?redirect_uri=${enc(`${url}/api/oauth/callback`)}&scope=${enc('atproto transition:generic')}`,
25
+
: `http://localhost?redirect_uri=${enc(`${url}/api/oauth/callback`)}&scope=${enc('atproto transition:generic transition:chat.bsky')}`,
26
26
client_uri: url,
27
27
redirect_uris: [`${url}/api/oauth/callback`],
28
-
scope: 'atproto transition:generic',
28
+
scope: 'atproto transition:generic transition:chat.bsky',
29
29
grant_types: ['authorization_code', 'refresh_token'],
30
30
response_types: ['code'],
31
31
application_type: 'web',