| ... | @@ -1,5 +1,20 @@ | ... | @@ -1,5 +1,20 @@ |
| | 1 | import * as Schema from "effect/Schema"; |
| | 2 | |
| 1 | const OAUTH_SCOPE_TOKEN = /^[\u0021\u0023-\u005b\u005d-\u007e]+$/u; | 3 | const OAUTH_SCOPE_TOKEN = /^[\u0021\u0023-\u005b\u005d-\u007e]+$/u; |
| 2 | | 4 | |
| | 5 | export class OAuthScopeEncodingError extends Schema.TaggedErrorClass<OAuthScopeEncodingError>()( |
| | 6 | "OAuthScopeEncodingError", |
| | 7 | { |
| | 8 | scopes: Schema.Array(Schema.String), |
| | 9 | invalidScopes: Schema.Array(Schema.String), |
| | 10 | duplicateScopes: Schema.Array(Schema.String), |
| | 11 | }, |
| | 12 | ) { |
| | 13 | override get message(): string { |
| | 14 | return "OAuth scopes must be non-empty, syntactically valid, and unique."; |
| | 15 | } |
| | 16 | } |
| | 17 | |
| 3 | /** | 18 | /** |
| 4 | * Decodes an RFC 6749 `scope` value as a set while preserving its first-seen | 19 | * Decodes an RFC 6749 `scope` value as a set while preserving its first-seen |
| 5 | * order for canonical responses and logs. | 20 | * order for canonical responses and logs. |
| ... | @@ -18,12 +33,22 @@ export function parseOAuthScope(value: string): ReadonlyArray<string> | null { | ... | @@ -18,12 +33,22 @@ export function parseOAuthScope(value: string): ReadonlyArray<string> | null { |
| 18 | } | 33 | } |
| 19 | | 34 | |
| 20 | export function encodeOAuthScope(scopes: ReadonlyArray<string>): string { | 35 | export function encodeOAuthScope(scopes: ReadonlyArray<string>): string { |
| 21 | const encoded = scopes.join(" "); | 36 | const invalidScopes = scopes.filter((scope) => !OAUTH_SCOPE_TOKEN.test(scope)); |
| 22 | const parsed = parseOAuthScope(encoded); | 37 | const seen = new Set<string>(); |
| 23 | if (parsed === null || parsed.length !== scopes.length) { | 38 | const duplicateScopes = new Set<string>(); |
| 24 | throw new Error("OAuth scopes must be non-empty, valid, and unique."); | 39 | for (const scope of scopes) { |
| | 40 | if (seen.has(scope)) duplicateScopes.add(scope); |
| | 41 | seen.add(scope); |
| | 42 | } |
| | 43 | |
| | 44 | if (scopes.length === 0 || invalidScopes.length > 0 || duplicateScopes.size > 0) { |
| | 45 | throw new OAuthScopeEncodingError({ |
| | 46 | scopes, |
| | 47 | invalidScopes, |
| | 48 | duplicateScopes: [...duplicateScopes], |
| | 49 | }); |
| 25 | } | 50 | } |
| 26 | return encoded; | 51 | return scopes.join(" "); |
| 27 | } | 52 | } |
| 28 | | 53 | |
| 29 | export function oauthScopeSetEquals(value: string, expectedScopes: ReadonlyArray<string>): boolean { | 54 | export function oauthScopeSetEquals(value: string, expectedScopes: ReadonlyArray<string>): boolean { |