Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

PDS pipethrough #2150

Merged
merged 16 commits into from
Feb 8, 2024
Merged

PDS pipethrough #2150

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
16 commits
Select commit Hold shift + click to select a range
d7ec2c8
initial impl
dholms Feb 7, 2024
854f521
re-codegen
dholms Feb 7, 2024
f4bddfb
tweak pipethrough
dholms Feb 7, 2024
15d6a13
wip
dholms Feb 7, 2024
cc31a38
read after write pipethrough
dholms Feb 7, 2024
a61718e
integrate read after write
dholms Feb 7, 2024
02d1b51
setup pds pipethrough logic
devinivy Feb 7, 2024
478b23a
pipe through repo rev header
dholms Feb 7, 2024
a737327
fix up tests
dholms Feb 7, 2024
aa1dd7e
apply pipethrough to most pds routes
devinivy Feb 7, 2024
56c9879
apply pipethrough to remaining pds routes
devinivy Feb 7, 2024
37eddfb
fix/tidy
devinivy Feb 7, 2024
bf0728b
getRecord
dholms Feb 7, 2024
7a1763e
final details for passthrough in xrpc-server
devinivy Feb 7, 2024
90049a8
Merge remote-tracking branch 'origin/main' into pds-pipethrough
devinivy Feb 7, 2024
b519a1d
build
devinivy Feb 7, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
1 change: 1 addition & 0 deletions .github/workflows/build-and-push-pds-ghcr.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ on:
push:
branches:
- main
- pds-pipethrough
env:
REGISTRY: ghcr.io
USERNAME: ${{ github.actor }}
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/actor/getPreferences.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyActorDefs from './defs'

export interface QueryParams {}
Expand All @@ -31,7 +31,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/actor/getProfile.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyActorDefs from './defs'

export interface QueryParams {
Expand All @@ -28,7 +28,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/actor/getProfiles.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyActorDefs from './defs'

export interface QueryParams {
Expand All @@ -33,7 +33,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/actor/getSuggestions.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyActorDefs from './defs'

export interface QueryParams {
Expand Down Expand Up @@ -35,7 +35,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
2 changes: 1 addition & 1 deletion packages/bsky/src/lexicon/types/app/bsky/actor/putPreferences.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyActorDefs from './defs'

export interface QueryParams {}
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/actor/searchActors.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyActorDefs from './defs'

export interface QueryParams {
Expand Down Expand Up @@ -39,7 +39,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/actor/searchActorsTypeahead.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyActorDefs from './defs'

export interface QueryParams {
Expand Down Expand Up @@ -37,7 +37,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/describeFeedGenerator.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'

export interface QueryParams {}

Expand All @@ -32,7 +32,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/getActorFeeds.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyFeedDefs from './defs'

export interface QueryParams {
Expand Down Expand Up @@ -36,7 +36,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/getActorLikes.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyFeedDefs from './defs'

export interface QueryParams {
Expand Down Expand Up @@ -37,7 +37,7 @@ export interface HandlerError {
error?: 'BlockedActor' | 'BlockedByActor'
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/getAuthorFeed.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyFeedDefs from './defs'

export interface QueryParams {
Expand Down Expand Up @@ -43,7 +43,7 @@ export interface HandlerError {
error?: 'BlockedActor' | 'BlockedByActor'
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/getFeed.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyFeedDefs from './defs'

export interface QueryParams {
Expand Down Expand Up @@ -37,7 +37,7 @@ export interface HandlerError {
error?: 'UnknownFeed'
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/getFeedGenerator.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyFeedDefs from './defs'

export interface QueryParams {
Expand Down Expand Up @@ -35,7 +35,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/getFeedGenerators.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyFeedDefs from './defs'

export interface QueryParams {
Expand All @@ -33,7 +33,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/getFeedSkeleton.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyFeedDefs from './defs'

export interface QueryParams {
Expand Down Expand Up @@ -37,7 +37,7 @@ export interface HandlerError {
error?: 'UnknownFeed'
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/getLikes.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyActorDefs from '../actor/defs'

export interface QueryParams {
Expand Down Expand Up @@ -39,7 +39,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/getListFeed.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyFeedDefs from './defs'

export interface QueryParams {
Expand Down Expand Up @@ -37,7 +37,7 @@ export interface HandlerError {
error?: 'UnknownList'
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/getPostThread.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyFeedDefs from './defs'

export interface QueryParams {
Expand Down Expand Up @@ -40,7 +40,7 @@ export interface HandlerError {
error?: 'NotFound'
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/getPosts.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyFeedDefs from './defs'

export interface QueryParams {
Expand All @@ -33,7 +33,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/getRepostedBy.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyActorDefs from '../actor/defs'

export interface QueryParams {
Expand Down Expand Up @@ -39,7 +39,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/getSuggestedFeeds.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyFeedDefs from './defs'

export interface QueryParams {
Expand Down Expand Up @@ -35,7 +35,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
4 changes: 2 additions & 2 deletions packages/bsky/src/lexicon/types/app/bsky/feed/getTimeline.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { ValidationResult, BlobRef } from '@atproto/lexicon'
import { lexicons } from '../../../../lexicons'
import { isObj, hasProp } from '../../../../util'
import { CID } from 'multiformats/cid'
import { HandlerAuth } from '@atproto/xrpc-server'
import { HandlerAuth, HandlerPipeThrough } from '@atproto/xrpc-server'
import * as AppBskyFeedDefs from './defs'

export interface QueryParams {
Expand Down Expand Up @@ -36,7 +36,7 @@ export interface HandlerError {
message?: string
}

export type HandlerOutput = HandlerError | HandlerSuccess
export type HandlerOutput = HandlerError | HandlerSuccess | HandlerPipeThrough
export type HandlerReqCtx<HA extends HandlerAuth = never> = {
auth: HA
params: QueryParams
Expand Down
Loading
Loading