Repo checkouts

lexicons/com/atproto/sync/getCheckout.json

@@ -0,0 +1,21 @@
+{
+  "lexicon": 1,
+  "id": "com.atproto.sync.getCheckout",
+  "defs": {
+    "main": {
+      "type": "query",
+      "description": "Gets the repo state.",
+      "parameters": {
+        "type": "params",
+        "required": ["did"],
+        "properties": {
+          "did": {"type": "string", "description": "The DID of the repo."},
+          "commit": {"type": "string", "description": "The commit to get the checkout from. Defaults to current HEAD."}
+        }
+      },
+      "output": {
+        "encoding": "application/cbor"
+      }
+    }
+  }
+}

lexicons/com/atproto/sync/getCommitPath.json

@@ -0,0 +1,32 @@
+{
+  "lexicon": 1,
+  "id": "com.atproto.sync.getCommitPath",
+  "defs": {
+    "main": {
+      "type": "query",
+      "description": "Gets the path of repo commits",
+      "parameters": {
+        "type": "params",
+        "required": ["did"],
+        "properties": {
+          "did": {"type": "string", "description": "The DID of the repo."},
+          "latest": { "type": "string", "description": "The most recent commit"},
+          "earliest": { "type": "string", "description": "The earliest commit to start from"}
+        }
+      },
+      "output": {
+        "encoding": "application/json",
+        "schema": {
+          "type": "object",
+          "required": ["commits"],
+          "properties": {
+            "commits": {
+              "type": "array",
+              "items": { "type": "string" }
+            }
+          }
+        }
+      }
+    }
+  }
+}

packages/README.md

@@ -9,7 +9,6 @@
 ## Libraries
 
 - [API](./api): A library for communicating with ATP servers.
-- [Auth](./auth): ATP's core permissioning library (based on UCANs).
 - [Common](./common): A library containing code which is shared between ATP packages.
 - [Crypto](./crypto): ATP's common cryptographic operations.
 - [DID Resolver](./did-resolver): A library for resolving ATP's Decentralized ID methods.

packages/api/src/client/index.ts

@@ -27,6 +27,8 @@ import * as ComAtprotoSessionCreate from './types/com/atproto/session/create'
 import * as ComAtprotoSessionDelete from './types/com/atproto/session/delete'
 import * as ComAtprotoSessionGet from './types/com/atproto/session/get'
 import * as ComAtprotoSessionRefresh from './types/com/atproto/session/refresh'
+import * as ComAtprotoSyncGetCheckout from './types/com/atproto/sync/getCheckout'
+import * as ComAtprotoSyncGetCommitPath from './types/com/atproto/sync/getCommitPath'
 import * as ComAtprotoSyncGetRepo from './types/com/atproto/sync/getRepo'
 import * as ComAtprotoSyncGetRoot from './types/com/atproto/sync/getRoot'
 import * as ComAtprotoSyncUpdateRepo from './types/com/atproto/sync/updateRepo'
@@ -90,6 +92,8 @@ export * as ComAtprotoSessionCreate from './types/com/atproto/session/create'
 export * as ComAtprotoSessionDelete from './types/com/atproto/session/delete'
 export * as ComAtprotoSessionGet from './types/com/atproto/session/get'
 export * as ComAtprotoSessionRefresh from './types/com/atproto/session/refresh'
+export * as ComAtprotoSyncGetCheckout from './types/com/atproto/sync/getCheckout'
+export * as ComAtprotoSyncGetCommitPath from './types/com/atproto/sync/getCommitPath'
 export * as ComAtprotoSyncGetRepo from './types/com/atproto/sync/getRepo'
 export * as ComAtprotoSyncGetRoot from './types/com/atproto/sync/getRoot'
 export * as ComAtprotoSyncUpdateRepo from './types/com/atproto/sync/updateRepo'
@@ -481,6 +485,28 @@ export class SyncNS {
     this._service = service
   }
 
+  getCheckout(
+    params?: ComAtprotoSyncGetCheckout.QueryParams,
+    opts?: ComAtprotoSyncGetCheckout.CallOptions,
+  ): Promise<ComAtprotoSyncGetCheckout.Response> {
+    return this._service.xrpc
+      .call('com.atproto.sync.getCheckout', params, undefined, opts)
+      .catch((e) => {
+        throw ComAtprotoSyncGetCheckout.toKnownErr(e)
+      })
+  }
+
+  getCommitPath(
+    params?: ComAtprotoSyncGetCommitPath.QueryParams,
+    opts?: ComAtprotoSyncGetCommitPath.CallOptions,
+  ): Promise<ComAtprotoSyncGetCommitPath.Response> {
+    return this._service.xrpc
+      .call('com.atproto.sync.getCommitPath', params, undefined, opts)
+      .catch((e) => {
+        throw ComAtprotoSyncGetCommitPath.toKnownErr(e)
+      })
+  }
+
   getRepo(
     params?: ComAtprotoSyncGetRepo.QueryParams,
     opts?: ComAtprotoSyncGetRepo.CallOptions,

packages/api/src/client/lexicons.ts

@@ -828,6 +828,77 @@ export const schemaDict = {
       },
     },
   },
