diff options
Diffstat (limited to 'src/state/lib/api.ts')
| -rw-r--r-- | src/state/lib/api.ts | 346 |
1 files changed, 95 insertions, 251 deletions
diff --git a/src/state/lib/api.ts b/src/state/lib/api.ts index 3324525bf..c0dc34fbb 100644 --- a/src/state/lib/api.ts +++ b/src/state/lib/api.ts @@ -3,33 +3,18 @@ * models live. They are made available to every model via dependency injection. */ +import RNFetchBlob from 'rn-fetch-blob' // import {ReactNativeStore} from './auth' -import { - AdxClient, - AdxRepoClient, - AdxRepoCollectionClient, - AdxUri, - bsky, - SchemaOpt, - ListRecordsResponseValidated, - GetRecordResponseValidated, -} from '@adxp/mock-api' +import AdxApi, {ServiceClient} from '../../third-party/api' +import {AdxUri} from '../../third-party/uri' import * as storage from './storage' -import {postTexts} from './mock-data/post-texts' -import {replyTexts} from './mock-data/reply-texts' -export async function setup(adx: AdxClient) { - await adx.setupMock( - () => storage.load('mock-root'), - async root => { - await storage.save('mock-root', root) - }, - () => generateMockData(adx), - ) +export async function setup(adx: ServiceClient) { + AdxApi.xrpc.fetch = fetchHandler } export async function post( - adx: AdxClient, + adx: ServiceClient, user: string, text: string, replyToUri?: string, @@ -37,10 +22,10 @@ export async function post( let reply if (replyToUri) { const replyToUrip = new AdxUri(replyToUri) - const parentPost = await adx - .repo(replyToUrip.host, false) - .collection(replyToUrip.collection) - .get('Post', replyToUrip.recordKey) + const parentPost = await adx.todo.social.post.get({ + nameOrDid: replyToUrip.host, + tid: replyToUrip.recordKey, + }) if (parentPost) { reply = { root: parentPost.value.reply?.root || parentPost.uri, @@ -48,94 +33,126 @@ export async function post( } } } - return await adx - .repo(user, true) - .collection('blueskyweb.xyz:Posts') - .create('Post', { - $type: 'blueskyweb.xyz:Post', + return await adx.todo.social.post.create( + {did: user}, + { text, reply, createdAt: new Date().toISOString(), - }) + }, + ) } -export async function like(adx: AdxClient, user: string, uri: string) { - return await adx - .repo(user, true) - .collection('blueskyweb.xyz:Likes') - .create('Like', { - $type: 'blueskyweb.xyz:Like', +export async function like(adx: ServiceClient, user: string, uri: string) { + return await adx.todo.social.like.create( + {did: user}, + { subject: uri, createdAt: new Date().toISOString(), - }) + }, + ) } -export async function unlike(adx: AdxClient, user: string, uri: string) { - const coll = adx.repo(user, true).collection('blueskyweb.xyz:Likes') - const numDels = await deleteWhere(coll, 'Like', record => { - return record.value.subject === uri - }) - return numDels > 0 +export async function unlike(adx: ServiceClient, user: string, uri: string) { + throw new Error('TODO') } -export async function repost(adx: AdxClient, user: string, uri: string) { - return await adx - .repo(user, true) - .collection('blueskyweb.xyz:Posts') - .create('Repost', { - $type: 'blueskyweb.xyz:Repost', +export async function repost(adx: ServiceClient, user: string, uri: string) { + return await adx.todo.social.repost.create( + {did: user}, + { subject: uri, createdAt: new Date().toISOString(), - }) + }, + ) } -export async function unrepost(adx: AdxClient, user: string, uri: string) { - const coll = adx.repo(user, true).collection('blueskyweb.xyz:Posts') - const numDels = await deleteWhere(coll, 'Repost', record => { - return record.value.subject === uri - }) - return numDels > 0 +export async function unrepost(adx: ServiceClient, user: string, uri: string) { + throw new Error('TODO') } export async function follow( - adx: AdxClient, + adx: ServiceClient, user: string, - subject: {did: string; name: string}, + subject: string, ) { - return await adx - .repo(user, true) - .collection('blueskyweb.xyz:Follows') - .create('Follow', { - $type: 'blueskyweb.xyz:Follow', + return await adx.todo.social.follow.create( + {did: user}, + { subject, createdAt: new Date().toISOString(), - }) + }, + ) } export async function unfollow( - adx: AdxClient, + adx: ServiceClient, user: string, subject: {did: string}, ) { - const coll = adx.repo(user, true).collection('blueskyweb.xyz:Follows') - const numDels = await deleteWhere(coll, 'Follow', record => { - return record.value.subject.did === subject.did - }) - return numDels > 0 + throw new Error('TODO') } export async function updateProfile( - adx: AdxClient, + adx: ServiceClient, user: string, profile: bsky.Profile.Record, ) { - return await adx - .repo(user, true) - .collection('blueskyweb.xyz:Profiles') - .put('Profile', 'profile', {$type: 'blueskyweb.xyz:Profile', ...profile}) + throw new Error('TODO') +} + +interface FetchHandlerResponse { + status: number + headers: Record<string, string> + body: ArrayBuffer | undefined } -type WherePred = (_record: GetRecordResponseValidated) => Boolean +async function fetchHandler( + httpUri: string, + httpMethod: string, + httpHeaders: Record<string, string>, + httpReqBody: any, +): Promise<FetchHandlerResponse> { + httpHeaders['Authorization'] = 'did:test:alice' // DEBUG + const res = await RNFetchBlob.fetch( + /** @ts-ignore method coersion, it's fine -prf */ + httpMethod, + httpUri, + httpHeaders, + httpReqBody, + ) + + const status = res.info().status + const headers = (res.info().headers || {}) as Record<string, string> + const mimeType = headers['Content-Type'] || headers['content-type'] + let resBody + if (mimeType) { + if (mimeType.startsWith('application/json')) { + resBody = res.json() + } else if (mimeType.startsWith('text/')) { + resBody = res.text() + } else { + resBody = res.base64() + } + } + return { + status, + headers, + body: resBody, + } + // const res = await fetch(httpUri, { + // method: httpMethod, + // headers: httpHeaders, + // body: encodeMethodCallBody(httpHeaders, httpReqBody), + // }) + // const resBody = await res.arrayBuffer() + // return { + // status: res.status, + // headers: Object.fromEntries(res.headers.entries()), + // body: httpResponseBodyParse(res.headers.get('content-type'), resBody), + // } +} +/*type WherePred = (_record: GetRecordResponseValidated) => Boolean async function deleteWhere( coll: AdxRepoCollectionClient, schema: SchemaOpt, @@ -170,177 +187,4 @@ async function iterateAll( } } } while (res.records.length === 100) -} - -// TEMPORARY -// mock api config -// ======= - -function* dateGen() { - let start = 1657846031914 - while (true) { - yield new Date(start).toISOString() - start += 1e3 - } -} -const date = dateGen() - -function repo(adx: AdxClient, didOrName: string) { - const userDb = adx.mockDb.getUser(didOrName) - if (!userDb) throw new Error(`User not found: ${didOrName}`) - return adx.mainPds.repo(userDb.did, userDb.writable) -} - -export async function generateMockData(adx: AdxClient) { - const rand = (n: number) => Math.floor(Math.random() * n) - const picka = <T>(arr: Array<T>): T => { - if (arr.length) { - return arr[rand(arr.length)] || arr[0] - } - throw new Error('Not found') - } - - await adx.mockDb.addUser({name: 'alice.com', writable: true}) - await adx.mockDb.addUser({name: 'bob.com', writable: true}) - await adx.mockDb.addUser({name: 'carla.com', writable: true}) - - const alice = repo(adx, 'alice.com') - const bob = repo(adx, 'bob.com') - const carla = repo(adx, 'carla.com') - const repos = [alice, bob, carla] - - await alice.collection('blueskyweb.xyz:Profiles').put('Profile', 'profile', { - $type: 'blueskyweb.xyz:Profile', - displayName: 'Alice', - description: 'Test user 1', - }) - await bob.collection('blueskyweb.xyz:Profiles').put('Profile', 'profile', { - $type: 'blueskyweb.xyz:Profile', - displayName: 'Bob', - description: 'Test user 2', - }) - await carla.collection('blueskyweb.xyz:Profiles').put('Profile', 'profile', { - $type: 'blueskyweb.xyz:Profile', - displayName: 'Carla', - description: 'Test user 3', - }) - - // everybody follows everybody - const follow = async (who: AdxRepoClient, subjectName: string) => { - const subjectDb = adx.mockDb.getUser(subjectName) - return who.collection('blueskyweb.xyz:Follows').create('Follow', { - $type: 'blueskyweb.xyz:Follow', - subject: { - did: subjectDb?.did, - name: subjectDb?.name, - }, - createdAt: date.next().value, - }) - } - await follow(alice, 'bob.com') - await follow(alice, 'carla.com') - await follow(bob, 'alice.com') - await follow(bob, 'carla.com') - await follow(carla, 'alice.com') - await follow(carla, 'bob.com') - - // a set of posts and reposts - const posts: {uri: string}[] = [] - for (let i = 0; i < postTexts.length; i++) { - const author = picka(repos) - posts.push( - await author.collection('blueskyweb.xyz:Posts').create('Post', { - $type: 'blueskyweb.xyz:Post', - text: postTexts[i], - createdAt: date.next().value, - }), - ) - if (rand(10) === 0) { - await picka(repos) - .collection('blueskyweb.xyz:Posts') - .create('Repost', { - $type: 'blueskyweb.xyz:Repost', - subject: picka(posts).uri, - createdAt: date.next().value, - }) - } - } - - // a set of replies - for (let i = 0; i < 100; i++) { - const targetUri = picka(posts).uri - const urip = new AdxUri(targetUri) - const target = await adx.mainPds - .repo(urip.host, true) - .collection(urip.collection) - .get('Post', urip.recordKey) - const targetRecord = target.value as bsky.Post.Record - const author = picka(repos) - posts.push( - await author.collection('blueskyweb.xyz:Posts').create('Post', { - $type: 'blueskyweb.xyz:Post', - text: picka(replyTexts), - reply: { - root: targetRecord.reply ? targetRecord.reply.root : target.uri, - parent: target.uri, - }, - createdAt: date.next().value, - }), - ) - } - - // a set of likes - for (const post of posts) { - for (const repo of repos) { - if (rand(3) === 0) { - await repo.collection('blueskyweb.xyz:Likes').create('Like', { - $type: 'blueskyweb.xyz:Like', - subject: post.uri, - createdAt: date.next().value, - }) - } - } - } - - // give alice 3 badges, 2 from bob and 2 from carla, with one ignored - const inviteBadge = await bob - .collection('blueskyweb.xyz:Badges') - .create('Badge', { - $type: 'blueskyweb.xyz:Badge', - subject: {did: alice.did, name: 'alice.com'}, - assertion: {type: 'invite'}, - createdAt: date.next().value, - }) - const techTagBadge1 = await bob - .collection('blueskyweb.xyz:Badges') - .create('Badge', { - $type: 'blueskyweb.xyz:Badge', - subject: {did: alice.did, name: 'alice.com'}, - assertion: {type: 'tag', tag: 'tech'}, - createdAt: date.next().value, - }) - const techTagBadge2 = await carla - .collection('blueskyweb.xyz:Badges') - .create('Badge', { - $type: 'blueskyweb.xyz:Badge', - subject: {did: alice.did, name: 'alice.com'}, - assertion: {type: 'tag', tag: 'tech'}, - createdAt: date.next().value, - }) - await bob.collection('blueskyweb.xyz:Badges').create('Badge', { - $type: 'blueskyweb.xyz:Badge', - subject: {did: alice.did, name: 'alice.com'}, - assertion: {type: 'employee'}, - createdAt: date.next().value, - }) - await alice.collection('blueskyweb.xyz:Profiles').put('Profile', 'profile', { - $type: 'blueskyweb.xyz:Profile', - displayName: 'Alice', - description: 'Test user 1', - badges: [ - {uri: inviteBadge.uri}, - {uri: techTagBadge1.uri}, - {uri: techTagBadge2.uri}, - ], - }) -} +}*/ |