+  ComAtprotoSyncGetCheckout: {
+    lexicon: 1,
+    id: 'com.atproto.sync.getCheckout',
+    defs: {
+      main: {
+        type: 'query',
+        description: 'Gets the repo state.',
+        parameters: {
+          type: 'params',
+          required: ['did'],
+          properties: {
+            did: {
+              type: 'string',
+              description: 'The DID of the repo.',
+            },
+            commit: {
+              type: 'string',
+              description:
+                'The commit to get the checkout from. Defaults to current HEAD.',
+            },
+          },
+        },
+        output: {
+          encoding: 'application/cbor',
+        },
+      },
+    },
+  },
+  ComAtprotoSyncGetCommitPath: {
+    lexicon: 1,
+    id: 'com.atproto.sync.getCommitPath',
+    defs: {
+      main: {
+        type: 'query',
+        description: 'Gets the path of repo commits',
+        parameters: {
+          type: 'params',
+          required: ['did'],
+          properties: {
+            did: {
+              type: 'string',
+              description: 'The DID of the repo.',
+            },
+            latest: {
+              type: 'string',
+              description: 'The most recent commit',
+            },
+            earliest: {
+              type: 'string',
+              description: 'The earliest commit to start from',
+            },
+          },
+        },
+        output: {
+          encoding: 'application/json',
+          schema: {
+            type: 'object',
+            required: ['commits'],
+            properties: {
+              commits: {
+                type: 'array',
+                items: {
+                  type: 'string',
+                },
+              },
+            },
+          },
+        },
+      },
+    },
+  },
   ComAtprotoSyncGetRepo: {
     lexicon: 1,
     id: 'com.atproto.sync.getRepo',
@@ -2998,6 +3069,8 @@ export const ids = {
   ComAtprotoSessionDelete: 'com.atproto.session.delete',
   ComAtprotoSessionGet: 'com.atproto.session.get',
   ComAtprotoSessionRefresh: 'com.atproto.session.refresh',
+  ComAtprotoSyncGetCheckout: 'com.atproto.sync.getCheckout',
+  ComAtprotoSyncGetCommitPath: 'com.atproto.sync.getCommitPath',
   ComAtprotoSyncGetRepo: 'com.atproto.sync.getRepo',
   ComAtprotoSyncGetRoot: 'com.atproto.sync.getRoot',
   ComAtprotoSyncUpdateRepo: 'com.atproto.sync.updateRepo',

packages/api/src/client/types/com/atproto/sync/getCheckout.ts

@@ -0,0 +1,29 @@
+/**
+ * GENERATED CODE - DO NOT MODIFY
+ */
+import { Headers, XRPCError } from '@atproto/xrpc'
+
+export interface QueryParams {
+  /** The DID of the repo. */
+  did: string
+  /** The commit to get the checkout from. Defaults to current HEAD. */
+  commit?: string
+}
+
+export type InputSchema = undefined
+
+export interface CallOptions {
+  headers?: Headers
+}
+
+export interface Response {
+  success: boolean
+  headers: Headers
+  data: Uint8Array
+}
+
+export function toKnownErr(e: any) {
+  if (e instanceof XRPCError) {
+  }
+  return e
+}

packages/api/src/client/types/com/atproto/sync/getCommitPath.ts

@@ -0,0 +1,36 @@
+/**
+ * GENERATED CODE - DO NOT MODIFY
+ */
+import { Headers, XRPCError } from '@atproto/xrpc'
+
+export interface QueryParams {
+  /** The DID of the repo. */
+  did: string
+  /** The most recent commit */
+  latest?: string
+  /** The earliest commit to start from */
+  earliest?: string
+}
+
+export type InputSchema = undefined
+
+export interface OutputSchema {
+  commits: string[]
+  [k: string]: unknown
+}
+
+export interface CallOptions {
+  headers?: Headers
+}
+
+export interface Response {
+  success: boolean
+  headers: Headers
+  data: OutputSchema
+}
+
+export function toKnownErr(e: any) {
+  if (e instanceof XRPCError) {
+  }
+  return e
+}